airflow.providers.apache.spark.decorators.pyspark¶

Attributes¶

SPARK_CONTEXT_KEYS

Functions¶

pyspark_task([python_callable, multiple_outputs])

Module Contents¶

airflow.providers.apache.spark.decorators.pyspark.SPARK_CONTEXT_KEYS = ['spark', 'sc'][source]¶

airflow.providers.apache.spark.decorators.pyspark.pyspark_task(python_callable=None, multiple_outputs=None, **kwargs)[source]¶

Was this entry helpful?