accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vi...@apache.org
Subject [02/10] ACCUMULO-2197 provide generated proxy libraries, with modified generate-thrift script which tacks on headers
Date Tue, 04 Feb 2014 22:19:17 GMT
http://git-wip-us.apache.org/repos/asf/accumulo/blob/3d436e7b/proxy/src/main/ruby/accumulo_proxy.rb
----------------------------------------------------------------------
diff --git a/proxy/src/main/ruby/accumulo_proxy.rb b/proxy/src/main/ruby/accumulo_proxy.rb
new file mode 100644
index 0000000..a7ae2db
--- /dev/null
+++ b/proxy/src/main/ruby/accumulo_proxy.rb
@@ -0,0 +1,5072 @@
+# 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
+#
+
+require 'thrift'
+require 'proxy_types'
+
+module Accumulo
+  module AccumuloProxy
+    class Client
+      include ::Thrift::Client
+
+      def login(principal, loginProperties)
+        send_login(principal, loginProperties)
+        return recv_login()
+      end
+
+      def send_login(principal, loginProperties)
+        send_message('login', Login_args, :principal => principal, :loginProperties => loginProperties)
+      end
+
+      def recv_login()
+        result = receive_message(Login_result)
+        return result.success unless result.success.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'login failed: unknown result')
+      end
+
+      def addConstraint(login, tableName, constraintClassName)
+        send_addConstraint(login, tableName, constraintClassName)
+        return recv_addConstraint()
+      end
+
+      def send_addConstraint(login, tableName, constraintClassName)
+        send_message('addConstraint', AddConstraint_args, :login => login, :tableName => tableName, :constraintClassName => constraintClassName)
+      end
+
+      def recv_addConstraint()
+        result = receive_message(AddConstraint_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'addConstraint failed: unknown result')
+      end
+
+      def addSplits(login, tableName, splits)
+        send_addSplits(login, tableName, splits)
+        recv_addSplits()
+      end
+
+      def send_addSplits(login, tableName, splits)
+        send_message('addSplits', AddSplits_args, :login => login, :tableName => tableName, :splits => splits)
+      end
+
+      def recv_addSplits()
+        result = receive_message(AddSplits_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def attachIterator(login, tableName, setting, scopes)
+        send_attachIterator(login, tableName, setting, scopes)
+        recv_attachIterator()
+      end
+
+      def send_attachIterator(login, tableName, setting, scopes)
+        send_message('attachIterator', AttachIterator_args, :login => login, :tableName => tableName, :setting => setting, :scopes => scopes)
+      end
+
+      def recv_attachIterator()
+        result = receive_message(AttachIterator_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def checkIteratorConflicts(login, tableName, setting, scopes)
+        send_checkIteratorConflicts(login, tableName, setting, scopes)
+        recv_checkIteratorConflicts()
+      end
+
+      def send_checkIteratorConflicts(login, tableName, setting, scopes)
+        send_message('checkIteratorConflicts', CheckIteratorConflicts_args, :login => login, :tableName => tableName, :setting => setting, :scopes => scopes)
+      end
+
+      def recv_checkIteratorConflicts()
+        result = receive_message(CheckIteratorConflicts_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def clearLocatorCache(login, tableName)
+        send_clearLocatorCache(login, tableName)
+        recv_clearLocatorCache()
+      end
+
+      def send_clearLocatorCache(login, tableName)
+        send_message('clearLocatorCache', ClearLocatorCache_args, :login => login, :tableName => tableName)
+      end
+
+      def recv_clearLocatorCache()
+        result = receive_message(ClearLocatorCache_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        return
+      end
+
+      def cloneTable(login, tableName, newTableName, flush, propertiesToSet, propertiesToExclude)
+        send_cloneTable(login, tableName, newTableName, flush, propertiesToSet, propertiesToExclude)
+        recv_cloneTable()
+      end
+
+      def send_cloneTable(login, tableName, newTableName, flush, propertiesToSet, propertiesToExclude)
+        send_message('cloneTable', CloneTable_args, :login => login, :tableName => tableName, :newTableName => newTableName, :flush => flush, :propertiesToSet => propertiesToSet, :propertiesToExclude => propertiesToExclude)
+      end
+
+      def recv_cloneTable()
+        result = receive_message(CloneTable_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise result.ouch4 unless result.ouch4.nil?
+        return
+      end
+
+      def compactTable(login, tableName, startRow, endRow, iterators, flush, wait)
+        send_compactTable(login, tableName, startRow, endRow, iterators, flush, wait)
+        recv_compactTable()
+      end
+
+      def send_compactTable(login, tableName, startRow, endRow, iterators, flush, wait)
+        send_message('compactTable', CompactTable_args, :login => login, :tableName => tableName, :startRow => startRow, :endRow => endRow, :iterators => iterators, :flush => flush, :wait => wait)
+      end
+
+      def recv_compactTable()
+        result = receive_message(CompactTable_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def cancelCompaction(login, tableName)
+        send_cancelCompaction(login, tableName)
+        recv_cancelCompaction()
+      end
+
+      def send_cancelCompaction(login, tableName)
+        send_message('cancelCompaction', CancelCompaction_args, :login => login, :tableName => tableName)
+      end
+
+      def recv_cancelCompaction()
+        result = receive_message(CancelCompaction_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def createTable(login, tableName, versioningIter, type)
+        send_createTable(login, tableName, versioningIter, type)
+        recv_createTable()
+      end
+
+      def send_createTable(login, tableName, versioningIter, type)
+        send_message('createTable', CreateTable_args, :login => login, :tableName => tableName, :versioningIter => versioningIter, :type => type)
+      end
+
+      def recv_createTable()
+        result = receive_message(CreateTable_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def deleteTable(login, tableName)
+        send_deleteTable(login, tableName)
+        recv_deleteTable()
+      end
+
+      def send_deleteTable(login, tableName)
+        send_message('deleteTable', DeleteTable_args, :login => login, :tableName => tableName)
+      end
+
+      def recv_deleteTable()
+        result = receive_message(DeleteTable_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def deleteRows(login, tableName, startRow, endRow)
+        send_deleteRows(login, tableName, startRow, endRow)
+        recv_deleteRows()
+      end
+
+      def send_deleteRows(login, tableName, startRow, endRow)
+        send_message('deleteRows', DeleteRows_args, :login => login, :tableName => tableName, :startRow => startRow, :endRow => endRow)
+      end
+
+      def recv_deleteRows()
+        result = receive_message(DeleteRows_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def exportTable(login, tableName, exportDir)
+        send_exportTable(login, tableName, exportDir)
+        recv_exportTable()
+      end
+
+      def send_exportTable(login, tableName, exportDir)
+        send_message('exportTable', ExportTable_args, :login => login, :tableName => tableName, :exportDir => exportDir)
+      end
+
+      def recv_exportTable()
+        result = receive_message(ExportTable_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def flushTable(login, tableName, startRow, endRow, wait)
+        send_flushTable(login, tableName, startRow, endRow, wait)
+        recv_flushTable()
+      end
+
+      def send_flushTable(login, tableName, startRow, endRow, wait)
+        send_message('flushTable', FlushTable_args, :login => login, :tableName => tableName, :startRow => startRow, :endRow => endRow, :wait => wait)
+      end
+
+      def recv_flushTable()
+        result = receive_message(FlushTable_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def getLocalityGroups(login, tableName)
+        send_getLocalityGroups(login, tableName)
+        return recv_getLocalityGroups()
+      end
+
+      def send_getLocalityGroups(login, tableName)
+        send_message('getLocalityGroups', GetLocalityGroups_args, :login => login, :tableName => tableName)
+      end
+
+      def recv_getLocalityGroups()
+        result = receive_message(GetLocalityGroups_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getLocalityGroups failed: unknown result')
+      end
+
+      def getIteratorSetting(login, tableName, iteratorName, scope)
+        send_getIteratorSetting(login, tableName, iteratorName, scope)
+        return recv_getIteratorSetting()
+      end
+
+      def send_getIteratorSetting(login, tableName, iteratorName, scope)
+        send_message('getIteratorSetting', GetIteratorSetting_args, :login => login, :tableName => tableName, :iteratorName => iteratorName, :scope => scope)
+      end
+
+      def recv_getIteratorSetting()
+        result = receive_message(GetIteratorSetting_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getIteratorSetting failed: unknown result')
+      end
+
+      def getMaxRow(login, tableName, auths, startRow, startInclusive, endRow, endInclusive)
+        send_getMaxRow(login, tableName, auths, startRow, startInclusive, endRow, endInclusive)
+        return recv_getMaxRow()
+      end
+
+      def send_getMaxRow(login, tableName, auths, startRow, startInclusive, endRow, endInclusive)
+        send_message('getMaxRow', GetMaxRow_args, :login => login, :tableName => tableName, :auths => auths, :startRow => startRow, :startInclusive => startInclusive, :endRow => endRow, :endInclusive => endInclusive)
+      end
+
+      def recv_getMaxRow()
+        result = receive_message(GetMaxRow_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getMaxRow failed: unknown result')
+      end
+
+      def getTableProperties(login, tableName)
+        send_getTableProperties(login, tableName)
+        return recv_getTableProperties()
+      end
+
+      def send_getTableProperties(login, tableName)
+        send_message('getTableProperties', GetTableProperties_args, :login => login, :tableName => tableName)
+      end
+
+      def recv_getTableProperties()
+        result = receive_message(GetTableProperties_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTableProperties failed: unknown result')
+      end
+
+      def importDirectory(login, tableName, importDir, failureDir, setTime)
+        send_importDirectory(login, tableName, importDir, failureDir, setTime)
+        recv_importDirectory()
+      end
+
+      def send_importDirectory(login, tableName, importDir, failureDir, setTime)
+        send_message('importDirectory', ImportDirectory_args, :login => login, :tableName => tableName, :importDir => importDir, :failureDir => failureDir, :setTime => setTime)
+      end
+
+      def recv_importDirectory()
+        result = receive_message(ImportDirectory_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise result.ouch4 unless result.ouch4.nil?
+        return
+      end
+
+      def importTable(login, tableName, importDir)
+        send_importTable(login, tableName, importDir)
+        recv_importTable()
+      end
+
+      def send_importTable(login, tableName, importDir)
+        send_message('importTable', ImportTable_args, :login => login, :tableName => tableName, :importDir => importDir)
+      end
+
+      def recv_importTable()
+        result = receive_message(ImportTable_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def listSplits(login, tableName, maxSplits)
+        send_listSplits(login, tableName, maxSplits)
+        return recv_listSplits()
+      end
+
+      def send_listSplits(login, tableName, maxSplits)
+        send_message('listSplits', ListSplits_args, :login => login, :tableName => tableName, :maxSplits => maxSplits)
+      end
+
+      def recv_listSplits()
+        result = receive_message(ListSplits_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'listSplits failed: unknown result')
+      end
+
+      def listTables(login)
+        send_listTables(login)
+        return recv_listTables()
+      end
+
+      def send_listTables(login)
+        send_message('listTables', ListTables_args, :login => login)
+      end
+
+      def recv_listTables()
+        result = receive_message(ListTables_result)
+        return result.success unless result.success.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'listTables failed: unknown result')
+      end
+
+      def listIterators(login, tableName)
+        send_listIterators(login, tableName)
+        return recv_listIterators()
+      end
+
+      def send_listIterators(login, tableName)
+        send_message('listIterators', ListIterators_args, :login => login, :tableName => tableName)
+      end
+
+      def recv_listIterators()
+        result = receive_message(ListIterators_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'listIterators failed: unknown result')
+      end
+
+      def listConstraints(login, tableName)
+        send_listConstraints(login, tableName)
+        return recv_listConstraints()
+      end
+
+      def send_listConstraints(login, tableName)
+        send_message('listConstraints', ListConstraints_args, :login => login, :tableName => tableName)
+      end
+
+      def recv_listConstraints()
+        result = receive_message(ListConstraints_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'listConstraints failed: unknown result')
+      end
+
+      def mergeTablets(login, tableName, startRow, endRow)
+        send_mergeTablets(login, tableName, startRow, endRow)
+        recv_mergeTablets()
+      end
+
+      def send_mergeTablets(login, tableName, startRow, endRow)
+        send_message('mergeTablets', MergeTablets_args, :login => login, :tableName => tableName, :startRow => startRow, :endRow => endRow)
+      end
+
+      def recv_mergeTablets()
+        result = receive_message(MergeTablets_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def offlineTable(login, tableName)
+        send_offlineTable(login, tableName)
+        recv_offlineTable()
+      end
+
+      def send_offlineTable(login, tableName)
+        send_message('offlineTable', OfflineTable_args, :login => login, :tableName => tableName)
+      end
+
+      def recv_offlineTable()
+        result = receive_message(OfflineTable_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def onlineTable(login, tableName)
+        send_onlineTable(login, tableName)
+        recv_onlineTable()
+      end
+
+      def send_onlineTable(login, tableName)
+        send_message('onlineTable', OnlineTable_args, :login => login, :tableName => tableName)
+      end
+
+      def recv_onlineTable()
+        result = receive_message(OnlineTable_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def removeConstraint(login, tableName, constraint)
+        send_removeConstraint(login, tableName, constraint)
+        recv_removeConstraint()
+      end
+
+      def send_removeConstraint(login, tableName, constraint)
+        send_message('removeConstraint', RemoveConstraint_args, :login => login, :tableName => tableName, :constraint => constraint)
+      end
+
+      def recv_removeConstraint()
+        result = receive_message(RemoveConstraint_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def removeIterator(login, tableName, iterName, scopes)
+        send_removeIterator(login, tableName, iterName, scopes)
+        recv_removeIterator()
+      end
+
+      def send_removeIterator(login, tableName, iterName, scopes)
+        send_message('removeIterator', RemoveIterator_args, :login => login, :tableName => tableName, :iterName => iterName, :scopes => scopes)
+      end
+
+      def recv_removeIterator()
+        result = receive_message(RemoveIterator_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def removeTableProperty(login, tableName, property)
+        send_removeTableProperty(login, tableName, property)
+        recv_removeTableProperty()
+      end
+
+      def send_removeTableProperty(login, tableName, property)
+        send_message('removeTableProperty', RemoveTableProperty_args, :login => login, :tableName => tableName, :property => property)
+      end
+
+      def recv_removeTableProperty()
+        result = receive_message(RemoveTableProperty_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def renameTable(login, oldTableName, newTableName)
+        send_renameTable(login, oldTableName, newTableName)
+        recv_renameTable()
+      end
+
+      def send_renameTable(login, oldTableName, newTableName)
+        send_message('renameTable', RenameTable_args, :login => login, :oldTableName => oldTableName, :newTableName => newTableName)
+      end
+
+      def recv_renameTable()
+        result = receive_message(RenameTable_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise result.ouch4 unless result.ouch4.nil?
+        return
+      end
+
+      def setLocalityGroups(login, tableName, groups)
+        send_setLocalityGroups(login, tableName, groups)
+        recv_setLocalityGroups()
+      end
+
+      def send_setLocalityGroups(login, tableName, groups)
+        send_message('setLocalityGroups', SetLocalityGroups_args, :login => login, :tableName => tableName, :groups => groups)
+      end
+
+      def recv_setLocalityGroups()
+        result = receive_message(SetLocalityGroups_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def setTableProperty(login, tableName, property, value)
+        send_setTableProperty(login, tableName, property, value)
+        recv_setTableProperty()
+      end
+
+      def send_setTableProperty(login, tableName, property, value)
+        send_message('setTableProperty', SetTableProperty_args, :login => login, :tableName => tableName, :property => property, :value => value)
+      end
+
+      def recv_setTableProperty()
+        result = receive_message(SetTableProperty_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def splitRangeByTablets(login, tableName, range, maxSplits)
+        send_splitRangeByTablets(login, tableName, range, maxSplits)
+        return recv_splitRangeByTablets()
+      end
+
+      def send_splitRangeByTablets(login, tableName, range, maxSplits)
+        send_message('splitRangeByTablets', SplitRangeByTablets_args, :login => login, :tableName => tableName, :range => range, :maxSplits => maxSplits)
+      end
+
+      def recv_splitRangeByTablets()
+        result = receive_message(SplitRangeByTablets_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'splitRangeByTablets failed: unknown result')
+      end
+
+      def tableExists(login, tableName)
+        send_tableExists(login, tableName)
+        return recv_tableExists()
+      end
+
+      def send_tableExists(login, tableName)
+        send_message('tableExists', TableExists_args, :login => login, :tableName => tableName)
+      end
+
+      def recv_tableExists()
+        result = receive_message(TableExists_result)
+        return result.success unless result.success.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'tableExists failed: unknown result')
+      end
+
+      def tableIdMap(login)
+        send_tableIdMap(login)
+        return recv_tableIdMap()
+      end
+
+      def send_tableIdMap(login)
+        send_message('tableIdMap', TableIdMap_args, :login => login)
+      end
+
+      def recv_tableIdMap()
+        result = receive_message(TableIdMap_result)
+        return result.success unless result.success.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'tableIdMap failed: unknown result')
+      end
+
+      def testTableClassLoad(login, tableName, className, asTypeName)
+        send_testTableClassLoad(login, tableName, className, asTypeName)
+        return recv_testTableClassLoad()
+      end
+
+      def send_testTableClassLoad(login, tableName, className, asTypeName)
+        send_message('testTableClassLoad', TestTableClassLoad_args, :login => login, :tableName => tableName, :className => className, :asTypeName => asTypeName)
+      end
+
+      def recv_testTableClassLoad()
+        result = receive_message(TestTableClassLoad_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'testTableClassLoad failed: unknown result')
+      end
+
+      def pingTabletServer(login, tserver)
+        send_pingTabletServer(login, tserver)
+        recv_pingTabletServer()
+      end
+
+      def send_pingTabletServer(login, tserver)
+        send_message('pingTabletServer', PingTabletServer_args, :login => login, :tserver => tserver)
+      end
+
+      def recv_pingTabletServer()
+        result = receive_message(PingTabletServer_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        return
+      end
+
+      def getActiveScans(login, tserver)
+        send_getActiveScans(login, tserver)
+        return recv_getActiveScans()
+      end
+
+      def send_getActiveScans(login, tserver)
+        send_message('getActiveScans', GetActiveScans_args, :login => login, :tserver => tserver)
+      end
+
+      def recv_getActiveScans()
+        result = receive_message(GetActiveScans_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getActiveScans failed: unknown result')
+      end
+
+      def getActiveCompactions(login, tserver)
+        send_getActiveCompactions(login, tserver)
+        return recv_getActiveCompactions()
+      end
+
+      def send_getActiveCompactions(login, tserver)
+        send_message('getActiveCompactions', GetActiveCompactions_args, :login => login, :tserver => tserver)
+      end
+
+      def recv_getActiveCompactions()
+        result = receive_message(GetActiveCompactions_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getActiveCompactions failed: unknown result')
+      end
+
+      def getSiteConfiguration(login)
+        send_getSiteConfiguration(login)
+        return recv_getSiteConfiguration()
+      end
+
+      def send_getSiteConfiguration(login)
+        send_message('getSiteConfiguration', GetSiteConfiguration_args, :login => login)
+      end
+
+      def recv_getSiteConfiguration()
+        result = receive_message(GetSiteConfiguration_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getSiteConfiguration failed: unknown result')
+      end
+
+      def getSystemConfiguration(login)
+        send_getSystemConfiguration(login)
+        return recv_getSystemConfiguration()
+      end
+
+      def send_getSystemConfiguration(login)
+        send_message('getSystemConfiguration', GetSystemConfiguration_args, :login => login)
+      end
+
+      def recv_getSystemConfiguration()
+        result = receive_message(GetSystemConfiguration_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getSystemConfiguration failed: unknown result')
+      end
+
+      def getTabletServers(login)
+        send_getTabletServers(login)
+        return recv_getTabletServers()
+      end
+
+      def send_getTabletServers(login)
+        send_message('getTabletServers', GetTabletServers_args, :login => login)
+      end
+
+      def recv_getTabletServers()
+        result = receive_message(GetTabletServers_result)
+        return result.success unless result.success.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTabletServers failed: unknown result')
+      end
+
+      def removeProperty(login, property)
+        send_removeProperty(login, property)
+        recv_removeProperty()
+      end
+
+      def send_removeProperty(login, property)
+        send_message('removeProperty', RemoveProperty_args, :login => login, :property => property)
+      end
+
+      def recv_removeProperty()
+        result = receive_message(RemoveProperty_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        return
+      end
+
+      def setProperty(login, property, value)
+        send_setProperty(login, property, value)
+        recv_setProperty()
+      end
+
+      def send_setProperty(login, property, value)
+        send_message('setProperty', SetProperty_args, :login => login, :property => property, :value => value)
+      end
+
+      def recv_setProperty()
+        result = receive_message(SetProperty_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        return
+      end
+
+      def testClassLoad(login, className, asTypeName)
+        send_testClassLoad(login, className, asTypeName)
+        return recv_testClassLoad()
+      end
+
+      def send_testClassLoad(login, className, asTypeName)
+        send_message('testClassLoad', TestClassLoad_args, :login => login, :className => className, :asTypeName => asTypeName)
+      end
+
+      def recv_testClassLoad()
+        result = receive_message(TestClassLoad_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'testClassLoad failed: unknown result')
+      end
+
+      def authenticateUser(login, user, properties)
+        send_authenticateUser(login, user, properties)
+        return recv_authenticateUser()
+      end
+
+      def send_authenticateUser(login, user, properties)
+        send_message('authenticateUser', AuthenticateUser_args, :login => login, :user => user, :properties => properties)
+      end
+
+      def recv_authenticateUser()
+        result = receive_message(AuthenticateUser_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'authenticateUser failed: unknown result')
+      end
+
+      def changeUserAuthorizations(login, user, authorizations)
+        send_changeUserAuthorizations(login, user, authorizations)
+        recv_changeUserAuthorizations()
+      end
+
+      def send_changeUserAuthorizations(login, user, authorizations)
+        send_message('changeUserAuthorizations', ChangeUserAuthorizations_args, :login => login, :user => user, :authorizations => authorizations)
+      end
+
+      def recv_changeUserAuthorizations()
+        result = receive_message(ChangeUserAuthorizations_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        return
+      end
+
+      def changeLocalUserPassword(login, user, password)
+        send_changeLocalUserPassword(login, user, password)
+        recv_changeLocalUserPassword()
+      end
+
+      def send_changeLocalUserPassword(login, user, password)
+        send_message('changeLocalUserPassword', ChangeLocalUserPassword_args, :login => login, :user => user, :password => password)
+      end
+
+      def recv_changeLocalUserPassword()
+        result = receive_message(ChangeLocalUserPassword_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        return
+      end
+
+      def createLocalUser(login, user, password)
+        send_createLocalUser(login, user, password)
+        recv_createLocalUser()
+      end
+
+      def send_createLocalUser(login, user, password)
+        send_message('createLocalUser', CreateLocalUser_args, :login => login, :user => user, :password => password)
+      end
+
+      def recv_createLocalUser()
+        result = receive_message(CreateLocalUser_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        return
+      end
+
+      def dropLocalUser(login, user)
+        send_dropLocalUser(login, user)
+        recv_dropLocalUser()
+      end
+
+      def send_dropLocalUser(login, user)
+        send_message('dropLocalUser', DropLocalUser_args, :login => login, :user => user)
+      end
+
+      def recv_dropLocalUser()
+        result = receive_message(DropLocalUser_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        return
+      end
+
+      def getUserAuthorizations(login, user)
+        send_getUserAuthorizations(login, user)
+        return recv_getUserAuthorizations()
+      end
+
+      def send_getUserAuthorizations(login, user)
+        send_message('getUserAuthorizations', GetUserAuthorizations_args, :login => login, :user => user)
+      end
+
+      def recv_getUserAuthorizations()
+        result = receive_message(GetUserAuthorizations_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getUserAuthorizations failed: unknown result')
+      end
+
+      def grantSystemPermission(login, user, perm)
+        send_grantSystemPermission(login, user, perm)
+        recv_grantSystemPermission()
+      end
+
+      def send_grantSystemPermission(login, user, perm)
+        send_message('grantSystemPermission', GrantSystemPermission_args, :login => login, :user => user, :perm => perm)
+      end
+
+      def recv_grantSystemPermission()
+        result = receive_message(GrantSystemPermission_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        return
+      end
+
+      def grantTablePermission(login, user, table, perm)
+        send_grantTablePermission(login, user, table, perm)
+        recv_grantTablePermission()
+      end
+
+      def send_grantTablePermission(login, user, table, perm)
+        send_message('grantTablePermission', GrantTablePermission_args, :login => login, :user => user, :table => table, :perm => perm)
+      end
+
+      def recv_grantTablePermission()
+        result = receive_message(GrantTablePermission_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def hasSystemPermission(login, user, perm)
+        send_hasSystemPermission(login, user, perm)
+        return recv_hasSystemPermission()
+      end
+
+      def send_hasSystemPermission(login, user, perm)
+        send_message('hasSystemPermission', HasSystemPermission_args, :login => login, :user => user, :perm => perm)
+      end
+
+      def recv_hasSystemPermission()
+        result = receive_message(HasSystemPermission_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'hasSystemPermission failed: unknown result')
+      end
+
+      def hasTablePermission(login, user, table, perm)
+        send_hasTablePermission(login, user, table, perm)
+        return recv_hasTablePermission()
+      end
+
+      def send_hasTablePermission(login, user, table, perm)
+        send_message('hasTablePermission', HasTablePermission_args, :login => login, :user => user, :table => table, :perm => perm)
+      end
+
+      def recv_hasTablePermission()
+        result = receive_message(HasTablePermission_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'hasTablePermission failed: unknown result')
+      end
+
+      def listLocalUsers(login)
+        send_listLocalUsers(login)
+        return recv_listLocalUsers()
+      end
+
+      def send_listLocalUsers(login)
+        send_message('listLocalUsers', ListLocalUsers_args, :login => login)
+      end
+
+      def recv_listLocalUsers()
+        result = receive_message(ListLocalUsers_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'listLocalUsers failed: unknown result')
+      end
+
+      def revokeSystemPermission(login, user, perm)
+        send_revokeSystemPermission(login, user, perm)
+        recv_revokeSystemPermission()
+      end
+
+      def send_revokeSystemPermission(login, user, perm)
+        send_message('revokeSystemPermission', RevokeSystemPermission_args, :login => login, :user => user, :perm => perm)
+      end
+
+      def recv_revokeSystemPermission()
+        result = receive_message(RevokeSystemPermission_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        return
+      end
+
+      def revokeTablePermission(login, user, table, perm)
+        send_revokeTablePermission(login, user, table, perm)
+        recv_revokeTablePermission()
+      end
+
+      def send_revokeTablePermission(login, user, table, perm)
+        send_message('revokeTablePermission', RevokeTablePermission_args, :login => login, :user => user, :table => table, :perm => perm)
+      end
+
+      def recv_revokeTablePermission()
+        result = receive_message(RevokeTablePermission_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        return
+      end
+
+      def createBatchScanner(login, tableName, options)
+        send_createBatchScanner(login, tableName, options)
+        return recv_createBatchScanner()
+      end
+
+      def send_createBatchScanner(login, tableName, options)
+        send_message('createBatchScanner', CreateBatchScanner_args, :login => login, :tableName => tableName, :options => options)
+      end
+
+      def recv_createBatchScanner()
+        result = receive_message(CreateBatchScanner_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'createBatchScanner failed: unknown result')
+      end
+
+      def createScanner(login, tableName, options)
+        send_createScanner(login, tableName, options)
+        return recv_createScanner()
+      end
+
+      def send_createScanner(login, tableName, options)
+        send_message('createScanner', CreateScanner_args, :login => login, :tableName => tableName, :options => options)
+      end
+
+      def recv_createScanner()
+        result = receive_message(CreateScanner_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'createScanner failed: unknown result')
+      end
+
+      def hasNext(scanner)
+        send_hasNext(scanner)
+        return recv_hasNext()
+      end
+
+      def send_hasNext(scanner)
+        send_message('hasNext', HasNext_args, :scanner => scanner)
+      end
+
+      def recv_hasNext()
+        result = receive_message(HasNext_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'hasNext failed: unknown result')
+      end
+
+      def nextEntry(scanner)
+        send_nextEntry(scanner)
+        return recv_nextEntry()
+      end
+
+      def send_nextEntry(scanner)
+        send_message('nextEntry', NextEntry_args, :scanner => scanner)
+      end
+
+      def recv_nextEntry()
+        result = receive_message(NextEntry_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'nextEntry failed: unknown result')
+      end
+
+      def nextK(scanner, k)
+        send_nextK(scanner, k)
+        return recv_nextK()
+      end
+
+      def send_nextK(scanner, k)
+        send_message('nextK', NextK_args, :scanner => scanner, :k => k)
+      end
+
+      def recv_nextK()
+        result = receive_message(NextK_result)
+        return result.success unless result.success.nil?
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'nextK failed: unknown result')
+      end
+
+      def closeScanner(scanner)
+        send_closeScanner(scanner)
+        recv_closeScanner()
+      end
+
+      def send_closeScanner(scanner)
+        send_message('closeScanner', CloseScanner_args, :scanner => scanner)
+      end
+
+      def recv_closeScanner()
+        result = receive_message(CloseScanner_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        return
+      end
+
+      def updateAndFlush(login, tableName, cells)
+        send_updateAndFlush(login, tableName, cells)
+        recv_updateAndFlush()
+      end
+
+      def send_updateAndFlush(login, tableName, cells)
+        send_message('updateAndFlush', UpdateAndFlush_args, :login => login, :tableName => tableName, :cells => cells)
+      end
+
+      def recv_updateAndFlush()
+        result = receive_message(UpdateAndFlush_result)
+        raise result.outch1 unless result.outch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise result.ouch4 unless result.ouch4.nil?
+        return
+      end
+
+      def createWriter(login, tableName, opts)
+        send_createWriter(login, tableName, opts)
+        return recv_createWriter()
+      end
+
+      def send_createWriter(login, tableName, opts)
+        send_message('createWriter', CreateWriter_args, :login => login, :tableName => tableName, :opts => opts)
+      end
+
+      def recv_createWriter()
+        result = receive_message(CreateWriter_result)
+        return result.success unless result.success.nil?
+        raise result.outch1 unless result.outch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        raise result.ouch3 unless result.ouch3.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'createWriter failed: unknown result')
+      end
+
+      def update(writer, cells)
+        send_update(writer, cells)
+      end
+
+      def send_update(writer, cells)
+        send_message('update', Update_args, :writer => writer, :cells => cells)
+      end
+      def flush(writer)
+        send_flush(writer)
+        recv_flush()
+      end
+
+      def send_flush(writer)
+        send_message('flush', Flush_args, :writer => writer)
+      end
+
+      def recv_flush()
+        result = receive_message(Flush_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        return
+      end
+
+      def closeWriter(writer)
+        send_closeWriter(writer)
+        recv_closeWriter()
+      end
+
+      def send_closeWriter(writer)
+        send_message('closeWriter', CloseWriter_args, :writer => writer)
+      end
+
+      def recv_closeWriter()
+        result = receive_message(CloseWriter_result)
+        raise result.ouch1 unless result.ouch1.nil?
+        raise result.ouch2 unless result.ouch2.nil?
+        return
+      end
+
+      def getRowRange(row)
+        send_getRowRange(row)
+        return recv_getRowRange()
+      end
+
+      def send_getRowRange(row)
+        send_message('getRowRange', GetRowRange_args, :row => row)
+      end
+
+      def recv_getRowRange()
+        result = receive_message(GetRowRange_result)
+        return result.success unless result.success.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getRowRange failed: unknown result')
+      end
+
+      def getFollowing(key, part)
+        send_getFollowing(key, part)
+        return recv_getFollowing()
+      end
+
+      def send_getFollowing(key, part)
+        send_message('getFollowing', GetFollowing_args, :key => key, :part => part)
+      end
+
+      def recv_getFollowing()
+        result = receive_message(GetFollowing_result)
+        return result.success unless result.success.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getFollowing failed: unknown result')
+      end
+
+    end
+
+    class Processor
+      include ::Thrift::Processor
+
+      def process_login(seqid, iprot, oprot)
+        args = read_args(iprot, Login_args)
+        result = Login_result.new()
+        begin
+          result.success = @handler.login(args.principal, args.loginProperties)
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'login', seqid)
+      end
+
+      def process_addConstraint(seqid, iprot, oprot)
+        args = read_args(iprot, AddConstraint_args)
+        result = AddConstraint_result.new()
+        begin
+          result.success = @handler.addConstraint(args.login, args.tableName, args.constraintClassName)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'addConstraint', seqid)
+      end
+
+      def process_addSplits(seqid, iprot, oprot)
+        args = read_args(iprot, AddSplits_args)
+        result = AddSplits_result.new()
+        begin
+          @handler.addSplits(args.login, args.tableName, args.splits)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'addSplits', seqid)
+      end
+
+      def process_attachIterator(seqid, iprot, oprot)
+        args = read_args(iprot, AttachIterator_args)
+        result = AttachIterator_result.new()
+        begin
+          @handler.attachIterator(args.login, args.tableName, args.setting, args.scopes)
+        rescue ::Accumulo::AccumuloSecurityException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'attachIterator', seqid)
+      end
+
+      def process_checkIteratorConflicts(seqid, iprot, oprot)
+        args = read_args(iprot, CheckIteratorConflicts_args)
+        result = CheckIteratorConflicts_result.new()
+        begin
+          @handler.checkIteratorConflicts(args.login, args.tableName, args.setting, args.scopes)
+        rescue ::Accumulo::AccumuloSecurityException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'checkIteratorConflicts', seqid)
+      end
+
+      def process_clearLocatorCache(seqid, iprot, oprot)
+        args = read_args(iprot, ClearLocatorCache_args)
+        result = ClearLocatorCache_result.new()
+        begin
+          @handler.clearLocatorCache(args.login, args.tableName)
+        rescue ::Accumulo::TableNotFoundException => ouch1
+          result.ouch1 = ouch1
+        end
+        write_result(result, oprot, 'clearLocatorCache', seqid)
+      end
+
+      def process_cloneTable(seqid, iprot, oprot)
+        args = read_args(iprot, CloneTable_args)
+        result = CloneTable_result.new()
+        begin
+          @handler.cloneTable(args.login, args.tableName, args.newTableName, args.flush, args.propertiesToSet, args.propertiesToExclude)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        rescue ::Accumulo::TableExistsException => ouch4
+          result.ouch4 = ouch4
+        end
+        write_result(result, oprot, 'cloneTable', seqid)
+      end
+
+      def process_compactTable(seqid, iprot, oprot)
+        args = read_args(iprot, CompactTable_args)
+        result = CompactTable_result.new()
+        begin
+          @handler.compactTable(args.login, args.tableName, args.startRow, args.endRow, args.iterators, args.flush, args.wait)
+        rescue ::Accumulo::AccumuloSecurityException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::TableNotFoundException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::AccumuloException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'compactTable', seqid)
+      end
+
+      def process_cancelCompaction(seqid, iprot, oprot)
+        args = read_args(iprot, CancelCompaction_args)
+        result = CancelCompaction_result.new()
+        begin
+          @handler.cancelCompaction(args.login, args.tableName)
+        rescue ::Accumulo::AccumuloSecurityException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::TableNotFoundException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::AccumuloException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'cancelCompaction', seqid)
+      end
+
+      def process_createTable(seqid, iprot, oprot)
+        args = read_args(iprot, CreateTable_args)
+        result = CreateTable_result.new()
+        begin
+          @handler.createTable(args.login, args.tableName, args.versioningIter, args.type)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableExistsException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'createTable', seqid)
+      end
+
+      def process_deleteTable(seqid, iprot, oprot)
+        args = read_args(iprot, DeleteTable_args)
+        result = DeleteTable_result.new()
+        begin
+          @handler.deleteTable(args.login, args.tableName)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'deleteTable', seqid)
+      end
+
+      def process_deleteRows(seqid, iprot, oprot)
+        args = read_args(iprot, DeleteRows_args)
+        result = DeleteRows_result.new()
+        begin
+          @handler.deleteRows(args.login, args.tableName, args.startRow, args.endRow)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'deleteRows', seqid)
+      end
+
+      def process_exportTable(seqid, iprot, oprot)
+        args = read_args(iprot, ExportTable_args)
+        result = ExportTable_result.new()
+        begin
+          @handler.exportTable(args.login, args.tableName, args.exportDir)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'exportTable', seqid)
+      end
+
+      def process_flushTable(seqid, iprot, oprot)
+        args = read_args(iprot, FlushTable_args)
+        result = FlushTable_result.new()
+        begin
+          @handler.flushTable(args.login, args.tableName, args.startRow, args.endRow, args.wait)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'flushTable', seqid)
+      end
+
+      def process_getLocalityGroups(seqid, iprot, oprot)
+        args = read_args(iprot, GetLocalityGroups_args)
+        result = GetLocalityGroups_result.new()
+        begin
+          result.success = @handler.getLocalityGroups(args.login, args.tableName)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'getLocalityGroups', seqid)
+      end
+
+      def process_getIteratorSetting(seqid, iprot, oprot)
+        args = read_args(iprot, GetIteratorSetting_args)
+        result = GetIteratorSetting_result.new()
+        begin
+          result.success = @handler.getIteratorSetting(args.login, args.tableName, args.iteratorName, args.scope)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'getIteratorSetting', seqid)
+      end
+
+      def process_getMaxRow(seqid, iprot, oprot)
+        args = read_args(iprot, GetMaxRow_args)
+        result = GetMaxRow_result.new()
+        begin
+          result.success = @handler.getMaxRow(args.login, args.tableName, args.auths, args.startRow, args.startInclusive, args.endRow, args.endInclusive)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'getMaxRow', seqid)
+      end
+
+      def process_getTableProperties(seqid, iprot, oprot)
+        args = read_args(iprot, GetTableProperties_args)
+        result = GetTableProperties_result.new()
+        begin
+          result.success = @handler.getTableProperties(args.login, args.tableName)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'getTableProperties', seqid)
+      end
+
+      def process_importDirectory(seqid, iprot, oprot)
+        args = read_args(iprot, ImportDirectory_args)
+        result = ImportDirectory_result.new()
+        begin
+          @handler.importDirectory(args.login, args.tableName, args.importDir, args.failureDir, args.setTime)
+        rescue ::Accumulo::TableNotFoundException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloException => ouch3
+          result.ouch3 = ouch3
+        rescue ::Accumulo::AccumuloSecurityException => ouch4
+          result.ouch4 = ouch4
+        end
+        write_result(result, oprot, 'importDirectory', seqid)
+      end
+
+      def process_importTable(seqid, iprot, oprot)
+        args = read_args(iprot, ImportTable_args)
+        result = ImportTable_result.new()
+        begin
+          @handler.importTable(args.login, args.tableName, args.importDir)
+        rescue ::Accumulo::TableExistsException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::AccumuloSecurityException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'importTable', seqid)
+      end
+
+      def process_listSplits(seqid, iprot, oprot)
+        args = read_args(iprot, ListSplits_args)
+        result = ListSplits_result.new()
+        begin
+          result.success = @handler.listSplits(args.login, args.tableName, args.maxSplits)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'listSplits', seqid)
+      end
+
+      def process_listTables(seqid, iprot, oprot)
+        args = read_args(iprot, ListTables_args)
+        result = ListTables_result.new()
+        result.success = @handler.listTables(args.login)
+        write_result(result, oprot, 'listTables', seqid)
+      end
+
+      def process_listIterators(seqid, iprot, oprot)
+        args = read_args(iprot, ListIterators_args)
+        result = ListIterators_result.new()
+        begin
+          result.success = @handler.listIterators(args.login, args.tableName)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'listIterators', seqid)
+      end
+
+      def process_listConstraints(seqid, iprot, oprot)
+        args = read_args(iprot, ListConstraints_args)
+        result = ListConstraints_result.new()
+        begin
+          result.success = @handler.listConstraints(args.login, args.tableName)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'listConstraints', seqid)
+      end
+
+      def process_mergeTablets(seqid, iprot, oprot)
+        args = read_args(iprot, MergeTablets_args)
+        result = MergeTablets_result.new()
+        begin
+          @handler.mergeTablets(args.login, args.tableName, args.startRow, args.endRow)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'mergeTablets', seqid)
+      end
+
+      def process_offlineTable(seqid, iprot, oprot)
+        args = read_args(iprot, OfflineTable_args)
+        result = OfflineTable_result.new()
+        begin
+          @handler.offlineTable(args.login, args.tableName)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'offlineTable', seqid)
+      end
+
+      def process_onlineTable(seqid, iprot, oprot)
+        args = read_args(iprot, OnlineTable_args)
+        result = OnlineTable_result.new()
+        begin
+          @handler.onlineTable(args.login, args.tableName)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'onlineTable', seqid)
+      end
+
+      def process_removeConstraint(seqid, iprot, oprot)
+        args = read_args(iprot, RemoveConstraint_args)
+        result = RemoveConstraint_result.new()
+        begin
+          @handler.removeConstraint(args.login, args.tableName, args.constraint)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'removeConstraint', seqid)
+      end
+
+      def process_removeIterator(seqid, iprot, oprot)
+        args = read_args(iprot, RemoveIterator_args)
+        result = RemoveIterator_result.new()
+        begin
+          @handler.removeIterator(args.login, args.tableName, args.iterName, args.scopes)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'removeIterator', seqid)
+      end
+
+      def process_removeTableProperty(seqid, iprot, oprot)
+        args = read_args(iprot, RemoveTableProperty_args)
+        result = RemoveTableProperty_result.new()
+        begin
+          @handler.removeTableProperty(args.login, args.tableName, args.property)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'removeTableProperty', seqid)
+      end
+
+      def process_renameTable(seqid, iprot, oprot)
+        args = read_args(iprot, RenameTable_args)
+        result = RenameTable_result.new()
+        begin
+          @handler.renameTable(args.login, args.oldTableName, args.newTableName)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        rescue ::Accumulo::TableExistsException => ouch4
+          result.ouch4 = ouch4
+        end
+        write_result(result, oprot, 'renameTable', seqid)
+      end
+
+      def process_setLocalityGroups(seqid, iprot, oprot)
+        args = read_args(iprot, SetLocalityGroups_args)
+        result = SetLocalityGroups_result.new()
+        begin
+          @handler.setLocalityGroups(args.login, args.tableName, args.groups)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'setLocalityGroups', seqid)
+      end
+
+      def process_setTableProperty(seqid, iprot, oprot)
+        args = read_args(iprot, SetTableProperty_args)
+        result = SetTableProperty_result.new()
+        begin
+          @handler.setTableProperty(args.login, args.tableName, args.property, args.value)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'setTableProperty', seqid)
+      end
+
+      def process_splitRangeByTablets(seqid, iprot, oprot)
+        args = read_args(iprot, SplitRangeByTablets_args)
+        result = SplitRangeByTablets_result.new()
+        begin
+          result.success = @handler.splitRangeByTablets(args.login, args.tableName, args.range, args.maxSplits)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'splitRangeByTablets', seqid)
+      end
+
+      def process_tableExists(seqid, iprot, oprot)
+        args = read_args(iprot, TableExists_args)
+        result = TableExists_result.new()
+        result.success = @handler.tableExists(args.login, args.tableName)
+        write_result(result, oprot, 'tableExists', seqid)
+      end
+
+      def process_tableIdMap(seqid, iprot, oprot)
+        args = read_args(iprot, TableIdMap_args)
+        result = TableIdMap_result.new()
+        result.success = @handler.tableIdMap(args.login)
+        write_result(result, oprot, 'tableIdMap', seqid)
+      end
+
+      def process_testTableClassLoad(seqid, iprot, oprot)
+        args = read_args(iprot, TestTableClassLoad_args)
+        result = TestTableClassLoad_result.new()
+        begin
+          result.success = @handler.testTableClassLoad(args.login, args.tableName, args.className, args.asTypeName)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'testTableClassLoad', seqid)
+      end
+
+      def process_pingTabletServer(seqid, iprot, oprot)
+        args = read_args(iprot, PingTabletServer_args)
+        result = PingTabletServer_result.new()
+        begin
+          @handler.pingTabletServer(args.login, args.tserver)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'pingTabletServer', seqid)
+      end
+
+      def process_getActiveScans(seqid, iprot, oprot)
+        args = read_args(iprot, GetActiveScans_args)
+        result = GetActiveScans_result.new()
+        begin
+          result.success = @handler.getActiveScans(args.login, args.tserver)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'getActiveScans', seqid)
+      end
+
+      def process_getActiveCompactions(seqid, iprot, oprot)
+        args = read_args(iprot, GetActiveCompactions_args)
+        result = GetActiveCompactions_result.new()
+        begin
+          result.success = @handler.getActiveCompactions(args.login, args.tserver)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'getActiveCompactions', seqid)
+      end
+
+      def process_getSiteConfiguration(seqid, iprot, oprot)
+        args = read_args(iprot, GetSiteConfiguration_args)
+        result = GetSiteConfiguration_result.new()
+        begin
+          result.success = @handler.getSiteConfiguration(args.login)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'getSiteConfiguration', seqid)
+      end
+
+      def process_getSystemConfiguration(seqid, iprot, oprot)
+        args = read_args(iprot, GetSystemConfiguration_args)
+        result = GetSystemConfiguration_result.new()
+        begin
+          result.success = @handler.getSystemConfiguration(args.login)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'getSystemConfiguration', seqid)
+      end
+
+      def process_getTabletServers(seqid, iprot, oprot)
+        args = read_args(iprot, GetTabletServers_args)
+        result = GetTabletServers_result.new()
+        result.success = @handler.getTabletServers(args.login)
+        write_result(result, oprot, 'getTabletServers', seqid)
+      end
+
+      def process_removeProperty(seqid, iprot, oprot)
+        args = read_args(iprot, RemoveProperty_args)
+        result = RemoveProperty_result.new()
+        begin
+          @handler.removeProperty(args.login, args.property)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'removeProperty', seqid)
+      end
+
+      def process_setProperty(seqid, iprot, oprot)
+        args = read_args(iprot, SetProperty_args)
+        result = SetProperty_result.new()
+        begin
+          @handler.setProperty(args.login, args.property, args.value)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'setProperty', seqid)
+      end
+
+      def process_testClassLoad(seqid, iprot, oprot)
+        args = read_args(iprot, TestClassLoad_args)
+        result = TestClassLoad_result.new()
+        begin
+          result.success = @handler.testClassLoad(args.login, args.className, args.asTypeName)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'testClassLoad', seqid)
+      end
+
+      def process_authenticateUser(seqid, iprot, oprot)
+        args = read_args(iprot, AuthenticateUser_args)
+        result = AuthenticateUser_result.new()
+        begin
+          result.success = @handler.authenticateUser(args.login, args.user, args.properties)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'authenticateUser', seqid)
+      end
+
+      def process_changeUserAuthorizations(seqid, iprot, oprot)
+        args = read_args(iprot, ChangeUserAuthorizations_args)
+        result = ChangeUserAuthorizations_result.new()
+        begin
+          @handler.changeUserAuthorizations(args.login, args.user, args.authorizations)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'changeUserAuthorizations', seqid)
+      end
+
+      def process_changeLocalUserPassword(seqid, iprot, oprot)
+        args = read_args(iprot, ChangeLocalUserPassword_args)
+        result = ChangeLocalUserPassword_result.new()
+        begin
+          @handler.changeLocalUserPassword(args.login, args.user, args.password)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'changeLocalUserPassword', seqid)
+      end
+
+      def process_createLocalUser(seqid, iprot, oprot)
+        args = read_args(iprot, CreateLocalUser_args)
+        result = CreateLocalUser_result.new()
+        begin
+          @handler.createLocalUser(args.login, args.user, args.password)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'createLocalUser', seqid)
+      end
+
+      def process_dropLocalUser(seqid, iprot, oprot)
+        args = read_args(iprot, DropLocalUser_args)
+        result = DropLocalUser_result.new()
+        begin
+          @handler.dropLocalUser(args.login, args.user)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'dropLocalUser', seqid)
+      end
+
+      def process_getUserAuthorizations(seqid, iprot, oprot)
+        args = read_args(iprot, GetUserAuthorizations_args)
+        result = GetUserAuthorizations_result.new()
+        begin
+          result.success = @handler.getUserAuthorizations(args.login, args.user)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'getUserAuthorizations', seqid)
+      end
+
+      def process_grantSystemPermission(seqid, iprot, oprot)
+        args = read_args(iprot, GrantSystemPermission_args)
+        result = GrantSystemPermission_result.new()
+        begin
+          @handler.grantSystemPermission(args.login, args.user, args.perm)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'grantSystemPermission', seqid)
+      end
+
+      def process_grantTablePermission(seqid, iprot, oprot)
+        args = read_args(iprot, GrantTablePermission_args)
+        result = GrantTablePermission_result.new()
+        begin
+          @handler.grantTablePermission(args.login, args.user, args.table, args.perm)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'grantTablePermission', seqid)
+      end
+
+      def process_hasSystemPermission(seqid, iprot, oprot)
+        args = read_args(iprot, HasSystemPermission_args)
+        result = HasSystemPermission_result.new()
+        begin
+          result.success = @handler.hasSystemPermission(args.login, args.user, args.perm)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'hasSystemPermission', seqid)
+      end
+
+      def process_hasTablePermission(seqid, iprot, oprot)
+        args = read_args(iprot, HasTablePermission_args)
+        result = HasTablePermission_result.new()
+        begin
+          result.success = @handler.hasTablePermission(args.login, args.user, args.table, args.perm)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'hasTablePermission', seqid)
+      end
+
+      def process_listLocalUsers(seqid, iprot, oprot)
+        args = read_args(iprot, ListLocalUsers_args)
+        result = ListLocalUsers_result.new()
+        begin
+          result.success = @handler.listLocalUsers(args.login)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'listLocalUsers', seqid)
+      end
+
+      def process_revokeSystemPermission(seqid, iprot, oprot)
+        args = read_args(iprot, RevokeSystemPermission_args)
+        result = RevokeSystemPermission_result.new()
+        begin
+          @handler.revokeSystemPermission(args.login, args.user, args.perm)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'revokeSystemPermission', seqid)
+      end
+
+      def process_revokeTablePermission(seqid, iprot, oprot)
+        args = read_args(iprot, RevokeTablePermission_args)
+        result = RevokeTablePermission_result.new()
+        begin
+          @handler.revokeTablePermission(args.login, args.user, args.table, args.perm)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'revokeTablePermission', seqid)
+      end
+
+      def process_createBatchScanner(seqid, iprot, oprot)
+        args = read_args(iprot, CreateBatchScanner_args)
+        result = CreateBatchScanner_result.new()
+        begin
+          result.success = @handler.createBatchScanner(args.login, args.tableName, args.options)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'createBatchScanner', seqid)
+      end
+
+      def process_createScanner(seqid, iprot, oprot)
+        args = read_args(iprot, CreateScanner_args)
+        result = CreateScanner_result.new()
+        begin
+          result.success = @handler.createScanner(args.login, args.tableName, args.options)
+        rescue ::Accumulo::AccumuloException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'createScanner', seqid)
+      end
+
+      def process_hasNext(seqid, iprot, oprot)
+        args = read_args(iprot, HasNext_args)
+        result = HasNext_result.new()
+        begin
+          result.success = @handler.hasNext(args.scanner)
+        rescue ::Accumulo::UnknownScanner => ouch1
+          result.ouch1 = ouch1
+        end
+        write_result(result, oprot, 'hasNext', seqid)
+      end
+
+      def process_nextEntry(seqid, iprot, oprot)
+        args = read_args(iprot, NextEntry_args)
+        result = NextEntry_result.new()
+        begin
+          result.success = @handler.nextEntry(args.scanner)
+        rescue ::Accumulo::NoMoreEntriesException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::UnknownScanner => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::AccumuloSecurityException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'nextEntry', seqid)
+      end
+
+      def process_nextK(seqid, iprot, oprot)
+        args = read_args(iprot, NextK_args)
+        result = NextK_result.new()
+        begin
+          result.success = @handler.nextK(args.scanner, args.k)
+        rescue ::Accumulo::NoMoreEntriesException => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::UnknownScanner => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::AccumuloSecurityException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'nextK', seqid)
+      end
+
+      def process_closeScanner(seqid, iprot, oprot)
+        args = read_args(iprot, CloseScanner_args)
+        result = CloseScanner_result.new()
+        begin
+          @handler.closeScanner(args.scanner)
+        rescue ::Accumulo::UnknownScanner => ouch1
+          result.ouch1 = ouch1
+        end
+        write_result(result, oprot, 'closeScanner', seqid)
+      end
+
+      def process_updateAndFlush(seqid, iprot, oprot)
+        args = read_args(iprot, UpdateAndFlush_args)
+        result = UpdateAndFlush_result.new()
+        begin
+          @handler.updateAndFlush(args.login, args.tableName, args.cells)
+        rescue ::Accumulo::AccumuloException => outch1
+          result.outch1 = outch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        rescue ::Accumulo::MutationsRejectedException => ouch4
+          result.ouch4 = ouch4
+        end
+        write_result(result, oprot, 'updateAndFlush', seqid)
+      end
+
+      def process_createWriter(seqid, iprot, oprot)
+        args = read_args(iprot, CreateWriter_args)
+        result = CreateWriter_result.new()
+        begin
+          result.success = @handler.createWriter(args.login, args.tableName, args.opts)
+        rescue ::Accumulo::AccumuloException => outch1
+          result.outch1 = outch1
+        rescue ::Accumulo::AccumuloSecurityException => ouch2
+          result.ouch2 = ouch2
+        rescue ::Accumulo::TableNotFoundException => ouch3
+          result.ouch3 = ouch3
+        end
+        write_result(result, oprot, 'createWriter', seqid)
+      end
+
+      def process_update(seqid, iprot, oprot)
+        args = read_args(iprot, Update_args)
+        @handler.update(args.writer, args.cells)
+        return
+      end
+
+      def process_flush(seqid, iprot, oprot)
+        args = read_args(iprot, Flush_args)
+        result = Flush_result.new()
+        begin
+          @handler.flush(args.writer)
+        rescue ::Accumulo::UnknownWriter => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::MutationsRejectedException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'flush', seqid)
+      end
+
+      def process_closeWriter(seqid, iprot, oprot)
+        args = read_args(iprot, CloseWriter_args)
+        result = CloseWriter_result.new()
+        begin
+          @handler.closeWriter(args.writer)
+        rescue ::Accumulo::UnknownWriter => ouch1
+          result.ouch1 = ouch1
+        rescue ::Accumulo::MutationsRejectedException => ouch2
+          result.ouch2 = ouch2
+        end
+        write_result(result, oprot, 'closeWriter', seqid)
+      end
+
+      def process_getRowRange(seqid, iprot, oprot)
+        args = read_args(iprot, GetRowRange_args)
+        result = GetRowRange_result.new()
+        result.success = @handler.getRowRange(args.row)
+        write_result(result, oprot, 'getRowRange', seqid)
+      end
+
+      def process_getFollowing(seqid, iprot, oprot)
+        args = read_args(iprot, GetFollowing_args)
+        result = GetFollowing_result.new()
+        result.success = @handler.getFollowing(args.key, args.part)
+        write_result(result, oprot, 'getFollowing', seqid)
+      end
+
+    end
+
+    # HELPER FUNCTIONS AND STRUCTURES
+
+    class Login_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      PRINCIPAL = 1
+      LOGINPROPERTIES = 2
+
+      FIELDS = {
+        PRINCIPAL => {:type => ::Thrift::Types::STRING, :name => 'principal'},
+       

<TRUNCATED>

Mime
View raw message