ThriftHadoopFileSystem.h
上传用户:quxuerui
上传日期:2018-01-08
资源大小:41811k
文件大小:60k
- /**
- * Autogenerated by Thrift
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- */
- #ifndef ThriftHadoopFileSystem_H
- #define ThriftHadoopFileSystem_H
- #include <TProcessor.h>
- #include "hadoopfs_types.h"
- class ThriftHadoopFileSystemIf {
- public:
- virtual ~ThriftHadoopFileSystemIf() {}
- virtual void setInactivityTimeoutPeriod(const int64_t periodInSeconds) = 0;
- virtual void shutdown(const int32_t status) = 0;
- virtual void create(ThriftHandle& _return, const Pathname& path) = 0;
- virtual void createFile(ThriftHandle& _return, const Pathname& path, const int16_t mode, const bool overwrite, const int32_t bufferSize, const int16_t block_replication, const int64_t blocksize) = 0;
- virtual void open(ThriftHandle& _return, const Pathname& path) = 0;
- virtual void append(ThriftHandle& _return, const Pathname& path) = 0;
- virtual bool write(const ThriftHandle& handle, const std::string& data) = 0;
- virtual void read(std::string& _return, const ThriftHandle& handle, const int64_t offset, const int32_t size) = 0;
- virtual bool close(const ThriftHandle& out) = 0;
- virtual bool rm(const Pathname& path, const bool recursive) = 0;
- virtual bool rename(const Pathname& path, const Pathname& dest) = 0;
- virtual bool mkdirs(const Pathname& path) = 0;
- virtual bool exists(const Pathname& path) = 0;
- virtual void stat(FileStatus& _return, const Pathname& path) = 0;
- virtual void listStatus(std::vector<FileStatus> & _return, const Pathname& path) = 0;
- virtual void chmod(const Pathname& path, const int16_t mode) = 0;
- virtual void chown(const Pathname& path, const std::string& owner, const std::string& group) = 0;
- virtual void setReplication(const Pathname& path, const int16_t replication) = 0;
- virtual void getFileBlockLocations(std::vector<BlockLocation> & _return, const Pathname& path, const int64_t start, const int64_t length) = 0;
- };
- class ThriftHadoopFileSystemNull : virtual public ThriftHadoopFileSystemIf {
- public:
- virtual ~ThriftHadoopFileSystemNull() {}
- void setInactivityTimeoutPeriod(const int64_t /* periodInSeconds */) {
- return;
- }
- void shutdown(const int32_t /* status */) {
- return;
- }
- void create(ThriftHandle& /* _return */, const Pathname& /* path */) {
- return;
- }
- void createFile(ThriftHandle& /* _return */, const Pathname& /* path */, const int16_t /* mode */, const bool /* overwrite */, const int32_t /* bufferSize */, const int16_t /* block_replication */, const int64_t /* blocksize */) {
- return;
- }
- void open(ThriftHandle& /* _return */, const Pathname& /* path */) {
- return;
- }
- void append(ThriftHandle& /* _return */, const Pathname& /* path */) {
- return;
- }
- bool write(const ThriftHandle& /* handle */, const std::string& /* data */) {
- bool _return = false;
- return _return;
- }
- void read(std::string& /* _return */, const ThriftHandle& /* handle */, const int64_t /* offset */, const int32_t /* size */) {
- return;
- }
- bool close(const ThriftHandle& /* out */) {
- bool _return = false;
- return _return;
- }
- bool rm(const Pathname& /* path */, const bool /* recursive */) {
- bool _return = false;
- return _return;
- }
- bool rename(const Pathname& /* path */, const Pathname& /* dest */) {
- bool _return = false;
- return _return;
- }
- bool mkdirs(const Pathname& /* path */) {
- bool _return = false;
- return _return;
- }
- bool exists(const Pathname& /* path */) {
- bool _return = false;
- return _return;
- }
- void stat(FileStatus& /* _return */, const Pathname& /* path */) {
- return;
- }
- void listStatus(std::vector<FileStatus> & /* _return */, const Pathname& /* path */) {
- return;
- }
- void chmod(const Pathname& /* path */, const int16_t /* mode */) {
- return;
- }
- void chown(const Pathname& /* path */, const std::string& /* owner */, const std::string& /* group */) {
- return;
- }
- void setReplication(const Pathname& /* path */, const int16_t /* replication */) {
- return;
- }
- void getFileBlockLocations(std::vector<BlockLocation> & /* _return */, const Pathname& /* path */, const int64_t /* start */, const int64_t /* length */) {
- return;
- }
- };
- class ThriftHadoopFileSystem_setInactivityTimeoutPeriod_args {
- public:
- ThriftHadoopFileSystem_setInactivityTimeoutPeriod_args() : periodInSeconds(0) {
- }
- virtual ~ThriftHadoopFileSystem_setInactivityTimeoutPeriod_args() throw() {}
- int64_t periodInSeconds;
- struct __isset {
- __isset() : periodInSeconds(false) {}
- bool periodInSeconds;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_setInactivityTimeoutPeriod_args & rhs) const
- {
- if (!(periodInSeconds == rhs.periodInSeconds))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_setInactivityTimeoutPeriod_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_setInactivityTimeoutPeriod_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_setInactivityTimeoutPeriod_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_setInactivityTimeoutPeriod_pargs() throw() {}
- const int64_t* periodInSeconds;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_setInactivityTimeoutPeriod_result {
- public:
- ThriftHadoopFileSystem_setInactivityTimeoutPeriod_result() {
- }
- virtual ~ThriftHadoopFileSystem_setInactivityTimeoutPeriod_result() throw() {}
- bool operator == (const ThriftHadoopFileSystem_setInactivityTimeoutPeriod_result & /* rhs */) const
- {
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_setInactivityTimeoutPeriod_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_setInactivityTimeoutPeriod_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_setInactivityTimeoutPeriod_presult {
- public:
- virtual ~ThriftHadoopFileSystem_setInactivityTimeoutPeriod_presult() throw() {}
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_shutdown_args {
- public:
- ThriftHadoopFileSystem_shutdown_args() : status(0) {
- }
- virtual ~ThriftHadoopFileSystem_shutdown_args() throw() {}
- int32_t status;
- struct __isset {
- __isset() : status(false) {}
- bool status;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_shutdown_args & rhs) const
- {
- if (!(status == rhs.status))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_shutdown_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_shutdown_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_shutdown_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_shutdown_pargs() throw() {}
- const int32_t* status;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_shutdown_result {
- public:
- ThriftHadoopFileSystem_shutdown_result() {
- }
- virtual ~ThriftHadoopFileSystem_shutdown_result() throw() {}
- bool operator == (const ThriftHadoopFileSystem_shutdown_result & /* rhs */) const
- {
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_shutdown_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_shutdown_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_shutdown_presult {
- public:
- virtual ~ThriftHadoopFileSystem_shutdown_presult() throw() {}
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_create_args {
- public:
- ThriftHadoopFileSystem_create_args() {
- }
- virtual ~ThriftHadoopFileSystem_create_args() throw() {}
- Pathname path;
- struct __isset {
- __isset() : path(false) {}
- bool path;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_create_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_create_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_create_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_create_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_create_pargs() throw() {}
- const Pathname* path;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_create_result {
- public:
- ThriftHadoopFileSystem_create_result() {
- }
- virtual ~ThriftHadoopFileSystem_create_result() throw() {}
- ThriftHandle success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_create_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_create_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_create_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_create_presult {
- public:
- virtual ~ThriftHadoopFileSystem_create_presult() throw() {}
- ThriftHandle* success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_createFile_args {
- public:
- ThriftHadoopFileSystem_createFile_args() : mode(0), overwrite(0), bufferSize(0), block_replication(0), blocksize(0) {
- }
- virtual ~ThriftHadoopFileSystem_createFile_args() throw() {}
- Pathname path;
- int16_t mode;
- bool overwrite;
- int32_t bufferSize;
- int16_t block_replication;
- int64_t blocksize;
- struct __isset {
- __isset() : path(false), mode(false), overwrite(false), bufferSize(false), block_replication(false), blocksize(false) {}
- bool path;
- bool mode;
- bool overwrite;
- bool bufferSize;
- bool block_replication;
- bool blocksize;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_createFile_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- if (!(mode == rhs.mode))
- return false;
- if (!(overwrite == rhs.overwrite))
- return false;
- if (!(bufferSize == rhs.bufferSize))
- return false;
- if (!(block_replication == rhs.block_replication))
- return false;
- if (!(blocksize == rhs.blocksize))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_createFile_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_createFile_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_createFile_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_createFile_pargs() throw() {}
- const Pathname* path;
- const int16_t* mode;
- const bool* overwrite;
- const int32_t* bufferSize;
- const int16_t* block_replication;
- const int64_t* blocksize;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_createFile_result {
- public:
- ThriftHadoopFileSystem_createFile_result() {
- }
- virtual ~ThriftHadoopFileSystem_createFile_result() throw() {}
- ThriftHandle success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_createFile_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_createFile_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_createFile_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_createFile_presult {
- public:
- virtual ~ThriftHadoopFileSystem_createFile_presult() throw() {}
- ThriftHandle* success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_open_args {
- public:
- ThriftHadoopFileSystem_open_args() {
- }
- virtual ~ThriftHadoopFileSystem_open_args() throw() {}
- Pathname path;
- struct __isset {
- __isset() : path(false) {}
- bool path;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_open_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_open_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_open_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_open_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_open_pargs() throw() {}
- const Pathname* path;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_open_result {
- public:
- ThriftHadoopFileSystem_open_result() {
- }
- virtual ~ThriftHadoopFileSystem_open_result() throw() {}
- ThriftHandle success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_open_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_open_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_open_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_open_presult {
- public:
- virtual ~ThriftHadoopFileSystem_open_presult() throw() {}
- ThriftHandle* success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_append_args {
- public:
- ThriftHadoopFileSystem_append_args() {
- }
- virtual ~ThriftHadoopFileSystem_append_args() throw() {}
- Pathname path;
- struct __isset {
- __isset() : path(false) {}
- bool path;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_append_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_append_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_append_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_append_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_append_pargs() throw() {}
- const Pathname* path;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_append_result {
- public:
- ThriftHadoopFileSystem_append_result() {
- }
- virtual ~ThriftHadoopFileSystem_append_result() throw() {}
- ThriftHandle success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_append_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_append_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_append_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_append_presult {
- public:
- virtual ~ThriftHadoopFileSystem_append_presult() throw() {}
- ThriftHandle* success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_write_args {
- public:
- ThriftHadoopFileSystem_write_args() : data("") {
- }
- virtual ~ThriftHadoopFileSystem_write_args() throw() {}
- ThriftHandle handle;
- std::string data;
- struct __isset {
- __isset() : handle(false), data(false) {}
- bool handle;
- bool data;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_write_args & rhs) const
- {
- if (!(handle == rhs.handle))
- return false;
- if (!(data == rhs.data))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_write_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_write_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_write_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_write_pargs() throw() {}
- const ThriftHandle* handle;
- const std::string* data;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_write_result {
- public:
- ThriftHadoopFileSystem_write_result() : success(0) {
- }
- virtual ~ThriftHadoopFileSystem_write_result() throw() {}
- bool success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_write_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_write_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_write_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_write_presult {
- public:
- virtual ~ThriftHadoopFileSystem_write_presult() throw() {}
- bool* success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_read_args {
- public:
- ThriftHadoopFileSystem_read_args() : offset(0), size(0) {
- }
- virtual ~ThriftHadoopFileSystem_read_args() throw() {}
- ThriftHandle handle;
- int64_t offset;
- int32_t size;
- struct __isset {
- __isset() : handle(false), offset(false), size(false) {}
- bool handle;
- bool offset;
- bool size;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_read_args & rhs) const
- {
- if (!(handle == rhs.handle))
- return false;
- if (!(offset == rhs.offset))
- return false;
- if (!(size == rhs.size))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_read_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_read_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_read_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_read_pargs() throw() {}
- const ThriftHandle* handle;
- const int64_t* offset;
- const int32_t* size;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_read_result {
- public:
- ThriftHadoopFileSystem_read_result() : success("") {
- }
- virtual ~ThriftHadoopFileSystem_read_result() throw() {}
- std::string success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_read_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_read_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_read_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_read_presult {
- public:
- virtual ~ThriftHadoopFileSystem_read_presult() throw() {}
- std::string* success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_close_args {
- public:
- ThriftHadoopFileSystem_close_args() {
- }
- virtual ~ThriftHadoopFileSystem_close_args() throw() {}
- ThriftHandle out;
- struct __isset {
- __isset() : out(false) {}
- bool out;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_close_args & rhs) const
- {
- if (!(out == rhs.out))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_close_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_close_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_close_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_close_pargs() throw() {}
- const ThriftHandle* out;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_close_result {
- public:
- ThriftHadoopFileSystem_close_result() : success(0) {
- }
- virtual ~ThriftHadoopFileSystem_close_result() throw() {}
- bool success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_close_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_close_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_close_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_close_presult {
- public:
- virtual ~ThriftHadoopFileSystem_close_presult() throw() {}
- bool* success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_rm_args {
- public:
- ThriftHadoopFileSystem_rm_args() : recursive(0) {
- }
- virtual ~ThriftHadoopFileSystem_rm_args() throw() {}
- Pathname path;
- bool recursive;
- struct __isset {
- __isset() : path(false), recursive(false) {}
- bool path;
- bool recursive;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_rm_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- if (!(recursive == rhs.recursive))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_rm_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_rm_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_rm_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_rm_pargs() throw() {}
- const Pathname* path;
- const bool* recursive;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_rm_result {
- public:
- ThriftHadoopFileSystem_rm_result() : success(0) {
- }
- virtual ~ThriftHadoopFileSystem_rm_result() throw() {}
- bool success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_rm_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_rm_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_rm_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_rm_presult {
- public:
- virtual ~ThriftHadoopFileSystem_rm_presult() throw() {}
- bool* success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_rename_args {
- public:
- ThriftHadoopFileSystem_rename_args() {
- }
- virtual ~ThriftHadoopFileSystem_rename_args() throw() {}
- Pathname path;
- Pathname dest;
- struct __isset {
- __isset() : path(false), dest(false) {}
- bool path;
- bool dest;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_rename_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- if (!(dest == rhs.dest))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_rename_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_rename_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_rename_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_rename_pargs() throw() {}
- const Pathname* path;
- const Pathname* dest;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_rename_result {
- public:
- ThriftHadoopFileSystem_rename_result() : success(0) {
- }
- virtual ~ThriftHadoopFileSystem_rename_result() throw() {}
- bool success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_rename_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_rename_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_rename_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_rename_presult {
- public:
- virtual ~ThriftHadoopFileSystem_rename_presult() throw() {}
- bool* success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_mkdirs_args {
- public:
- ThriftHadoopFileSystem_mkdirs_args() {
- }
- virtual ~ThriftHadoopFileSystem_mkdirs_args() throw() {}
- Pathname path;
- struct __isset {
- __isset() : path(false) {}
- bool path;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_mkdirs_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_mkdirs_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_mkdirs_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_mkdirs_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_mkdirs_pargs() throw() {}
- const Pathname* path;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_mkdirs_result {
- public:
- ThriftHadoopFileSystem_mkdirs_result() : success(0) {
- }
- virtual ~ThriftHadoopFileSystem_mkdirs_result() throw() {}
- bool success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_mkdirs_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_mkdirs_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_mkdirs_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_mkdirs_presult {
- public:
- virtual ~ThriftHadoopFileSystem_mkdirs_presult() throw() {}
- bool* success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_exists_args {
- public:
- ThriftHadoopFileSystem_exists_args() {
- }
- virtual ~ThriftHadoopFileSystem_exists_args() throw() {}
- Pathname path;
- struct __isset {
- __isset() : path(false) {}
- bool path;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_exists_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_exists_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_exists_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_exists_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_exists_pargs() throw() {}
- const Pathname* path;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_exists_result {
- public:
- ThriftHadoopFileSystem_exists_result() : success(0) {
- }
- virtual ~ThriftHadoopFileSystem_exists_result() throw() {}
- bool success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_exists_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_exists_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_exists_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_exists_presult {
- public:
- virtual ~ThriftHadoopFileSystem_exists_presult() throw() {}
- bool* success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_stat_args {
- public:
- ThriftHadoopFileSystem_stat_args() {
- }
- virtual ~ThriftHadoopFileSystem_stat_args() throw() {}
- Pathname path;
- struct __isset {
- __isset() : path(false) {}
- bool path;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_stat_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_stat_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_stat_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_stat_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_stat_pargs() throw() {}
- const Pathname* path;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_stat_result {
- public:
- ThriftHadoopFileSystem_stat_result() {
- }
- virtual ~ThriftHadoopFileSystem_stat_result() throw() {}
- FileStatus success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_stat_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_stat_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_stat_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_stat_presult {
- public:
- virtual ~ThriftHadoopFileSystem_stat_presult() throw() {}
- FileStatus* success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_listStatus_args {
- public:
- ThriftHadoopFileSystem_listStatus_args() {
- }
- virtual ~ThriftHadoopFileSystem_listStatus_args() throw() {}
- Pathname path;
- struct __isset {
- __isset() : path(false) {}
- bool path;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_listStatus_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_listStatus_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_listStatus_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_listStatus_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_listStatus_pargs() throw() {}
- const Pathname* path;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_listStatus_result {
- public:
- ThriftHadoopFileSystem_listStatus_result() {
- }
- virtual ~ThriftHadoopFileSystem_listStatus_result() throw() {}
- std::vector<FileStatus> success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_listStatus_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_listStatus_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_listStatus_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_listStatus_presult {
- public:
- virtual ~ThriftHadoopFileSystem_listStatus_presult() throw() {}
- std::vector<FileStatus> * success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_chmod_args {
- public:
- ThriftHadoopFileSystem_chmod_args() : mode(0) {
- }
- virtual ~ThriftHadoopFileSystem_chmod_args() throw() {}
- Pathname path;
- int16_t mode;
- struct __isset {
- __isset() : path(false), mode(false) {}
- bool path;
- bool mode;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_chmod_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- if (!(mode == rhs.mode))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_chmod_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_chmod_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_chmod_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_chmod_pargs() throw() {}
- const Pathname* path;
- const int16_t* mode;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_chmod_result {
- public:
- ThriftHadoopFileSystem_chmod_result() {
- }
- virtual ~ThriftHadoopFileSystem_chmod_result() throw() {}
- ThriftIOException ouch;
- struct __isset {
- __isset() : ouch(false) {}
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_chmod_result & rhs) const
- {
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_chmod_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_chmod_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_chmod_presult {
- public:
- virtual ~ThriftHadoopFileSystem_chmod_presult() throw() {}
- ThriftIOException ouch;
- struct __isset {
- __isset() : ouch(false) {}
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_chown_args {
- public:
- ThriftHadoopFileSystem_chown_args() : owner(""), group("") {
- }
- virtual ~ThriftHadoopFileSystem_chown_args() throw() {}
- Pathname path;
- std::string owner;
- std::string group;
- struct __isset {
- __isset() : path(false), owner(false), group(false) {}
- bool path;
- bool owner;
- bool group;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_chown_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- if (!(owner == rhs.owner))
- return false;
- if (!(group == rhs.group))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_chown_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_chown_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_chown_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_chown_pargs() throw() {}
- const Pathname* path;
- const std::string* owner;
- const std::string* group;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_chown_result {
- public:
- ThriftHadoopFileSystem_chown_result() {
- }
- virtual ~ThriftHadoopFileSystem_chown_result() throw() {}
- ThriftIOException ouch;
- struct __isset {
- __isset() : ouch(false) {}
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_chown_result & rhs) const
- {
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_chown_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_chown_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_chown_presult {
- public:
- virtual ~ThriftHadoopFileSystem_chown_presult() throw() {}
- ThriftIOException ouch;
- struct __isset {
- __isset() : ouch(false) {}
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_setReplication_args {
- public:
- ThriftHadoopFileSystem_setReplication_args() : replication(0) {
- }
- virtual ~ThriftHadoopFileSystem_setReplication_args() throw() {}
- Pathname path;
- int16_t replication;
- struct __isset {
- __isset() : path(false), replication(false) {}
- bool path;
- bool replication;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_setReplication_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- if (!(replication == rhs.replication))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_setReplication_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_setReplication_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_setReplication_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_setReplication_pargs() throw() {}
- const Pathname* path;
- const int16_t* replication;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_setReplication_result {
- public:
- ThriftHadoopFileSystem_setReplication_result() {
- }
- virtual ~ThriftHadoopFileSystem_setReplication_result() throw() {}
- ThriftIOException ouch;
- struct __isset {
- __isset() : ouch(false) {}
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_setReplication_result & rhs) const
- {
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_setReplication_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_setReplication_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_setReplication_presult {
- public:
- virtual ~ThriftHadoopFileSystem_setReplication_presult() throw() {}
- ThriftIOException ouch;
- struct __isset {
- __isset() : ouch(false) {}
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystem_getFileBlockLocations_args {
- public:
- ThriftHadoopFileSystem_getFileBlockLocations_args() : start(0), length(0) {
- }
- virtual ~ThriftHadoopFileSystem_getFileBlockLocations_args() throw() {}
- Pathname path;
- int64_t start;
- int64_t length;
- struct __isset {
- __isset() : path(false), start(false), length(false) {}
- bool path;
- bool start;
- bool length;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_getFileBlockLocations_args & rhs) const
- {
- if (!(path == rhs.path))
- return false;
- if (!(start == rhs.start))
- return false;
- if (!(length == rhs.length))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_getFileBlockLocations_args &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_getFileBlockLocations_args & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_getFileBlockLocations_pargs {
- public:
- virtual ~ThriftHadoopFileSystem_getFileBlockLocations_pargs() throw() {}
- const Pathname* path;
- const int64_t* start;
- const int64_t* length;
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_getFileBlockLocations_result {
- public:
- ThriftHadoopFileSystem_getFileBlockLocations_result() {
- }
- virtual ~ThriftHadoopFileSystem_getFileBlockLocations_result() throw() {}
- std::vector<BlockLocation> success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- bool operator == (const ThriftHadoopFileSystem_getFileBlockLocations_result & rhs) const
- {
- if (!(success == rhs.success))
- return false;
- if (!(ouch == rhs.ouch))
- return false;
- return true;
- }
- bool operator != (const ThriftHadoopFileSystem_getFileBlockLocations_result &rhs) const {
- return !(*this == rhs);
- }
- bool operator < (const ThriftHadoopFileSystem_getFileBlockLocations_result & ) const;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- uint32_t write(facebook::thrift::protocol::TProtocol* oprot) const;
- };
- class ThriftHadoopFileSystem_getFileBlockLocations_presult {
- public:
- virtual ~ThriftHadoopFileSystem_getFileBlockLocations_presult() throw() {}
- std::vector<BlockLocation> * success;
- ThriftIOException ouch;
- struct __isset {
- __isset() : success(false), ouch(false) {}
- bool success;
- bool ouch;
- } __isset;
- uint32_t read(facebook::thrift::protocol::TProtocol* iprot);
- };
- class ThriftHadoopFileSystemClient : virtual public ThriftHadoopFileSystemIf {
- public:
- ThriftHadoopFileSystemClient(boost::shared_ptr<facebook::thrift::protocol::TProtocol> prot) :
- piprot_(prot),
- poprot_(prot) {
- iprot_ = prot.get();
- oprot_ = prot.get();
- }
- ThriftHadoopFileSystemClient(boost::shared_ptr<facebook::thrift::protocol::TProtocol> iprot, boost::shared_ptr<facebook::thrift::protocol::TProtocol> oprot) :
- piprot_(iprot),
- poprot_(oprot) {
- iprot_ = iprot.get();
- oprot_ = oprot.get();
- }
- boost::shared_ptr<facebook::thrift::protocol::TProtocol> getInputProtocol() {
- return piprot_;
- }
- boost::shared_ptr<facebook::thrift::protocol::TProtocol> getOutputProtocol() {
- return poprot_;
- }
- void setInactivityTimeoutPeriod(const int64_t periodInSeconds);
- void send_setInactivityTimeoutPeriod(const int64_t periodInSeconds);
- void recv_setInactivityTimeoutPeriod();
- void shutdown(const int32_t status);
- void send_shutdown(const int32_t status);
- void recv_shutdown();
- void create(ThriftHandle& _return, const Pathname& path);
- void send_create(const Pathname& path);
- void recv_create(ThriftHandle& _return);
- void createFile(ThriftHandle& _return, const Pathname& path, const int16_t mode, const bool overwrite, const int32_t bufferSize, const int16_t block_replication, const int64_t blocksize);
- void send_createFile(const Pathname& path, const int16_t mode, const bool overwrite, const int32_t bufferSize, const int16_t block_replication, const int64_t blocksize);
- void recv_createFile(ThriftHandle& _return);
- void open(ThriftHandle& _return, const Pathname& path);
- void send_open(const Pathname& path);
- void recv_open(ThriftHandle& _return);
- void append(ThriftHandle& _return, const Pathname& path);
- void send_append(const Pathname& path);
- void recv_append(ThriftHandle& _return);
- bool write(const ThriftHandle& handle, const std::string& data);
- void send_write(const ThriftHandle& handle, const std::string& data);
- bool recv_write();
- void read(std::string& _return, const ThriftHandle& handle, const int64_t offset, const int32_t size);
- void send_read(const ThriftHandle& handle, const int64_t offset, const int32_t size);
- void recv_read(std::string& _return);
- bool close(const ThriftHandle& out);
- void send_close(const ThriftHandle& out);
- bool recv_close();
- bool rm(const Pathname& path, const bool recursive);
- void send_rm(const Pathname& path, const bool recursive);
- bool recv_rm();
- bool rename(const Pathname& path, const Pathname& dest);
- void send_rename(const Pathname& path, const Pathname& dest);
- bool recv_rename();
- bool mkdirs(const Pathname& path);
- void send_mkdirs(const Pathname& path);
- bool recv_mkdirs();
- bool exists(const Pathname& path);
- void send_exists(const Pathname& path);
- bool recv_exists();
- void stat(FileStatus& _return, const Pathname& path);
- void send_stat(const Pathname& path);
- void recv_stat(FileStatus& _return);
- void listStatus(std::vector<FileStatus> & _return, const Pathname& path);
- void send_listStatus(const Pathname& path);
- void recv_listStatus(std::vector<FileStatus> & _return);
- void chmod(const Pathname& path, const int16_t mode);
- void send_chmod(const Pathname& path, const int16_t mode);
- void recv_chmod();
- void chown(const Pathname& path, const std::string& owner, const std::string& group);
- void send_chown(const Pathname& path, const std::string& owner, const std::string& group);
- void recv_chown();
- void setReplication(const Pathname& path, const int16_t replication);
- void send_setReplication(const Pathname& path, const int16_t replication);
- void recv_setReplication();
- void getFileBlockLocations(std::vector<BlockLocation> & _return, const Pathname& path, const int64_t start, const int64_t length);
- void send_getFileBlockLocations(const Pathname& path, const int64_t start, const int64_t length);
- void recv_getFileBlockLocations(std::vector<BlockLocation> & _return);
- protected:
- boost::shared_ptr<facebook::thrift::protocol::TProtocol> piprot_;
- boost::shared_ptr<facebook::thrift::protocol::TProtocol> poprot_;
- facebook::thrift::protocol::TProtocol* iprot_;
- facebook::thrift::protocol::TProtocol* oprot_;
- };
- class ThriftHadoopFileSystemProcessor : virtual public facebook::thrift::TProcessor {
- protected:
- boost::shared_ptr<ThriftHadoopFileSystemIf> iface_;
- virtual bool process_fn(facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot, std::string& fname, int32_t seqid);
- private:
- std::map<std::string, void (ThriftHadoopFileSystemProcessor::*)(int32_t, facebook::thrift::protocol::TProtocol*, facebook::thrift::protocol::TProtocol*)> processMap_;
- void process_setInactivityTimeoutPeriod(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_shutdown(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_create(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_createFile(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_open(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_append(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_write(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_read(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_close(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_rm(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_rename(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_mkdirs(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_exists(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_stat(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_listStatus(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_chmod(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_chown(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_setReplication(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- void process_getFileBlockLocations(int32_t seqid, facebook::thrift::protocol::TProtocol* iprot, facebook::thrift::protocol::TProtocol* oprot);
- public:
- ThriftHadoopFileSystemProcessor(boost::shared_ptr<ThriftHadoopFileSystemIf> iface) :
- iface_(iface) {
- processMap_["setInactivityTimeoutPeriod"] = &ThriftHadoopFileSystemProcessor::process_setInactivityTimeoutPeriod;
- processMap_["shutdown"] = &ThriftHadoopFileSystemProcessor::process_shutdown;
- processMap_["create"] = &ThriftHadoopFileSystemProcessor::process_create;
- processMap_["createFile"] = &ThriftHadoopFileSystemProcessor::process_createFile;
- processMap_["open"] = &ThriftHadoopFileSystemProcessor::process_open;
- processMap_["append"] = &ThriftHadoopFileSystemProcessor::process_append;
- processMap_["write"] = &ThriftHadoopFileSystemProcessor::process_write;
- processMap_["read"] = &ThriftHadoopFileSystemProcessor::process_read;
- processMap_["close"] = &ThriftHadoopFileSystemProcessor::process_close;
- processMap_["rm"] = &ThriftHadoopFileSystemProcessor::process_rm;
- processMap_["rename"] = &ThriftHadoopFileSystemProcessor::process_rename;
- processMap_["mkdirs"] = &ThriftHadoopFileSystemProcessor::process_mkdirs;
- processMap_["exists"] = &ThriftHadoopFileSystemProcessor::process_exists;
- processMap_["stat"] = &ThriftHadoopFileSystemProcessor::process_stat;
- processMap_["listStatus"] = &ThriftHadoopFileSystemProcessor::process_listStatus;
- processMap_["chmod"] = &ThriftHadoopFileSystemProcessor::process_chmod;
- processMap_["chown"] = &ThriftHadoopFileSystemProcessor::process_chown;
- processMap_["setReplication"] = &ThriftHadoopFileSystemProcessor::process_setReplication;
- processMap_["getFileBlockLocations"] = &ThriftHadoopFileSystemProcessor::process_getFileBlockLocations;
- }
- virtual bool process(boost::shared_ptr<facebook::thrift::protocol::TProtocol> piprot, boost::shared_ptr<facebook::thrift::protocol::TProtocol> poprot);
- virtual ~ThriftHadoopFileSystemProcessor() {}
- };
- class ThriftHadoopFileSystemMultiface : virtual public ThriftHadoopFileSystemIf {
- public:
- ThriftHadoopFileSystemMultiface(std::vector<boost::shared_ptr<ThriftHadoopFileSystemIf> >& ifaces) : ifaces_(ifaces) {
- }
- virtual ~ThriftHadoopFileSystemMultiface() {}
- protected:
- std::vector<boost::shared_ptr<ThriftHadoopFileSystemIf> > ifaces_;
- ThriftHadoopFileSystemMultiface() {}
- void add(boost::shared_ptr<ThriftHadoopFileSystemIf> iface) {
- ifaces_.push_back(iface);
- }
- public:
- void setInactivityTimeoutPeriod(const int64_t periodInSeconds) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- ifaces_[i]->setInactivityTimeoutPeriod(periodInSeconds);
- }
- }
- void shutdown(const int32_t status) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- ifaces_[i]->shutdown(status);
- }
- }
- void create(ThriftHandle& _return, const Pathname& path) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- ifaces_[i]->create(_return, path);
- return;
- } else {
- ifaces_[i]->create(_return, path);
- }
- }
- }
- void createFile(ThriftHandle& _return, const Pathname& path, const int16_t mode, const bool overwrite, const int32_t bufferSize, const int16_t block_replication, const int64_t blocksize) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- ifaces_[i]->createFile(_return, path, mode, overwrite, bufferSize, block_replication, blocksize);
- return;
- } else {
- ifaces_[i]->createFile(_return, path, mode, overwrite, bufferSize, block_replication, blocksize);
- }
- }
- }
- void open(ThriftHandle& _return, const Pathname& path) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- ifaces_[i]->open(_return, path);
- return;
- } else {
- ifaces_[i]->open(_return, path);
- }
- }
- }
- void append(ThriftHandle& _return, const Pathname& path) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- ifaces_[i]->append(_return, path);
- return;
- } else {
- ifaces_[i]->append(_return, path);
- }
- }
- }
- bool write(const ThriftHandle& handle, const std::string& data) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- return ifaces_[i]->write(handle, data);
- } else {
- ifaces_[i]->write(handle, data);
- }
- }
- }
- void read(std::string& _return, const ThriftHandle& handle, const int64_t offset, const int32_t size) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- ifaces_[i]->read(_return, handle, offset, size);
- return;
- } else {
- ifaces_[i]->read(_return, handle, offset, size);
- }
- }
- }
- bool close(const ThriftHandle& out) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- return ifaces_[i]->close(out);
- } else {
- ifaces_[i]->close(out);
- }
- }
- }
- bool rm(const Pathname& path, const bool recursive) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- return ifaces_[i]->rm(path, recursive);
- } else {
- ifaces_[i]->rm(path, recursive);
- }
- }
- }
- bool rename(const Pathname& path, const Pathname& dest) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- return ifaces_[i]->rename(path, dest);
- } else {
- ifaces_[i]->rename(path, dest);
- }
- }
- }
- bool mkdirs(const Pathname& path) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- return ifaces_[i]->mkdirs(path);
- } else {
- ifaces_[i]->mkdirs(path);
- }
- }
- }
- bool exists(const Pathname& path) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- return ifaces_[i]->exists(path);
- } else {
- ifaces_[i]->exists(path);
- }
- }
- }
- void stat(FileStatus& _return, const Pathname& path) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- ifaces_[i]->stat(_return, path);
- return;
- } else {
- ifaces_[i]->stat(_return, path);
- }
- }
- }
- void listStatus(std::vector<FileStatus> & _return, const Pathname& path) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- ifaces_[i]->listStatus(_return, path);
- return;
- } else {
- ifaces_[i]->listStatus(_return, path);
- }
- }
- }
- void chmod(const Pathname& path, const int16_t mode) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- ifaces_[i]->chmod(path, mode);
- }
- }
- void chown(const Pathname& path, const std::string& owner, const std::string& group) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- ifaces_[i]->chown(path, owner, group);
- }
- }
- void setReplication(const Pathname& path, const int16_t replication) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- ifaces_[i]->setReplication(path, replication);
- }
- }
- void getFileBlockLocations(std::vector<BlockLocation> & _return, const Pathname& path, const int64_t start, const int64_t length) {
- uint32_t sz = ifaces_.size();
- for (uint32_t i = 0; i < sz; ++i) {
- if (i == sz - 1) {
- ifaces_[i]->getFileBlockLocations(_return, path, start, length);
- return;
- } else {
- ifaces_[i]->getFileBlockLocations(_return, path, start, length);
- }
- }
- }
- };
- #endif