incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [2/28] Initial commit of the back port. The blur-util, blur-store, have been completed. Also a new distribution project help with the building of the project. Also all of the pom files have been updated to the new version. This is very much a work in
Date Mon, 18 Mar 2013 01:10:31 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a4601422/src/distribution/src/main/scripts/interface/gen-rb/blur.rb
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-rb/blur.rb b/src/distribution/src/main/scripts/interface/gen-rb/blur.rb
new file mode 100644
index 0000000..aa17c7a
--- /dev/null
+++ b/src/distribution/src/main/scripts/interface/gen-rb/blur.rb
@@ -0,0 +1,1671 @@
+#
+# 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 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
+
+    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
+
+    end
+
+    # HELPER FUNCTIONS AND STRUCTURES
+
+    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 = {
+        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 = {
+        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 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 = {
+        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 = {
+        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 Query_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
+      BLURQUERY = 2
+
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+        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 CancelQuery_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
+      UUID = 2
+
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+        UUID => {:type => ::Thrift::Types::I64, :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 CurrentQueries_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 CurrentQueries_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::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 QueryStatusIdList_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 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 validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class QueryStatusById_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
+      UUID = 2
+
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+        UUID => {:type => ::Thrift::Types::I64, :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 Schema_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 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 GetTableStats_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 GetTableStats_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 TableStats_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 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 Terms_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
+      COLUMNFAMILY = 2
+      COLUMNNAME = 3
+      STARTWITH = 4
+      SIZE = 5
+
+      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'}
+      }
+
+      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 = {
+        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'}
+      }
+
+      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 FetchRow_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
+      SELECTOR = 2
+
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+        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 Mutate_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      MUTATION = 1
+
+      FIELDS = {
+        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 MutateBatch_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      MUTATIONS = 1
+
+      FIELDS = {
+        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 CreateTable_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLEDESCRIPTOR = 1
+
+      FIELDS = {
+        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 = {
+        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 = {
+        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 = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+        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 Optimize_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
+      NUMBEROFSEGMENTSPERSHARD = 2
+
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+        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 IsInSafeMode_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      CLUSTER = 1
+
+      FIELDS = {
+        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
+
+  end
+
+end

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a4601422/src/distribution/src/main/scripts/interface/gen-rb/blur_constants.rb
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-rb/blur_constants.rb b/src/distribution/src/main/scripts/interface/gen-rb/blur_constants.rb
new file mode 100644
index 0000000..e455224
--- /dev/null
+++ b/src/distribution/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

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a4601422/src/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-rb/blur_types.rb b/src/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
new file mode 100644
index 0000000..aa9e9eb
--- /dev/null
+++ b/src/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
@@ -0,0 +1,755 @@
+#
+# Autogenerated by Thrift Compiler (0.9.0)
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+
+require 'thrift'
+
+module Blur
+  module ScoreType
+    SUPER = 0
+    AGGREGATE = 1
+    BEST = 2
+    CONSTANT = 3
+    VALUE_MAP = {0 => "SUPER", 1 => "AGGREGATE", 2 => "BEST", 3 => "CONSTANT"}
+    VALID_VALUES = Set.new([SUPER, AGGREGATE, BEST, CONSTANT]).freeze
+  end
+
+  module QueryState
+    RUNNING = 0
+    INTERRUPTED = 1
+    COMPLETE = 2
+    VALUE_MAP = {0 => "RUNNING", 1 => "INTERRUPTED", 2 => "COMPLETE"}
+    VALID_VALUES = Set.new([RUNNING, INTERRUPTED, COMPLETE]).freeze
+  end
+
+  module RowMutationType
+    DELETE_ROW = 0
+    REPLACE_ROW = 1
+    UPDATE_ROW = 2
+    VALUE_MAP = {0 => "DELETE_ROW", 1 => "REPLACE_ROW", 2 => "UPDATE_ROW"}
+    VALID_VALUES = Set.new([DELETE_ROW, REPLACE_ROW, UPDATE_ROW]).freeze
+  end
+
+  module RecordMutationType
+    DELETE_ENTIRE_RECORD = 0
+    REPLACE_ENTIRE_RECORD = 1
+    REPLACE_COLUMNS = 2
+    APPEND_COLUMN_VALUES = 3
+    VALUE_MAP = {0 => "DELETE_ENTIRE_RECORD", 1 => "REPLACE_ENTIRE_RECORD", 2 => "REPLACE_COLUMNS", 3 => "APPEND_COLUMN_VALUES"}
+    VALID_VALUES = Set.new([DELETE_ENTIRE_RECORD, REPLACE_ENTIRE_RECORD, REPLACE_COLUMNS, APPEND_COLUMN_VALUES]).freeze
+  end
+
+  # BlurException that carries a message plus the original stack
+# trace (if any).
+  class BlurException < ::Thrift::Exception
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    MESSAGE = 1
+    STACKTRACESTR = 2
+
+    FIELDS = {
+      # The message in the exception.
+      MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'},
+      # The original stack trace (if any).
+      STACKTRACESTR => {:type => ::Thrift::Types::STRING, :name => 'stackTraceStr'}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # Column is the lowest storage element in Blur, it stores a single name and value pair.
+  class Column
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    NAME = 1
+    VALUE = 2
+
+    FIELDS = {
+      # The name of the column.
+      NAME => {:type => ::Thrift::Types::STRING, :name => 'name'},
+      # The value to be indexed and stored.
+      VALUE => {:type => ::Thrift::Types::STRING, :name => 'value'}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # Records contain a list of columns, multiple columns with the same name are allowed.
+  class Record
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    RECORDID = 1
+    FAMILY = 2
+    COLUMNS = 3
+
+    FIELDS = {
+      # Record id uniquely identifies a record within a single row.
+      RECORDID => {:type => ::Thrift::Types::STRING, :name => 'recordId'},
+      # The family in which this record resides.
+      FAMILY => {:type => ::Thrift::Types::STRING, :name => 'family'},
+      # A list of columns, multiple columns with the same name are allowed.
+      COLUMNS => {:type => ::Thrift::Types::LIST, :name => 'columns', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::Column}}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # Rows contain a list of records.
+  class Row
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    ID = 1
+    RECORDS = 2
+    RECORDCOUNT = 3
+
+    FIELDS = {
+      # The row id.
+      ID => {:type => ::Thrift::Types::STRING, :name => 'id'},
+      # The list records within the row.  If paging is used this list will only
+# reflect the paged records from the selector.
+      RECORDS => {:type => ::Thrift::Types::LIST, :name => 'records', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::Record}},
+      # The total record count for the row.  If paging is used in a selector to page
+# through records of a row, this count will reflect the entire row.
+      RECORDCOUNT => {:type => ::Thrift::Types::I32, :name => 'recordCount'}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # Select carries the request for information to be retrieved from the stored columns.
+  class Selector
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    RECORDONLY = 1
+    LOCATIONID = 2
+    ROWID = 3
+    RECORDID = 4
+    COLUMNFAMILIESTOFETCH = 5
+    COLUMNSTOFETCH = 6
+    ALLOWSTALEDATA = 7
+
+    FIELDS = {
+      # Fetch the Record only, not the entire Row.
+      RECORDONLY => {:type => ::Thrift::Types::BOOL, :name => 'recordOnly'},
+      # The location id of the Record or Row to be fetched.
+      LOCATIONID => {:type => ::Thrift::Types::STRING, :name => 'locationId'},
+      # The row id of the Row to be fetched, not to be used with location id.
+      ROWID => {:type => ::Thrift::Types::STRING, :name => 'rowId'},
+      # The record id of the Record to be fetched, not to be used with location id.  However the row id needs to be provided to locate the correct Row with the requested Record.
+      RECORDID => {:type => ::Thrift::Types::STRING, :name => 'recordId'},
+      # The column families to fetch.  If null, fetch all.  If empty, fetch none.
+      COLUMNFAMILIESTOFETCH => {:type => ::Thrift::Types::SET, :name => 'columnFamiliesToFetch', :element => {:type => ::Thrift::Types::STRING}},
+      # The columns in the families to fetch.  If null, fetch all.  If empty, fetch none.
+      COLUMNSTOFETCH => {:type => ::Thrift::Types::MAP, :name => 'columnsToFetch', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::SET, :element => {:type => ::Thrift::Types::STRING}}},
+      # @deprecated This value is no longer used.  This allows the fetch to see the most current data that has been added to the table.
+      ALLOWSTALEDATA => {:type => ::Thrift::Types::BOOL, :name => 'allowStaleData'}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # FetchRowResult contains row result from a fetch.
+  class FetchRowResult
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    ROW = 1
+
+    FIELDS = {
+      # The row fetched.
+      ROW => {:type => ::Thrift::Types::STRUCT, :name => 'row', :class => ::Blur::Row}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # FetchRecordResult contains rowid of the record and the record result from a fetch.
+  class FetchRecordResult
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    ROWID = 1
+    RECORD = 2
+
+    FIELDS = {
+      # The row id of the record being fetched.
+      ROWID => {:type => ::Thrift::Types::STRING, :name => 'rowid'},
+      # The record fetched.
+      RECORD => {:type => ::Thrift::Types::STRUCT, :name => 'record', :class => ::Blur::Record}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # FetchResult contains the row or record fetch result based if the Selector was going to fetch the entire row or a single record.
+  class FetchResult
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    EXISTS = 1
+    DELETED = 2
+    TABLE = 3
+    ROWRESULT = 4
+    RECORDRESULT = 5
+
+    FIELDS = {
+      # True if the result exists, false if it doesn't.
+      EXISTS => {:type => ::Thrift::Types::BOOL, :name => 'exists'},
+      # If the row was marked as deleted.
+      DELETED => {:type => ::Thrift::Types::BOOL, :name => 'deleted'},
+      # The table the fetch result came from.
+      TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+      # The row result if a row was selected form the Selector.
+      ROWRESULT => {:type => ::Thrift::Types::STRUCT, :name => 'rowResult', :class => ::Blur::FetchRowResult},
+      # The record result if a record was selected form the Selector.
+      RECORDRESULT => {:type => ::Thrift::Types::STRUCT, :name => 'recordResult', :class => ::Blur::FetchRecordResult}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # The SimpleQuery object holds the query string (normal Lucene syntax), filters and type of scoring (used when super query is on).
+  class SimpleQuery
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    QUERYSTR = 1
+    SUPERQUERYON = 2
+    TYPE = 3
+    POSTSUPERFILTER = 4
+    PRESUPERFILTER = 5
+
+    FIELDS = {
+      # A Lucene syntax based query.
+      QUERYSTR => {:type => ::Thrift::Types::STRING, :name => 'queryStr'},
+      # If the super query is on, meaning the query will be perform against all the records (joining records in some cases) and the result will be Rows (groupings of Record).
+      SUPERQUERYON => {:type => ::Thrift::Types::BOOL, :name => 'superQueryOn', :default => true},
+      # The scoring type, see the document on ScoreType for explanation of each score type.
+      TYPE => {:type => ::Thrift::Types::I32, :name => 'type', :default =>       0, :enum_class => ::Blur::ScoreType},
+      # The post super filter (normal Lucene syntax), is a filter performed after the join to filter out entire rows from the results.
+      POSTSUPERFILTER => {:type => ::Thrift::Types::STRING, :name => 'postSuperFilter'},
+      # The pre super filter (normal Lucene syntax), is a filter performed before the join to filter out records from the results.
+      PRESUPERFILTER => {:type => ::Thrift::Types::STRING, :name => 'preSuperFilter'}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+      unless @type.nil? || ::Blur::ScoreType::VALID_VALUES.include?(@type)
+        raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field type!')
+      end
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # The expert query allows for submission of a serialized query and filter object to be executed against all the queries.
+  class ExpertQuery
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    QUERY = 1
+    FILTER = 2
+
+    FIELDS = {
+      # The serialized query.
+      QUERY => {:type => ::Thrift::Types::STRING, :name => 'query', :binary => true},
+      # The serialized filter.
+      FILTER => {:type => ::Thrift::Types::STRING, :name => 'filter', :binary => true}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # Blur facet.
+  class Facet
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    QUERYSTR = 1
+    MINIMUMNUMBEROFBLURRESULTS = 2
+
+    FIELDS = {
+      QUERYSTR => {:type => ::Thrift::Types::STRING, :name => 'queryStr'},
+      MINIMUMNUMBEROFBLURRESULTS => {:type => ::Thrift::Types::I64, :name => 'minimumNumberOfBlurResults', :default => 9223372036854775807}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class BlurQuery
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    SIMPLEQUERY = 1
+    EXPERTQUERY = 2
+    FACETS = 3
+    SELECTOR = 4
+    ALLOWSTALEDATA = 5
+    USECACHEIFPRESENT = 6
+    START = 7
+    FETCH = 8
+    MINIMUMNUMBEROFRESULTS = 9
+    MAXQUERYTIME = 10
+    UUID = 11
+    USERCONTEXT = 12
+    CACHERESULT = 13
+    STARTTIME = 14
+    MODIFYFILECACHES = 15
+
+    FIELDS = {
+      # 
+      SIMPLEQUERY => {:type => ::Thrift::Types::STRUCT, :name => 'simpleQuery', :class => ::Blur::SimpleQuery},
+      # 
+      EXPERTQUERY => {:type => ::Thrift::Types::STRUCT, :name => 'expertQuery', :class => ::Blur::ExpertQuery},
+      # 
+      FACETS => {:type => ::Thrift::Types::LIST, :name => 'facets', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::Facet}},
+      # Selector is used to fetch data in the search results, if null only location ids will be fetched.
+      SELECTOR => {:type => ::Thrift::Types::STRUCT, :name => 'selector', :class => ::Blur::Selector},
+      # @deprecated This value is no longer used.  This allows the query to see the most current data that has been added to the table.
+      ALLOWSTALEDATA => {:type => ::Thrift::Types::BOOL, :name => 'allowStaleData', :default => false},
+      # 
+      USECACHEIFPRESENT => {:type => ::Thrift::Types::BOOL, :name => 'useCacheIfPresent', :default => true},
+      # 
+      START => {:type => ::Thrift::Types::I64, :name => 'start', :default => 0},
+      # 
+      FETCH => {:type => ::Thrift::Types::I32, :name => 'fetch', :default => 10},
+      # 
+      MINIMUMNUMBEROFRESULTS => {:type => ::Thrift::Types::I64, :name => 'minimumNumberOfResults', :default => 9223372036854775807},
+      # 
+      MAXQUERYTIME => {:type => ::Thrift::Types::I64, :name => 'maxQueryTime', :default => 9223372036854775807},
+      # 
+      UUID => {:type => ::Thrift::Types::I64, :name => 'uuid'},
+      # 
+      USERCONTEXT => {:type => ::Thrift::Types::STRING, :name => 'userContext'},
+      # 
+      CACHERESULT => {:type => ::Thrift::Types::BOOL, :name => 'cacheResult', :default => true},
+      # 
+      STARTTIME => {:type => ::Thrift::Types::I64, :name => 'startTime', :default => 0},
+      # 
+      MODIFYFILECACHES => {:type => ::Thrift::Types::BOOL, :name => 'modifyFileCaches', :default => true}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class BlurResult
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    LOCATIONID = 1
+    SCORE = 2
+    FETCHRESULT = 3
+
+    FIELDS = {
+      # 
+      LOCATIONID => {:type => ::Thrift::Types::STRING, :name => 'locationId'},
+      # 
+      SCORE => {:type => ::Thrift::Types::DOUBLE, :name => 'score'},
+      # 
+      FETCHRESULT => {:type => ::Thrift::Types::STRUCT, :name => 'fetchResult', :class => ::Blur::FetchResult}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class BlurResults
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    TOTALRESULTS = 1
+    SHARDINFO = 2
+    RESULTS = 3
+    FACETCOUNTS = 4
+    EXCEPTIONS = 5
+    QUERY = 6
+
+    FIELDS = {
+      # 
+      TOTALRESULTS => {:type => ::Thrift::Types::I64, :name => 'totalResults', :default => 0},
+      # 
+      SHARDINFO => {:type => ::Thrift::Types::MAP, :name => 'shardInfo', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::I64}},
+      # 
+      RESULTS => {:type => ::Thrift::Types::LIST, :name => 'results', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::BlurResult}},
+      # 
+      FACETCOUNTS => {:type => ::Thrift::Types::LIST, :name => 'facetCounts', :element => {:type => ::Thrift::Types::I64}},
+      # 
+      EXCEPTIONS => {:type => ::Thrift::Types::LIST, :name => 'exceptions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::BlurException}},
+      # 
+      QUERY => {:type => ::Thrift::Types::STRUCT, :name => 'query', :class => ::Blur::BlurQuery}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class RecordMutation
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    RECORDMUTATIONTYPE = 1
+    RECORD = 2
+
+    FIELDS = {
+      # 
+      RECORDMUTATIONTYPE => {:type => ::Thrift::Types::I32, :name => 'recordMutationType', :enum_class => ::Blur::RecordMutationType},
+      # 
+      RECORD => {:type => ::Thrift::Types::STRUCT, :name => 'record', :class => ::Blur::Record}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+      unless @recordMutationType.nil? || ::Blur::RecordMutationType::VALID_VALUES.include?(@recordMutationType)
+        raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field recordMutationType!')
+      end
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class RowMutation
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    TABLE = 1
+    ROWID = 2
+    WAL = 3
+    ROWMUTATIONTYPE = 4
+    RECORDMUTATIONS = 5
+    WAITTOBEVISIBLE = 6
+
+    FIELDS = {
+      # The that that the row mutation is to act upon.
+      TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+      # The row id that the row mutation is to act upon.
+      ROWID => {:type => ::Thrift::Types::STRING, :name => 'rowId'},
+      # Write ahead log, by default all updates are written to a write ahead log before the update is applied.  That way if a failure occurs before the index is committed the WAL can be replayed to recover any data that could have been lost.
+      WAL => {:type => ::Thrift::Types::BOOL, :name => 'wal', :default => true},
+      ROWMUTATIONTYPE => {:type => ::Thrift::Types::I32, :name => 'rowMutationType', :enum_class => ::Blur::RowMutationType},
+      RECORDMUTATIONS => {:type => ::Thrift::Types::LIST, :name => 'recordMutations', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::RecordMutation}},
+      # On mutate waits for the mutation to be visible to queries and fetch requests.
+      WAITTOBEVISIBLE => {:type => ::Thrift::Types::BOOL, :name => 'waitToBeVisible', :default => false}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+      unless @rowMutationType.nil? || ::Blur::RowMutationType::VALID_VALUES.include?(@rowMutationType)
+        raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field rowMutationType!')
+      end
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class CpuTime
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    CPUTIME = 1
+    REALTIME = 2
+
+    FIELDS = {
+      # 
+      CPUTIME => {:type => ::Thrift::Types::I64, :name => 'cpuTime'},
+      # 
+      REALTIME => {:type => ::Thrift::Types::I64, :name => 'realTime'}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class BlurQueryStatus
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    QUERY = 1
+    CPUTIMES = 2
+    COMPLETESHARDS = 3
+    TOTALSHARDS = 4
+    STATE = 5
+    UUID = 6
+
+    FIELDS = {
+      # 
+      QUERY => {:type => ::Thrift::Types::STRUCT, :name => 'query', :class => ::Blur::BlurQuery},
+      # 
+      CPUTIMES => {:type => ::Thrift::Types::MAP, :name => 'cpuTimes', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::CpuTime}},
+      # 
+      COMPLETESHARDS => {:type => ::Thrift::Types::I32, :name => 'completeShards'},
+      # 
+      TOTALSHARDS => {:type => ::Thrift::Types::I32, :name => 'totalShards'},
+      # 
+      STATE => {:type => ::Thrift::Types::I32, :name => 'state', :enum_class => ::Blur::QueryState},
+      # 
+      UUID => {:type => ::Thrift::Types::I64, :name => 'uuid'}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+      unless @state.nil? || ::Blur::QueryState::VALID_VALUES.include?(@state)
+        raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field state!')
+      end
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class TableStats
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    TABLENAME = 1
+    BYTES = 2
+    RECORDCOUNT = 3
+    ROWCOUNT = 4
+    QUERIES = 5
+
+    FIELDS = {
+      # 
+      TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'},
+      # 
+      BYTES => {:type => ::Thrift::Types::I64, :name => 'bytes'},
+      # 
+      RECORDCOUNT => {:type => ::Thrift::Types::I64, :name => 'recordCount'},
+      # 
+      ROWCOUNT => {:type => ::Thrift::Types::I64, :name => 'rowCount'},
+      # 
+      QUERIES => {:type => ::Thrift::Types::I64, :name => 'queries'}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class Schema
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    TABLE = 1
+    COLUMNFAMILIES = 2
+
+    FIELDS = {
+      # 
+      TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+      # 
+      COLUMNFAMILIES => {:type => ::Thrift::Types::MAP, :name => 'columnFamilies', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::SET, :element => {:type => ::Thrift::Types::STRING}}}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class AlternateColumnDefinition
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    ANALYZERCLASSNAME = 1
+
+    FIELDS = {
+      # 
+      ANALYZERCLASSNAME => {:type => ::Thrift::Types::STRING, :name => 'analyzerClassName'}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class ColumnDefinition
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    ANALYZERCLASSNAME = 1
+    FULLTEXTINDEX = 2
+    ALTERNATECOLUMNDEFINITIONS = 3
+
+    FIELDS = {
+      ANALYZERCLASSNAME => {:type => ::Thrift::Types::STRING, :name => 'analyzerClassName', :default => %q"org.apache.lucene.analysis.standard.StandardAnalyzer"},
+      FULLTEXTINDEX => {:type => ::Thrift::Types::BOOL, :name => 'fullTextIndex'},
+      ALTERNATECOLUMNDEFINITIONS => {:type => ::Thrift::Types::MAP, :name => 'alternateColumnDefinitions', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::AlternateColumnDefinition}}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class ColumnFamilyDefinition
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    DEFAULTDEFINITION = 1
+    COLUMNDEFINITIONS = 2
+
+    FIELDS = {
+      # 
+      DEFAULTDEFINITION => {:type => ::Thrift::Types::STRUCT, :name => 'defaultDefinition', :class => ::Blur::ColumnDefinition},
+      # 
+      COLUMNDEFINITIONS => {:type => ::Thrift::Types::MAP, :name => 'columnDefinitions', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::ColumnDefinition}}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class AnalyzerDefinition
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    DEFAULTDEFINITION = 1
+    FULLTEXTANALYZERCLASSNAME = 2
+    COLUMNFAMILYDEFINITIONS = 3
+
+    FIELDS = {
+      # 
+      DEFAULTDEFINITION => {:type => ::Thrift::Types::STRUCT, :name => 'defaultDefinition', :class => ::Blur::ColumnDefinition},
+      # 
+      FULLTEXTANALYZERCLASSNAME => {:type => ::Thrift::Types::STRING, :name => 'fullTextAnalyzerClassName', :default => %q"org.apache.lucene.analysis.standard.StandardAnalyzer"},
+      # 
+      COLUMNFAMILYDEFINITIONS => {:type => ::Thrift::Types::MAP, :name => 'columnFamilyDefinitions', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::ColumnFamilyDefinition}}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class ColumnPreCache
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    PRECACHECOLS = 1
+
+    FIELDS = {
+      # This map sets what column families and columns to prefetch into block cache on shard open.
+      PRECACHECOLS => {:type => ::Thrift::Types::LIST, :name => 'preCacheCols', :element => {:type => ::Thrift::Types::STRING}}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+  # 
+  class TableDescriptor
+    include ::Thrift::Struct, ::Thrift::Struct_Union
+    ISENABLED = 1
+    ANALYZERDEFINITION = 2
+    SHARDCOUNT = 3
+    TABLEURI = 4
+    COMPRESSIONCLASS = 5
+    COMPRESSIONBLOCKSIZE = 6
+    CLUSTER = 7
+    NAME = 8
+    SIMILARITYCLASS = 9
+    BLOCKCACHING = 10
+    BLOCKCACHINGFILETYPES = 11
+    READONLY = 12
+    COLUMNPRECACHE = 13
+
+    FIELDS = {
+      # 
+      ISENABLED => {:type => ::Thrift::Types::BOOL, :name => 'isEnabled', :default => true},
+      # 
+      ANALYZERDEFINITION => {:type => ::Thrift::Types::STRUCT, :name => 'analyzerDefinition', :class => ::Blur::AnalyzerDefinition},
+      # 
+      SHARDCOUNT => {:type => ::Thrift::Types::I32, :name => 'shardCount', :default => 1},
+      # 
+      TABLEURI => {:type => ::Thrift::Types::STRING, :name => 'tableUri'},
+      # 
+      COMPRESSIONCLASS => {:type => ::Thrift::Types::STRING, :name => 'compressionClass', :default => %q"org.apache.hadoop.io.compress.DefaultCodec"},
+      # 
+      COMPRESSIONBLOCKSIZE => {:type => ::Thrift::Types::I32, :name => 'compressionBlockSize', :default => 32768},
+      # 
+      CLUSTER => {:type => ::Thrift::Types::STRING, :name => 'cluster', :default => %q"default"},
+      # 
+      NAME => {:type => ::Thrift::Types::STRING, :name => 'name'},
+      # 
+      SIMILARITYCLASS => {:type => ::Thrift::Types::STRING, :name => 'similarityClass'},
+      # 
+      BLOCKCACHING => {:type => ::Thrift::Types::BOOL, :name => 'blockCaching', :default => true},
+      # 
+      BLOCKCACHINGFILETYPES => {:type => ::Thrift::Types::SET, :name => 'blockCachingFileTypes', :element => {:type => ::Thrift::Types::STRING}},
+      # If a table is set to be readonly, that means that mutates through Thrift are NOT allowed.  However
+# updates through MapReduce are allowed and in fact they are only allowed if the table is in readOnly mode.
+      READONLY => {:type => ::Thrift::Types::BOOL, :name => 'readOnly', :default => false},
+      # Sets what column families and columns to prefetch into block cache on shard open.
+      COLUMNPRECACHE => {:type => ::Thrift::Types::STRUCT, :name => 'columnPreCache', :class => ::Blur::ColumnPreCache}
+    }
+
+    def struct_fields; FIELDS; end
+
+    def validate
+    end
+
+    ::Thrift::Struct.generate_accessors self
+  end
+
+end

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a4601422/src/distribution/src/main/scripts/interface/genAndReplace.sh
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/genAndReplace.sh b/src/distribution/src/main/scripts/interface/genAndReplace.sh
new file mode 100755
index 0000000..860716c
--- /dev/null
+++ b/src/distribution/src/main/scripts/interface/genAndReplace.sh
@@ -0,0 +1,28 @@
+#!/usr/bin/env bash
+
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+
+
+rm ../../../../../../src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/*
+rm -r gen-java/ gen-perl/ gen-rb/ gen-html/
+thrift --gen html --gen perl --gen java --gen rb Blur.thrift
+for f in gen-java/org/apache/blur/thrift/generated/*.java; do
+  awk -v f="apache.header" 'BEGIN {while (getline < f) txt=txt $0 "\n"} /package org\.apache\.blur\.thrift\.generated;/ {sub("package org.apache.blur.thrift.generated;", txt)} 1' $f > $f.new
+  rm $f
+  mv $f.new $f
+done
+cp -r gen-java/* ../../../../../../src/blur-thrift/src/main/java/

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a4601422/src/distribution/src/main/scripts/logs/.empty
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/logs/.empty b/src/distribution/src/main/scripts/logs/.empty
new file mode 100644
index 0000000..e69de29

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a4601422/src/distribution/src/main/scripts/pids/.empty
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/pids/.empty b/src/distribution/src/main/scripts/pids/.empty
new file mode 100644
index 0000000..e69de29

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a4601422/src/pom.xml
----------------------------------------------------------------------
diff --git a/src/pom.xml b/src/pom.xml
index e1a32d2..a789a44 100644
--- a/src/pom.xml
+++ b/src/pom.xml
@@ -20,24 +20,52 @@ under the License.
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 	<modelVersion>4.0.0</modelVersion>
+
+	<parent>
+		<groupId>org.apache</groupId>
+		<artifactId>apache</artifactId>
+		<version>11</version>
+	</parent>
+
 	<groupId>org.apache.blur</groupId>
 	<artifactId>blur</artifactId>
+	<version>0.1.5</version>
 	<packaging>pom</packaging>
-	<version>0.1.3</version>
+
 	<name>Blur</name>
+	<description>Blur is a search platform capable of searching massive amounts of data in a cloud computing environment.</description>
+	<url>http://incubator.apache.org/blur/</url>
+	<inceptionYear>2012</inceptionYear>
 	
+	<properties>
+		<hadoop.version>1.0.4</hadoop.version>
+		<zookeeper.version>3.4.5</zookeeper.version>
+		<log4j.version>1.2.15</log4j.version>
+		<jersey.version>1.14</jersey.version>
+		<lucene.version>4.1.0</lucene.version>
+		<junit.version>4.7</junit.version>
+		<thrift.version>0.9.0</thrift.version>
+		<slf4j.version>1.6.1</slf4j.version>
+		<commons-cli.version>1.2</commons-cli.version>
+		<concurrentlinkedhashmap-lru.version>1.3.2</concurrentlinkedhashmap-lru.version>
+		<jline.version>2.7</jline.version>
+		<guava.version>12.0</guava.version>
+		<metrics-core.version>2.2.0</metrics-core.version>
+	</properties>
+
 	<modules>
 		<module>blur-core</module>
-		<module>blur-demo</module>
 		<module>blur-thrift</module>
+		<module>blur-query</module>
 		<module>blur-store</module>
 		<module>blur-mapred</module>
 		<module>blur-util</module>
 		<module>blur-gui</module>
-		<module>blur-jdbc</module>
-                <module>blur-testsuite</module>
+		<module>blur-testsuite</module>
+		<!--module>blur-shell</module-->
+		<module>distribution</module>
 	</modules>
-	
+
 	<dependencies>
 		<dependency>
 			<groupId>junit</groupId>
@@ -46,4 +74,120 @@ under the License.
 			<scope>test</scope>
 		</dependency>
 	</dependencies>
+
+	<build>		
+		<plugins>
+			<plugin>
+				<groupId>org.apache.rat</groupId>
+				<artifactId>apache-rat-plugin</artifactId>
+				<configuration>
+					<excludes>
+						<exclude>**/generated/**</exclude>
+						<exclude>**/*min.js</exclude>
+						<exclude>**/input-data/*.txt</exclude>
+						<exclude>**/testsuite/words.txt</exclude>
+						<exclude>**/README.textile</exclude>
+					</excludes>
+				</configuration>
+			</plugin>
+		</plugins>
+
+		<pluginManagement>
+			<plugins>
+				<!-- Ignore/Execute plugin execution -->
+		        <plugin>
+		          <artifactId>maven-assembly-plugin</artifactId>
+		          <configuration>
+		            <descriptors>
+		              <descriptor>src/assemble/bin.xml</descriptor>
+		            </descriptors>
+		          </configuration>
+		        </plugin>
+				<plugin>
+					<groupId>org.eclipse.m2e</groupId>
+					<artifactId>lifecycle-mapping</artifactId>
+					<version>1.0.0</version>
+					<configuration>
+						<lifecycleMappingMetadata>
+							<pluginExecutions>
+								<!-- copy-dependency plugin -->
+								<pluginExecution>
+									<pluginExecutionFilter>
+										<groupId>org.apache.maven.plugins</groupId>
+										<artifactId>maven-dependency-plugin</artifactId>
+										<versionRange>[1.0.0,)</versionRange>
+										<goals>
+											<goal>copy-dependencies</goal>
+										</goals>
+									</pluginExecutionFilter>
+									<action>
+										<ignore />
+									</action>
+								</pluginExecution>
+							</pluginExecutions>
+						</lifecycleMappingMetadata>
+					</configuration>
+				</plugin>
+			</plugins>
+		</pluginManagement>
+	</build>
+	<profiles>
+		<profile>
+			<id>default</id>
+			<activation>
+				<activeByDefault>true</activeByDefault>
+			</activation>
+			<build>
+				<plugins>
+					<plugin>
+						<groupId>org.apache.maven.plugins</groupId>
+						<artifactId>maven-surefire-plugin</artifactId>
+						<configuration>
+							<excludes>
+								<exclude>**/IT*.java</exclude>
+							</excludes>
+							<systemPropertyVariables>
+								<blur.tmp.dir>${project.build.directory}/tmp</blur.tmp.dir>
+							</systemPropertyVariables>
+						</configuration>
+					</plugin>
+				</plugins>
+			</build>
+		</profile>
+		<profile>
+			<id>integration-test</id>
+			<activation>
+				<activeByDefault>false</activeByDefault>
+			</activation>
+			<build>
+				<plugins>
+					<plugin>
+						<groupId>org.apache.maven.plugins</groupId>
+						<artifactId>maven-surefire-plugin</artifactId>
+						<configuration>
+							<includes>
+								<include>**/IT*.java</include>
+							</includes>
+							<systemPropertyVariables>
+								<blur.tmp.dir>${project.build.directory}/tmp</blur.tmp.dir>
+							</systemPropertyVariables>
+						</configuration>
+					</plugin>
+					<plugin>
+						<groupId>org.apache.maven.plugins</groupId>
+						<artifactId>maven-failsafe-plugin</artifactId>
+						<version>2.12</version>
+						<executions>
+							<execution>
+								<goals>
+									<goal>integration-test</goal>
+									<goal>verify</goal>
+								</goals>
+							</execution>
+						</executions>
+					</plugin>
+				</plugins>
+			</build>
+		</profile>
+	</profiles>
 </project>


Mime
View raw message