luigi.contrib.hdfs.clients

The implementations of the hdfs clients.

Functions

exists(*args, **kwargs)

get_autoconfig_client([client_cache])

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

listdir(*args, **kwargs)

mkdir(*args, **kwargs)

remove(*args, **kwargs)

rename(*args, **kwargs)

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)