easy_sql.local_spark

Module Contents

Classes

LocalSpark

class easy_sql.local_spark.LocalSpark

spark :Optional[pyspark.sql.SparkSession]

static get(conf=None, clean_existing_data=True)

Parameters

• conf (Optional[Dict[str, Any]]) –

• clean_existing_data (bool) –

Return type

pyspark.sql.SparkSession

static stop()