blob: f823bed3a6c4b30c17113030fd127ccdab9128a1 [file] [log] [blame]
/**
* 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