airflow.providers.amazon.aws.operators.emr_create_job_flow
¶
Module Contents¶
-
class
airflow.providers.amazon.aws.operators.emr_create_job_flow.
EmrClusterLink
[source]¶ Bases:
airflow.models.BaseOperatorLink
Operator link for EmrCreateJobFlowOperator. It allows users to access the EMR Cluster
-
class
airflow.providers.amazon.aws.operators.emr_create_job_flow.
EmrCreateJobFlowOperator
(*, aws_conn_id: str = 'aws_default', emr_conn_id: str = 'emr_default', job_flow_overrides: Optional[Union[str, Dict[str, Any]]] = None, region_name: Optional[str] = None, **kwargs)[source]¶ Bases:
airflow.models.BaseOperator
Creates an EMR JobFlow, reading the config from the EMR connection. A dictionary of JobFlow overrides can be passed that override the config from the connection.
- Parameters