Imported Libraries
- from databricks.sdk.runtime import dbutils
- from pyspark.context import SparkContext
- from pyspark.sql.session import SparkSession
- from pyspark.sql.functions import col
- import sys
- import os
- from pyspark.sql import functions as F
- from datetime import datetime
- from pyspark.sql.functions import lit,unix_timestamp
- from omop_pipeline.OMOP_Staging import omop_stagings
- from omop_pipeline.RdcJob import rdcjob
- from omop_pipeline.RDCLogging import rdclogging