17 #ifndef __URI_FETCHERS_HADOOP_HPP__ 18 #define __URI_FETCHERS_HADOOP_HPP__ 54 std::set<std::string>
schemes()
const override;
56 std::string
name()
const override;
60 const std::string& directory,
67 const std::set<std::string>& _schemes)
72 std::set<std::string> schemes_;
78 #endif // __URI_FETCHERS_HADOOP_HPP__
static Try< process::Owned< Fetcher::Plugin > > create(const Flags &flags)
Definition: hadoop.hpp:36
static const char NAME[]
Definition: hadoop.hpp:48
URI hdfs(const std::string &path, const Option< std::string > &host=None(), const Option< int > &port=None())
Creates an hdfs URI with the given path.
Definition: hdfs.hpp:32
std::string name() const override
Returns the name that this plugin registered with.
Option< std::string > hadoop_client
Definition: hadoop.hpp:44
std::set< std::string > schemes() const override
Returns the URI schemes that this plugin handles.
std::string hadoop_client_supported_schemes
Definition: hadoop.hpp:45
~HadoopFetcherPlugin() override
Definition: hadoop.hpp:52
process::Future< Nothing > fetch(const URI &uri, const std::string &directory, const Option< std::string > &data=None(), const Option< std::string > &outputFileName=None()) const override
Fetches a URI to the given directory.
Definition: hadoop.hpp:39
Represents a fetcher plugin that handles one or more URI schemes.
Definition: fetcher.hpp:52