blob: d097df558c9d074c6440dda215c065944bf5179b [file] [log] [blame]
: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