SparkSession

org.apache.spark.sql.SparkSession => com.snowflake.snowpark.Session

Spark
SnowPark
Notes

conf.get(string key)

get

Transformation cause SPRKSCL1170arrow-up-right

conf.set(string key, value)

set

Transformation cause SPRKSCL1170arrow-up-right

createDataFrame(java.util.List<Row> rows, StructType schema)

range(long end)

range(long start,long end, long step)

range(long start,long end, long step, int numPartitions)

sql(String sqlText)

table(String tableName)

getOrCreate()

create()

Last updated

Was this helpful?