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

Table of Contents


Updated on August 12, 2025