http://git-wip-us.apache.org/repos/asf/accumulo/blob/62bbce43/proxy/src/main/python/AccumuloProxy.py ---------------------------------------------------------------------- diff --git a/proxy/src/main/python/AccumuloProxy.py b/proxy/src/main/python/AccumuloProxy.py index 19bd257..ea6e63a 100644 --- a/proxy/src/main/python/AccumuloProxy.py +++ b/proxy/src/main/python/AccumuloProxy.py @@ -13,83 +13,8495 @@ # See the License for the specific language governing permissions and # limitations under the License. # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.10.0) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # # options string: py # -from thrift.Thrift import TType, TMessageType, TException, TApplicationException +from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException +from thrift.protocol.TProtocol import TProtocolException +import sys import logging -from ttypes import * +from .ttypes import * from thrift.Thrift import TProcessor from thrift.transport import TTransport -from thrift.protocol import TBinaryProtocol, TProtocol -try: - from thrift.protocol import fastbinary -except: - fastbinary = None -class Iface: - def login(self, principal, loginProperties): +class Iface(object): + def login(self, principal, loginProperties): + """ + Parameters: + - principal + - loginProperties + """ + pass + + def addConstraint(self, login, tableName, constraintClassName): + """ + Parameters: + - login + - tableName + - constraintClassName + """ + pass + + def addSplits(self, login, tableName, splits): + """ + Parameters: + - login + - tableName + - splits + """ + pass + + def attachIterator(self, login, tableName, setting, scopes): + """ + Parameters: + - login + - tableName + - setting + - scopes + """ + pass + + def checkIteratorConflicts(self, login, tableName, setting, scopes): + """ + Parameters: + - login + - tableName + - setting + - scopes + """ + pass + + def clearLocatorCache(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + pass + + def cloneTable(self, login, tableName, newTableName, flush, propertiesToSet, propertiesToExclude): + """ + Parameters: + - login + - tableName + - newTableName + - flush + - propertiesToSet + - propertiesToExclude + """ + pass + + def compactTable(self, login, tableName, startRow, endRow, iterators, flush, wait, compactionStrategy): + """ + Parameters: + - login + - tableName + - startRow + - endRow + - iterators + - flush + - wait + - compactionStrategy + """ + pass + + def cancelCompaction(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + pass + + def createTable(self, login, tableName, versioningIter, type): + """ + Parameters: + - login + - tableName + - versioningIter + - type + """ + pass + + def deleteTable(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + pass + + def deleteRows(self, login, tableName, startRow, endRow): + """ + Parameters: + - login + - tableName + - startRow + - endRow + """ + pass + + def exportTable(self, login, tableName, exportDir): + """ + Parameters: + - login + - tableName + - exportDir + """ + pass + + def flushTable(self, login, tableName, startRow, endRow, wait): + """ + Parameters: + - login + - tableName + - startRow + - endRow + - wait + """ + pass + + def getDiskUsage(self, login, tables): + """ + Parameters: + - login + - tables + """ + pass + + def getLocalityGroups(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + pass + + def getIteratorSetting(self, login, tableName, iteratorName, scope): + """ + Parameters: + - login + - tableName + - iteratorName + - scope + """ + pass + + def getMaxRow(self, login, tableName, auths, startRow, startInclusive, endRow, endInclusive): + """ + Parameters: + - login + - tableName + - auths + - startRow + - startInclusive + - endRow + - endInclusive + """ + pass + + def getTableProperties(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + pass + + def importDirectory(self, login, tableName, importDir, failureDir, setTime): + """ + Parameters: + - login + - tableName + - importDir + - failureDir + - setTime + """ + pass + + def importTable(self, login, tableName, importDir): + """ + Parameters: + - login + - tableName + - importDir + """ + pass + + def listSplits(self, login, tableName, maxSplits): + """ + Parameters: + - login + - tableName + - maxSplits + """ + pass + + def listTables(self, login): + """ + Parameters: + - login + """ + pass + + def listIterators(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + pass + + def listConstraints(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + pass + + def mergeTablets(self, login, tableName, startRow, endRow): + """ + Parameters: + - login + - tableName + - startRow + - endRow + """ + pass + + def offlineTable(self, login, tableName, wait): + """ + Parameters: + - login + - tableName + - wait + """ + pass + + def onlineTable(self, login, tableName, wait): + """ + Parameters: + - login + - tableName + - wait + """ + pass + + def removeConstraint(self, login, tableName, constraint): + """ + Parameters: + - login + - tableName + - constraint + """ + pass + + def removeIterator(self, login, tableName, iterName, scopes): + """ + Parameters: + - login + - tableName + - iterName + - scopes + """ + pass + + def removeTableProperty(self, login, tableName, property): + """ + Parameters: + - login + - tableName + - property + """ + pass + + def renameTable(self, login, oldTableName, newTableName): + """ + Parameters: + - login + - oldTableName + - newTableName + """ + pass + + def setLocalityGroups(self, login, tableName, groups): + """ + Parameters: + - login + - tableName + - groups + """ + pass + + def setTableProperty(self, login, tableName, property, value): + """ + Parameters: + - login + - tableName + - property + - value + """ + pass + + def splitRangeByTablets(self, login, tableName, range, maxSplits): + """ + Parameters: + - login + - tableName + - range + - maxSplits + """ + pass + + def tableExists(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + pass + + def tableIdMap(self, login): + """ + Parameters: + - login + """ + pass + + def testTableClassLoad(self, login, tableName, className, asTypeName): + """ + Parameters: + - login + - tableName + - className + - asTypeName + """ + pass + + def pingTabletServer(self, login, tserver): + """ + Parameters: + - login + - tserver + """ + pass + + def getActiveScans(self, login, tserver): + """ + Parameters: + - login + - tserver + """ + pass + + def getActiveCompactions(self, login, tserver): + """ + Parameters: + - login + - tserver + """ + pass + + def getSiteConfiguration(self, login): + """ + Parameters: + - login + """ + pass + + def getSystemConfiguration(self, login): + """ + Parameters: + - login + """ + pass + + def getTabletServers(self, login): + """ + Parameters: + - login + """ + pass + + def removeProperty(self, login, property): + """ + Parameters: + - login + - property + """ + pass + + def setProperty(self, login, property, value): + """ + Parameters: + - login + - property + - value + """ + pass + + def testClassLoad(self, login, className, asTypeName): + """ + Parameters: + - login + - className + - asTypeName + """ + pass + + def authenticateUser(self, login, user, properties): + """ + Parameters: + - login + - user + - properties + """ + pass + + def changeUserAuthorizations(self, login, user, authorizations): + """ + Parameters: + - login + - user + - authorizations + """ + pass + + def changeLocalUserPassword(self, login, user, password): + """ + Parameters: + - login + - user + - password + """ + pass + + def createLocalUser(self, login, user, password): + """ + Parameters: + - login + - user + - password + """ + pass + + def dropLocalUser(self, login, user): + """ + Parameters: + - login + - user + """ + pass + + def getUserAuthorizations(self, login, user): + """ + Parameters: + - login + - user + """ + pass + + def grantSystemPermission(self, login, user, perm): + """ + Parameters: + - login + - user + - perm + """ + pass + + def grantTablePermission(self, login, user, table, perm): + """ + Parameters: + - login + - user + - table + - perm + """ + pass + + def hasSystemPermission(self, login, user, perm): + """ + Parameters: + - login + - user + - perm + """ + pass + + def hasTablePermission(self, login, user, table, perm): + """ + Parameters: + - login + - user + - table + - perm + """ + pass + + def listLocalUsers(self, login): + """ + Parameters: + - login + """ + pass + + def revokeSystemPermission(self, login, user, perm): + """ + Parameters: + - login + - user + - perm + """ + pass + + def revokeTablePermission(self, login, user, table, perm): + """ + Parameters: + - login + - user + - table + - perm + """ + pass + + def grantNamespacePermission(self, login, user, namespaceName, perm): + """ + Parameters: + - login + - user + - namespaceName + - perm + """ + pass + + def hasNamespacePermission(self, login, user, namespaceName, perm): + """ + Parameters: + - login + - user + - namespaceName + - perm + """ + pass + + def revokeNamespacePermission(self, login, user, namespaceName, perm): + """ + Parameters: + - login + - user + - namespaceName + - perm + """ + pass + + def createBatchScanner(self, login, tableName, options): + """ + Parameters: + - login + - tableName + - options + """ + pass + + def createScanner(self, login, tableName, options): + """ + Parameters: + - login + - tableName + - options + """ + pass + + def hasNext(self, scanner): + """ + Parameters: + - scanner + """ + pass + + def nextEntry(self, scanner): + """ + Parameters: + - scanner + """ + pass + + def nextK(self, scanner, k): + """ + Parameters: + - scanner + - k + """ + pass + + def closeScanner(self, scanner): + """ + Parameters: + - scanner + """ + pass + + def updateAndFlush(self, login, tableName, cells): + """ + Parameters: + - login + - tableName + - cells + """ + pass + + def createWriter(self, login, tableName, opts): + """ + Parameters: + - login + - tableName + - opts + """ + pass + + def update(self, writer, cells): + """ + Parameters: + - writer + - cells + """ + pass + + def flush(self, writer): + """ + Parameters: + - writer + """ + pass + + def closeWriter(self, writer): + """ + Parameters: + - writer + """ + pass + + def updateRowConditionally(self, login, tableName, row, updates): + """ + Parameters: + - login + - tableName + - row + - updates + """ + pass + + def createConditionalWriter(self, login, tableName, options): + """ + Parameters: + - login + - tableName + - options + """ + pass + + def updateRowsConditionally(self, conditionalWriter, updates): + """ + Parameters: + - conditionalWriter + - updates + """ + pass + + def closeConditionalWriter(self, conditionalWriter): + """ + Parameters: + - conditionalWriter + """ + pass + + def getRowRange(self, row): + """ + Parameters: + - row + """ + pass + + def getFollowing(self, key, part): + """ + Parameters: + - key + - part + """ + pass + + def systemNamespace(self): + pass + + def defaultNamespace(self): + pass + + def listNamespaces(self, login): + """ + Parameters: + - login + """ + pass + + def namespaceExists(self, login, namespaceName): + """ + Parameters: + - login + - namespaceName + """ + pass + + def createNamespace(self, login, namespaceName): + """ + Parameters: + - login + - namespaceName + """ + pass + + def deleteNamespace(self, login, namespaceName): + """ + Parameters: + - login + - namespaceName + """ + pass + + def renameNamespace(self, login, oldNamespaceName, newNamespaceName): + """ + Parameters: + - login + - oldNamespaceName + - newNamespaceName + """ + pass + + def setNamespaceProperty(self, login, namespaceName, property, value): + """ + Parameters: + - login + - namespaceName + - property + - value + """ + pass + + def removeNamespaceProperty(self, login, namespaceName, property): + """ + Parameters: + - login + - namespaceName + - property + """ + pass + + def getNamespaceProperties(self, login, namespaceName): + """ + Parameters: + - login + - namespaceName + """ + pass + + def namespaceIdMap(self, login): + """ + Parameters: + - login + """ + pass + + def attachNamespaceIterator(self, login, namespaceName, setting, scopes): + """ + Parameters: + - login + - namespaceName + - setting + - scopes + """ + pass + + def removeNamespaceIterator(self, login, namespaceName, name, scopes): + """ + Parameters: + - login + - namespaceName + - name + - scopes + """ + pass + + def getNamespaceIteratorSetting(self, login, namespaceName, name, scope): + """ + Parameters: + - login + - namespaceName + - name + - scope + """ + pass + + def listNamespaceIterators(self, login, namespaceName): + """ + Parameters: + - login + - namespaceName + """ + pass + + def checkNamespaceIteratorConflicts(self, login, namespaceName, setting, scopes): + """ + Parameters: + - login + - namespaceName + - setting + - scopes + """ + pass + + def addNamespaceConstraint(self, login, namespaceName, constraintClassName): + """ + Parameters: + - login + - namespaceName + - constraintClassName + """ + pass + + def removeNamespaceConstraint(self, login, namespaceName, id): + """ + Parameters: + - login + - namespaceName + - id + """ + pass + + def listNamespaceConstraints(self, login, namespaceName): + """ + Parameters: + - login + - namespaceName + """ + pass + + def testNamespaceClassLoad(self, login, namespaceName, className, asTypeName): + """ + Parameters: + - login + - namespaceName + - className + - asTypeName + """ + pass + + +class Client(Iface): + def __init__(self, iprot, oprot=None): + self._iprot = self._oprot = iprot + if oprot is not None: + self._oprot = oprot + self._seqid = 0 + + def login(self, principal, loginProperties): + """ + Parameters: + - principal + - loginProperties + """ + self.send_login(principal, loginProperties) + return self.recv_login() + + def send_login(self, principal, loginProperties): + self._oprot.writeMessageBegin('login', TMessageType.CALL, self._seqid) + args = login_args() + args.principal = principal + args.loginProperties = loginProperties + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_login(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = login_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch2 is not None: + raise result.ouch2 + raise TApplicationException(TApplicationException.MISSING_RESULT, "login failed: unknown result") + + def addConstraint(self, login, tableName, constraintClassName): + """ + Parameters: + - login + - tableName + - constraintClassName + """ + self.send_addConstraint(login, tableName, constraintClassName) + return self.recv_addConstraint() + + def send_addConstraint(self, login, tableName, constraintClassName): + self._oprot.writeMessageBegin('addConstraint', TMessageType.CALL, self._seqid) + args = addConstraint_args() + args.login = login + args.tableName = tableName + args.constraintClassName = constraintClassName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_addConstraint(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = addConstraint_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + raise TApplicationException(TApplicationException.MISSING_RESULT, "addConstraint failed: unknown result") + + def addSplits(self, login, tableName, splits): + """ + Parameters: + - login + - tableName + - splits + """ + self.send_addSplits(login, tableName, splits) + self.recv_addSplits() + + def send_addSplits(self, login, tableName, splits): + self._oprot.writeMessageBegin('addSplits', TMessageType.CALL, self._seqid) + args = addSplits_args() + args.login = login + args.tableName = tableName + args.splits = splits + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_addSplits(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = addSplits_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def attachIterator(self, login, tableName, setting, scopes): + """ + Parameters: + - login + - tableName + - setting + - scopes + """ + self.send_attachIterator(login, tableName, setting, scopes) + self.recv_attachIterator() + + def send_attachIterator(self, login, tableName, setting, scopes): + self._oprot.writeMessageBegin('attachIterator', TMessageType.CALL, self._seqid) + args = attachIterator_args() + args.login = login + args.tableName = tableName + args.setting = setting + args.scopes = scopes + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_attachIterator(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = attachIterator_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def checkIteratorConflicts(self, login, tableName, setting, scopes): + """ + Parameters: + - login + - tableName + - setting + - scopes + """ + self.send_checkIteratorConflicts(login, tableName, setting, scopes) + self.recv_checkIteratorConflicts() + + def send_checkIteratorConflicts(self, login, tableName, setting, scopes): + self._oprot.writeMessageBegin('checkIteratorConflicts', TMessageType.CALL, self._seqid) + args = checkIteratorConflicts_args() + args.login = login + args.tableName = tableName + args.setting = setting + args.scopes = scopes + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_checkIteratorConflicts(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = checkIteratorConflicts_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def clearLocatorCache(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + self.send_clearLocatorCache(login, tableName) + self.recv_clearLocatorCache() + + def send_clearLocatorCache(self, login, tableName): + self._oprot.writeMessageBegin('clearLocatorCache', TMessageType.CALL, self._seqid) + args = clearLocatorCache_args() + args.login = login + args.tableName = tableName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_clearLocatorCache(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = clearLocatorCache_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + return + + def cloneTable(self, login, tableName, newTableName, flush, propertiesToSet, propertiesToExclude): + """ + Parameters: + - login + - tableName + - newTableName + - flush + - propertiesToSet + - propertiesToExclude + """ + self.send_cloneTable(login, tableName, newTableName, flush, propertiesToSet, propertiesToExclude) + self.recv_cloneTable() + + def send_cloneTable(self, login, tableName, newTableName, flush, propertiesToSet, propertiesToExclude): + self._oprot.writeMessageBegin('cloneTable', TMessageType.CALL, self._seqid) + args = cloneTable_args() + args.login = login + args.tableName = tableName + args.newTableName = newTableName + args.flush = flush + args.propertiesToSet = propertiesToSet + args.propertiesToExclude = propertiesToExclude + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_cloneTable(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = cloneTable_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + if result.ouch4 is not None: + raise result.ouch4 + return + + def compactTable(self, login, tableName, startRow, endRow, iterators, flush, wait, compactionStrategy): + """ + Parameters: + - login + - tableName + - startRow + - endRow + - iterators + - flush + - wait + - compactionStrategy + """ + self.send_compactTable(login, tableName, startRow, endRow, iterators, flush, wait, compactionStrategy) + self.recv_compactTable() + + def send_compactTable(self, login, tableName, startRow, endRow, iterators, flush, wait, compactionStrategy): + self._oprot.writeMessageBegin('compactTable', TMessageType.CALL, self._seqid) + args = compactTable_args() + args.login = login + args.tableName = tableName + args.startRow = startRow + args.endRow = endRow + args.iterators = iterators + args.flush = flush + args.wait = wait + args.compactionStrategy = compactionStrategy + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_compactTable(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = compactTable_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def cancelCompaction(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + self.send_cancelCompaction(login, tableName) + self.recv_cancelCompaction() + + def send_cancelCompaction(self, login, tableName): + self._oprot.writeMessageBegin('cancelCompaction', TMessageType.CALL, self._seqid) + args = cancelCompaction_args() + args.login = login + args.tableName = tableName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_cancelCompaction(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = cancelCompaction_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def createTable(self, login, tableName, versioningIter, type): + """ + Parameters: + - login + - tableName + - versioningIter + - type + """ + self.send_createTable(login, tableName, versioningIter, type) + self.recv_createTable() + + def send_createTable(self, login, tableName, versioningIter, type): + self._oprot.writeMessageBegin('createTable', TMessageType.CALL, self._seqid) + args = createTable_args() + args.login = login + args.tableName = tableName + args.versioningIter = versioningIter + args.type = type + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_createTable(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = createTable_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def deleteTable(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + self.send_deleteTable(login, tableName) + self.recv_deleteTable() + + def send_deleteTable(self, login, tableName): + self._oprot.writeMessageBegin('deleteTable', TMessageType.CALL, self._seqid) + args = deleteTable_args() + args.login = login + args.tableName = tableName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_deleteTable(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = deleteTable_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def deleteRows(self, login, tableName, startRow, endRow): + """ + Parameters: + - login + - tableName + - startRow + - endRow + """ + self.send_deleteRows(login, tableName, startRow, endRow) + self.recv_deleteRows() + + def send_deleteRows(self, login, tableName, startRow, endRow): + self._oprot.writeMessageBegin('deleteRows', TMessageType.CALL, self._seqid) + args = deleteRows_args() + args.login = login + args.tableName = tableName + args.startRow = startRow + args.endRow = endRow + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_deleteRows(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = deleteRows_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def exportTable(self, login, tableName, exportDir): + """ + Parameters: + - login + - tableName + - exportDir + """ + self.send_exportTable(login, tableName, exportDir) + self.recv_exportTable() + + def send_exportTable(self, login, tableName, exportDir): + self._oprot.writeMessageBegin('exportTable', TMessageType.CALL, self._seqid) + args = exportTable_args() + args.login = login + args.tableName = tableName + args.exportDir = exportDir + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_exportTable(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = exportTable_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def flushTable(self, login, tableName, startRow, endRow, wait): + """ + Parameters: + - login + - tableName + - startRow + - endRow + - wait + """ + self.send_flushTable(login, tableName, startRow, endRow, wait) + self.recv_flushTable() + + def send_flushTable(self, login, tableName, startRow, endRow, wait): + self._oprot.writeMessageBegin('flushTable', TMessageType.CALL, self._seqid) + args = flushTable_args() + args.login = login + args.tableName = tableName + args.startRow = startRow + args.endRow = endRow + args.wait = wait + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_flushTable(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = flushTable_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def getDiskUsage(self, login, tables): + """ + Parameters: + - login + - tables + """ + self.send_getDiskUsage(login, tables) + return self.recv_getDiskUsage() + + def send_getDiskUsage(self, login, tables): + self._oprot.writeMessageBegin('getDiskUsage', TMessageType.CALL, self._seqid) + args = getDiskUsage_args() + args.login = login + args.tables = tables + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getDiskUsage(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getDiskUsage_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + raise TApplicationException(TApplicationException.MISSING_RESULT, "getDiskUsage failed: unknown result") + + def getLocalityGroups(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + self.send_getLocalityGroups(login, tableName) + return self.recv_getLocalityGroups() + + def send_getLocalityGroups(self, login, tableName): + self._oprot.writeMessageBegin('getLocalityGroups', TMessageType.CALL, self._seqid) + args = getLocalityGroups_args() + args.login = login + args.tableName = tableName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getLocalityGroups(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getLocalityGroups_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + raise TApplicationException(TApplicationException.MISSING_RESULT, "getLocalityGroups failed: unknown result") + + def getIteratorSetting(self, login, tableName, iteratorName, scope): + """ + Parameters: + - login + - tableName + - iteratorName + - scope + """ + self.send_getIteratorSetting(login, tableName, iteratorName, scope) + return self.recv_getIteratorSetting() + + def send_getIteratorSetting(self, login, tableName, iteratorName, scope): + self._oprot.writeMessageBegin('getIteratorSetting', TMessageType.CALL, self._seqid) + args = getIteratorSetting_args() + args.login = login + args.tableName = tableName + args.iteratorName = iteratorName + args.scope = scope + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getIteratorSetting(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getIteratorSetting_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + raise TApplicationException(TApplicationException.MISSING_RESULT, "getIteratorSetting failed: unknown result") + + def getMaxRow(self, login, tableName, auths, startRow, startInclusive, endRow, endInclusive): + """ + Parameters: + - login + - tableName + - auths + - startRow + - startInclusive + - endRow + - endInclusive + """ + self.send_getMaxRow(login, tableName, auths, startRow, startInclusive, endRow, endInclusive) + return self.recv_getMaxRow() + + def send_getMaxRow(self, login, tableName, auths, startRow, startInclusive, endRow, endInclusive): + self._oprot.writeMessageBegin('getMaxRow', TMessageType.CALL, self._seqid) + args = getMaxRow_args() + args.login = login + args.tableName = tableName + args.auths = auths + args.startRow = startRow + args.startInclusive = startInclusive + args.endRow = endRow + args.endInclusive = endInclusive + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getMaxRow(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getMaxRow_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + raise TApplicationException(TApplicationException.MISSING_RESULT, "getMaxRow failed: unknown result") + + def getTableProperties(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + self.send_getTableProperties(login, tableName) + return self.recv_getTableProperties() + + def send_getTableProperties(self, login, tableName): + self._oprot.writeMessageBegin('getTableProperties', TMessageType.CALL, self._seqid) + args = getTableProperties_args() + args.login = login + args.tableName = tableName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getTableProperties(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getTableProperties_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + raise TApplicationException(TApplicationException.MISSING_RESULT, "getTableProperties failed: unknown result") + + def importDirectory(self, login, tableName, importDir, failureDir, setTime): + """ + Parameters: + - login + - tableName + - importDir + - failureDir + - setTime + """ + self.send_importDirectory(login, tableName, importDir, failureDir, setTime) + self.recv_importDirectory() + + def send_importDirectory(self, login, tableName, importDir, failureDir, setTime): + self._oprot.writeMessageBegin('importDirectory', TMessageType.CALL, self._seqid) + args = importDirectory_args() + args.login = login + args.tableName = tableName + args.importDir = importDir + args.failureDir = failureDir + args.setTime = setTime + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_importDirectory(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = importDirectory_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch3 is not None: + raise result.ouch3 + if result.ouch4 is not None: + raise result.ouch4 + return + + def importTable(self, login, tableName, importDir): + """ + Parameters: + - login + - tableName + - importDir + """ + self.send_importTable(login, tableName, importDir) + self.recv_importTable() + + def send_importTable(self, login, tableName, importDir): + self._oprot.writeMessageBegin('importTable', TMessageType.CALL, self._seqid) + args = importTable_args() + args.login = login + args.tableName = tableName + args.importDir = importDir + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_importTable(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = importTable_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def listSplits(self, login, tableName, maxSplits): + """ + Parameters: + - login + - tableName + - maxSplits + """ + self.send_listSplits(login, tableName, maxSplits) + return self.recv_listSplits() + + def send_listSplits(self, login, tableName, maxSplits): + self._oprot.writeMessageBegin('listSplits', TMessageType.CALL, self._seqid) + args = listSplits_args() + args.login = login + args.tableName = tableName + args.maxSplits = maxSplits + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_listSplits(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = listSplits_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + raise TApplicationException(TApplicationException.MISSING_RESULT, "listSplits failed: unknown result") + + def listTables(self, login): + """ + Parameters: + - login + """ + self.send_listTables(login) + return self.recv_listTables() + + def send_listTables(self, login): + self._oprot.writeMessageBegin('listTables', TMessageType.CALL, self._seqid) + args = listTables_args() + args.login = login + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_listTables(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = listTables_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "listTables failed: unknown result") + + def listIterators(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + self.send_listIterators(login, tableName) + return self.recv_listIterators() + + def send_listIterators(self, login, tableName): + self._oprot.writeMessageBegin('listIterators', TMessageType.CALL, self._seqid) + args = listIterators_args() + args.login = login + args.tableName = tableName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_listIterators(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = listIterators_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + raise TApplicationException(TApplicationException.MISSING_RESULT, "listIterators failed: unknown result") + + def listConstraints(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + self.send_listConstraints(login, tableName) + return self.recv_listConstraints() + + def send_listConstraints(self, login, tableName): + self._oprot.writeMessageBegin('listConstraints', TMessageType.CALL, self._seqid) + args = listConstraints_args() + args.login = login + args.tableName = tableName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_listConstraints(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = listConstraints_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + raise TApplicationException(TApplicationException.MISSING_RESULT, "listConstraints failed: unknown result") + + def mergeTablets(self, login, tableName, startRow, endRow): + """ + Parameters: + - login + - tableName + - startRow + - endRow + """ + self.send_mergeTablets(login, tableName, startRow, endRow) + self.recv_mergeTablets() + + def send_mergeTablets(self, login, tableName, startRow, endRow): + self._oprot.writeMessageBegin('mergeTablets', TMessageType.CALL, self._seqid) + args = mergeTablets_args() + args.login = login + args.tableName = tableName + args.startRow = startRow + args.endRow = endRow + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_mergeTablets(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = mergeTablets_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def offlineTable(self, login, tableName, wait): + """ + Parameters: + - login + - tableName + - wait + """ + self.send_offlineTable(login, tableName, wait) + self.recv_offlineTable() + + def send_offlineTable(self, login, tableName, wait): + self._oprot.writeMessageBegin('offlineTable', TMessageType.CALL, self._seqid) + args = offlineTable_args() + args.login = login + args.tableName = tableName + args.wait = wait + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_offlineTable(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = offlineTable_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def onlineTable(self, login, tableName, wait): + """ + Parameters: + - login + - tableName + - wait + """ + self.send_onlineTable(login, tableName, wait) + self.recv_onlineTable() + + def send_onlineTable(self, login, tableName, wait): + self._oprot.writeMessageBegin('onlineTable', TMessageType.CALL, self._seqid) + args = onlineTable_args() + args.login = login + args.tableName = tableName + args.wait = wait + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_onlineTable(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = onlineTable_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def removeConstraint(self, login, tableName, constraint): + """ + Parameters: + - login + - tableName + - constraint + """ + self.send_removeConstraint(login, tableName, constraint) + self.recv_removeConstraint() + + def send_removeConstraint(self, login, tableName, constraint): + self._oprot.writeMessageBegin('removeConstraint', TMessageType.CALL, self._seqid) + args = removeConstraint_args() + args.login = login + args.tableName = tableName + args.constraint = constraint + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_removeConstraint(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = removeConstraint_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def removeIterator(self, login, tableName, iterName, scopes): + """ + Parameters: + - login + - tableName + - iterName + - scopes + """ + self.send_removeIterator(login, tableName, iterName, scopes) + self.recv_removeIterator() + + def send_removeIterator(self, login, tableName, iterName, scopes): + self._oprot.writeMessageBegin('removeIterator', TMessageType.CALL, self._seqid) + args = removeIterator_args() + args.login = login + args.tableName = tableName + args.iterName = iterName + args.scopes = scopes + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_removeIterator(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = removeIterator_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def removeTableProperty(self, login, tableName, property): + """ + Parameters: + - login + - tableName + - property + """ + self.send_removeTableProperty(login, tableName, property) + self.recv_removeTableProperty() + + def send_removeTableProperty(self, login, tableName, property): + self._oprot.writeMessageBegin('removeTableProperty', TMessageType.CALL, self._seqid) + args = removeTableProperty_args() + args.login = login + args.tableName = tableName + args.property = property + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_removeTableProperty(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = removeTableProperty_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def renameTable(self, login, oldTableName, newTableName): + """ + Parameters: + - login + - oldTableName + - newTableName + """ + self.send_renameTable(login, oldTableName, newTableName) + self.recv_renameTable() + + def send_renameTable(self, login, oldTableName, newTableName): + self._oprot.writeMessageBegin('renameTable', TMessageType.CALL, self._seqid) + args = renameTable_args() + args.login = login + args.oldTableName = oldTableName + args.newTableName = newTableName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_renameTable(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = renameTable_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + if result.ouch4 is not None: + raise result.ouch4 + return + + def setLocalityGroups(self, login, tableName, groups): + """ + Parameters: + - login + - tableName + - groups + """ + self.send_setLocalityGroups(login, tableName, groups) + self.recv_setLocalityGroups() + + def send_setLocalityGroups(self, login, tableName, groups): + self._oprot.writeMessageBegin('setLocalityGroups', TMessageType.CALL, self._seqid) + args = setLocalityGroups_args() + args.login = login + args.tableName = tableName + args.groups = groups + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_setLocalityGroups(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = setLocalityGroups_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def setTableProperty(self, login, tableName, property, value): + """ + Parameters: + - login + - tableName + - property + - value + """ + self.send_setTableProperty(login, tableName, property, value) + self.recv_setTableProperty() + + def send_setTableProperty(self, login, tableName, property, value): + self._oprot.writeMessageBegin('setTableProperty', TMessageType.CALL, self._seqid) + args = setTableProperty_args() + args.login = login + args.tableName = tableName + args.property = property + args.value = value + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_setTableProperty(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = setTableProperty_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + return + + def splitRangeByTablets(self, login, tableName, range, maxSplits): + """ + Parameters: + - login + - tableName + - range + - maxSplits + """ + self.send_splitRangeByTablets(login, tableName, range, maxSplits) + return self.recv_splitRangeByTablets() + + def send_splitRangeByTablets(self, login, tableName, range, maxSplits): + self._oprot.writeMessageBegin('splitRangeByTablets', TMessageType.CALL, self._seqid) + args = splitRangeByTablets_args() + args.login = login + args.tableName = tableName + args.range = range + args.maxSplits = maxSplits + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_splitRangeByTablets(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = splitRangeByTablets_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + raise TApplicationException(TApplicationException.MISSING_RESULT, "splitRangeByTablets failed: unknown result") + + def tableExists(self, login, tableName): + """ + Parameters: + - login + - tableName + """ + self.send_tableExists(login, tableName) + return self.recv_tableExists() + + def send_tableExists(self, login, tableName): + self._oprot.writeMessageBegin('tableExists', TMessageType.CALL, self._seqid) + args = tableExists_args() + args.login = login + args.tableName = tableName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_tableExists(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = tableExists_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "tableExists failed: unknown result") + + def tableIdMap(self, login): + """ + Parameters: + - login + """ + self.send_tableIdMap(login) + return self.recv_tableIdMap() + + def send_tableIdMap(self, login): + self._oprot.writeMessageBegin('tableIdMap', TMessageType.CALL, self._seqid) + args = tableIdMap_args() + args.login = login + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_tableIdMap(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = tableIdMap_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "tableIdMap failed: unknown result") + + def testTableClassLoad(self, login, tableName, className, asTypeName): + """ + Parameters: + - login + - tableName + - className + - asTypeName + """ + self.send_testTableClassLoad(login, tableName, className, asTypeName) + return self.recv_testTableClassLoad() + + def send_testTableClassLoad(self, login, tableName, className, asTypeName): + self._oprot.writeMessageBegin('testTableClassLoad', TMessageType.CALL, self._seqid) + args = testTableClassLoad_args() + args.login = login + args.tableName = tableName + args.className = className + args.asTypeName = asTypeName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_testTableClassLoad(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = testTableClassLoad_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + if result.ouch3 is not None: + raise result.ouch3 + raise TApplicationException(TApplicationException.MISSING_RESULT, "testTableClassLoad failed: unknown result") + + def pingTabletServer(self, login, tserver): + """ + Parameters: + - login + - tserver + """ + self.send_pingTabletServer(login, tserver) + self.recv_pingTabletServer() + + def send_pingTabletServer(self, login, tserver): + self._oprot.writeMessageBegin('pingTabletServer', TMessageType.CALL, self._seqid) + args = pingTabletServer_args() + args.login = login + args.tserver = tserver + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_pingTabletServer(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = pingTabletServer_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + return + + def getActiveScans(self, login, tserver): + """ + Parameters: + - login + - tserver + """ + self.send_getActiveScans(login, tserver) + return self.recv_getActiveScans() + + def send_getActiveScans(self, login, tserver): + self._oprot.writeMessageBegin('getActiveScans', TMessageType.CALL, self._seqid) + args = getActiveScans_args() + args.login = login + args.tserver = tserver + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getActiveScans(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getActiveScans_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + raise TApplicationException(TApplicationException.MISSING_RESULT, "getActiveScans failed: unknown result") + + def getActiveCompactions(self, login, tserver): + """ + Parameters: + - login + - tserver + """ + self.send_getActiveCompactions(login, tserver) + return self.recv_getActiveCompactions() + + def send_getActiveCompactions(self, login, tserver): + self._oprot.writeMessageBegin('getActiveCompactions', TMessageType.CALL, self._seqid) + args = getActiveCompactions_args() + args.login = login + args.tserver = tserver + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getActiveCompactions(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getActiveCompactions_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + raise TApplicationException(TApplicationException.MISSING_RESULT, "getActiveCompactions failed: unknown result") + + def getSiteConfiguration(self, login): + """ + Parameters: + - login + """ + self.send_getSiteConfiguration(login) + return self.recv_getSiteConfiguration() + + def send_getSiteConfiguration(self, login): + self._oprot.writeMessageBegin('getSiteConfiguration', TMessageType.CALL, self._seqid) + args = getSiteConfiguration_args() + args.login = login + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getSiteConfiguration(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getSiteConfiguration_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + raise TApplicationException(TApplicationException.MISSING_RESULT, "getSiteConfiguration failed: unknown result") + + def getSystemConfiguration(self, login): + """ + Parameters: + - login + """ + self.send_getSystemConfiguration(login) + return self.recv_getSystemConfiguration() + + def send_getSystemConfiguration(self, login): + self._oprot.writeMessageBegin('getSystemConfiguration', TMessageType.CALL, self._seqid) + args = getSystemConfiguration_args() + args.login = login + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getSystemConfiguration(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getSystemConfiguration_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + raise TApplicationException(TApplicationException.MISSING_RESULT, "getSystemConfiguration failed: unknown result") + + def getTabletServers(self, login): + """ + Parameters: + - login + """ + self.send_getTabletServers(login) + return self.recv_getTabletServers() + + def send_getTabletServers(self, login): + self._oprot.writeMessageBegin('getTabletServers', TMessageType.CALL, self._seqid) + args = getTabletServers_args() + args.login = login + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getTabletServers(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getTabletServers_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "getTabletServers failed: unknown result") + + def removeProperty(self, login, property): + """ + Parameters: + - login + - property + """ + self.send_removeProperty(login, property) + self.recv_removeProperty() + + def send_removeProperty(self, login, property): + self._oprot.writeMessageBegin('removeProperty', TMessageType.CALL, self._seqid) + args = removeProperty_args() + args.login = login + args.property = property + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_removeProperty(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = removeProperty_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + return + + def setProperty(self, login, property, value): + """ + Parameters: + - login + - property + - value + """ + self.send_setProperty(login, property, value) + self.recv_setProperty() + + def send_setProperty(self, login, property, value): + self._oprot.writeMessageBegin('setProperty', TMessageType.CALL, self._seqid) + args = setProperty_args() + args.login = login + args.property = property + args.value = value + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_setProperty(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = setProperty_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + return + + def testClassLoad(self, login, className, asTypeName): + """ + Parameters: + - login + - className + - asTypeName + """ + self.send_testClassLoad(login, className, asTypeName) + return self.recv_testClassLoad() + + def send_testClassLoad(self, login, className, asTypeName): + self._oprot.writeMessageBegin('testClassLoad', TMessageType.CALL, self._seqid) + args = testClassLoad_args() + args.login = login + args.className = className + args.asTypeName = asTypeName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_testClassLoad(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = testClassLoad_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + raise TApplicationException(TApplicationException.MISSING_RESULT, "testClassLoad failed: unknown result") + + def authenticateUser(self, login, user, properties): + """ + Parameters: + - login + - user + - properties + """ + self.send_authenticateUser(login, user, properties) + return self.recv_authenticateUser() + + def send_authenticateUser(self, login, user, properties): + self._oprot.writeMessageBegin('authenticateUser', TMessageType.CALL, self._seqid) + args = authenticateUser_args() + args.login = login + args.user = user + args.properties = properties + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_authenticateUser(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = authenticateUser_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + raise TApplicationException(TApplicationException.MISSING_RESULT, "authenticateUser failed: unknown result") + + def changeUserAuthorizations(self, login, user, authorizations): + """ + Parameters: + - login + - user + - authorizations + """ + self.send_changeUserAuthorizations(login, user, authorizations) + self.recv_changeUserAuthorizations() + + def send_changeUserAuthorizations(self, login, user, authorizations): + self._oprot.writeMessageBegin('changeUserAuthorizations', TMessageType.CALL, self._seqid) + args = changeUserAuthorizations_args() + args.login = login + args.user = user + args.authorizations = authorizations + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_changeUserAuthorizations(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = changeUserAuthorizations_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + return + + def changeLocalUserPassword(self, login, user, password): + """ + Parameters: + - login + - user + - password + """ + self.send_changeLocalUserPassword(login, user, password) + self.recv_changeLocalUserPassword() + + def send_changeLocalUserPassword(self, login, user, password): + self._oprot.writeMessageBegin('changeLocalUserPassword', TMessageType.CALL, self._seqid) + args = changeLocalUserPassword_args() + args.login = login + args.user = user + args.password = password + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_changeLocalUserPassword(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = changeLocalUserPassword_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + return + + def createLocalUser(self, login, user, password): + """ + Parameters: + - login + - user + - password + """ + self.send_createLocalUser(login, user, password) + self.recv_createLocalUser() + + def send_createLocalUser(self, login, user, password): + self._oprot.writeMessageBegin('createLocalUser', TMessageType.CALL, self._seqid) + args = createLocalUser_args() + args.login = login + args.user = user + args.password = password + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_createLocalUser(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = createLocalUser_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + return + + def dropLocalUser(self, login, user): + """ + Parameters: + - login + - user + """ + self.send_dropLocalUser(login, user) + self.recv_dropLocalUser() + + def send_dropLocalUser(self, login, user): + self._oprot.writeMessageBegin('dropLocalUser', TMessageType.CALL, self._seqid) + args = dropLocalUser_args() + args.login = login + args.user = user + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_dropLocalUser(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = dropLocalUser_result() + result.read(iprot) + iprot.readMessageEnd() + if result.ouch1 is not None: + raise result.ouch1 + if result.ouch2 is not None: + raise result.ouch2 + return + + def getUserAuthorizations(self, login, user): + """ + Parameters: + - login + - user + """ + self.send_getUserAuthorizations(login, user) + return self.recv_getUserAuthorizations() + + def send_getUserAuthorizations(self, login, user): + self._oprot.writeMessageBegin('getUserAuthorizations', TMessageType.CALL, self._seqid) + args = getUserAuthorizations_args() + args.login = login + args.user = user + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getUserAuthorizations(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getUserAuthorizations_result() + result.read(iprot) + iprot.readMessageEn
<TRUNCATED>