accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vi...@apache.org
Subject [04/17] ACCUMULO-2197 provide generated proxy libraries, with modified generate-thrift script which tacks on headers
Date Tue, 04 Feb 2014 22:19:41 GMT
http://git-wip-us.apache.org/repos/asf/accumulo/blob/3d436e7b/proxy/src/main/python/AccumuloProxy.py
----------------------------------------------------------------------
diff --git a/proxy/src/main/python/AccumuloProxy.py b/proxy/src/main/python/AccumuloProxy.py
new file mode 100644
index 0000000..45bb010
--- /dev/null
+++ b/proxy/src/main/python/AccumuloProxy.py
@@ -0,0 +1,16796 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+# Autogenerated by Thrift Compiler (0.9.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 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):
+    """
+    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):
+    """
+    Parameters:
+     - login
+     - tableName
+     - startRow
+     - endRow
+     - iterators
+     - flush
+     - wait
+    """
+    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 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):
+    """
+    Parameters:
+     - login
+     - tableName
+    """
+    pass
+
+  def onlineTable(self, login, tableName):
+    """
+    Parameters:
+     - login
+     - tableName
+    """
+    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 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 getRowRange(self, row):
+    """
+    Parameters:
+     - row
+    """
+    pass
+
+  def getFollowing(self, key, part):
+    """
+    Parameters:
+     - key
+     - part
+    """
+    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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = login_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = addConstraint_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = addSplits_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = attachIterator_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = checkIteratorConflicts_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = clearLocatorCache_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = cloneTable_result()
+    result.read(self._iprot)
+    self._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):
+    """
+    Parameters:
+     - login
+     - tableName
+     - startRow
+     - endRow
+     - iterators
+     - flush
+     - wait
+    """
+    self.send_compactTable(login, tableName, startRow, endRow, iterators, flush, wait)
+    self.recv_compactTable()
+
+  def send_compactTable(self, login, tableName, startRow, endRow, iterators, flush, wait):
+    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.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_compactTable(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = compactTable_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = cancelCompaction_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = createTable_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = deleteTable_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = deleteRows_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = exportTable_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = flushTable_result()
+    result.read(self._iprot)
+    self._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 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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getLocalityGroups_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getIteratorSetting_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getMaxRow_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getTableProperties_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = importDirectory_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = importTable_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = listSplits_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = listTables_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = listIterators_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = listConstraints_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = mergeTablets_result()
+    result.read(self._iprot)
+    self._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):
+    """
+    Parameters:
+     - login
+     - tableName
+    """
+    self.send_offlineTable(login, tableName)
+    self.recv_offlineTable()
+
+  def send_offlineTable(self, login, tableName):
+    self._oprot.writeMessageBegin('offlineTable', TMessageType.CALL, self._seqid)
+    args = offlineTable_args()
+    args.login = login
+    args.tableName = tableName
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_offlineTable(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = offlineTable_result()
+    result.read(self._iprot)
+    self._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):
+    """
+    Parameters:
+     - login
+     - tableName
+    """
+    self.send_onlineTable(login, tableName)
+    self.recv_onlineTable()
+
+  def send_onlineTable(self, login, tableName):
+    self._oprot.writeMessageBegin('onlineTable', TMessageType.CALL, self._seqid)
+    args = onlineTable_args()
+    args.login = login
+    args.tableName = tableName
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_onlineTable(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = onlineTable_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = removeConstraint_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = removeIterator_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = removeTableProperty_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = renameTable_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = setLocalityGroups_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = setTableProperty_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = splitRangeByTablets_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = tableExists_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = tableIdMap_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = testTableClassLoad_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = pingTabletServer_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getActiveScans_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getActiveCompactions_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getSiteConfiguration_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getSystemConfiguration_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getTabletServers_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = removeProperty_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = setProperty_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = testClassLoad_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = authenticateUser_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = changeUserAuthorizations_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = changeLocalUserPassword_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = createLocalUser_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = dropLocalUser_result()
+    result.read(self._iprot)
+    self._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, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = getUserAuthorizations_result()
+    result.read(self._iprot)
+    self._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, "getUserAuthorizations failed: unknown result");
+
+  def grantSystemPermission(self, login, user, perm):
+    """
+    Parameters:
+     - login
+     - user
+     - perm
+    """
+    self.send_grantSystemPermission(login, user, perm)
+    self.recv_grantSystemPermission()
+
+  def send_grantSystemPermission(self, login, user, perm):
+    self._oprot.writeMessageBegin('grantSystemPermission', TMessageType.CALL, self._seqid)
+    args = grantSystemPermission_args()
+    args.login = login
+    args.user = user
+    args.perm = perm
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_grantSystemPermission(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = grantSystemPermission_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.ouch1 is not None:
+      raise result.ouch1
+    if result.ouch2 is not None:
+      raise result.ouch2
+    return
+
+  def grantTablePermission(self, login, user, table, perm):
+    """
+    Parameters:
+     - login
+     - user
+     - table
+     - perm
+    """
+    self.send_grantTablePermission(login, user, table, perm)
+    self.recv_grantTablePermission()
+
+  def send_grantTablePermission(self, login, user, table, perm):
+    self._oprot.writeMessageBegin('grantTablePermission', TMessageType.CALL, self._seqid)
+    args = grantTablePermission_args()
+    args.login = login
+    args.user = user
+    args.table = table
+    args.perm = perm
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_grantTablePermission(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = grantTablePermission_result()
+    result.read(self._iprot)
+    self._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 hasSystemPermission(self, login, user, perm):
+    """
+    Parameters:
+     - login
+     - user
+     - perm
+    """
+    self.send_hasSystemPermission(login, user, perm)
+    return self.recv_hasSystemPermission()
+
+  def send_hasSystemPermission(self, login, user, perm):
+    self._oprot.writeMessageBegin('hasSystemPermission', TMessageType.CALL, self._seqid)
+    args = hasSystemPermission_args()
+    args.login = login
+    args.user = user
+    args.perm = perm
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_hasSystemPermission(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = hasSystemPermission_result()
+    result.read(self._iprot)
+    self._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, "hasSystemPermission failed: unknown result");
+
+  def hasTablePermission(self, login, user, table, perm):
+    """
+    Parameters:
+     - login
+     - user
+     - table
+     - perm
+    """
+    self.send_hasTablePermission(login, user, table, perm)
+    return self.recv_hasTablePermission()
+
+  def send_hasTablePermission(self, login, user, table, perm):
+    self._oprot.writeMessageBegin('hasTablePermission', TMessageType.CALL, self._seqid)
+    args = hasTablePermission_args()
+    args.login = login
+    args.user = user
+    args.table = table
+    args.perm = perm
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_hasTablePermission(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = hasTablePermission_result()
+    result.read(self._iprot)
+    self._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, "hasTablePermission failed: unknown result");
+
+  def listLocalUsers(self, login):
+    """
+    Parameters:
+     - login
+    """
+    self.send_listLocalUsers(login)
+    return self.recv_listLocalUsers()
+
+  def send_listLocalUsers(self, login):
+    self._oprot.writeMessageBegin('listLocalUsers', TMessageType.CALL, self._seqid)
+    args = listLocalUsers_args()
+    args.login = login
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_listLocalUsers(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = listLocalUsers_result()
+    result.read(self._iprot)
+    self._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, "listLocalUsers failed: unknown result");
+
+  def revokeSystemPermission(self, login, user, perm):
+    """
+    Parameters:
+     - login
+     - user
+     - perm
+    """
+    self.send_revokeSystemPermission(login, user, perm)
+    self.recv_revokeSystemPermission()
+
+  def send_revokeSystemPermission(self, login, user, perm):
+    self._oprot.writeMessageBegin('revokeSystemPermission', TMessageType.CALL, self._seqid)
+    args = revokeSystemPermission_args()
+    args.login = login
+    args.user = user
+    args.perm = perm
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_revokeSystemPermission(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = revokeSystemPermission_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.ouch1 is not None:
+      raise result.ouch1
+    if result.ouch2 is not None:
+      raise result.ouch2
+    return
+
+  def revokeTablePermission(self, login, user, table, perm):
+    """
+    Parameters:
+     - login
+     - user
+     - table
+     - perm
+    """
+    self.send_revokeTablePermission(login, user, table, perm)
+    self.recv_revokeTablePermission()
+
+  def send_revokeTablePermission(self, login, user, table, perm):
+    self._oprot.writeMessageBegin('revokeTablePermission', TMessageType.CALL, self._seqid)
+    args = revokeTablePermission_args()
+    args.login = login
+    args.user = user
+    args.table = table
+    args.perm = perm
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_revokeTablePermission(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = revokeTablePermission_result()
+    result.read(self._iprot)
+    self._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 createBatchScanner(self, login, tableName, options):
+    """
+    Parameters:
+     - login
+     - tableName
+     - options
+    """
+    self.send_createBatchScanner(login, tableName, options)
+    return self.recv_createBatchScanner()
+
+  def send_createBatchScanner(self, login, tableName, options):
+    self._oprot.writeMessageBegin('createBatchScanner', TMessageType.CALL, self._seqid)
+    args = createBatchScanner_args()
+    args.login = login
+    args.tableName = tableName
+    args.options = options
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_createBatchScanner(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = createBatchScanner_result()
+    result.read(self._iprot)
+    self._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, "createBatchScanner failed: unknown result");
+
+  def createScanner(self, login, tableName, options):
+    """
+    Parameters:
+     - login
+     - tableName
+     - options
+    """
+    self.send_createScanner(login, tableName, options)
+    return self.recv_createScanner()
+
+  def send_createScanner(self, login, tableName, options):
+    self._oprot.writeMessageBegin('createScanner', TMessageType.CALL, self._seqid)
+    args = createScanner_args()
+    args.login = login
+    args.tableName = tableName
+    args.options = options
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_createScanner(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = createScanner_result()
+    result.read(self._iprot)
+    self._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, "createScanner failed: unknown result");
+
+  def hasNext(self, scanner):
+    """
+    Parameters:
+     - scanner
+    """
+    self.send_hasNext(scanner)
+    return self.recv_hasNext()
+
+  def send_hasNext(self, scanner):
+    self._oprot.writeMessageBegin('hasNext', TMessageType.CALL, self._seqid)
+    args = hasNext_args()
+    args.scanner = scanner
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_hasNext(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = hasNext_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.success is not None:
+      return result.success
+    if result.ouch1 is not None:
+      raise result.ouch1
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "hasNext failed: unknown result");
+
+  def nextEntry(self, scanner):
+    """
+    Parameters:
+     - scanner
+    """
+    self.send_nextEntry(scanner)
+    return self.recv_nextEntry()
+
+  def send_nextEntry(self, scanner):
+    self._oprot.writeMessageBegin('nextEntry', TMessageType.CALL, self._seqid)
+    args = nextEntry_args()
+    args.scanner = scanner
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_nextEntry(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = nextEntry_result()
+    result.read(self._iprot)
+    self._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, "nextEntry failed: unknown result");
+
+  def nextK(self, scanner, k):
+    """
+    Parameters:
+     - scanner
+     - k
+    """
+    self.send_nextK(scanner, k)
+    return self.recv_nextK()
+
+  def send_nextK(self, scanner, k):
+    self._oprot.writeMessageBegin('nextK', TMessageType.CALL, self._seqid)
+    args = nextK_args()
+    args.scanner = scanner
+    args.k = k
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_nextK(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = nextK_result()
+    result.read(self._iprot)
+    self._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, "nextK failed: unknown result");
+
+  def closeScanner(self, scanner):
+    """
+    Parameters:
+     - scanner
+    """
+    self.send_closeScanner(scanner)
+    self.recv_closeScanner()
+
+  def send_closeScanner(self, scanner):
+    self._oprot.writeMessageBegin('closeScanner', TMessageType.CALL, self._seqid)
+    args = closeScanner_args()
+    args.scanner = scanner
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_closeScanner(self, ):
+    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(self._iprot)
+      self._iprot.readMessageEnd()
+      raise x
+    result = closeScanner_result()
+    result.read(self._iprot)
+    self._iprot.readMessageEnd()
+    if result.ouch1 is not None:
+      raise result.ouch1
+    return
+
+  def updateAndFlush(self, login, tableName, cells):
+    """
+    Parameters:
+     - login
+     - tableName
+     - cells
+    """
+    self.send_updateAndFlush(login, tableName, cells)
+    self.recv_updateAndFlush()
+
+  def send_updateAndFlush(self, login, tableName, cells):
+    self._oprot.writeMessageBegin('updateAndFlush', TMessageType.CALL, self._seqid)
+    args = updateAndFlush_args()
+    args.login = login
+    args.tableName = tableName
+    args.cells = cells
+    args.write(self._oprot)
+    s

<TRUNCATED>

Mime
View raw message