diff options
Diffstat (limited to 'happybase/hbase/Hbase-remote')
| -rwxr-xr-x | happybase/hbase/Hbase-remote | 396 |
1 files changed, 0 insertions, 396 deletions
diff --git a/happybase/hbase/Hbase-remote b/happybase/hbase/Hbase-remote deleted file mode 100755 index 34ea020..0000000 --- a/happybase/hbase/Hbase-remote +++ /dev/null @@ -1,396 +0,0 @@ -#!/usr/bin/env python -# -# Autogenerated by Thrift Compiler (0.9.0) -# -# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING -# -# options string: py:new_style -# - -import sys -import pprint -from urlparse import urlparse -from thrift.transport import TTransport -from thrift.transport import TSocket -from thrift.transport import THttpClient -from thrift.protocol import TBinaryProtocol - -import Hbase -from ttypes import * - -if len(sys.argv) <= 1 or sys.argv[1] == '--help': - print '' - print 'Usage: ' + sys.argv[0] + ' [-h host[:port]] [-u url] [-f[ramed]] function [arg1 [arg2...]]' - print '' - print 'Functions:' - print ' void enableTable(Bytes tableName)' - print ' void disableTable(Bytes tableName)' - print ' bool isTableEnabled(Bytes tableName)' - print ' void compact(Bytes tableNameOrRegionName)' - print ' void majorCompact(Bytes tableNameOrRegionName)' - print ' getTableNames()' - print ' getColumnDescriptors(Text tableName)' - print ' getTableRegions(Text tableName)' - print ' void createTable(Text tableName, columnFamilies)' - print ' void deleteTable(Text tableName)' - print ' get(Text tableName, Text row, Text column, attributes)' - print ' getVer(Text tableName, Text row, Text column, i32 numVersions, attributes)' - print ' getVerTs(Text tableName, Text row, Text column, i64 timestamp, i32 numVersions, attributes)' - print ' getRow(Text tableName, Text row, attributes)' - print ' getRowWithColumns(Text tableName, Text row, columns, attributes)' - print ' getRowTs(Text tableName, Text row, i64 timestamp, attributes)' - print ' getRowWithColumnsTs(Text tableName, Text row, columns, i64 timestamp, attributes)' - print ' getRows(Text tableName, rows, attributes)' - print ' getRowsWithColumns(Text tableName, rows, columns, attributes)' - print ' getRowsTs(Text tableName, rows, i64 timestamp, attributes)' - print ' getRowsWithColumnsTs(Text tableName, rows, columns, i64 timestamp, attributes)' - print ' void mutateRow(Text tableName, Text row, mutations, attributes)' - print ' void mutateRowTs(Text tableName, Text row, mutations, i64 timestamp, attributes)' - print ' void mutateRows(Text tableName, rowBatches, attributes)' - print ' void mutateRowsTs(Text tableName, rowBatches, i64 timestamp, attributes)' - print ' i64 atomicIncrement(Text tableName, Text row, Text column, i64 value)' - print ' void deleteAll(Text tableName, Text row, Text column, attributes)' - print ' void deleteAllTs(Text tableName, Text row, Text column, i64 timestamp, attributes)' - print ' void deleteAllRow(Text tableName, Text row, attributes)' - print ' void increment(TIncrement increment)' - print ' void incrementRows( increments)' - print ' void deleteAllRowTs(Text tableName, Text row, i64 timestamp, attributes)' - print ' ScannerID scannerOpenWithScan(Text tableName, TScan scan, attributes)' - print ' ScannerID scannerOpen(Text tableName, Text startRow, columns, attributes)' - print ' ScannerID scannerOpenWithStop(Text tableName, Text startRow, Text stopRow, columns, attributes)' - print ' ScannerID scannerOpenWithPrefix(Text tableName, Text startAndPrefix, columns, attributes)' - print ' ScannerID scannerOpenTs(Text tableName, Text startRow, columns, i64 timestamp, attributes)' - print ' ScannerID scannerOpenWithStopTs(Text tableName, Text startRow, Text stopRow, columns, i64 timestamp, attributes)' - print ' scannerGet(ScannerID id)' - print ' scannerGetList(ScannerID id, i32 nbRows)' - print ' void scannerClose(ScannerID id)' - print ' getRowOrBefore(Text tableName, Text row, Text family)' - print ' TRegionInfo getRegionInfo(Text row)' - print ' append(TAppend append)' - print ' bool checkAndPut(Text tableName, Text row, Text column, Text value, Mutation mput, attributes)' - print '' - sys.exit(0) - -pp = pprint.PrettyPrinter(indent = 2) -host = 'localhost' -port = 9090 -uri = '' -framed = False -http = False -argi = 1 - -if sys.argv[argi] == '-h': - parts = sys.argv[argi+1].split(':') - host = parts[0] - if len(parts) > 1: - port = int(parts[1]) - argi += 2 - -if sys.argv[argi] == '-u': - url = urlparse(sys.argv[argi+1]) - parts = url[1].split(':') - host = parts[0] - if len(parts) > 1: - port = int(parts[1]) - else: - port = 80 - uri = url[2] - if url[4]: - uri += '?%s' % url[4] - http = True - argi += 2 - -if sys.argv[argi] == '-f' or sys.argv[argi] == '-framed': - framed = True - argi += 1 - -cmd = sys.argv[argi] -args = sys.argv[argi+1:] - -if http: - transport = THttpClient.THttpClient(host, port, uri) -else: - socket = TSocket.TSocket(host, port) - if framed: - transport = TTransport.TFramedTransport(socket) - else: - transport = TTransport.TBufferedTransport(socket) -protocol = TBinaryProtocol.TBinaryProtocol(transport) -client = Hbase.Client(protocol) -transport.open() - -if cmd == 'enableTable': - if len(args) != 1: - print 'enableTable requires 1 args' - sys.exit(1) - pp.pprint(client.enableTable(eval(args[0]),)) - -elif cmd == 'disableTable': - if len(args) != 1: - print 'disableTable requires 1 args' - sys.exit(1) - pp.pprint(client.disableTable(eval(args[0]),)) - -elif cmd == 'isTableEnabled': - if len(args) != 1: - print 'isTableEnabled requires 1 args' - sys.exit(1) - pp.pprint(client.isTableEnabled(eval(args[0]),)) - -elif cmd == 'compact': - if len(args) != 1: - print 'compact requires 1 args' - sys.exit(1) - pp.pprint(client.compact(eval(args[0]),)) - -elif cmd == 'majorCompact': - if len(args) != 1: - print 'majorCompact requires 1 args' - sys.exit(1) - pp.pprint(client.majorCompact(eval(args[0]),)) - -elif cmd == 'getTableNames': - if len(args) != 0: - print 'getTableNames requires 0 args' - sys.exit(1) - pp.pprint(client.getTableNames()) - -elif cmd == 'getColumnDescriptors': - if len(args) != 1: - print 'getColumnDescriptors requires 1 args' - sys.exit(1) - pp.pprint(client.getColumnDescriptors(eval(args[0]),)) - -elif cmd == 'getTableRegions': - if len(args) != 1: - print 'getTableRegions requires 1 args' - sys.exit(1) - pp.pprint(client.getTableRegions(eval(args[0]),)) - -elif cmd == 'createTable': - if len(args) != 2: - print 'createTable requires 2 args' - sys.exit(1) - pp.pprint(client.createTable(eval(args[0]),eval(args[1]),)) - -elif cmd == 'deleteTable': - if len(args) != 1: - print 'deleteTable requires 1 args' - sys.exit(1) - pp.pprint(client.deleteTable(eval(args[0]),)) - -elif cmd == 'get': - if len(args) != 4: - print 'get requires 4 args' - sys.exit(1) - pp.pprint(client.get(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),)) - -elif cmd == 'getVer': - if len(args) != 5: - print 'getVer requires 5 args' - sys.exit(1) - pp.pprint(client.getVer(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),)) - -elif cmd == 'getVerTs': - if len(args) != 6: - print 'getVerTs requires 6 args' - sys.exit(1) - pp.pprint(client.getVerTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),eval(args[5]),)) - -elif cmd == 'getRow': - if len(args) != 3: - print 'getRow requires 3 args' - sys.exit(1) - pp.pprint(client.getRow(eval(args[0]),eval(args[1]),eval(args[2]),)) - -elif cmd == 'getRowWithColumns': - if len(args) != 4: - print 'getRowWithColumns requires 4 args' - sys.exit(1) - pp.pprint(client.getRowWithColumns(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),)) - -elif cmd == 'getRowTs': - if len(args) != 4: - print 'getRowTs requires 4 args' - sys.exit(1) - pp.pprint(client.getRowTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),)) - -elif cmd == 'getRowWithColumnsTs': - if len(args) != 5: - print 'getRowWithColumnsTs requires 5 args' - sys.exit(1) - pp.pprint(client.getRowWithColumnsTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),)) - -elif cmd == 'getRows': - if len(args) != 3: - print 'getRows requires 3 args' - sys.exit(1) - pp.pprint(client.getRows(eval(args[0]),eval(args[1]),eval(args[2]),)) - -elif cmd == 'getRowsWithColumns': - if len(args) != 4: - print 'getRowsWithColumns requires 4 args' - sys.exit(1) - pp.pprint(client.getRowsWithColumns(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),)) - -elif cmd == 'getRowsTs': - if len(args) != 4: - print 'getRowsTs requires 4 args' - sys.exit(1) - pp.pprint(client.getRowsTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),)) - -elif cmd == 'getRowsWithColumnsTs': - if len(args) != 5: - print 'getRowsWithColumnsTs requires 5 args' - sys.exit(1) - pp.pprint(client.getRowsWithColumnsTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),)) - -elif cmd == 'mutateRow': - if len(args) != 4: - print 'mutateRow requires 4 args' - sys.exit(1) - pp.pprint(client.mutateRow(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),)) - -elif cmd == 'mutateRowTs': - if len(args) != 5: - print 'mutateRowTs requires 5 args' - sys.exit(1) - pp.pprint(client.mutateRowTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),)) - -elif cmd == 'mutateRows': - if len(args) != 3: - print 'mutateRows requires 3 args' - sys.exit(1) - pp.pprint(client.mutateRows(eval(args[0]),eval(args[1]),eval(args[2]),)) - -elif cmd == 'mutateRowsTs': - if len(args) != 4: - print 'mutateRowsTs requires 4 args' - sys.exit(1) - pp.pprint(client.mutateRowsTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),)) - -elif cmd == 'atomicIncrement': - if len(args) != 4: - print 'atomicIncrement requires 4 args' - sys.exit(1) - pp.pprint(client.atomicIncrement(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),)) - -elif cmd == 'deleteAll': - if len(args) != 4: - print 'deleteAll requires 4 args' - sys.exit(1) - pp.pprint(client.deleteAll(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),)) - -elif cmd == 'deleteAllTs': - if len(args) != 5: - print 'deleteAllTs requires 5 args' - sys.exit(1) - pp.pprint(client.deleteAllTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),)) - -elif cmd == 'deleteAllRow': - if len(args) != 3: - print 'deleteAllRow requires 3 args' - sys.exit(1) - pp.pprint(client.deleteAllRow(eval(args[0]),eval(args[1]),eval(args[2]),)) - -elif cmd == 'increment': - if len(args) != 1: - print 'increment requires 1 args' - sys.exit(1) - pp.pprint(client.increment(eval(args[0]),)) - -elif cmd == 'incrementRows': - if len(args) != 1: - print 'incrementRows requires 1 args' - sys.exit(1) - pp.pprint(client.incrementRows(eval(args[0]),)) - -elif cmd == 'deleteAllRowTs': - if len(args) != 4: - print 'deleteAllRowTs requires 4 args' - sys.exit(1) - pp.pprint(client.deleteAllRowTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),)) - -elif cmd == 'scannerOpenWithScan': - if len(args) != 3: - print 'scannerOpenWithScan requires 3 args' - sys.exit(1) - pp.pprint(client.scannerOpenWithScan(eval(args[0]),eval(args[1]),eval(args[2]),)) - -elif cmd == 'scannerOpen': - if len(args) != 4: - print 'scannerOpen requires 4 args' - sys.exit(1) - pp.pprint(client.scannerOpen(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),)) - -elif cmd == 'scannerOpenWithStop': - if len(args) != 5: - print 'scannerOpenWithStop requires 5 args' - sys.exit(1) - pp.pprint(client.scannerOpenWithStop(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),)) - -elif cmd == 'scannerOpenWithPrefix': - if len(args) != 4: - print 'scannerOpenWithPrefix requires 4 args' - sys.exit(1) - pp.pprint(client.scannerOpenWithPrefix(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),)) - -elif cmd == 'scannerOpenTs': - if len(args) != 5: - print 'scannerOpenTs requires 5 args' - sys.exit(1) - pp.pprint(client.scannerOpenTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),)) - -elif cmd == 'scannerOpenWithStopTs': - if len(args) != 6: - print 'scannerOpenWithStopTs requires 6 args' - sys.exit(1) - pp.pprint(client.scannerOpenWithStopTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),eval(args[5]),)) - -elif cmd == 'scannerGet': - if len(args) != 1: - print 'scannerGet requires 1 args' - sys.exit(1) - pp.pprint(client.scannerGet(eval(args[0]),)) - -elif cmd == 'scannerGetList': - if len(args) != 2: - print 'scannerGetList requires 2 args' - sys.exit(1) - pp.pprint(client.scannerGetList(eval(args[0]),eval(args[1]),)) - -elif cmd == 'scannerClose': - if len(args) != 1: - print 'scannerClose requires 1 args' - sys.exit(1) - pp.pprint(client.scannerClose(eval(args[0]),)) - -elif cmd == 'getRowOrBefore': - if len(args) != 3: - print 'getRowOrBefore requires 3 args' - sys.exit(1) - pp.pprint(client.getRowOrBefore(eval(args[0]),eval(args[1]),eval(args[2]),)) - -elif cmd == 'getRegionInfo': - if len(args) != 1: - print 'getRegionInfo requires 1 args' - sys.exit(1) - pp.pprint(client.getRegionInfo(eval(args[0]),)) - -elif cmd == 'append': - if len(args) != 1: - print 'append requires 1 args' - sys.exit(1) - pp.pprint(client.append(eval(args[0]),)) - -elif cmd == 'checkAndPut': - if len(args) != 6: - print 'checkAndPut requires 6 args' - sys.exit(1) - pp.pprint(client.checkAndPut(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),eval(args[5]),)) - -else: - print 'Unrecognized method %s' % cmd - sys.exit(1) - -transport.close() |
