tests.system.apache.spark.example_pyspark

属性

dag

test_run

函数

example_pyspark()

### 示例 PySpark DAG

模块内容

tests.system.apache.spark.example_pyspark.example_pyspark()[源代码]

### 示例 PySpark DAG 这是一个使用 pyspark 的示例 DAG

tests.system.apache.spark.example_pyspark.dag = None[源代码]
tests.system.apache.spark.example_pyspark.test_run[源代码]

这篇文章对您有帮助吗?