airflow.providers.apache.hdfs.sensors.web_hdfs

Module Contents

Classes

WebHdfsSensor

Waits for a file or folder to land in HDFS.
class airflow.providers.apache.hdfs.sensors.web_hdfs.WebHdfsSensor(*, filepath, webhdfs_conn_id='webhdfs_default', **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Waits for a file or folder to land in HDFS.

template_fields: Sequence[str] = ('filepath',)[source]
poke(context)[source]

Override when deriving this class.

Was this entry helpful?