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[源代码]¶

这篇文章对您有帮助吗？