import requests
from datetime import datetime, timedelta
import os
from delta import *
import pyspark
from pyspark.sql.functions import col, expr , round

# Initiate spark session
builder = pyspark.sql.SparkSession.builder.appName("MyApp") \
    .config("spark.sql.extensions", "io.delta.sql.DeltaSparkSessionExtension") \
    .config("spark.sql.catalog.spark_catalog", "org.apache.spark.sql.delta.catalog.DeltaCatalog")

spark = configure_spark_with_delta_pip(builder).getOrCreate()


0 Comments

Leave a Reply

Avatar placeholder

Your email address will not be published. Required fields are marked *