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

Functions¶

pyspark_task([python_callable, multiple_outputs])

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