blob: 65d1243215709b7d7dd6b0012353bb90bb9a3223 [file] [log] [blame]
#!/usr/bin/env python
#
# 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
#
# https://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.
#
#
# Autogenerated by Thrift Compiler (0.17.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
# options string: py
#
import sys
import pprint
if sys.version_info[0] > 2:
from urllib.parse import urlparse
else:
from urlparse import urlparse
from thrift.transport import TTransport, TSocket, TSSLSocket, THttpClient
from thrift.protocol.TBinaryProtocol 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]] [-s[sl]] [-novalidate] [-ca_certs certs] [-keyfile keyfile] [-certfile certfile] function [arg1 [arg2...]]')
print('')
print('Functions:')
print(' i32 addConstraint(string sharedSecret, string tableName, string constraintClassName)')
print(' void addSplits(string sharedSecret, string tableName, splits)')
print(' void attachIterator(string sharedSecret, string tableName, IteratorSetting setting, scopes)')
print(' void checkIteratorConflicts(string sharedSecret, string tableName, IteratorSetting setting, scopes)')
print(' void clearLocatorCache(string sharedSecret, string tableName)')
print(' void cloneTable(string sharedSecret, string tableName, string newTableName, bool flush, propertiesToSet, propertiesToExclude)')
print(' void compactTable(string sharedSecret, string tableName, string startRow, string endRow, iterators, bool flush, bool wait, PluginConfig selectorConfig, PluginConfig configurerConfig)')
print(' void cancelCompaction(string sharedSecret, string tableName)')
print(' void createTable(string sharedSecret, string tableName, bool versioningIter, TimeType type)')
print(' void deleteTable(string sharedSecret, string tableName)')
print(' void deleteRows(string sharedSecret, string tableName, string startRow, string endRow)')
print(' void exportTable(string sharedSecret, string tableName, string exportDir)')
print(' void flushTable(string sharedSecret, string tableName, string startRow, string endRow, bool wait)')
print(' getDiskUsage(string sharedSecret, tables)')
print(' getLocalityGroups(string sharedSecret, string tableName)')
print(' IteratorSetting getIteratorSetting(string sharedSecret, string tableName, string iteratorName, IteratorScope scope)')
print(' string getMaxRow(string sharedSecret, string tableName, auths, string startRow, bool startInclusive, string endRow, bool endInclusive)')
print(' getTableProperties(string sharedSecret, string tableName)')
print(' void importDirectory(string sharedSecret, string tableName, string importDir, string failureDir, bool setTime)')
print(' void importTable(string sharedSecret, string tableName, string importDir)')
print(' listSplits(string sharedSecret, string tableName, i32 maxSplits)')
print(' listTables(string sharedSecret)')
print(' listIterators(string sharedSecret, string tableName)')
print(' listConstraints(string sharedSecret, string tableName)')
print(' void mergeTablets(string sharedSecret, string tableName, string startRow, string endRow)')
print(' void offlineTable(string sharedSecret, string tableName, bool wait)')
print(' void onlineTable(string sharedSecret, string tableName, bool wait)')
print(' void removeConstraint(string sharedSecret, string tableName, i32 constraint)')
print(' void removeIterator(string sharedSecret, string tableName, string iterName, scopes)')
print(' void removeTableProperty(string sharedSecret, string tableName, string property)')
print(' void renameTable(string sharedSecret, string oldTableName, string newTableName)')
print(' void setLocalityGroups(string sharedSecret, string tableName, groups)')
print(' void setTableProperty(string sharedSecret, string tableName, string property, string value)')
print(' splitRangeByTablets(string sharedSecret, string tableName, Range range, i32 maxSplits)')
print(' bool tableExists(string sharedSecret, string tableName)')
print(' tableIdMap(string sharedSecret)')
print(' bool testTableClassLoad(string sharedSecret, string tableName, string className, string asTypeName)')
print(' void pingTabletServer(string sharedSecret, string tserver)')
print(' getActiveScans(string sharedSecret, string tserver)')
print(' getActiveCompactions(string sharedSecret, string tserver)')
print(' getSiteConfiguration(string sharedSecret)')
print(' getSystemConfiguration(string sharedSecret)')
print(' getTabletServers(string sharedSecret)')
print(' void removeProperty(string sharedSecret, string property)')
print(' void setProperty(string sharedSecret, string property, string value)')
print(' bool testClassLoad(string sharedSecret, string className, string asTypeName)')
print(' bool authenticateUser(string sharedSecret, string user, properties)')
print(' void changeUserAuthorizations(string sharedSecret, string user, authorizations)')
print(' void changeLocalUserPassword(string sharedSecret, string user, string password)')
print(' void createLocalUser(string sharedSecret, string user, string password)')
print(' void dropLocalUser(string sharedSecret, string user)')
print(' getUserAuthorizations(string sharedSecret, string user)')
print(' void grantSystemPermission(string sharedSecret, string user, SystemPermission perm)')
print(' void grantTablePermission(string sharedSecret, string user, string table, TablePermission perm)')
print(' bool hasSystemPermission(string sharedSecret, string user, SystemPermission perm)')
print(' bool hasTablePermission(string sharedSecret, string user, string table, TablePermission perm)')
print(' listLocalUsers(string sharedSecret)')
print(' void revokeSystemPermission(string sharedSecret, string user, SystemPermission perm)')
print(' void revokeTablePermission(string sharedSecret, string user, string table, TablePermission perm)')
print(' void grantNamespacePermission(string sharedSecret, string user, string namespaceName, NamespacePermission perm)')
print(' bool hasNamespacePermission(string sharedSecret, string user, string namespaceName, NamespacePermission perm)')
print(' void revokeNamespacePermission(string sharedSecret, string user, string namespaceName, NamespacePermission perm)')
print(' string createBatchScanner(string sharedSecret, string tableName, BatchScanOptions options)')
print(' string createScanner(string sharedSecret, 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 sharedSecret, string tableName, cells)')
print(' string createWriter(string sharedSecret, string tableName, WriterOptions opts)')
print(' void update(string writer, cells)')
print(' void flush(string writer)')
print(' void closeWriter(string writer)')
print(' ConditionalStatus updateRowConditionally(string sharedSecret, string tableName, string row, ConditionalUpdates updates)')
print(' string createConditionalWriter(string sharedSecret, 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(' string systemNamespace()')
print(' string defaultNamespace()')
print(' listNamespaces(string sharedSecret)')
print(' bool namespaceExists(string sharedSecret, string namespaceName)')
print(' void createNamespace(string sharedSecret, string namespaceName)')
print(' void deleteNamespace(string sharedSecret, string namespaceName)')
print(' void renameNamespace(string sharedSecret, string oldNamespaceName, string newNamespaceName)')
print(' void setNamespaceProperty(string sharedSecret, string namespaceName, string property, string value)')
print(' void removeNamespaceProperty(string sharedSecret, string namespaceName, string property)')
print(' getNamespaceProperties(string sharedSecret, string namespaceName)')
print(' namespaceIdMap(string sharedSecret)')
print(' void attachNamespaceIterator(string sharedSecret, string namespaceName, IteratorSetting setting, scopes)')
print(' void removeNamespaceIterator(string sharedSecret, string namespaceName, string name, scopes)')
print(' IteratorSetting getNamespaceIteratorSetting(string sharedSecret, string namespaceName, string name, IteratorScope scope)')
print(' listNamespaceIterators(string sharedSecret, string namespaceName)')
print(' void checkNamespaceIteratorConflicts(string sharedSecret, string namespaceName, IteratorSetting setting, scopes)')
print(' i32 addNamespaceConstraint(string sharedSecret, string namespaceName, string constraintClassName)')
print(' void removeNamespaceConstraint(string sharedSecret, string namespaceName, i32 id)')
print(' listNamespaceConstraints(string sharedSecret, string namespaceName)')
print(' bool testNamespaceClassLoad(string sharedSecret, string namespaceName, string className, string asTypeName)')
print('')
sys.exit(0)
pp = pprint.PrettyPrinter(indent=2)
host = 'localhost'
port = 9090
uri = ''
framed = False
ssl = False
validate = True
ca_certs = None
keyfile = None
certfile = None
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
if sys.argv[argi] == '-s' or sys.argv[argi] == '-ssl':
ssl = True
argi += 1
if sys.argv[argi] == '-novalidate':
validate = False
argi += 1
if sys.argv[argi] == '-ca_certs':
ca_certs = sys.argv[argi+1]
argi += 2
if sys.argv[argi] == '-keyfile':
keyfile = sys.argv[argi+1]
argi += 2
if sys.argv[argi] == '-certfile':
certfile = sys.argv[argi+1]
argi += 2
cmd = sys.argv[argi]
args = sys.argv[argi + 1:]
if http:
transport = THttpClient.THttpClient(host, port, uri)
else:
if ssl:
socket = TSSLSocket.TSSLSocket(host, port, validate=validate, ca_certs=ca_certs, keyfile=keyfile, certfile=certfile)
else:
socket = TSocket.TSocket(host, port)
if framed:
transport = TTransport.TFramedTransport(socket)
else:
transport = TTransport.TBufferedTransport(socket)
protocol = TBinaryProtocol(transport)
client = AccumuloProxy.Client(protocol)
transport.open()
if 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) != 9:
print('compactTable requires 9 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]), eval(args[8]),))
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 == 'grantNamespacePermission':
if len(args) != 4:
print('grantNamespacePermission requires 4 args')
sys.exit(1)
pp.pprint(client.grantNamespacePermission(args[0], args[1], args[2], eval(args[3]),))
elif cmd == 'hasNamespacePermission':
if len(args) != 4:
print('hasNamespacePermission requires 4 args')
sys.exit(1)
pp.pprint(client.hasNamespacePermission(args[0], args[1], args[2], eval(args[3]),))
elif cmd == 'revokeNamespacePermission':
if len(args) != 4:
print('revokeNamespacePermission requires 4 args')
sys.exit(1)
pp.pprint(client.revokeNamespacePermission(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]),))
elif cmd == 'systemNamespace':
if len(args) != 0:
print('systemNamespace requires 0 args')
sys.exit(1)
pp.pprint(client.systemNamespace())
elif cmd == 'defaultNamespace':
if len(args) != 0:
print('defaultNamespace requires 0 args')
sys.exit(1)
pp.pprint(client.defaultNamespace())
elif cmd == 'listNamespaces':
if len(args) != 1:
print('listNamespaces requires 1 args')
sys.exit(1)
pp.pprint(client.listNamespaces(args[0],))
elif cmd == 'namespaceExists':
if len(args) != 2:
print('namespaceExists requires 2 args')
sys.exit(1)
pp.pprint(client.namespaceExists(args[0], args[1],))
elif cmd == 'createNamespace':
if len(args) != 2:
print('createNamespace requires 2 args')
sys.exit(1)
pp.pprint(client.createNamespace(args[0], args[1],))
elif cmd == 'deleteNamespace':
if len(args) != 2:
print('deleteNamespace requires 2 args')
sys.exit(1)
pp.pprint(client.deleteNamespace(args[0], args[1],))
elif cmd == 'renameNamespace':
if len(args) != 3:
print('renameNamespace requires 3 args')
sys.exit(1)
pp.pprint(client.renameNamespace(args[0], args[1], args[2],))
elif cmd == 'setNamespaceProperty':
if len(args) != 4:
print('setNamespaceProperty requires 4 args')
sys.exit(1)
pp.pprint(client.setNamespaceProperty(args[0], args[1], args[2], args[3],))
elif cmd == 'removeNamespaceProperty':
if len(args) != 3:
print('removeNamespaceProperty requires 3 args')
sys.exit(1)
pp.pprint(client.removeNamespaceProperty(args[0], args[1], args[2],))
elif cmd == 'getNamespaceProperties':
if len(args) != 2:
print('getNamespaceProperties requires 2 args')
sys.exit(1)
pp.pprint(client.getNamespaceProperties(args[0], args[1],))
elif cmd == 'namespaceIdMap':
if len(args) != 1:
print('namespaceIdMap requires 1 args')
sys.exit(1)
pp.pprint(client.namespaceIdMap(args[0],))
elif cmd == 'attachNamespaceIterator':
if len(args) != 4:
print('attachNamespaceIterator requires 4 args')
sys.exit(1)
pp.pprint(client.attachNamespaceIterator(args[0], args[1], eval(args[2]), eval(args[3]),))
elif cmd == 'removeNamespaceIterator':
if len(args) != 4:
print('removeNamespaceIterator requires 4 args')
sys.exit(1)
pp.pprint(client.removeNamespaceIterator(args[0], args[1], args[2], eval(args[3]),))
elif cmd == 'getNamespaceIteratorSetting':
if len(args) != 4:
print('getNamespaceIteratorSetting requires 4 args')
sys.exit(1)
pp.pprint(client.getNamespaceIteratorSetting(args[0], args[1], args[2], eval(args[3]),))
elif cmd == 'listNamespaceIterators':
if len(args) != 2:
print('listNamespaceIterators requires 2 args')
sys.exit(1)
pp.pprint(client.listNamespaceIterators(args[0], args[1],))
elif cmd == 'checkNamespaceIteratorConflicts':
if len(args) != 4:
print('checkNamespaceIteratorConflicts requires 4 args')
sys.exit(1)
pp.pprint(client.checkNamespaceIteratorConflicts(args[0], args[1], eval(args[2]), eval(args[3]),))
elif cmd == 'addNamespaceConstraint':
if len(args) != 3:
print('addNamespaceConstraint requires 3 args')
sys.exit(1)
pp.pprint(client.addNamespaceConstraint(args[0], args[1], args[2],))
elif cmd == 'removeNamespaceConstraint':
if len(args) != 3:
print('removeNamespaceConstraint requires 3 args')
sys.exit(1)
pp.pprint(client.removeNamespaceConstraint(args[0], args[1], eval(args[2]),))
elif cmd == 'listNamespaceConstraints':
if len(args) != 2:
print('listNamespaceConstraints requires 2 args')
sys.exit(1)
pp.pprint(client.listNamespaceConstraints(args[0], args[1],))
elif cmd == 'testNamespaceClassLoad':
if len(args) != 4:
print('testNamespaceClassLoad requires 4 args')
sys.exit(1)
pp.pprint(client.testNamespaceClassLoad(args[0], args[1], args[2], args[3],))
else:
print('Unrecognized method %s' % cmd)
sys.exit(1)
transport.close()