incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [18/51] [partial] git commit: Changing default jvm version to 1.8. Removing hadoop profiles, will only support hadoop 2 from this point forward. Broke up the distribution project into 4 projects. Source, binary, parcel and csd. Also changed blur's ve
Date Sun, 27 Sep 2015 18:52:08 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/distribution/src/main/scripts/interface/gen-rb/blur.rb
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-rb/blur.rb b/distribution/src/main/scripts/interface/gen-rb/blur.rb
deleted file mode 100644
index 66677f0..0000000
--- a/distribution/src/main/scripts/interface/gen-rb/blur.rb
+++ /dev/null
@@ -1,3630 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.0)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-
-require 'thrift'
-require 'blur_types'
-
-module Blur
-  module Blur
-    class Client
-      include ::Thrift::Client
-
-      def listInstalledCommands()
-        send_listInstalledCommands()
-        return recv_listInstalledCommands()
-      end
-
-      def send_listInstalledCommands()
-        send_message('listInstalledCommands', ListInstalledCommands_args)
-      end
-
-      def recv_listInstalledCommands()
-        result = receive_message(ListInstalledCommands_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'listInstalledCommands failed: unknown result')
-      end
-
-      def execute(commandName, arguments)
-        send_execute(commandName, arguments)
-        return recv_execute()
-      end
-
-      def send_execute(commandName, arguments)
-        send_message('execute', Execute_args, :commandName => commandName, :arguments => arguments)
-      end
-
-      def recv_execute()
-        result = receive_message(Execute_result)
-        return result.success unless result.success.nil?
-        raise result.bex unless result.bex.nil?
-        raise result.tex unless result.tex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'execute failed: unknown result')
-      end
-
-      def reconnect(instanceExecutionId)
-        send_reconnect(instanceExecutionId)
-        return recv_reconnect()
-      end
-
-      def send_reconnect(instanceExecutionId)
-        send_message('reconnect', Reconnect_args, :instanceExecutionId => instanceExecutionId)
-      end
-
-      def recv_reconnect()
-        result = receive_message(Reconnect_result)
-        return result.success unless result.success.nil?
-        raise result.bex unless result.bex.nil?
-        raise result.tex unless result.tex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'reconnect failed: unknown result')
-      end
-
-      def commandStatusList(startingAt, fetch, state)
-        send_commandStatusList(startingAt, fetch, state)
-        return recv_commandStatusList()
-      end
-
-      def send_commandStatusList(startingAt, fetch, state)
-        send_message('commandStatusList', CommandStatusList_args, :startingAt => startingAt, :fetch => fetch, :state => state)
-      end
-
-      def recv_commandStatusList()
-        result = receive_message(CommandStatusList_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'commandStatusList failed: unknown result')
-      end
-
-      def commandStatus(commandExecutionId)
-        send_commandStatus(commandExecutionId)
-        return recv_commandStatus()
-      end
-
-      def send_commandStatus(commandExecutionId)
-        send_message('commandStatus', CommandStatus_args, :commandExecutionId => commandExecutionId)
-      end
-
-      def recv_commandStatus()
-        result = receive_message(CommandStatus_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'commandStatus failed: unknown result')
-      end
-
-      def commandCancel(commandExecutionId)
-        send_commandCancel(commandExecutionId)
-        recv_commandCancel()
-      end
-
-      def send_commandCancel(commandExecutionId)
-        send_message('commandCancel', CommandCancel_args, :commandExecutionId => commandExecutionId)
-      end
-
-      def recv_commandCancel()
-        result = receive_message(CommandCancel_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def refresh()
-        send_refresh()
-      end
-
-      def send_refresh()
-        send_message('refresh', Refresh_args)
-      end
-      def createTable(tableDescriptor)
-        send_createTable(tableDescriptor)
-        recv_createTable()
-      end
-
-      def send_createTable(tableDescriptor)
-        send_message('createTable', CreateTable_args, :tableDescriptor => tableDescriptor)
-      end
-
-      def recv_createTable()
-        result = receive_message(CreateTable_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def enableTable(table)
-        send_enableTable(table)
-        recv_enableTable()
-      end
-
-      def send_enableTable(table)
-        send_message('enableTable', EnableTable_args, :table => table)
-      end
-
-      def recv_enableTable()
-        result = receive_message(EnableTable_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def disableTable(table)
-        send_disableTable(table)
-        recv_disableTable()
-      end
-
-      def send_disableTable(table)
-        send_message('disableTable', DisableTable_args, :table => table)
-      end
-
-      def recv_disableTable()
-        result = receive_message(DisableTable_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def removeTable(table, deleteIndexFiles)
-        send_removeTable(table, deleteIndexFiles)
-        recv_removeTable()
-      end
-
-      def send_removeTable(table, deleteIndexFiles)
-        send_message('removeTable', RemoveTable_args, :table => table, :deleteIndexFiles => deleteIndexFiles)
-      end
-
-      def recv_removeTable()
-        result = receive_message(RemoveTable_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def addColumnDefinition(table, columnDefinition)
-        send_addColumnDefinition(table, columnDefinition)
-        return recv_addColumnDefinition()
-      end
-
-      def send_addColumnDefinition(table, columnDefinition)
-        send_message('addColumnDefinition', AddColumnDefinition_args, :table => table, :columnDefinition => columnDefinition)
-      end
-
-      def recv_addColumnDefinition()
-        result = receive_message(AddColumnDefinition_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'addColumnDefinition failed: unknown result')
-      end
-
-      def tableList()
-        send_tableList()
-        return recv_tableList()
-      end
-
-      def send_tableList()
-        send_message('tableList', TableList_args)
-      end
-
-      def recv_tableList()
-        result = receive_message(TableList_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'tableList failed: unknown result')
-      end
-
-      def tableListByCluster(cluster)
-        send_tableListByCluster(cluster)
-        return recv_tableListByCluster()
-      end
-
-      def send_tableListByCluster(cluster)
-        send_message('tableListByCluster', TableListByCluster_args, :cluster => cluster)
-      end
-
-      def recv_tableListByCluster()
-        result = receive_message(TableListByCluster_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'tableListByCluster failed: unknown result')
-      end
-
-      def describe(table)
-        send_describe(table)
-        return recv_describe()
-      end
-
-      def send_describe(table)
-        send_message('describe', Describe_args, :table => table)
-      end
-
-      def recv_describe()
-        result = receive_message(Describe_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'describe failed: unknown result')
-      end
-
-      def schema(table)
-        send_schema(table)
-        return recv_schema()
-      end
-
-      def send_schema(table)
-        send_message('schema', Schema_args, :table => table)
-      end
-
-      def recv_schema()
-        result = receive_message(Schema_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'schema failed: unknown result')
-      end
-
-      def parseQuery(table, query)
-        send_parseQuery(table, query)
-        return recv_parseQuery()
-      end
-
-      def send_parseQuery(table, query)
-        send_message('parseQuery', ParseQuery_args, :table => table, :query => query)
-      end
-
-      def recv_parseQuery()
-        result = receive_message(ParseQuery_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'parseQuery failed: unknown result')
-      end
-
-      def tableStats(table)
-        send_tableStats(table)
-        return recv_tableStats()
-      end
-
-      def send_tableStats(table)
-        send_message('tableStats', TableStats_args, :table => table)
-      end
-
-      def recv_tableStats()
-        result = receive_message(TableStats_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'tableStats failed: unknown result')
-      end
-
-      def optimize(table, numberOfSegmentsPerShard)
-        send_optimize(table, numberOfSegmentsPerShard)
-        recv_optimize()
-      end
-
-      def send_optimize(table, numberOfSegmentsPerShard)
-        send_message('optimize', Optimize_args, :table => table, :numberOfSegmentsPerShard => numberOfSegmentsPerShard)
-      end
-
-      def recv_optimize()
-        result = receive_message(Optimize_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def createSnapshot(table, name)
-        send_createSnapshot(table, name)
-        recv_createSnapshot()
-      end
-
-      def send_createSnapshot(table, name)
-        send_message('createSnapshot', CreateSnapshot_args, :table => table, :name => name)
-      end
-
-      def recv_createSnapshot()
-        result = receive_message(CreateSnapshot_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def removeSnapshot(table, name)
-        send_removeSnapshot(table, name)
-        recv_removeSnapshot()
-      end
-
-      def send_removeSnapshot(table, name)
-        send_message('removeSnapshot', RemoveSnapshot_args, :table => table, :name => name)
-      end
-
-      def recv_removeSnapshot()
-        result = receive_message(RemoveSnapshot_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def listSnapshots(table)
-        send_listSnapshots(table)
-        return recv_listSnapshots()
-      end
-
-      def send_listSnapshots(table)
-        send_message('listSnapshots', ListSnapshots_args, :table => table)
-      end
-
-      def recv_listSnapshots()
-        result = receive_message(ListSnapshots_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'listSnapshots failed: unknown result')
-      end
-
-      def setUser(user)
-        send_setUser(user)
-      end
-
-      def send_setUser(user)
-        send_message('setUser', SetUser_args, :user => user)
-      end
-      def query(table, blurQuery)
-        send_query(table, blurQuery)
-        return recv_query()
-      end
-
-      def send_query(table, blurQuery)
-        send_message('query', Query_args, :table => table, :blurQuery => blurQuery)
-      end
-
-      def recv_query()
-        result = receive_message(Query_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'query failed: unknown result')
-      end
-
-      def fetchRow(table, selector)
-        send_fetchRow(table, selector)
-        return recv_fetchRow()
-      end
-
-      def send_fetchRow(table, selector)
-        send_message('fetchRow', FetchRow_args, :table => table, :selector => selector)
-      end
-
-      def recv_fetchRow()
-        result = receive_message(FetchRow_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'fetchRow failed: unknown result')
-      end
-
-      def fetchRowBatch(table, selectors)
-        send_fetchRowBatch(table, selectors)
-        return recv_fetchRowBatch()
-      end
-
-      def send_fetchRowBatch(table, selectors)
-        send_message('fetchRowBatch', FetchRowBatch_args, :table => table, :selectors => selectors)
-      end
-
-      def recv_fetchRowBatch()
-        result = receive_message(FetchRowBatch_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'fetchRowBatch failed: unknown result')
-      end
-
-      def loadData(table, location)
-        send_loadData(table, location)
-        recv_loadData()
-      end
-
-      def send_loadData(table, location)
-        send_message('loadData', LoadData_args, :table => table, :location => location)
-      end
-
-      def recv_loadData()
-        result = receive_message(LoadData_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def validateIndex(table, externalIndexPaths)
-        send_validateIndex(table, externalIndexPaths)
-        recv_validateIndex()
-      end
-
-      def send_validateIndex(table, externalIndexPaths)
-        send_message('validateIndex', ValidateIndex_args, :table => table, :externalIndexPaths => externalIndexPaths)
-      end
-
-      def recv_validateIndex()
-        result = receive_message(ValidateIndex_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def loadIndex(table, externalIndexPaths)
-        send_loadIndex(table, externalIndexPaths)
-        recv_loadIndex()
-      end
-
-      def send_loadIndex(table, externalIndexPaths)
-        send_message('loadIndex', LoadIndex_args, :table => table, :externalIndexPaths => externalIndexPaths)
-      end
-
-      def recv_loadIndex()
-        result = receive_message(LoadIndex_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def mutate(mutation)
-        send_mutate(mutation)
-        recv_mutate()
-      end
-
-      def send_mutate(mutation)
-        send_message('mutate', Mutate_args, :mutation => mutation)
-      end
-
-      def recv_mutate()
-        result = receive_message(Mutate_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def enqueueMutate(mutation)
-        send_enqueueMutate(mutation)
-        recv_enqueueMutate()
-      end
-
-      def send_enqueueMutate(mutation)
-        send_message('enqueueMutate', EnqueueMutate_args, :mutation => mutation)
-      end
-
-      def recv_enqueueMutate()
-        result = receive_message(EnqueueMutate_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def mutateBatch(mutations)
-        send_mutateBatch(mutations)
-        recv_mutateBatch()
-      end
-
-      def send_mutateBatch(mutations)
-        send_message('mutateBatch', MutateBatch_args, :mutations => mutations)
-      end
-
-      def recv_mutateBatch()
-        result = receive_message(MutateBatch_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def enqueueMutateBatch(mutations)
-        send_enqueueMutateBatch(mutations)
-        recv_enqueueMutateBatch()
-      end
-
-      def send_enqueueMutateBatch(mutations)
-        send_message('enqueueMutateBatch', EnqueueMutateBatch_args, :mutations => mutations)
-      end
-
-      def recv_enqueueMutateBatch()
-        result = receive_message(EnqueueMutateBatch_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def bulkMutateStart(bulkId)
-        send_bulkMutateStart(bulkId)
-        recv_bulkMutateStart()
-      end
-
-      def send_bulkMutateStart(bulkId)
-        send_message('bulkMutateStart', BulkMutateStart_args, :bulkId => bulkId)
-      end
-
-      def recv_bulkMutateStart()
-        result = receive_message(BulkMutateStart_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def bulkMutateAdd(bulkId, rowMutation)
-        send_bulkMutateAdd(bulkId, rowMutation)
-        recv_bulkMutateAdd()
-      end
-
-      def send_bulkMutateAdd(bulkId, rowMutation)
-        send_message('bulkMutateAdd', BulkMutateAdd_args, :bulkId => bulkId, :rowMutation => rowMutation)
-      end
-
-      def recv_bulkMutateAdd()
-        result = receive_message(BulkMutateAdd_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def bulkMutateAddMultiple(bulkId, rowMutations)
-        send_bulkMutateAddMultiple(bulkId, rowMutations)
-        recv_bulkMutateAddMultiple()
-      end
-
-      def send_bulkMutateAddMultiple(bulkId, rowMutations)
-        send_message('bulkMutateAddMultiple', BulkMutateAddMultiple_args, :bulkId => bulkId, :rowMutations => rowMutations)
-      end
-
-      def recv_bulkMutateAddMultiple()
-        result = receive_message(BulkMutateAddMultiple_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def bulkMutateFinish(bulkId, apply, blockUntilComplete)
-        send_bulkMutateFinish(bulkId, apply, blockUntilComplete)
-        recv_bulkMutateFinish()
-      end
-
-      def send_bulkMutateFinish(bulkId, apply, blockUntilComplete)
-        send_message('bulkMutateFinish', BulkMutateFinish_args, :bulkId => bulkId, :apply => apply, :blockUntilComplete => blockUntilComplete)
-      end
-
-      def recv_bulkMutateFinish()
-        result = receive_message(BulkMutateFinish_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def cancelQuery(table, uuid)
-        send_cancelQuery(table, uuid)
-        recv_cancelQuery()
-      end
-
-      def send_cancelQuery(table, uuid)
-        send_message('cancelQuery', CancelQuery_args, :table => table, :uuid => uuid)
-      end
-
-      def recv_cancelQuery()
-        result = receive_message(CancelQuery_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def queryStatusIdList(table)
-        send_queryStatusIdList(table)
-        return recv_queryStatusIdList()
-      end
-
-      def send_queryStatusIdList(table)
-        send_message('queryStatusIdList', QueryStatusIdList_args, :table => table)
-      end
-
-      def recv_queryStatusIdList()
-        result = receive_message(QueryStatusIdList_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'queryStatusIdList failed: unknown result')
-      end
-
-      def queryStatusById(table, uuid)
-        send_queryStatusById(table, uuid)
-        return recv_queryStatusById()
-      end
-
-      def send_queryStatusById(table, uuid)
-        send_message('queryStatusById', QueryStatusById_args, :table => table, :uuid => uuid)
-      end
-
-      def recv_queryStatusById()
-        result = receive_message(QueryStatusById_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'queryStatusById failed: unknown result')
-      end
-
-      def terms(table, columnFamily, columnName, startWith, size)
-        send_terms(table, columnFamily, columnName, startWith, size)
-        return recv_terms()
-      end
-
-      def send_terms(table, columnFamily, columnName, startWith, size)
-        send_message('terms', Terms_args, :table => table, :columnFamily => columnFamily, :columnName => columnName, :startWith => startWith, :size => size)
-      end
-
-      def recv_terms()
-        result = receive_message(Terms_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'terms failed: unknown result')
-      end
-
-      def recordFrequency(table, columnFamily, columnName, value)
-        send_recordFrequency(table, columnFamily, columnName, value)
-        return recv_recordFrequency()
-      end
-
-      def send_recordFrequency(table, columnFamily, columnName, value)
-        send_message('recordFrequency', RecordFrequency_args, :table => table, :columnFamily => columnFamily, :columnName => columnName, :value => value)
-      end
-
-      def recv_recordFrequency()
-        result = receive_message(RecordFrequency_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'recordFrequency failed: unknown result')
-      end
-
-      def shardClusterList()
-        send_shardClusterList()
-        return recv_shardClusterList()
-      end
-
-      def send_shardClusterList()
-        send_message('shardClusterList', ShardClusterList_args)
-      end
-
-      def recv_shardClusterList()
-        result = receive_message(ShardClusterList_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'shardClusterList failed: unknown result')
-      end
-
-      def shardServerList(cluster)
-        send_shardServerList(cluster)
-        return recv_shardServerList()
-      end
-
-      def send_shardServerList(cluster)
-        send_message('shardServerList', ShardServerList_args, :cluster => cluster)
-      end
-
-      def recv_shardServerList()
-        result = receive_message(ShardServerList_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'shardServerList failed: unknown result')
-      end
-
-      def controllerServerList()
-        send_controllerServerList()
-        return recv_controllerServerList()
-      end
-
-      def send_controllerServerList()
-        send_message('controllerServerList', ControllerServerList_args)
-      end
-
-      def recv_controllerServerList()
-        result = receive_message(ControllerServerList_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'controllerServerList failed: unknown result')
-      end
-
-      def shardServerLayout(table)
-        send_shardServerLayout(table)
-        return recv_shardServerLayout()
-      end
-
-      def send_shardServerLayout(table)
-        send_message('shardServerLayout', ShardServerLayout_args, :table => table)
-      end
-
-      def recv_shardServerLayout()
-        result = receive_message(ShardServerLayout_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'shardServerLayout failed: unknown result')
-      end
-
-      def shardServerLayoutState(table)
-        send_shardServerLayoutState(table)
-        return recv_shardServerLayoutState()
-      end
-
-      def send_shardServerLayoutState(table)
-        send_message('shardServerLayoutState', ShardServerLayoutState_args, :table => table)
-      end
-
-      def recv_shardServerLayoutState()
-        result = receive_message(ShardServerLayoutState_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'shardServerLayoutState failed: unknown result')
-      end
-
-      def isInSafeMode(cluster)
-        send_isInSafeMode(cluster)
-        return recv_isInSafeMode()
-      end
-
-      def send_isInSafeMode(cluster)
-        send_message('isInSafeMode', IsInSafeMode_args, :cluster => cluster)
-      end
-
-      def recv_isInSafeMode()
-        result = receive_message(IsInSafeMode_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'isInSafeMode failed: unknown result')
-      end
-
-      def configuration()
-        send_configuration()
-        return recv_configuration()
-      end
-
-      def send_configuration()
-        send_message('configuration', Configuration_args)
-      end
-
-      def recv_configuration()
-        result = receive_message(Configuration_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'configuration failed: unknown result')
-      end
-
-      def configurationPerServer(thriftServerPlusPort, configName)
-        send_configurationPerServer(thriftServerPlusPort, configName)
-        return recv_configurationPerServer()
-      end
-
-      def send_configurationPerServer(thriftServerPlusPort, configName)
-        send_message('configurationPerServer', ConfigurationPerServer_args, :thriftServerPlusPort => thriftServerPlusPort, :configName => configName)
-      end
-
-      def recv_configurationPerServer()
-        result = receive_message(ConfigurationPerServer_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'configurationPerServer failed: unknown result')
-      end
-
-      def metrics(metrics)
-        send_metrics(metrics)
-        return recv_metrics()
-      end
-
-      def send_metrics(metrics)
-        send_message('metrics', Metrics_args, :metrics => metrics)
-      end
-
-      def recv_metrics()
-        result = receive_message(Metrics_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'metrics failed: unknown result')
-      end
-
-      def startTrace(traceId, requestId)
-        send_startTrace(traceId, requestId)
-      end
-
-      def send_startTrace(traceId, requestId)
-        send_message('startTrace', StartTrace_args, :traceId => traceId, :requestId => requestId)
-      end
-      def traceList()
-        send_traceList()
-        return recv_traceList()
-      end
-
-      def send_traceList()
-        send_message('traceList', TraceList_args)
-      end
-
-      def recv_traceList()
-        result = receive_message(TraceList_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'traceList failed: unknown result')
-      end
-
-      def traceRequestList(traceId)
-        send_traceRequestList(traceId)
-        return recv_traceRequestList()
-      end
-
-      def send_traceRequestList(traceId)
-        send_message('traceRequestList', TraceRequestList_args, :traceId => traceId)
-      end
-
-      def recv_traceRequestList()
-        result = receive_message(TraceRequestList_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'traceRequestList failed: unknown result')
-      end
-
-      def traceRequestFetch(traceId, requestId)
-        send_traceRequestFetch(traceId, requestId)
-        return recv_traceRequestFetch()
-      end
-
-      def send_traceRequestFetch(traceId, requestId)
-        send_message('traceRequestFetch', TraceRequestFetch_args, :traceId => traceId, :requestId => requestId)
-      end
-
-      def recv_traceRequestFetch()
-        result = receive_message(TraceRequestFetch_result)
-        return result.success unless result.success.nil?
-        raise result.ex unless result.ex.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'traceRequestFetch failed: unknown result')
-      end
-
-      def traceRemove(traceId)
-        send_traceRemove(traceId)
-        recv_traceRemove()
-      end
-
-      def send_traceRemove(traceId)
-        send_message('traceRemove', TraceRemove_args, :traceId => traceId)
-      end
-
-      def recv_traceRemove()
-        result = receive_message(TraceRemove_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def ping()
-        send_ping()
-        recv_ping()
-      end
-
-      def send_ping()
-        send_message('ping', Ping_args)
-      end
-
-      def recv_ping()
-        result = receive_message(Ping_result)
-        return
-      end
-
-      def logging(classNameOrLoggerName, level)
-        send_logging(classNameOrLoggerName, level)
-        recv_logging()
-      end
-
-      def send_logging(classNameOrLoggerName, level)
-        send_message('logging', Logging_args, :classNameOrLoggerName => classNameOrLoggerName, :level => level)
-      end
-
-      def recv_logging()
-        result = receive_message(Logging_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-      def resetLogging()
-        send_resetLogging()
-        recv_resetLogging()
-      end
-
-      def send_resetLogging()
-        send_message('resetLogging', ResetLogging_args)
-      end
-
-      def recv_resetLogging()
-        result = receive_message(ResetLogging_result)
-        raise result.ex unless result.ex.nil?
-        return
-      end
-
-    end
-
-    class Processor
-      include ::Thrift::Processor
-
-      def process_listInstalledCommands(seqid, iprot, oprot)
-        args = read_args(iprot, ListInstalledCommands_args)
-        result = ListInstalledCommands_result.new()
-        begin
-          result.success = @handler.listInstalledCommands()
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'listInstalledCommands', seqid)
-      end
-
-      def process_execute(seqid, iprot, oprot)
-        args = read_args(iprot, Execute_args)
-        result = Execute_result.new()
-        begin
-          result.success = @handler.execute(args.commandName, args.arguments)
-        rescue ::Blur::BlurException => bex
-          result.bex = bex
-        rescue ::Blur::TimeoutException => tex
-          result.tex = tex
-        end
-        write_result(result, oprot, 'execute', seqid)
-      end
-
-      def process_reconnect(seqid, iprot, oprot)
-        args = read_args(iprot, Reconnect_args)
-        result = Reconnect_result.new()
-        begin
-          result.success = @handler.reconnect(args.instanceExecutionId)
-        rescue ::Blur::BlurException => bex
-          result.bex = bex
-        rescue ::Blur::TimeoutException => tex
-          result.tex = tex
-        end
-        write_result(result, oprot, 'reconnect', seqid)
-      end
-
-      def process_commandStatusList(seqid, iprot, oprot)
-        args = read_args(iprot, CommandStatusList_args)
-        result = CommandStatusList_result.new()
-        begin
-          result.success = @handler.commandStatusList(args.startingAt, args.fetch, args.state)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'commandStatusList', seqid)
-      end
-
-      def process_commandStatus(seqid, iprot, oprot)
-        args = read_args(iprot, CommandStatus_args)
-        result = CommandStatus_result.new()
-        begin
-          result.success = @handler.commandStatus(args.commandExecutionId)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'commandStatus', seqid)
-      end
-
-      def process_commandCancel(seqid, iprot, oprot)
-        args = read_args(iprot, CommandCancel_args)
-        result = CommandCancel_result.new()
-        begin
-          @handler.commandCancel(args.commandExecutionId)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'commandCancel', seqid)
-      end
-
-      def process_refresh(seqid, iprot, oprot)
-        args = read_args(iprot, Refresh_args)
-        @handler.refresh()
-        return
-      end
-
-      def process_createTable(seqid, iprot, oprot)
-        args = read_args(iprot, CreateTable_args)
-        result = CreateTable_result.new()
-        begin
-          @handler.createTable(args.tableDescriptor)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'createTable', seqid)
-      end
-
-      def process_enableTable(seqid, iprot, oprot)
-        args = read_args(iprot, EnableTable_args)
-        result = EnableTable_result.new()
-        begin
-          @handler.enableTable(args.table)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'enableTable', seqid)
-      end
-
-      def process_disableTable(seqid, iprot, oprot)
-        args = read_args(iprot, DisableTable_args)
-        result = DisableTable_result.new()
-        begin
-          @handler.disableTable(args.table)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'disableTable', seqid)
-      end
-
-      def process_removeTable(seqid, iprot, oprot)
-        args = read_args(iprot, RemoveTable_args)
-        result = RemoveTable_result.new()
-        begin
-          @handler.removeTable(args.table, args.deleteIndexFiles)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'removeTable', seqid)
-      end
-
-      def process_addColumnDefinition(seqid, iprot, oprot)
-        args = read_args(iprot, AddColumnDefinition_args)
-        result = AddColumnDefinition_result.new()
-        begin
-          result.success = @handler.addColumnDefinition(args.table, args.columnDefinition)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'addColumnDefinition', seqid)
-      end
-
-      def process_tableList(seqid, iprot, oprot)
-        args = read_args(iprot, TableList_args)
-        result = TableList_result.new()
-        begin
-          result.success = @handler.tableList()
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'tableList', seqid)
-      end
-
-      def process_tableListByCluster(seqid, iprot, oprot)
-        args = read_args(iprot, TableListByCluster_args)
-        result = TableListByCluster_result.new()
-        begin
-          result.success = @handler.tableListByCluster(args.cluster)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'tableListByCluster', seqid)
-      end
-
-      def process_describe(seqid, iprot, oprot)
-        args = read_args(iprot, Describe_args)
-        result = Describe_result.new()
-        begin
-          result.success = @handler.describe(args.table)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'describe', seqid)
-      end
-
-      def process_schema(seqid, iprot, oprot)
-        args = read_args(iprot, Schema_args)
-        result = Schema_result.new()
-        begin
-          result.success = @handler.schema(args.table)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'schema', seqid)
-      end
-
-      def process_parseQuery(seqid, iprot, oprot)
-        args = read_args(iprot, ParseQuery_args)
-        result = ParseQuery_result.new()
-        begin
-          result.success = @handler.parseQuery(args.table, args.query)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'parseQuery', seqid)
-      end
-
-      def process_tableStats(seqid, iprot, oprot)
-        args = read_args(iprot, TableStats_args)
-        result = TableStats_result.new()
-        begin
-          result.success = @handler.tableStats(args.table)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'tableStats', seqid)
-      end
-
-      def process_optimize(seqid, iprot, oprot)
-        args = read_args(iprot, Optimize_args)
-        result = Optimize_result.new()
-        begin
-          @handler.optimize(args.table, args.numberOfSegmentsPerShard)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'optimize', seqid)
-      end
-
-      def process_createSnapshot(seqid, iprot, oprot)
-        args = read_args(iprot, CreateSnapshot_args)
-        result = CreateSnapshot_result.new()
-        begin
-          @handler.createSnapshot(args.table, args.name)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'createSnapshot', seqid)
-      end
-
-      def process_removeSnapshot(seqid, iprot, oprot)
-        args = read_args(iprot, RemoveSnapshot_args)
-        result = RemoveSnapshot_result.new()
-        begin
-          @handler.removeSnapshot(args.table, args.name)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'removeSnapshot', seqid)
-      end
-
-      def process_listSnapshots(seqid, iprot, oprot)
-        args = read_args(iprot, ListSnapshots_args)
-        result = ListSnapshots_result.new()
-        begin
-          result.success = @handler.listSnapshots(args.table)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'listSnapshots', seqid)
-      end
-
-      def process_setUser(seqid, iprot, oprot)
-        args = read_args(iprot, SetUser_args)
-        @handler.setUser(args.user)
-        return
-      end
-
-      def process_query(seqid, iprot, oprot)
-        args = read_args(iprot, Query_args)
-        result = Query_result.new()
-        begin
-          result.success = @handler.query(args.table, args.blurQuery)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'query', seqid)
-      end
-
-      def process_fetchRow(seqid, iprot, oprot)
-        args = read_args(iprot, FetchRow_args)
-        result = FetchRow_result.new()
-        begin
-          result.success = @handler.fetchRow(args.table, args.selector)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'fetchRow', seqid)
-      end
-
-      def process_fetchRowBatch(seqid, iprot, oprot)
-        args = read_args(iprot, FetchRowBatch_args)
-        result = FetchRowBatch_result.new()
-        begin
-          result.success = @handler.fetchRowBatch(args.table, args.selectors)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'fetchRowBatch', seqid)
-      end
-
-      def process_loadData(seqid, iprot, oprot)
-        args = read_args(iprot, LoadData_args)
-        result = LoadData_result.new()
-        begin
-          @handler.loadData(args.table, args.location)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'loadData', seqid)
-      end
-
-      def process_validateIndex(seqid, iprot, oprot)
-        args = read_args(iprot, ValidateIndex_args)
-        result = ValidateIndex_result.new()
-        begin
-          @handler.validateIndex(args.table, args.externalIndexPaths)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'validateIndex', seqid)
-      end
-
-      def process_loadIndex(seqid, iprot, oprot)
-        args = read_args(iprot, LoadIndex_args)
-        result = LoadIndex_result.new()
-        begin
-          @handler.loadIndex(args.table, args.externalIndexPaths)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'loadIndex', seqid)
-      end
-
-      def process_mutate(seqid, iprot, oprot)
-        args = read_args(iprot, Mutate_args)
-        result = Mutate_result.new()
-        begin
-          @handler.mutate(args.mutation)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'mutate', seqid)
-      end
-
-      def process_enqueueMutate(seqid, iprot, oprot)
-        args = read_args(iprot, EnqueueMutate_args)
-        result = EnqueueMutate_result.new()
-        begin
-          @handler.enqueueMutate(args.mutation)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'enqueueMutate', seqid)
-      end
-
-      def process_mutateBatch(seqid, iprot, oprot)
-        args = read_args(iprot, MutateBatch_args)
-        result = MutateBatch_result.new()
-        begin
-          @handler.mutateBatch(args.mutations)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'mutateBatch', seqid)
-      end
-
-      def process_enqueueMutateBatch(seqid, iprot, oprot)
-        args = read_args(iprot, EnqueueMutateBatch_args)
-        result = EnqueueMutateBatch_result.new()
-        begin
-          @handler.enqueueMutateBatch(args.mutations)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'enqueueMutateBatch', seqid)
-      end
-
-      def process_bulkMutateStart(seqid, iprot, oprot)
-        args = read_args(iprot, BulkMutateStart_args)
-        result = BulkMutateStart_result.new()
-        begin
-          @handler.bulkMutateStart(args.bulkId)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'bulkMutateStart', seqid)
-      end
-
-      def process_bulkMutateAdd(seqid, iprot, oprot)
-        args = read_args(iprot, BulkMutateAdd_args)
-        result = BulkMutateAdd_result.new()
-        begin
-          @handler.bulkMutateAdd(args.bulkId, args.rowMutation)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'bulkMutateAdd', seqid)
-      end
-
-      def process_bulkMutateAddMultiple(seqid, iprot, oprot)
-        args = read_args(iprot, BulkMutateAddMultiple_args)
-        result = BulkMutateAddMultiple_result.new()
-        begin
-          @handler.bulkMutateAddMultiple(args.bulkId, args.rowMutations)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'bulkMutateAddMultiple', seqid)
-      end
-
-      def process_bulkMutateFinish(seqid, iprot, oprot)
-        args = read_args(iprot, BulkMutateFinish_args)
-        result = BulkMutateFinish_result.new()
-        begin
-          @handler.bulkMutateFinish(args.bulkId, args.apply, args.blockUntilComplete)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'bulkMutateFinish', seqid)
-      end
-
-      def process_cancelQuery(seqid, iprot, oprot)
-        args = read_args(iprot, CancelQuery_args)
-        result = CancelQuery_result.new()
-        begin
-          @handler.cancelQuery(args.table, args.uuid)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'cancelQuery', seqid)
-      end
-
-      def process_queryStatusIdList(seqid, iprot, oprot)
-        args = read_args(iprot, QueryStatusIdList_args)
-        result = QueryStatusIdList_result.new()
-        begin
-          result.success = @handler.queryStatusIdList(args.table)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'queryStatusIdList', seqid)
-      end
-
-      def process_queryStatusById(seqid, iprot, oprot)
-        args = read_args(iprot, QueryStatusById_args)
-        result = QueryStatusById_result.new()
-        begin
-          result.success = @handler.queryStatusById(args.table, args.uuid)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'queryStatusById', seqid)
-      end
-
-      def process_terms(seqid, iprot, oprot)
-        args = read_args(iprot, Terms_args)
-        result = Terms_result.new()
-        begin
-          result.success = @handler.terms(args.table, args.columnFamily, args.columnName, args.startWith, args.size)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'terms', seqid)
-      end
-
-      def process_recordFrequency(seqid, iprot, oprot)
-        args = read_args(iprot, RecordFrequency_args)
-        result = RecordFrequency_result.new()
-        begin
-          result.success = @handler.recordFrequency(args.table, args.columnFamily, args.columnName, args.value)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'recordFrequency', seqid)
-      end
-
-      def process_shardClusterList(seqid, iprot, oprot)
-        args = read_args(iprot, ShardClusterList_args)
-        result = ShardClusterList_result.new()
-        begin
-          result.success = @handler.shardClusterList()
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'shardClusterList', seqid)
-      end
-
-      def process_shardServerList(seqid, iprot, oprot)
-        args = read_args(iprot, ShardServerList_args)
-        result = ShardServerList_result.new()
-        begin
-          result.success = @handler.shardServerList(args.cluster)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'shardServerList', seqid)
-      end
-
-      def process_controllerServerList(seqid, iprot, oprot)
-        args = read_args(iprot, ControllerServerList_args)
-        result = ControllerServerList_result.new()
-        begin
-          result.success = @handler.controllerServerList()
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'controllerServerList', seqid)
-      end
-
-      def process_shardServerLayout(seqid, iprot, oprot)
-        args = read_args(iprot, ShardServerLayout_args)
-        result = ShardServerLayout_result.new()
-        begin
-          result.success = @handler.shardServerLayout(args.table)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'shardServerLayout', seqid)
-      end
-
-      def process_shardServerLayoutState(seqid, iprot, oprot)
-        args = read_args(iprot, ShardServerLayoutState_args)
-        result = ShardServerLayoutState_result.new()
-        begin
-          result.success = @handler.shardServerLayoutState(args.table)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'shardServerLayoutState', seqid)
-      end
-
-      def process_isInSafeMode(seqid, iprot, oprot)
-        args = read_args(iprot, IsInSafeMode_args)
-        result = IsInSafeMode_result.new()
-        begin
-          result.success = @handler.isInSafeMode(args.cluster)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'isInSafeMode', seqid)
-      end
-
-      def process_configuration(seqid, iprot, oprot)
-        args = read_args(iprot, Configuration_args)
-        result = Configuration_result.new()
-        begin
-          result.success = @handler.configuration()
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'configuration', seqid)
-      end
-
-      def process_configurationPerServer(seqid, iprot, oprot)
-        args = read_args(iprot, ConfigurationPerServer_args)
-        result = ConfigurationPerServer_result.new()
-        begin
-          result.success = @handler.configurationPerServer(args.thriftServerPlusPort, args.configName)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'configurationPerServer', seqid)
-      end
-
-      def process_metrics(seqid, iprot, oprot)
-        args = read_args(iprot, Metrics_args)
-        result = Metrics_result.new()
-        begin
-          result.success = @handler.metrics(args.metrics)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'metrics', seqid)
-      end
-
-      def process_startTrace(seqid, iprot, oprot)
-        args = read_args(iprot, StartTrace_args)
-        @handler.startTrace(args.traceId, args.requestId)
-        return
-      end
-
-      def process_traceList(seqid, iprot, oprot)
-        args = read_args(iprot, TraceList_args)
-        result = TraceList_result.new()
-        begin
-          result.success = @handler.traceList()
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'traceList', seqid)
-      end
-
-      def process_traceRequestList(seqid, iprot, oprot)
-        args = read_args(iprot, TraceRequestList_args)
-        result = TraceRequestList_result.new()
-        begin
-          result.success = @handler.traceRequestList(args.traceId)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'traceRequestList', seqid)
-      end
-
-      def process_traceRequestFetch(seqid, iprot, oprot)
-        args = read_args(iprot, TraceRequestFetch_args)
-        result = TraceRequestFetch_result.new()
-        begin
-          result.success = @handler.traceRequestFetch(args.traceId, args.requestId)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'traceRequestFetch', seqid)
-      end
-
-      def process_traceRemove(seqid, iprot, oprot)
-        args = read_args(iprot, TraceRemove_args)
-        result = TraceRemove_result.new()
-        begin
-          @handler.traceRemove(args.traceId)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'traceRemove', seqid)
-      end
-
-      def process_ping(seqid, iprot, oprot)
-        args = read_args(iprot, Ping_args)
-        result = Ping_result.new()
-        @handler.ping()
-        write_result(result, oprot, 'ping', seqid)
-      end
-
-      def process_logging(seqid, iprot, oprot)
-        args = read_args(iprot, Logging_args)
-        result = Logging_result.new()
-        begin
-          @handler.logging(args.classNameOrLoggerName, args.level)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'logging', seqid)
-      end
-
-      def process_resetLogging(seqid, iprot, oprot)
-        args = read_args(iprot, ResetLogging_args)
-        result = ResetLogging_result.new()
-        begin
-          @handler.resetLogging()
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
-        end
-        write_result(result, oprot, 'resetLogging', seqid)
-      end
-
-    end
-
-    # HELPER FUNCTIONS AND STRUCTURES
-
-    class ListInstalledCommands_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-
-      FIELDS = {
-
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class ListInstalledCommands_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::CommandDescriptor}},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Execute_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      COMMANDNAME = 1
-      ARGUMENTS = 2
-
-      FIELDS = {
-        COMMANDNAME => {:type => ::Thrift::Types::STRING, :name => 'commandName'},
-        ARGUMENTS => {:type => ::Thrift::Types::STRUCT, :name => 'arguments', :class => ::Blur::Arguments}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Execute_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      BEX = 1
-      TEX = 2
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::Response},
-        BEX => {:type => ::Thrift::Types::STRUCT, :name => 'bex', :class => ::Blur::BlurException},
-        TEX => {:type => ::Thrift::Types::STRUCT, :name => 'tex', :class => ::Blur::TimeoutException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Reconnect_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      INSTANCEEXECUTIONID = 1
-
-      FIELDS = {
-        INSTANCEEXECUTIONID => {:type => ::Thrift::Types::I64, :name => 'instanceExecutionId'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Reconnect_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      BEX = 1
-      TEX = 2
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::Response},
-        BEX => {:type => ::Thrift::Types::STRUCT, :name => 'bex', :class => ::Blur::BlurException},
-        TEX => {:type => ::Thrift::Types::STRUCT, :name => 'tex', :class => ::Blur::TimeoutException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CommandStatusList_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      STARTINGAT = 1
-      FETCH = 2
-      STATE = 3
-
-      FIELDS = {
-        STARTINGAT => {:type => ::Thrift::Types::I32, :name => 'startingAt'},
-        FETCH => {:type => ::Thrift::Types::I16, :name => 'fetch'},
-        STATE => {:type => ::Thrift::Types::I32, :name => 'state', :enum_class => ::Blur::CommandStatusState}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-        unless @state.nil? || ::Blur::CommandStatusState::VALID_VALUES.include?(@state)
-          raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field state!')
-        end
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CommandStatusList_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CommandStatus_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      COMMANDEXECUTIONID = 1
-
-      FIELDS = {
-        COMMANDEXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'commandExecutionId'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CommandStatus_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::CommandStatus},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CommandCancel_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      COMMANDEXECUTIONID = 1
-
-      FIELDS = {
-        COMMANDEXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'commandExecutionId'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CommandCancel_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Refresh_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-
-      FIELDS = {
-
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Refresh_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-
-      FIELDS = {
-
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CreateTable_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLEDESCRIPTOR = 1
-
-      FIELDS = {
-        # the TableDescriptor.
-        TABLEDESCRIPTOR => {:type => ::Thrift::Types::STRUCT, :name => 'tableDescriptor', :class => ::Blur::TableDescriptor}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CreateTable_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class EnableTable_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class EnableTable_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class DisableTable_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class DisableTable_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class RemoveTable_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      DELETEINDEXFILES = 2
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        # true to remove the index storage and false if to preserve.
-        DELETEINDEXFILES => {:type => ::Thrift::Types::BOOL, :name => 'deleteIndexFiles'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class RemoveTable_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class AddColumnDefinition_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      COLUMNDEFINITION = 2
-
-      FIELDS = {
-        # the name of the table.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        # the ColumnDefinition.
-        COLUMNDEFINITION => {:type => ::Thrift::Types::STRUCT, :name => 'columnDefinition', :class => ::Blur::ColumnDefinition}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class AddColumnDefinition_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::BOOL, :name => 'success'},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class TableList_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-
-      FIELDS = {
-
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class TableList_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class TableListByCluster_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      CLUSTER = 1
-
-      FIELDS = {
-        # the cluster name.
-        CLUSTER => {:type => ::Thrift::Types::STRING, :name => 'cluster'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class TableListByCluster_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Describe_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Describe_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::TableDescriptor},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Schema_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Schema_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::Schema},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class ParseQuery_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      QUERY = 2
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        # the query to parse.
-        QUERY => {:type => ::Thrift::Types::STRUCT, :name => 'query', :class => ::Blur::Query}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class ParseQuery_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::STRING, :name => 'success'},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class TableStats_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class TableStats_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::TableStats},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Optimize_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      NUMBEROFSEGMENTSPERSHARD = 2
-
-      FIELDS = {
-        # table the name of the table.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        # the maximum of segments per shard index after the operation is completed.
-        NUMBEROFSEGMENTSPERSHARD => {:type => ::Thrift::Types::I32, :name => 'numberOfSegmentsPerShard'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Optimize_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CreateSnapshot_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      NAME = 2
-
-      FIELDS = {
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        NAME => {:type => ::Thrift::Types::STRING, :name => 'name'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CreateSnapshot_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class RemoveSnapshot_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      NAME = 2
-
-      FIELDS = {
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        NAME => {:type => ::Thrift::Types::STRING, :name => 'name'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class RemoveSnapshot_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class ListSnapshots_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-
-      FIELDS = {
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class ListSnapshots_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::MAP, :name => 'success', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRING}}},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class SetUser_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      USER = 1
-
-      FIELDS = {
-        # the User object.
-        USER => {:type => ::Thrift::Types::STRUCT, :name => 'user', :class => ::Blur::User}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class SetUser_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-
-      FIELDS = {
-
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Query_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      BLURQUERY = 2
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        # the query to execute.
-        BLURQUERY => {:type => ::Thrift::Types::STRUCT, :name => 'blurQuery', :class => ::Blur::BlurQuery}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Query_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::BlurResults},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class FetchRow_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      SELECTOR = 2
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        # the Selector to use to fetch the Row or Record.
-        SELECTOR => {:type => ::Thrift::Types::STRUCT, :name => 'selector', :class => ::Blur::Selector}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class FetchRow_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::FetchResult},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class FetchRowBatch_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      SELECTORS = 2
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        # the Selector to use to fetch the Row or Record.
-        SELECTORS => {:type => ::Thrift::Types::LIST, :name => 'selectors', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::Selector}}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class FetchRowBatch_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::FetchResult}},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class LoadData_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      LOCATION = 2
-
-      FIELDS = {
-        # The table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        # Location of bulk data load.
-        LOCATION => {:type => ::Thrift::Types::STRING, :name => 'location'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class LoadData_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class ValidateIndex_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      EXTERNALINDEXPATHS = 2
-
-      FIELDS = {
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        EXTERNALINDEXPATHS => {:type => ::Thrift::Types::LIST, :name => 'externalIndexPaths', :element => {:type => ::Thrift::Types::STRING}}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class ValidateIndex_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class LoadIndex_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      EXTERNALINDEXPATHS = 2
-
-      FIELDS = {
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        EXTERNALINDEXPATHS => {:type => ::Thrift::Types::LIST, :name => 'externalIndexPaths', :element => {:type => ::Thrift::Types::STRING}}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class LoadIndex_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Mutate_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      MUTATION = 1
-
-      FIELDS = {
-        # the RowMutation.
-        MUTATION => {:type => ::Thrift::Types::STRUCT, :name => 'mutation', :class => ::Blur::RowMutation}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Mutate_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class EnqueueMutate_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      MUTATION = 1
-
-      FIELDS = {
-        # the RowMutation.
-        MUTATION => {:type => ::Thrift::Types::STRUCT, :name => 'mutation', :class => ::Blur::RowMutation}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class EnqueueMutate_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class MutateBatch_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      MUTATIONS = 1
-
-      FIELDS = {
-        # the batch of RowMutations.
-        MUTATIONS => {:type => ::Thrift::Types::LIST, :name => 'mutations', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::RowMutation}}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class MutateBatch_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class EnqueueMutateBatch_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      MUTATIONS = 1
-
-      FIELDS = {
-        # the batch of RowMutations.
-        MUTATIONS => {:type => ::Thrift::Types::LIST, :name => 'mutations', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::RowMutation}}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class EnqueueMutateBatch_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class BulkMutateStart_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      BULKID = 1
-
-      FIELDS = {
-        # The bulk id.
-        BULKID => {:type => ::Thrift::Types::STRING, :name => 'bulkId'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class BulkMutateStart_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class BulkMutateAdd_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      BULKID = 1
-      ROWMUTATION = 2
-
-      FIELDS = {
-        # The bulk id.
-        BULKID => {:type => ::Thrift::Types::STRING, :name => 'bulkId'},
-        # The row mutation.
-        ROWMUTATION => {:type => ::Thrift::Types::STRUCT, :name => 'rowMutation', :class => ::Blur::RowMutation}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class BulkMutateAdd_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class BulkMutateAddMultiple_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      BULKID = 1
-      ROWMUTATIONS = 2
-
-      FIELDS = {
-        # The bulk id.
-        BULKID => {:type => ::Thrift::Types::STRING, :name => 'bulkId'},
-        # The row mutation.
-        ROWMUTATIONS => {:type => ::Thrift::Types::LIST, :name => 'rowMutations', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::RowMutation}}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class BulkMutateAddMultiple_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class BulkMutateFinish_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      BULKID = 1
-      APPLY = 2
-      BLOCKUNTILCOMPLETE = 3
-
-      FIELDS = {
-        # The bulk id.
-        BULKID => {:type => ::Thrift::Types::STRING, :name => 'bulkId'},
-        # Apply the bulk mutate flag.
-        APPLY => {:type => ::Thrift::Types::BOOL, :name => 'apply'},
-        # If true this call will not block on bulk completion.  This may be required for loader bulk loads.
-        BLOCKUNTILCOMPLETE => {:type => ::Thrift::Types::BOOL, :name => 'blockUntilComplete'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class BulkMutateFinish_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CancelQuery_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      UUID = 2
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        # the uuid of the query.
-        UUID => {:type => ::Thrift::Types::STRING, :name => 'uuid'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CancelQuery_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      EX = 1
-
-      FIELDS = {
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class QueryStatusIdList_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class QueryStatusIdList_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class QueryStatusById_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      UUID = 2
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        # the uuid of the query.
-        UUID => {:type => ::Thrift::Types::STRING, :name => 'uuid'}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class QueryStatusById_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::BlurQueryStatus},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Terms_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      COLUMNFAMILY = 2
-      COLUMNNAME = 3
-      STARTWITH = 4
-      SIZE = 5
-
-      FIELDS = {
-        # the table name.
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        # the column fam

<TRUNCATED>

Mime
View raw message