airflow.providers.google.cloud.operators.managed_spark¶

Attributes¶

`ManagedSparkCreateClusterOperator`
`ManagedSparkDeleteClusterOperator`
`ManagedSparkStartClusterOperator`
`ManagedSparkStopClusterOperator`
`ManagedSparkCreateWorkflowTemplateOperator`
`ManagedSparkInstantiateWorkflowTemplateOperator`
`ManagedSparkInstantiateInlineWorkflowTemplateOperator`
`ManagedSparkSubmitJobOperator`
`ManagedSparkUpdateClusterOperator`
`ManagedSparkDiagnoseClusterOperator`
`ManagedSparkCreateBatchOperator`
`ManagedSparkDeleteBatchOperator`
`ManagedSparkGetBatchOperator`
`ManagedSparkListBatchesOperator`
`ManagedSparkCancelOperationOperator`

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkCreateClusterOperator = DataprocCreateClusterOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkDeleteClusterOperator = DataprocDeleteClusterOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkStartClusterOperator = DataprocStartClusterOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkStopClusterOperator = DataprocStopClusterOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkCreateWorkflowTemplateOperator = DataprocCreateWorkflowTemplateOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkInstantiateWorkflowTemplateOperator = DataprocInstantiateWorkflowTemplateOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkInstantiateInlineWorkflowTemplateOperator = DataprocInstantiateInlineWorkflowTemplateOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkSubmitJobOperator = DataprocSubmitJobOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkUpdateClusterOperator = DataprocUpdateClusterOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkDiagnoseClusterOperator = DataprocDiagnoseClusterOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkCreateBatchOperator = DataprocCreateBatchOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkDeleteBatchOperator = DataprocDeleteBatchOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkGetBatchOperator = DataprocGetBatchOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkListBatchesOperator = DataprocListBatchesOperator[source]¶

type airflow.providers.google.cloud.operators.managed_spark.ManagedSparkCancelOperationOperator = DataprocCancelOperationOperator[source]¶