airflow.providers.apache.flink.sensors.flink_kubernetes¶
Module Contents¶
Classes¶
Checks flinkDeployment object in kubernetes cluster. |
- class airflow.providers.apache.flink.sensors.flink_kubernetes.FlinkKubernetesSensor(*, application_name, attach_log=False, namespace=None, kubernetes_conn_id='kubernetes_default', api_group='flink.apache.org', api_version='v1beta1', plural='flinkdeployments', **kwargs)[source]¶
Bases:
airflow.sensors.base.BaseSensorOperatorChecks flinkDeployment object in kubernetes cluster.
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_name (str) – flink Application resource name
namespace (str | None) – the kubernetes namespace where the flinkDeployment reside in
kubernetes_conn_id (str) – The kubernetes connection to Kubernetes cluster
attach_log (bool) – determines whether logs for driver pod should be appended to the sensor log
api_group (str) – kubernetes api group of flinkDeployment
api_version (str) – kubernetes api version of flinkDeployment
plural (str) – kubernetes api custom object plural
- template_fields: collections.abc.Sequence[str] = ('application_name', 'namespace')[source]¶