#include #include #include #include #if USE_HDFS #include namespace DB { namespace detail { struct HDFSBuilderDeleter { void operator()(hdfsBuilder * builder_ptr) { hdfsFreeBuilder(builder_ptr); } }; struct HDFSFsDeleter { void operator()(hdfsFS fs_ptr) { hdfsDisconnect(fs_ptr); } }; } struct HDFSFileInfo { hdfsFileInfo * file_info; int length; HDFSFileInfo() : file_info(nullptr) , length(0) { } HDFSFileInfo(const HDFSFileInfo & other) = delete; HDFSFileInfo(HDFSFileInfo && other) = default; HDFSFileInfo & operator=(const HDFSFileInfo & other) = delete; HDFSFileInfo & operator=(HDFSFileInfo && other) = default; ~HDFSFileInfo() { hdfsFreeFileInfo(file_info, length); } }; using HDFSBuilderPtr = std::unique_ptr; using HDFSFSPtr = std::unique_ptr, detail::HDFSFsDeleter>; // set read/connect timeout, default value in libhdfs3 is about 1 hour, and too large /// TODO Allow to tune from query Settings. HDFSBuilderPtr createHDFSBuilder(const Poco::URI & hdfs_uri); HDFSFSPtr createHDFSFS(hdfsBuilder * builder); } #endif