incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [16/46] Regenerated thrift code.
Date Tue, 30 Oct 2012 02:53:18 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/1befa5f5/interface/gen-rb/blur.rb
----------------------------------------------------------------------
diff --git a/interface/gen-rb/blur.rb b/interface/gen-rb/blur.rb
index ef0b0f7..aa17c7a 100644
--- a/interface/gen-rb/blur.rb
+++ b/interface/gen-rb/blur.rb
@@ -1,5 +1,5 @@
 #
-# Autogenerated by Thrift Compiler (0.7.0)
+# Autogenerated by Thrift Compiler (0.9.0)
 #
 # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
 #
@@ -7,1665 +7,1665 @@
 require 'thrift'
 require 'blur_types'
 
-    module Blur
-      module Blur
-        class Client
-          include ::Thrift::Client
-
-          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 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 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 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 currentQueries(table)
-            send_currentQueries(table)
-            return recv_currentQueries()
-          end
-
-          def send_currentQueries(table)
-            send_message('currentQueries', CurrentQueries_args, :table => table)
-          end
-
-          def recv_currentQueries()
-            result = receive_message(CurrentQueries_result)
-            return result.success unless result.success.nil?
-            raise result.ex unless result.ex.nil?
-            raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'currentQueries failed: unknown result')
-          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 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 getTableStats(table)
-            send_getTableStats(table)
-            return recv_getTableStats()
-          end
-
-          def send_getTableStats(table)
-            send_message('getTableStats', GetTableStats_args, :table => table)
-          end
-
-          def recv_getTableStats()
-            result = receive_message(GetTableStats_result)
-            return result.success unless result.success.nil?
-            raise result.ex unless result.ex.nil?
-            raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTableStats 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 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 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 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 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 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 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 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
+module Blur
+  module Blur
+    class Client
+      include ::Thrift::Client
 
-        end
+      def shardClusterList()
+        send_shardClusterList()
+        return recv_shardClusterList()
+      end
 
-        class Processor
-          include ::Thrift::Processor
-
-          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_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_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_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_currentQueries(seqid, iprot, oprot)
-            args = read_args(iprot, CurrentQueries_args)
-            result = CurrentQueries_result.new()
-            begin
-              result.success = @handler.currentQueries(args.table)
-            rescue Blur::BlurException => ex
-              result.ex = ex
-            end
-            write_result(result, oprot, 'currentQueries', 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_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_getTableStats(seqid, iprot, oprot)
-            args = read_args(iprot, GetTableStats_args)
-            result = GetTableStats_result.new()
-            begin
-              result.success = @handler.getTableStats(args.table)
-            rescue Blur::BlurException => ex
-              result.ex = ex
-            end
-            write_result(result, oprot, 'getTableStats', 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_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_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_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_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_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_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_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 send_shardClusterList()
+        send_message('shardClusterList', ShardClusterList_args)
+      end
 
-        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
 
-        # HELPER FUNCTIONS AND STRUCTURES
+      def shardServerList(cluster)
+        send_shardServerList(cluster)
+        return recv_shardServerList()
+      end
 
-        class ShardClusterList_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
+      def send_shardServerList(cluster)
+        send_message('shardServerList', ShardServerList_args, :cluster => cluster)
+      end
 
-          FIELDS = {
+      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 struct_fields; FIELDS; end
+      def send_controllerServerList()
+        send_message('controllerServerList', ControllerServerList_args)
+      end
 
-          def validate
-          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
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def shardServerLayout(table)
+        send_shardServerLayout(table)
+        return recv_shardServerLayout()
+      end
 
-        class ShardClusterList_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      def send_shardServerLayout(table)
+        send_message('shardServerLayout', ShardServerLayout_args, :table => table)
+      end
 
-          FIELDS = {
-            SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+      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 struct_fields; FIELDS; end
+      def tableList()
+        send_tableList()
+        return recv_tableList()
+      end
 
-          def validate
-          end
+      def send_tableList()
+        send_message('tableList', TableList_args)
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        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
 
-        class ShardServerList_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          CLUSTER = 1
+      def tableListByCluster(cluster)
+        send_tableListByCluster(cluster)
+        return recv_tableListByCluster()
+      end
 
-          FIELDS = {
-            CLUSTER => {:type => ::Thrift::Types::STRING, :name => 'cluster'}
-          }
+      def send_tableListByCluster(cluster)
+        send_message('tableListByCluster', TableListByCluster_args, :cluster => cluster)
+      end
 
-          def struct_fields; FIELDS; 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 validate
-          end
+      def describe(table)
+        send_describe(table)
+        return recv_describe()
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def send_describe(table)
+        send_message('describe', Describe_args, :table => table)
+      end
 
-        class ShardServerList_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      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
 
-          FIELDS = {
-            SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+      def query(table, blurQuery)
+        send_query(table, blurQuery)
+        return recv_query()
+      end
 
-          def struct_fields; FIELDS; end
+      def send_query(table, blurQuery)
+        send_message('query', Query_args, :table => table, :blurQuery => blurQuery)
+      end
 
-          def validate
-          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
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def cancelQuery(table, uuid)
+        send_cancelQuery(table, uuid)
+        recv_cancelQuery()
+      end
 
-        class ControllerServerList_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
+      def send_cancelQuery(table, uuid)
+        send_message('cancelQuery', CancelQuery_args, :table => table, :uuid => uuid)
+      end
 
-          FIELDS = {
+      def recv_cancelQuery()
+        result = receive_message(CancelQuery_result)
+        raise result.ex unless result.ex.nil?
+        return
+      end
 
-          }
+      def currentQueries(table)
+        send_currentQueries(table)
+        return recv_currentQueries()
+      end
 
-          def struct_fields; FIELDS; end
+      def send_currentQueries(table)
+        send_message('currentQueries', CurrentQueries_args, :table => table)
+      end
 
-          def validate
-          end
+      def recv_currentQueries()
+        result = receive_message(CurrentQueries_result)
+        return result.success unless result.success.nil?
+        raise result.ex unless result.ex.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'currentQueries failed: unknown result')
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def queryStatusIdList(table)
+        send_queryStatusIdList(table)
+        return recv_queryStatusIdList()
+      end
 
-        class ControllerServerList_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      def send_queryStatusIdList(table)
+        send_message('queryStatusIdList', QueryStatusIdList_args, :table => table)
+      end
 
-          FIELDS = {
-            SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+      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 struct_fields; FIELDS; end
+      def queryStatusById(table, uuid)
+        send_queryStatusById(table, uuid)
+        return recv_queryStatusById()
+      end
 
-          def validate
-          end
+      def send_queryStatusById(table, uuid)
+        send_message('queryStatusById', QueryStatusById_args, :table => table, :uuid => uuid)
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        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
 
-        class ShardServerLayout_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
+      def schema(table)
+        send_schema(table)
+        return recv_schema()
+      end
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-          }
+      def send_schema(table)
+        send_message('schema', Schema_args, :table => table)
+      end
 
-          def struct_fields; FIELDS; 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 validate
-          end
+      def getTableStats(table)
+        send_getTableStats(table)
+        return recv_getTableStats()
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def send_getTableStats(table)
+        send_message('getTableStats', GetTableStats_args, :table => table)
+      end
 
-        class ShardServerLayout_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      def recv_getTableStats()
+        result = receive_message(GetTableStats_result)
+        return result.success unless result.success.nil?
+        raise result.ex unless result.ex.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTableStats failed: unknown result')
+      end
 
-          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 tableStats(table)
+        send_tableStats(table)
+        return recv_tableStats()
+      end
 
-          def struct_fields; FIELDS; end
+      def send_tableStats(table)
+        send_message('tableStats', TableStats_args, :table => table)
+      end
 
-          def validate
-          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
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def terms(table, columnFamily, columnName, startWith, size)
+        send_terms(table, columnFamily, columnName, startWith, size)
+        return recv_terms()
+      end
 
-        class TableList_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
+      def send_terms(table, columnFamily, columnName, startWith, size)
+        send_message('terms', Terms_args, :table => table, :columnFamily => columnFamily, :columnName => columnName, :startWith => startWith, :size => size)
+      end
 
-          FIELDS = {
+      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 struct_fields; FIELDS; end
+      def send_recordFrequency(table, columnFamily, columnName, value)
+        send_message('recordFrequency', RecordFrequency_args, :table => table, :columnFamily => columnFamily, :columnName => columnName, :value => value)
+      end
 
-          def validate
-          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
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def fetchRow(table, selector)
+        send_fetchRow(table, selector)
+        return recv_fetchRow()
+      end
 
-        class TableList_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      def send_fetchRow(table, selector)
+        send_message('fetchRow', FetchRow_args, :table => table, :selector => selector)
+      end
 
-          FIELDS = {
-            SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+      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 struct_fields; FIELDS; end
+      def mutate(mutation)
+        send_mutate(mutation)
+        recv_mutate()
+      end
 
-          def validate
-          end
+      def send_mutate(mutation)
+        send_message('mutate', Mutate_args, :mutation => mutation)
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def recv_mutate()
+        result = receive_message(Mutate_result)
+        raise result.ex unless result.ex.nil?
+        return
+      end
 
-        class TableListByCluster_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          CLUSTER = 1
+      def mutateBatch(mutations)
+        send_mutateBatch(mutations)
+        recv_mutateBatch()
+      end
 
-          FIELDS = {
-            CLUSTER => {:type => ::Thrift::Types::STRING, :name => 'cluster'}
-          }
+      def send_mutateBatch(mutations)
+        send_message('mutateBatch', MutateBatch_args, :mutations => mutations)
+      end
 
-          def struct_fields; FIELDS; end
+      def recv_mutateBatch()
+        result = receive_message(MutateBatch_result)
+        raise result.ex unless result.ex.nil?
+        return
+      end
 
-          def validate
-          end
+      def createTable(tableDescriptor)
+        send_createTable(tableDescriptor)
+        recv_createTable()
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def send_createTable(tableDescriptor)
+        send_message('createTable', CreateTable_args, :tableDescriptor => tableDescriptor)
+      end
 
-        class TableListByCluster_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      def recv_createTable()
+        result = receive_message(CreateTable_result)
+        raise result.ex unless result.ex.nil?
+        return
+      end
 
-          FIELDS = {
-            SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+      def enableTable(table)
+        send_enableTable(table)
+        recv_enableTable()
+      end
 
-          def struct_fields; FIELDS; end
+      def send_enableTable(table)
+        send_message('enableTable', EnableTable_args, :table => table)
+      end
 
-          def validate
-          end
+      def recv_enableTable()
+        result = receive_message(EnableTable_result)
+        raise result.ex unless result.ex.nil?
+        return
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def disableTable(table)
+        send_disableTable(table)
+        recv_disableTable()
+      end
 
-        class Describe_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
+      def send_disableTable(table)
+        send_message('disableTable', DisableTable_args, :table => table)
+      end
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-          }
+      def recv_disableTable()
+        result = receive_message(DisableTable_result)
+        raise result.ex unless result.ex.nil?
+        return
+      end
 
-          def struct_fields; FIELDS; end
+      def removeTable(table, deleteIndexFiles)
+        send_removeTable(table, deleteIndexFiles)
+        recv_removeTable()
+      end
 
-          def validate
-          end
+      def send_removeTable(table, deleteIndexFiles)
+        send_message('removeTable', RemoveTable_args, :table => table, :deleteIndexFiles => deleteIndexFiles)
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def recv_removeTable()
+        result = receive_message(RemoveTable_result)
+        raise result.ex unless result.ex.nil?
+        return
+      end
 
-        class Describe_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      def optimize(table, numberOfSegmentsPerShard)
+        send_optimize(table, numberOfSegmentsPerShard)
+        recv_optimize()
+      end
 
-          FIELDS = {
-            SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => Blur::TableDescriptor},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+      def send_optimize(table, numberOfSegmentsPerShard)
+        send_message('optimize', Optimize_args, :table => table, :numberOfSegmentsPerShard => numberOfSegmentsPerShard)
+      end
 
-          def struct_fields; FIELDS; end
+      def recv_optimize()
+        result = receive_message(Optimize_result)
+        raise result.ex unless result.ex.nil?
+        return
+      end
 
-          def validate
-          end
+      def isInSafeMode(cluster)
+        send_isInSafeMode(cluster)
+        return recv_isInSafeMode()
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        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
 
-        class Query_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
-          BLURQUERY = 2
+      def configuration()
+        send_configuration()
+        return recv_configuration()
+      end
+
+      def send_configuration()
+        send_message('configuration', Configuration_args)
+      end
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-            BLURQUERY => {:type => ::Thrift::Types::STRUCT, :name => 'blurQuery', :class => Blur::BlurQuery}
-          }
+      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 struct_fields; FIELDS; end
+    end
 
-          def validate
-          end
+    class Processor
+      include ::Thrift::Processor
 
-          ::Thrift::Struct.generate_accessors self
+      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
 
-        class Query_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      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
 
-          FIELDS = {
-            SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => Blur::BlurResults},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+      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 struct_fields; FIELDS; 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 validate
-          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
 
-          ::Thrift::Struct.generate_accessors self
+      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
 
-        class CancelQuery_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
-          UUID = 2
+      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
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-            UUID => {:type => ::Thrift::Types::I64, :name => 'uuid'}
-          }
+      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 struct_fields; FIELDS; 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 validate
-          end
+      def process_currentQueries(seqid, iprot, oprot)
+        args = read_args(iprot, CurrentQueries_args)
+        result = CurrentQueries_result.new()
+        begin
+          result.success = @handler.currentQueries(args.table)
+        rescue ::Blur::BlurException => ex
+          result.ex = ex
+        end
+        write_result(result, oprot, 'currentQueries', seqid)
+      end
 
-          ::Thrift::Struct.generate_accessors self
+      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
 
-        class CancelQuery_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          EX = 1
+      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
 
-          FIELDS = {
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+      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 struct_fields; FIELDS; end
+      def process_getTableStats(seqid, iprot, oprot)
+        args = read_args(iprot, GetTableStats_args)
+        result = GetTableStats_result.new()
+        begin
+          result.success = @handler.getTableStats(args.table)
+        rescue ::Blur::BlurException => ex
+          result.ex = ex
+        end
+        write_result(result, oprot, 'getTableStats', seqid)
+      end
 
-          def validate
-          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
 
-          ::Thrift::Struct.generate_accessors self
+      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
 
-        class CurrentQueries_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
+      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
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-          }
+      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 struct_fields; FIELDS; 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 validate
-          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
 
-          ::Thrift::Struct.generate_accessors self
+      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
 
-        class CurrentQueries_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      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
 
-          FIELDS = {
-            SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => Blur::BlurQueryStatus}},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+      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 struct_fields; FIELDS; 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 validate
-          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
 
-          ::Thrift::Struct.generate_accessors self
+      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
 
-        class QueryStatusIdList_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
+      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
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-          }
+    end
 
-          def struct_fields; FIELDS; end
+    # HELPER FUNCTIONS AND STRUCTURES
 
-          def validate
-          end
+    class ShardClusterList_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      FIELDS = {
 
-        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::I64}},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+      def struct_fields; FIELDS; end
 
-          def struct_fields; FIELDS; end
+      def validate
+      end
 
-          def validate
-          end
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+    class ShardClusterList_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-        class QueryStatusById_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
-          UUID = 2
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-            UUID => {:type => ::Thrift::Types::I64, :name => 'uuid'}
-          }
+      def struct_fields; FIELDS; end
 
-          def struct_fields; FIELDS; end
+      def validate
+      end
 
-          def validate
-          end
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+    class ShardServerList_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      CLUSTER = 1
 
-        class QueryStatusById_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      FIELDS = {
+        CLUSTER => {:type => ::Thrift::Types::STRING, :name => 'cluster'}
+      }
 
-          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 struct_fields; FIELDS; end
+      def validate
+      end
 
-          def validate
-          end
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+    class ShardServerList_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-        class Schema_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-          }
+      def struct_fields; FIELDS; end
 
-          def struct_fields; FIELDS; end
+      def validate
+      end
 
-          def validate
-          end
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+    class ControllerServerList_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
 
-        class Schema_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      FIELDS = {
 
-          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 struct_fields; FIELDS; end
 
-          def validate
-          end
+      def validate
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      ::Thrift::Struct.generate_accessors self
+    end
 
-        class GetTableStats_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
+    class ControllerServerList_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-          }
+      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 struct_fields; FIELDS; end
 
-          def validate
-          end
+      def validate
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      ::Thrift::Struct.generate_accessors self
+    end
 
-        class GetTableStats_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+    class ShardServerLayout_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
 
-          FIELDS = {
-            SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => Blur::TableStats},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
+      }
 
-          def struct_fields; FIELDS; end
+      def struct_fields; FIELDS; end
 
-          def validate
-          end
+      def validate
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      ::Thrift::Struct.generate_accessors self
+    end
 
-        class TableStats_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
+    class ShardServerLayout_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-          }
+      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 struct_fields; FIELDS; end
 
-          def validate
-          end
+      def validate
+      end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      ::Thrift::Struct.generate_accessors self
+    end
 
-        class TableStats_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+    class TableList_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
 
-          FIELDS = {
-            SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => Blur::TableStats},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+      FIELDS = {
 
-          def struct_fields; FIELDS; end
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class Terms_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
-          COLUMNFAMILY = 2
-          COLUMNNAME = 3
-          STARTWITH = 4
-          SIZE = 5
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-            COLUMNFAMILY => {:type => ::Thrift::Types::STRING, :name => 'columnFamily'},
-            COLUMNNAME => {:type => ::Thrift::Types::STRING, :name => 'columnName'},
-            STARTWITH => {:type => ::Thrift::Types::STRING, :name => 'startWith'},
-            SIZE => {:type => ::Thrift::Types::I16, :name => 'size'}
-          }
+    class TableList_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class Terms_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+    class TableListByCluster_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      CLUSTER = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        CLUSTER => {:type => ::Thrift::Types::STRING, :name => 'cluster'}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class RecordFrequency_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
-          COLUMNFAMILY = 2
-          COLUMNNAME = 3
-          VALUE = 4
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-            COLUMNFAMILY => {:type => ::Thrift::Types::STRING, :name => 'columnFamily'},
-            COLUMNNAME => {:type => ::Thrift::Types::STRING, :name => 'columnName'},
-            VALUE => {:type => ::Thrift::Types::STRING, :name => 'value'}
-          }
+    class TableListByCluster_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class RecordFrequency_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            SUCCESS => {:type => ::Thrift::Types::I64, :name => 'success'},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+    class Describe_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class FetchRow_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
-          SELECTOR = 2
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-            SELECTOR => {:type => ::Thrift::Types::STRUCT, :name => 'selector', :class => Blur::Selector}
-          }
+    class Describe_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::TableDescriptor},
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class FetchRow_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          SUCCESS = 0
-          EX = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => Blur::FetchResult},
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+    class Query_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
+      BLURQUERY = 2
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+        BLURQUERY => {:type => ::Thrift::Types::STRUCT, :name => 'blurQuery', :class => ::Blur::BlurQuery}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class Mutate_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          MUTATION = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            MUTATION => {:type => ::Thrift::Types::STRUCT, :name => 'mutation', :class => Blur::RowMutation}
-          }
+    class Query_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::BlurResults},
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class Mutate_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          EX = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+    class CancelQuery_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
+      UUID = 2
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+        UUID => {:type => ::Thrift::Types::I64, :name => 'uuid'}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class MutateBatch_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          MUTATIONS = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            MUTATIONS => {:type => ::Thrift::Types::LIST, :name => 'mutations', :element => {:type => ::Thrift::Types::STRUCT, :class => Blur::RowMutation}}
-          }
+    class CancelQuery_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      EX = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class MutateBatch_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          EX = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+    class CurrentQueries_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class CreateTable_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLEDESCRIPTOR = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            TABLEDESCRIPTOR => {:type => ::Thrift::Types::STRUCT, :name => 'tableDescriptor', :class => Blur::TableDescriptor}
-          }
+    class CurrentQueries_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::BlurQueryStatus}},
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class CreateTable_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          EX = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+    class QueryStatusIdList_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class EnableTable_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-          }
+    class QueryStatusIdList_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::I64}},
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class EnableTable_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          EX = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+    class QueryStatusById_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
+      UUID = 2
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+        UUID => {:type => ::Thrift::Types::I64, :name => 'uuid'}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class DisableTable_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
-          }
+    class QueryStatusById_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::BlurQueryStatus},
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class DisableTable_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          EX = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+    class Schema_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class RemoveTable_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
-          DELETEINDEXFILES = 2
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-            DELETEINDEXFILES => {:type => ::Thrift::Types::BOOL, :name => 'deleteIndexFiles'}
-          }
+    class Schema_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::Schema},
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class RemoveTable_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          EX = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+    class GetTableStats_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class Optimize_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          TABLE = 1
-          NUMBEROFSEGMENTSPERSHARD = 2
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-            NUMBEROFSEGMENTSPERSHARD => {:type => ::Thrift::Types::I32, :name => 'numberOfSegmentsPerShard'}
-          }
+    class GetTableStats_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::TableStats},
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class Optimize_result
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          EX = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => Blur::BlurException}
-          }
+    class TableStats_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class IsInSafeMode_args
-          include ::Thrift::Struct, ::Thrift::Struct_Union
-          CLUSTER = 1
+      ::Thrift::Struct.generate_accessors self
+    end
 
-          FIELDS = {
-            CLUSTER => {:type => ::Thrift::Types::STRING, :name => 'cluster'}
-          }
+    class TableStats_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
 
-          def struct_fields; FIELDS; end
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::TableStats},
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
 
-          def validate
-          end
+      def struct_fields; FIELDS; end
 
-          ::Thrift::Struct.generate_accessors self
-        end
+      def validate
+      end
 
-        class IsInSaf

<TRUNCATED>

Mime
View raw message