| :mod:`airflow.contrib.sensors.hdfs_sensor` |
| ========================================== |
| |
| .. py:module:: airflow.contrib.sensors.hdfs_sensor |
| |
| |
| Module Contents |
| --------------- |
| |
| .. py:class:: HdfsSensorRegex(regex, *args, **kwargs) |
| |
| Bases: :class:`airflow.sensors.hdfs_sensor.HdfsSensor` |
| |
| |
| .. method:: poke(self, context) |
| |
| poke matching files in a directory with self.regex |
| |
| :return: Bool depending on the search criteria |
| |
| |
| |
| |
| .. py:class:: HdfsSensorFolder(be_empty=False, *args, **kwargs) |
| |
| Bases: :class:`airflow.sensors.hdfs_sensor.HdfsSensor` |
| |
| |
| .. method:: poke(self, context) |
| |
| poke for a non empty directory |
| |
| :return: Bool depending on the search criteria |
| |
| |
| |
| |