airflow.providers.apache.flink.operators.flink_kubernetes¶
Module Contents¶
Classes¶
Creates flinkDeployment object in kubernetes cluster. |
- class airflow.providers.apache.flink.operators.flink_kubernetes.FlinkKubernetesOperator(*, application_file, namespace=None, kubernetes_conn_id='kubernetes_default', api_group='flink.apache.org', api_version='v1beta1', in_cluster=None, cluster_context=None, config_file=None, plural='flinkdeployments', **kwargs)[source]¶
Bases:
airflow.models.BaseOperatorCreates flinkDeployment object in kubernetes cluster.
See also
For more information on how to use this operator, take a look at the guide: FlinkKubernetesOperator
See also
For more detail about Flink Deployment Object have a look at the reference: https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/docs/custom-resource/reference/#flinkdeployment
- Parameters
application_file (str) – Defines Kubernetes ‘custom_resource_definition’ of ‘flinkDeployment’ as either a path to a ‘.yaml’ file, ‘.json’ file, YAML string or JSON string.
namespace (str | None) – kubernetes namespace to put flinkDeployment
kubernetes_conn_id (str) – The kubernetes connection id for the to Kubernetes cluster.
api_group (str) – kubernetes api group of flinkDeployment
api_version (str) – kubernetes api version of flinkDeployment
in_cluster (bool | None) – run kubernetes client with in_cluster configuration.
cluster_context (str | None) – context that points to kubernetes cluster. Ignored when in_cluster is True. If None, current-context is used.
config_file (str | None) – The path to the Kubernetes config file. (templated) If not specified, default value is
~/.kube/config
- template_fields: collections.abc.Sequence[str] = ('application_file', 'namespace')[source]¶
- template_ext: collections.abc.Sequence[str] = ('.yaml', '.yml', '.json')[source]¶