You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by vi...@apache.org on 2014/02/04 23:19:39 UTC
[02/17] ACCUMULO-2197 provide generated proxy libraries,
with modified generate-thrift script which tacks on headers
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>