thsutton

import logging
import time
from contextlib import AbstractContextManager
from logging import Handler, LogRecord
from typing import Any, List, Optional

from pyspark.sql import SparkSession


logging.basicConfig(level=logging.INFO)

deinspanjer

BEGIN;

    CREATE TABLE dwh.d_date
    (
        date_key CHAR(10) PRIMARY KEY NOT NULL,
        full_date DATE NOT NULL
    );
    CREATE UNIQUE INDEX d_date_full_date_uindex ON dwh.d_date (full_date);

    INSERT INTO dwh.d_date