src/main/python/AccumuloProxy-remote

# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#!/usr/bin/env python
#
# Autogenerated by Thrift Compiler (0.9.1)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
#  options string: py
#

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

from accumulo import AccumuloProxy
from accumulo.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 '  string login(string principal,  loginProperties)'
  print '  i32 addConstraint(string login, string tableName, string constraintClassName)'
  print '  void addSplits(string login, string tableName,  splits)'
  print '  void attachIterator(string login, string tableName, IteratorSetting setting,  scopes)'
  print '  void checkIteratorConflicts(string login, string tableName, IteratorSetting setting,  scopes)'
  print '  void clearLocatorCache(string login, string tableName)'
  print '  void cloneTable(string login, string tableName, string newTableName, bool flush,  propertiesToSet,  propertiesToExclude)'
  print '  void compactTable(string login, string tableName, string startRow, string endRow,  iterators, bool flush, bool wait, CompactionStrategyConfig compactionStrategy)'
  print '  void cancelCompaction(string login, string tableName)'
  print '  void createTable(string login, string tableName, bool versioningIter, TimeType type)'
  print '  void deleteTable(string login, string tableName)'
  print '  void deleteRows(string login, string tableName, string startRow, string endRow)'
  print '  void exportTable(string login, string tableName, string exportDir)'
  print '  void flushTable(string login, string tableName, string startRow, string endRow, bool wait)'
  print '   getDiskUsage(string login,  tables)'
  print '   getLocalityGroups(string login, string tableName)'
  print '  IteratorSetting getIteratorSetting(string login, string tableName, string iteratorName, IteratorScope scope)'
  print '  string getMaxRow(string login, string tableName,  auths, string startRow, bool startInclusive, string endRow, bool endInclusive)'
  print '   getTableProperties(string login, string tableName)'
  print '  void importDirectory(string login, string tableName, string importDir, string failureDir, bool setTime)'
  print '  void importTable(string login, string tableName, string importDir)'
  print '   listSplits(string login, string tableName, i32 maxSplits)'
  print '   listTables(string login)'
  print '   listIterators(string login, string tableName)'
  print '   listConstraints(string login, string tableName)'
  print '  void mergeTablets(string login, string tableName, string startRow, string endRow)'
  print '  void offlineTable(string login, string tableName, bool wait)'
  print '  void onlineTable(string login, string tableName, bool wait)'
  print '  void removeConstraint(string login, string tableName, i32 constraint)'
  print '  void removeIterator(string login, string tableName, string iterName,  scopes)'
  print '  void removeTableProperty(string login, string tableName, string property)'
  print '  void renameTable(string login, string oldTableName, string newTableName)'
  print '  void setLocalityGroups(string login, string tableName,  groups)'
  print '  void setTableProperty(string login, string tableName, string property, string value)'
  print '   splitRangeByTablets(string login, string tableName, Range range, i32 maxSplits)'
  print '  bool tableExists(string login, string tableName)'
  print '   tableIdMap(string login)'
  print '  bool testTableClassLoad(string login, string tableName, string className, string asTypeName)'
  print '  void pingTabletServer(string login, string tserver)'
  print '   getActiveScans(string login, string tserver)'
  print '   getActiveCompactions(string login, string tserver)'
  print '   getSiteConfiguration(string login)'
  print '   getSystemConfiguration(string login)'
  print '   getTabletServers(string login)'
  print '  void removeProperty(string login, string property)'
  print '  void setProperty(string login, string property, string value)'
  print '  bool testClassLoad(string login, string className, string asTypeName)'
  print '  bool authenticateUser(string login, string user,  properties)'
  print '  void changeUserAuthorizations(string login, string user,  authorizations)'
  print '  void changeLocalUserPassword(string login, string user, string password)'
  print '  void createLocalUser(string login, string user, string password)'
  print '  void dropLocalUser(string login, string user)'
  print '   getUserAuthorizations(string login, string user)'
  print '  void grantSystemPermission(string login, string user, SystemPermission perm)'
  print '  void grantTablePermission(string login, string user, string table, TablePermission perm)'
  print '  bool hasSystemPermission(string login, string user, SystemPermission perm)'
  print '  bool hasTablePermission(string login, string user, string table, TablePermission perm)'
  print '   listLocalUsers(string login)'
  print '  void revokeSystemPermission(string login, string user, SystemPermission perm)'
  print '  void revokeTablePermission(string login, string user, string table, TablePermission perm)'
  print '  string createBatchScanner(string login, string tableName, BatchScanOptions options)'
  print '  string createScanner(string login, string tableName, ScanOptions options)'
  print '  bool hasNext(string scanner)'
  print '  KeyValueAndPeek nextEntry(string scanner)'
  print '  ScanResult nextK(string scanner, i32 k)'
  print '  void closeScanner(string scanner)'
  print '  void updateAndFlush(string login, string tableName,  cells)'
  print '  string createWriter(string login, string tableName, WriterOptions opts)'
  print '  void update(string writer,  cells)'
  print '  void flush(string writer)'
  print '  void closeWriter(string writer)'
  print '  ConditionalStatus updateRowConditionally(string login, string tableName, string row, ConditionalUpdates updates)'
  print '  string createConditionalWriter(string login, string tableName, ConditionalWriterOptions options)'
  print '   updateRowsConditionally(string conditionalWriter,  updates)'
  print '  void closeConditionalWriter(string conditionalWriter)'
  print '  Range getRowRange(string row)'
  print '  Key getFollowing(Key key, PartialKey part)'
  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 = AccumuloProxy.Client(protocol)
transport.open()

if cmd == 'login':
  if len(args) != 2:
    print 'login requires 2 args'
    sys.exit(1)
  pp.pprint(client.login(args[0],eval(args[1]),))

elif cmd == 'addConstraint':
  if len(args) != 3:
    print 'addConstraint requires 3 args'
    sys.exit(1)
  pp.pprint(client.addConstraint(args[0],args[1],args[2],))

elif cmd == 'addSplits':
  if len(args) != 3:
    print 'addSplits requires 3 args'
    sys.exit(1)
  pp.pprint(client.addSplits(args[0],args[1],eval(args[2]),))

elif cmd == 'attachIterator':
  if len(args) != 4:
    print 'attachIterator requires 4 args'
    sys.exit(1)
  pp.pprint(client.attachIterator(args[0],args[1],eval(args[2]),eval(args[3]),))

elif cmd == 'checkIteratorConflicts':
  if len(args) != 4:
    print 'checkIteratorConflicts requires 4 args'
    sys.exit(1)
  pp.pprint(client.checkIteratorConflicts(args[0],args[1],eval(args[2]),eval(args[3]),))

elif cmd == 'clearLocatorCache':
  if len(args) != 2:
    print 'clearLocatorCache requires 2 args'
    sys.exit(1)
  pp.pprint(client.clearLocatorCache(args[0],args[1],))

elif cmd == 'cloneTable':
  if len(args) != 6:
    print 'cloneTable requires 6 args'
    sys.exit(1)
  pp.pprint(client.cloneTable(args[0],args[1],args[2],eval(args[3]),eval(args[4]),eval(args[5]),))

elif cmd == 'compactTable':
  if len(args) != 8:
    print 'compactTable requires 8 args'
    sys.exit(1)
  pp.pprint(client.compactTable(args[0],args[1],args[2],args[3],eval(args[4]),eval(args[5]),eval(args[6]),eval(args[7]),))

elif cmd == 'cancelCompaction':
  if len(args) != 2:
    print 'cancelCompaction requires 2 args'
    sys.exit(1)
  pp.pprint(client.cancelCompaction(args[0],args[1],))

elif cmd == 'createTable':
  if len(args) != 4:
    print 'createTable requires 4 args'
    sys.exit(1)
  pp.pprint(client.createTable(args[0],args[1],eval(args[2]),eval(args[3]),))

elif cmd == 'deleteTable':
  if len(args) != 2:
    print 'deleteTable requires 2 args'
    sys.exit(1)
  pp.pprint(client.deleteTable(args[0],args[1],))

elif cmd == 'deleteRows':
  if len(args) != 4:
    print 'deleteRows requires 4 args'
    sys.exit(1)
  pp.pprint(client.deleteRows(args[0],args[1],args[2],args[3],))

elif cmd == 'exportTable':
  if len(args) != 3:
    print 'exportTable requires 3 args'
    sys.exit(1)
  pp.pprint(client.exportTable(args[0],args[1],args[2],))

elif cmd == 'flushTable':
  if len(args) != 5:
    print 'flushTable requires 5 args'
    sys.exit(1)
  pp.pprint(client.flushTable(args[0],args[1],args[2],args[3],eval(args[4]),))

elif cmd == 'getDiskUsage':
  if len(args) != 2:
    print 'getDiskUsage requires 2 args'
    sys.exit(1)
  pp.pprint(client.getDiskUsage(args[0],eval(args[1]),))

elif cmd == 'getLocalityGroups':
  if len(args) != 2:
    print 'getLocalityGroups requires 2 args'
    sys.exit(1)
  pp.pprint(client.getLocalityGroups(args[0],args[1],))

elif cmd == 'getIteratorSetting':
  if len(args) != 4:
    print 'getIteratorSetting requires 4 args'
    sys.exit(1)
  pp.pprint(client.getIteratorSetting(args[0],args[1],args[2],eval(args[3]),))

elif cmd == 'getMaxRow':
  if len(args) != 7:
    print 'getMaxRow requires 7 args'
    sys.exit(1)
  pp.pprint(client.getMaxRow(args[0],args[1],eval(args[2]),args[3],eval(args[4]),args[5],eval(args[6]),))

elif cmd == 'getTableProperties':
  if len(args) != 2:
    print 'getTableProperties requires 2 args'
    sys.exit(1)
  pp.pprint(client.getTableProperties(args[0],args[1],))

elif cmd == 'importDirectory':
  if len(args) != 5:
    print 'importDirectory requires 5 args'
    sys.exit(1)
  pp.pprint(client.importDirectory(args[0],args[1],args[2],args[3],eval(args[4]),))

elif cmd == 'importTable':
  if len(args) != 3:
    print 'importTable requires 3 args'
    sys.exit(1)
  pp.pprint(client.importTable(args[0],args[1],args[2],))

elif cmd == 'listSplits':
  if len(args) != 3:
    print 'listSplits requires 3 args'
    sys.exit(1)
  pp.pprint(client.listSplits(args[0],args[1],eval(args[2]),))

elif cmd == 'listTables':
  if len(args) != 1:
    print 'listTables requires 1 args'
    sys.exit(1)
  pp.pprint(client.listTables(args[0],))

elif cmd == 'listIterators':
  if len(args) != 2:
    print 'listIterators requires 2 args'
    sys.exit(1)
  pp.pprint(client.listIterators(args[0],args[1],))

elif cmd == 'listConstraints':
  if len(args) != 2:
    print 'listConstraints requires 2 args'
    sys.exit(1)
  pp.pprint(client.listConstraints(args[0],args[1],))

elif cmd == 'mergeTablets':
  if len(args) != 4:
    print 'mergeTablets requires 4 args'
    sys.exit(1)
  pp.pprint(client.mergeTablets(args[0],args[1],args[2],args[3],))

elif cmd == 'offlineTable':
  if len(args) != 3:
    print 'offlineTable requires 3 args'
    sys.exit(1)
  pp.pprint(client.offlineTable(args[0],args[1],eval(args[2]),))

elif cmd == 'onlineTable':
  if len(args) != 3:
    print 'onlineTable requires 3 args'
    sys.exit(1)
  pp.pprint(client.onlineTable(args[0],args[1],eval(args[2]),))

elif cmd == 'removeConstraint':
  if len(args) != 3:
    print 'removeConstraint requires 3 args'
    sys.exit(1)
  pp.pprint(client.removeConstraint(args[0],args[1],eval(args[2]),))

elif cmd == 'removeIterator':
  if len(args) != 4:
    print 'removeIterator requires 4 args'
    sys.exit(1)
  pp.pprint(client.removeIterator(args[0],args[1],args[2],eval(args[3]),))

elif cmd == 'removeTableProperty':
  if len(args) != 3:
    print 'removeTableProperty requires 3 args'
    sys.exit(1)
  pp.pprint(client.removeTableProperty(args[0],args[1],args[2],))

elif cmd == 'renameTable':
  if len(args) != 3:
    print 'renameTable requires 3 args'
    sys.exit(1)
  pp.pprint(client.renameTable(args[0],args[1],args[2],))

elif cmd == 'setLocalityGroups':
  if len(args) != 3:
    print 'setLocalityGroups requires 3 args'
    sys.exit(1)
  pp.pprint(client.setLocalityGroups(args[0],args[1],eval(args[2]),))

elif cmd == 'setTableProperty':
  if len(args) != 4:
    print 'setTableProperty requires 4 args'
    sys.exit(1)
  pp.pprint(client.setTableProperty(args[0],args[1],args[2],args[3],))

elif cmd == 'splitRangeByTablets':
  if len(args) != 4:
    print 'splitRangeByTablets requires 4 args'
    sys.exit(1)
  pp.pprint(client.splitRangeByTablets(args[0],args[1],eval(args[2]),eval(args[3]),))

elif cmd == 'tableExists':
  if len(args) != 2:
    print 'tableExists requires 2 args'
    sys.exit(1)
  pp.pprint(client.tableExists(args[0],args[1],))

elif cmd == 'tableIdMap':
  if len(args) != 1:
    print 'tableIdMap requires 1 args'
    sys.exit(1)
  pp.pprint(client.tableIdMap(args[0],))

elif cmd == 'testTableClassLoad':
  if len(args) != 4:
    print 'testTableClassLoad requires 4 args'
    sys.exit(1)
  pp.pprint(client.testTableClassLoad(args[0],args[1],args[2],args[3],))

elif cmd == 'pingTabletServer':
  if len(args) != 2:
    print 'pingTabletServer requires 2 args'
    sys.exit(1)
  pp.pprint(client.pingTabletServer(args[0],args[1],))

elif cmd == 'getActiveScans':
  if len(args) != 2:
    print 'getActiveScans requires 2 args'
    sys.exit(1)
  pp.pprint(client.getActiveScans(args[0],args[1],))

elif cmd == 'getActiveCompactions':
  if len(args) != 2:
    print 'getActiveCompactions requires 2 args'
    sys.exit(1)
  pp.pprint(client.getActiveCompactions(args[0],args[1],))

elif cmd == 'getSiteConfiguration':
  if len(args) != 1:
    print 'getSiteConfiguration requires 1 args'
    sys.exit(1)
  pp.pprint(client.getSiteConfiguration(args[0],))

elif cmd == 'getSystemConfiguration':
  if len(args) != 1:
    print 'getSystemConfiguration requires 1 args'
    sys.exit(1)
  pp.pprint(client.getSystemConfiguration(args[0],))

elif cmd == 'getTabletServers':
  if len(args) != 1:
    print 'getTabletServers requires 1 args'
    sys.exit(1)
  pp.pprint(client.getTabletServers(args[0],))

elif cmd == 'removeProperty':
  if len(args) != 2:
    print 'removeProperty requires 2 args'
    sys.exit(1)
  pp.pprint(client.removeProperty(args[0],args[1],))

elif cmd == 'setProperty':
  if len(args) != 3:
    print 'setProperty requires 3 args'
    sys.exit(1)
  pp.pprint(client.setProperty(args[0],args[1],args[2],))

elif cmd == 'testClassLoad':
  if len(args) != 3:
    print 'testClassLoad requires 3 args'
    sys.exit(1)
  pp.pprint(client.testClassLoad(args[0],args[1],args[2],))

elif cmd == 'authenticateUser':
  if len(args) != 3:
    print 'authenticateUser requires 3 args'
    sys.exit(1)
  pp.pprint(client.authenticateUser(args[0],args[1],eval(args[2]),))

elif cmd == 'changeUserAuthorizations':
  if len(args) != 3:
    print 'changeUserAuthorizations requires 3 args'
    sys.exit(1)
  pp.pprint(client.changeUserAuthorizations(args[0],args[1],eval(args[2]),))

elif cmd == 'changeLocalUserPassword':
  if len(args) != 3:
    print 'changeLocalUserPassword requires 3 args'
    sys.exit(1)
  pp.pprint(client.changeLocalUserPassword(args[0],args[1],args[2],))

elif cmd == 'createLocalUser':
  if len(args) != 3:
    print 'createLocalUser requires 3 args'
    sys.exit(1)
  pp.pprint(client.createLocalUser(args[0],args[1],args[2],))

elif cmd == 'dropLocalUser':
  if len(args) != 2:
    print 'dropLocalUser requires 2 args'
    sys.exit(1)
  pp.pprint(client.dropLocalUser(args[0],args[1],))

elif cmd == 'getUserAuthorizations':
  if len(args) != 2:
    print 'getUserAuthorizations requires 2 args'
    sys.exit(1)
  pp.pprint(client.getUserAuthorizations(args[0],args[1],))

elif cmd == 'grantSystemPermission':
  if len(args) != 3:
    print 'grantSystemPermission requires 3 args'
    sys.exit(1)
  pp.pprint(client.grantSystemPermission(args[0],args[1],eval(args[2]),))

elif cmd == 'grantTablePermission':
  if len(args) != 4:
    print 'grantTablePermission requires 4 args'
    sys.exit(1)
  pp.pprint(client.grantTablePermission(args[0],args[1],args[2],eval(args[3]),))

elif cmd == 'hasSystemPermission':
  if len(args) != 3:
    print 'hasSystemPermission requires 3 args'
    sys.exit(1)
  pp.pprint(client.hasSystemPermission(args[0],args[1],eval(args[2]),))

elif cmd == 'hasTablePermission':
  if len(args) != 4:
    print 'hasTablePermission requires 4 args'
    sys.exit(1)
  pp.pprint(client.hasTablePermission(args[0],args[1],args[2],eval(args[3]),))

elif cmd == 'listLocalUsers':
  if len(args) != 1:
    print 'listLocalUsers requires 1 args'
    sys.exit(1)
  pp.pprint(client.listLocalUsers(args[0],))

elif cmd == 'revokeSystemPermission':
  if len(args) != 3:
    print 'revokeSystemPermission requires 3 args'
    sys.exit(1)
  pp.pprint(client.revokeSystemPermission(args[0],args[1],eval(args[2]),))

elif cmd == 'revokeTablePermission':
  if len(args) != 4:
    print 'revokeTablePermission requires 4 args'
    sys.exit(1)
  pp.pprint(client.revokeTablePermission(args[0],args[1],args[2],eval(args[3]),))

elif cmd == 'createBatchScanner':
  if len(args) != 3:
    print 'createBatchScanner requires 3 args'
    sys.exit(1)
  pp.pprint(client.createBatchScanner(args[0],args[1],eval(args[2]),))

elif cmd == 'createScanner':
  if len(args) != 3:
    print 'createScanner requires 3 args'
    sys.exit(1)
  pp.pprint(client.createScanner(args[0],args[1],eval(args[2]),))

elif cmd == 'hasNext':
  if len(args) != 1:
    print 'hasNext requires 1 args'
    sys.exit(1)
  pp.pprint(client.hasNext(args[0],))

elif cmd == 'nextEntry':
  if len(args) != 1:
    print 'nextEntry requires 1 args'
    sys.exit(1)
  pp.pprint(client.nextEntry(args[0],))

elif cmd == 'nextK':
  if len(args) != 2:
    print 'nextK requires 2 args'
    sys.exit(1)
  pp.pprint(client.nextK(args[0],eval(args[1]),))

elif cmd == 'closeScanner':
  if len(args) != 1:
    print 'closeScanner requires 1 args'
    sys.exit(1)
  pp.pprint(client.closeScanner(args[0],))

elif cmd == 'updateAndFlush':
  if len(args) != 3:
    print 'updateAndFlush requires 3 args'
    sys.exit(1)
  pp.pprint(client.updateAndFlush(args[0],args[1],eval(args[2]),))

elif cmd == 'createWriter':
  if len(args) != 3:
    print 'createWriter requires 3 args'
    sys.exit(1)
  pp.pprint(client.createWriter(args[0],args[1],eval(args[2]),))

elif cmd == 'update':
  if len(args) != 2:
    print 'update requires 2 args'
    sys.exit(1)
  pp.pprint(client.update(args[0],eval(args[1]),))

elif cmd == 'flush':
  if len(args) != 1:
    print 'flush requires 1 args'
    sys.exit(1)
  pp.pprint(client.flush(args[0],))

elif cmd == 'closeWriter':
  if len(args) != 1:
    print 'closeWriter requires 1 args'
    sys.exit(1)
  pp.pprint(client.closeWriter(args[0],))

elif cmd == 'updateRowConditionally':
  if len(args) != 4:
    print 'updateRowConditionally requires 4 args'
    sys.exit(1)
  pp.pprint(client.updateRowConditionally(args[0],args[1],args[2],eval(args[3]),))

elif cmd == 'createConditionalWriter':
  if len(args) != 3:
    print 'createConditionalWriter requires 3 args'
    sys.exit(1)
  pp.pprint(client.createConditionalWriter(args[0],args[1],eval(args[2]),))

elif cmd == 'updateRowsConditionally':
  if len(args) != 2:
    print 'updateRowsConditionally requires 2 args'
    sys.exit(1)
  pp.pprint(client.updateRowsConditionally(args[0],eval(args[1]),))

elif cmd == 'closeConditionalWriter':
  if len(args) != 1:
    print 'closeConditionalWriter requires 1 args'
    sys.exit(1)
  pp.pprint(client.closeConditionalWriter(args[0],))

elif cmd == 'getRowRange':
  if len(args) != 1:
    print 'getRowRange requires 1 args'
    sys.exit(1)
  pp.pprint(client.getRowRange(args[0],))

elif cmd == 'getFollowing':
  if len(args) != 2:
    print 'getFollowing requires 2 args'
    sys.exit(1)
  pp.pprint(client.getFollowing(eval(args[0]),eval(args[1]),))

else:
  print 'Unrecognized method %s' % cmd
  sys.exit(1)

transport.close()