incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [27/51] [partial] Restructuring the distribution projects to allow for seperate hadoop2 and hadoop1 binaries.
Date Tue, 29 Apr 2014 21:51:45 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/7395b9cb/distribution-hadoop1/src/main/scripts/interface/gen-rb/blur.rb
----------------------------------------------------------------------
diff --git a/distribution-hadoop1/src/main/scripts/interface/gen-rb/blur.rb b/distribution-hadoop1/src/main/scripts/interface/gen-rb/blur.rb
new file mode 100644
index 0000000..5de32dd
--- /dev/null
+++ b/distribution-hadoop1/src/main/scripts/interface/gen-rb/blur.rb
@@ -0,0 +1,2713 @@
+#
+# 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 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 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 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 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_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_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_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_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 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 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 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 family. If the frequency requested is a system field like "rowid", "recordid", "family", etc then columnFamily can be null.
+        COLUMNFAMILY => {:type => ::Thrift::Types::STRING, :name => 'columnFamily'},
+        # the column name.
+        COLUMNNAME => {:type => ::Thrift::Types::STRING, :name => 'columnName'},
+        # the term to start with assuming that you are paging through the term list.
+        STARTWITH => {:type => ::Thrift::Types::STRING, :name => 'startWith'},
+        # the number to fetch at once.
+        SIZE => {:type => ::Thrift::Types::I16, :name => 'size'}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class Terms_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 RecordFrequency_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
+      COLUMNFAMILY = 2
+      COLUMNNAME = 3
+      VALUE = 4
+
+      FIELDS = {
+        # the table name.
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+        # the column family. If the frequency requested is a system field like "rowid", "recordid", "family", etc then columnFamily can be null.
+        COLUMNFAMILY => {:type => ::Thrift::Types::STRING, :name => 'columnFamily'},
+        # the column name.
+        COLUMNNAME => {:type => ::Thrift::Types::STRING, :name => 'columnName'},
+        # the value.
+        VALUE => {:type => ::Thrift::Types::STRING, :name => 'value'}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class RecordFrequency_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
+
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::I64, :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 ShardClusterList_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+
+      FIELDS = {
+
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class ShardClusterList_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 ShardServerList_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 ShardServerList_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 ControllerServerList_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+
+      FIELDS = {
+
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class ControllerServerList_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 ShardServerLayout_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 ShardServerLayout_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::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 ShardServerLayoutState_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 ShardServerLayoutState_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::MAP, :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::I32, :enum_class => ::Blur::ShardState}}},
+        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 IsInSafeMode_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      CLUSTER = 1
+
+      FIELDS = {
+        # the name of the cluster.
+        CLUSTER => {:type => ::Thrift::Types::STRING, :name => 'cluster'}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class IsInSafeMode_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 Configuration_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+
+      FIELDS = {
+
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class Configuration_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::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 Metrics_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      METRICS = 1
+
+      FIELDS = {
+        # the names of the metrics to return.  If null all are returned.
+        METRICS => {:type => ::Thrift::Types::SET, :name => 'metrics', :element => {:type => ::Thrift::Types::STRING}}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class Metrics_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::STRUCT, :class => ::Blur::Metric}},
+        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 StartTrace_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TRACEID = 1
+      REQUESTID = 2
+
+      FIELDS = {
+        # the trace id.
+        TRACEID => {:type => ::Thrift::Types::STRING, :name => 'traceId'},
+        # the request id, used to connected remote calls together.  Client can pass null.
+        REQUESTID => {:type => ::Thrift::Types::STRING, :name => 'requestId'}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class StartTrace_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+
+      FIELDS = {
+
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class TraceList_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+
+      FIELDS = {
+
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class TraceList_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 TraceRequestList_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TRACEID = 1
+
+      FIELDS = {
+        # the trace id.
+        TRACEID => {:type => ::Thrift::Types::STRING, :name => 'traceId'}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class TraceRequestList_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 TraceRequestFetch_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TRACEID = 1
+      REQUESTID = 2
+
+      FIELDS = {
+        # the trace id.
+        TRACEID => {:type => ::Thrift::Types::STRING, :name => 'traceId'},
+        # the request id.
+        REQUESTID => {:type => ::Thrift::Types::STRING, :name => 'requestId'}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class TraceRequestFetch_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 TraceRemove_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TRACEID = 1
+
+      FIELDS = {
+        # the trace id.
+        TRACEID => {:type => ::Thrift::Types::STRING, :name => 'traceId'}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class TraceRemove_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 Ping_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+
+      FIELDS = {
+
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class Ping_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+
+      FIELDS = {
+
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class Logging_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      CLASSNAMEORLOGGERNAME = 1
+      LEVEL = 2
+
+      FIELDS = {
+        # the className or Logger Name of the Logger to be changed.
+        CLASSNAMEORLOGGERNAME => {:type => ::Thrift::Types::STRING, :name => 'classNameOrLoggerName'},
+        # the logging level.
+        LEVEL => {:type => ::Thrift::Types::I32, :name => 'level', :enum_class => ::Blur::Level}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+        unless @level.nil? || ::Blur::Level::VALID_VALUES.include?(@level)
+          raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field level!')
+        end
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class Logging_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 ResetLogging_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+
+      FIELDS = {
+
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class ResetLogging_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
+
+  end
+
+end

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/7395b9cb/distribution-hadoop1/src/main/scripts/interface/gen-rb/blur_constants.rb
----------------------------------------------------------------------
diff --git a/distribution-hadoop1/src/main/scripts/interface/gen-rb/blur_constants.rb b/distribution-hadoop1/src/main/scripts/interface/gen-rb/blur_constants.rb
new file mode 100644
index 0000000..e455224
--- /dev/null
+++ b/distribution-hadoop1/src/main/scripts/interface/gen-rb/blur_constants.rb
@@ -0,0 +1,11 @@
+#
+# 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
+end


Mime
View raw message