blob: f2e1488ddfd92974a499bcd241e3664efb44f029 [file] [log] [blame]
// This autogenerated skeleton file illustrates how to build a server.
// You should copy it to another filename to avoid overwriting it.
#include "Hbase.h"
#include <thrift/protocol/TBinaryProtocol.h>
#include <thrift/server/TSimpleServer.h>
#include <thrift/transport/TServerSocket.h>
#include <thrift/transport/TBufferTransports.h>
using namespace ::apache::thrift;
using namespace ::apache::thrift::protocol;
using namespace ::apache::thrift::transport;
using namespace ::apache::thrift::server;
using namespace ::apache::hadoop::hbase::thrift;
class HbaseHandler : virtual public HbaseIf {
public:
HbaseHandler() {
// Your initialization goes here
}
void enableTable(const Bytes& tableName) {
// Your implementation goes here
printf("enableTable\n");
}
void disableTable(const Bytes& tableName) {
// Your implementation goes here
printf("disableTable\n");
}
bool isTableEnabled(const Bytes& tableName) {
// Your implementation goes here
printf("isTableEnabled\n");
}
void compact(const Bytes& tableNameOrRegionName) {
// Your implementation goes here
printf("compact\n");
}
void majorCompact(const Bytes& tableNameOrRegionName) {
// Your implementation goes here
printf("majorCompact\n");
}
void getTableNames(std::vector<Text> & _return) {
// Your implementation goes here
printf("getTableNames\n");
}
void getColumnDescriptors(std::map<Text, ColumnDescriptor> & _return, const Text& tableName) {
// Your implementation goes here
printf("getColumnDescriptors\n");
}
void getTableRegions(std::vector<TRegionInfo> & _return, const Text& tableName) {
// Your implementation goes here
printf("getTableRegions\n");
}
void createTable(const Text& tableName, const std::vector<ColumnDescriptor> & columnFamilies) {
// Your implementation goes here
printf("createTable\n");
}
void deleteTable(const Text& tableName) {
// Your implementation goes here
printf("deleteTable\n");
}
void get(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& column, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("get\n");
}
void getVer(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& column, const int32_t numVersions, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("getVer\n");
}
void getVerTs(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& column, const int64_t timestamp, const int32_t numVersions, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("getVerTs\n");
}
void getRow(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("getRow\n");
}
void getRowWithColumns(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("getRowWithColumns\n");
}
void getRowTs(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const int64_t timestamp, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("getRowTs\n");
}
void getRowWithColumnsTs(std::vector<TRowResult> & _return, const Text& tableName, const Text& row, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("getRowWithColumnsTs\n");
}
void getRows(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("getRows\n");
}
void getRowsWithColumns(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("getRowsWithColumns\n");
}
void getRowsTs(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const int64_t timestamp, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("getRowsTs\n");
}
void getRowsWithColumnsTs(std::vector<TRowResult> & _return, const Text& tableName, const std::vector<Text> & rows, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("getRowsWithColumnsTs\n");
}
void mutateRow(const Text& tableName, const Text& row, const std::vector<Mutation> & mutations, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("mutateRow\n");
}
void mutateRowTs(const Text& tableName, const Text& row, const std::vector<Mutation> & mutations, const int64_t timestamp, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("mutateRowTs\n");
}
void mutateRows(const Text& tableName, const std::vector<BatchMutation> & rowBatches, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("mutateRows\n");
}
void mutateRowsTs(const Text& tableName, const std::vector<BatchMutation> & rowBatches, const int64_t timestamp, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("mutateRowsTs\n");
}
int64_t atomicIncrement(const Text& tableName, const Text& row, const Text& column, const int64_t value) {
// Your implementation goes here
printf("atomicIncrement\n");
}
void deleteAll(const Text& tableName, const Text& row, const Text& column, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("deleteAll\n");
}
void deleteAllTs(const Text& tableName, const Text& row, const Text& column, const int64_t timestamp, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("deleteAllTs\n");
}
void deleteAllRow(const Text& tableName, const Text& row, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("deleteAllRow\n");
}
void increment(const TIncrement& increment) {
// Your implementation goes here
printf("increment\n");
}
void incrementRows(const std::vector<TIncrement> & increments) {
// Your implementation goes here
printf("incrementRows\n");
}
void deleteAllRowTs(const Text& tableName, const Text& row, const int64_t timestamp, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("deleteAllRowTs\n");
}
ScannerID scannerOpenWithScan(const Text& tableName, const TScan& scan, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("scannerOpenWithScan\n");
}
ScannerID scannerOpen(const Text& tableName, const Text& startRow, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("scannerOpen\n");
}
ScannerID scannerOpenWithStop(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("scannerOpenWithStop\n");
}
ScannerID scannerOpenWithPrefix(const Text& tableName, const Text& startAndPrefix, const std::vector<Text> & columns, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("scannerOpenWithPrefix\n");
}
ScannerID scannerOpenTs(const Text& tableName, const Text& startRow, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("scannerOpenTs\n");
}
ScannerID scannerOpenWithStopTs(const Text& tableName, const Text& startRow, const Text& stopRow, const std::vector<Text> & columns, const int64_t timestamp, const std::map<Text, Text> & attributes) {
// Your implementation goes here
printf("scannerOpenWithStopTs\n");
}
void scannerGet(std::vector<TRowResult> & _return, const ScannerID id) {
// Your implementation goes here
printf("scannerGet\n");
}
void scannerGetList(std::vector<TRowResult> & _return, const ScannerID id, const int32_t nbRows) {
// Your implementation goes here
printf("scannerGetList\n");
}
void scannerClose(const ScannerID id) {
// Your implementation goes here
printf("scannerClose\n");
}
void getRowOrBefore(std::vector<TCell> & _return, const Text& tableName, const Text& row, const Text& family) {
// Your implementation goes here
printf("getRowOrBefore\n");
}
void getRegionInfo(TRegionInfo& _return, const Text& row) {
// Your implementation goes here
printf("getRegionInfo\n");
}
};
int main(int argc, char **argv) {
int port = 9090;
std::shared_ptr<HbaseHandler> handler(new HbaseHandler());
std::shared_ptr<TProcessor> processor(new HbaseProcessor(handler));
std::shared_ptr<TServerTransport> serverTransport(new TServerSocket(port));
std::shared_ptr<TTransportFactory> transportFactory(new TBufferedTransportFactory());
std::shared_ptr<TProtocolFactory> protocolFactory(new TBinaryProtocolFactory());
TSimpleServer server(processor, serverTransport, transportFactory, protocolFactory);
server.serve();
return 0;
}