luigi.contrib.hdfs.clients module

The implementations of the hdfs clients.

luigi.contrib.hdfs.clients.get_autoconfig_client(client_cache=<_thread._local object>)[source]

Creates the client as specified in the luigi.cfg configuration.

luigi.contrib.hdfs.clients.exists(*args, **kwargs)
luigi.contrib.hdfs.clients.rename(*args, **kwargs)
luigi.contrib.hdfs.clients.remove(*args, **kwargs)
luigi.contrib.hdfs.clients.mkdir(*args, **kwargs)
luigi.contrib.hdfs.clients.listdir(*args, **kwargs)