`airflow.providers.apache.hdfs.sensors.web_hdfs`¶

Module Contents¶

class airflow.providers.apache.hdfs.sensors.web_hdfs.WebHdfsSensor(*, filepath: str, webhdfs_conn_id: str = 'webhdfs_default', **kwargs)[source]¶

Bases: airflow.sensors.base.BaseSensorOperator

Waits for a file or folder to land in HDFS

template_fields = ['filepath'][source]¶

poke(self, context: Dict[Any, Any])[source]¶

Was this entry helpful?