You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ct...@apache.org on 2017/02/09 19:29:33 UTC
[05/41] accumulo git commit: ACCUMULO-4551 Add thrift-gen changes
from 0.10.0
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>