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()
Leave a Reply