incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [39/51] [abbrv] Massive changes to the the thrift API. Getting closer to the final version, this commit also removes the controller from the architecture.
Date Tue, 11 Dec 2012 02:21:00 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/aee531c2/interface/gen-rb/blur.rb
----------------------------------------------------------------------
diff --git a/interface/gen-rb/blur.rb b/interface/gen-rb/blur.rb
index b3fa84e..2288816 100644
--- a/interface/gen-rb/blur.rb
+++ b/interface/gen-rb/blur.rb
@@ -12,211 +12,191 @@ module Blur
     class Client
       include ::Thrift::Client
 
-      def shardClusterList()
-        send_shardClusterList()
-        return recv_shardClusterList()
+      def openReadSession(table)
+        send_openReadSession(table)
+        return recv_openReadSession()
       end
 
-      def send_shardClusterList()
-        send_message('shardClusterList', ShardClusterList_args)
+      def send_openReadSession(table)
+        send_message('openReadSession', OpenReadSession_args, :table => table)
       end
 
-      def recv_shardClusterList()
-        result = receive_message(ShardClusterList_result)
+      def recv_openReadSession()
+        result = receive_message(OpenReadSession_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')
+        raise result.e unless result.e.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'openReadSession failed: unknown result')
       end
 
-      def shardServerList(cluster)
-        send_shardServerList(cluster)
-        return recv_shardServerList()
+      def search(session, queryArgs)
+        send_search(session, queryArgs)
+        return recv_search()
       end
 
-      def send_shardServerList(cluster)
-        send_message('shardServerList', ShardServerList_args, :cluster => cluster)
+      def send_search(session, queryArgs)
+        send_message('search', Search_args, :session => session, :queryArgs => queryArgs)
       end
 
-      def recv_shardServerList()
-        result = receive_message(ShardServerList_result)
+      def recv_search()
+        result = receive_message(Search_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')
+        raise result.e unless result.e.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'search failed: unknown result')
       end
 
-      def controllerServerList()
-        send_controllerServerList()
-        return recv_controllerServerList()
+      def doc(session, docLocations, fields)
+        send_doc(session, docLocations, fields)
+        return recv_doc()
       end
 
-      def send_controllerServerList()
-        send_message('controllerServerList', ControllerServerList_args)
+      def send_doc(session, docLocations, fields)
+        send_message('doc', Doc_args, :session => session, :docLocations => docLocations, :fields => fields)
       end
 
-      def recv_controllerServerList()
-        result = receive_message(ControllerServerList_result)
+      def recv_doc()
+        result = receive_message(Doc_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')
+        raise result.e unless result.e.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'doc failed: unknown result')
       end
 
-      def shardServerLayout(table)
-        send_shardServerLayout(table)
-        return recv_shardServerLayout()
+      def closeReadSession(session)
+        send_closeReadSession(session)
+        recv_closeReadSession()
       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')
+      def send_closeReadSession(session)
+        send_message('closeReadSession', CloseReadSession_args, :session => session)
       end
 
-      def tableList()
-        send_tableList()
-        return recv_tableList()
-      end
-
-      def send_tableList()
-        send_message('tableList', TableList_args)
+      def recv_closeReadSession()
+        result = receive_message(CloseReadSession_result)
+        raise result.e unless result.e.nil?
+        return
       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')
+      def addDocuments(options, documents)
+        send_addDocuments(options, documents)
+        recv_addDocuments()
       end
 
-      def tableListByCluster(cluster)
-        send_tableListByCluster(cluster)
-        return recv_tableListByCluster()
+      def send_addDocuments(options, documents)
+        send_message('addDocuments', AddDocuments_args, :options => options, :documents => documents)
       end
 
-      def send_tableListByCluster(cluster)
-        send_message('tableListByCluster', TableListByCluster_args, :cluster => cluster)
+      def recv_addDocuments()
+        result = receive_message(AddDocuments_result)
+        raise result.e unless result.e.nil?
+        return
       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')
+      def deleteDocumentsByQueries(options, queries)
+        send_deleteDocumentsByQueries(options, queries)
+        recv_deleteDocumentsByQueries()
       end
 
-      def describe(table)
-        send_describe(table)
-        return recv_describe()
+      def send_deleteDocumentsByQueries(options, queries)
+        send_message('deleteDocumentsByQueries', DeleteDocumentsByQueries_args, :options => options, :queries => queries)
       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')
+      def recv_deleteDocumentsByQueries()
+        result = receive_message(DeleteDocumentsByQueries_result)
+        raise result.e unless result.e.nil?
+        return
       end
 
-      def cancelQuery(table, uuid)
-        send_cancelQuery(table, uuid)
-        recv_cancelQuery()
+      def deleteDocuments(options, terms)
+        send_deleteDocuments(options, terms)
+        recv_deleteDocuments()
       end
 
-      def send_cancelQuery(table, uuid)
-        send_message('cancelQuery', CancelQuery_args, :table => table, :uuid => uuid)
+      def send_deleteDocuments(options, terms)
+        send_message('deleteDocuments', DeleteDocuments_args, :options => options, :terms => terms)
       end
 
-      def recv_cancelQuery()
-        result = receive_message(CancelQuery_result)
-        raise result.ex unless result.ex.nil?
+      def recv_deleteDocuments()
+        result = receive_message(DeleteDocuments_result)
+        raise result.e unless result.e.nil?
         return
       end
 
-      def currentQueries(table)
-        send_currentQueries(table)
-        return recv_currentQueries()
+      def updateDocuments(options, updatePackages)
+        send_updateDocuments(options, updatePackages)
+        recv_updateDocuments()
       end
 
-      def send_currentQueries(table)
-        send_message('currentQueries', CurrentQueries_args, :table => table)
+      def send_updateDocuments(options, updatePackages)
+        send_message('updateDocuments', UpdateDocuments_args, :options => options, :updatePackages => updatePackages)
       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')
+      def recv_updateDocuments()
+        result = receive_message(UpdateDocuments_result)
+        raise result.e unless result.e.nil?
+        return
       end
 
-      def queryStatusIdList(table)
-        send_queryStatusIdList(table)
-        return recv_queryStatusIdList()
+      def serverList()
+        send_serverList()
+        return recv_serverList()
       end
 
-      def send_queryStatusIdList(table)
-        send_message('queryStatusIdList', QueryStatusIdList_args, :table => table)
+      def send_serverList()
+        send_message('serverList', ServerList_args)
       end
 
-      def recv_queryStatusIdList()
-        result = receive_message(QueryStatusIdList_result)
+      def recv_serverList()
+        result = receive_message(ServerList_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')
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'serverList failed: unknown result')
       end
 
-      def queryStatusById(table, uuid)
-        send_queryStatusById(table, uuid)
-        return recv_queryStatusById()
+      def serverLayout(table, server)
+        send_serverLayout(table, server)
+        return recv_serverLayout()
       end
 
-      def send_queryStatusById(table, uuid)
-        send_message('queryStatusById', QueryStatusById_args, :table => table, :uuid => uuid)
+      def send_serverLayout(table, server)
+        send_message('serverLayout', ServerLayout_args, :table => table, :server => server)
       end
 
-      def recv_queryStatusById()
-        result = receive_message(QueryStatusById_result)
+      def recv_serverLayout()
+        result = receive_message(ServerLayout_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')
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'serverLayout failed: unknown result')
       end
 
-      def schema(table)
-        send_schema(table)
-        return recv_schema()
+      def tableList()
+        send_tableList()
+        return recv_tableList()
       end
 
-      def send_schema(table)
-        send_message('schema', Schema_args, :table => table)
+      def send_tableList()
+        send_message('tableList', TableList_args)
       end
 
-      def recv_schema()
-        result = receive_message(Schema_result)
+      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, 'schema failed: unknown result')
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'tableList failed: unknown result')
       end
 
-      def tableStats(table)
-        send_tableStats(table)
-        return recv_tableStats()
+      def isInSafeMode()
+        send_isInSafeMode()
+        return recv_isInSafeMode()
       end
 
-      def send_tableStats(table)
-        send_message('tableStats', TableStats_args, :table => table)
+      def send_isInSafeMode()
+        send_message('isInSafeMode', IsInSafeMode_args)
       end
 
-      def recv_tableStats()
-        result = receive_message(TableStats_result)
+      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, 'tableStats failed: unknown result')
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'isInSafeMode failed: unknown result')
       end
 
       def createTable(tableDescriptor)
@@ -279,51 +259,99 @@ module Blur
         return
       end
 
-      def optimize(table, numberOfSegmentsPerShard)
-        send_optimize(table, numberOfSegmentsPerShard)
-        recv_optimize()
+      def describe(table)
+        send_describe(table)
+        return recv_describe()
       end
 
-      def send_optimize(table, numberOfSegmentsPerShard)
-        send_message('optimize', Optimize_args, :table => table, :numberOfSegmentsPerShard => numberOfSegmentsPerShard)
+      def send_describe(table)
+        send_message('describe', Describe_args, :table => table)
       end
 
-      def recv_optimize()
-        result = receive_message(Optimize_result)
+      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 cancelQuery(session, id)
+        send_cancelQuery(session, id)
+        recv_cancelQuery()
+      end
+
+      def send_cancelQuery(session, id)
+        send_message('cancelQuery', CancelQuery_args, :session => session, :id => id)
+      end
+
+      def recv_cancelQuery()
+        result = receive_message(CancelQuery_result)
         raise result.ex unless result.ex.nil?
         return
       end
 
-      def isInSafeMode(cluster)
-        send_isInSafeMode(cluster)
-        return recv_isInSafeMode()
+      def queryStatusIdList(session)
+        send_queryStatusIdList(session)
+        return recv_queryStatusIdList()
       end
 
-      def send_isInSafeMode(cluster)
-        send_message('isInSafeMode', IsInSafeMode_args, :cluster => cluster)
+      def send_queryStatusIdList(session)
+        send_message('queryStatusIdList', QueryStatusIdList_args, :session => session)
       end
 
-      def recv_isInSafeMode()
-        result = receive_message(IsInSafeMode_result)
+      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, 'isInSafeMode failed: unknown result')
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'queryStatusIdList failed: unknown result')
       end
 
-      def configuration()
-        send_configuration()
-        return recv_configuration()
+      def queryStatus(session, id)
+        send_queryStatus(session, id)
+        return recv_queryStatus()
       end
 
-      def send_configuration()
-        send_message('configuration', Configuration_args)
+      def send_queryStatus(session, id)
+        send_message('queryStatus', QueryStatus_args, :session => session, :id => id)
       end
 
-      def recv_configuration()
-        result = receive_message(Configuration_result)
+      def recv_queryStatus()
+        result = receive_message(QueryStatus_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')
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'queryStatus 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 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
 
     end
@@ -331,147 +359,136 @@ module Blur
     class Processor
       include ::Thrift::Processor
 
-      def process_shardClusterList(seqid, iprot, oprot)
-        args = read_args(iprot, ShardClusterList_args)
-        result = ShardClusterList_result.new()
+      def process_openReadSession(seqid, iprot, oprot)
+        args = read_args(iprot, OpenReadSession_args)
+        result = OpenReadSession_result.new()
         begin
-          result.success = @handler.shardClusterList()
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
+          result.success = @handler.openReadSession(args.table)
+        rescue ::Blur::BlurException => e
+          result.e = e
         end
-        write_result(result, oprot, 'shardClusterList', seqid)
+        write_result(result, oprot, 'openReadSession', seqid)
       end
 
-      def process_shardServerList(seqid, iprot, oprot)
-        args = read_args(iprot, ShardServerList_args)
-        result = ShardServerList_result.new()
+      def process_search(seqid, iprot, oprot)
+        args = read_args(iprot, Search_args)
+        result = Search_result.new()
         begin
-          result.success = @handler.shardServerList(args.cluster)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
+          result.success = @handler.search(args.session, args.queryArgs)
+        rescue ::Blur::BlurException => e
+          result.e = e
         end
-        write_result(result, oprot, 'shardServerList', seqid)
+        write_result(result, oprot, 'search', seqid)
       end
 
-      def process_controllerServerList(seqid, iprot, oprot)
-        args = read_args(iprot, ControllerServerList_args)
-        result = ControllerServerList_result.new()
+      def process_doc(seqid, iprot, oprot)
+        args = read_args(iprot, Doc_args)
+        result = Doc_result.new()
         begin
-          result.success = @handler.controllerServerList()
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
+          result.success = @handler.doc(args.session, args.docLocations, args.fields)
+        rescue ::Blur::BlurException => e
+          result.e = e
         end
-        write_result(result, oprot, 'controllerServerList', seqid)
+        write_result(result, oprot, 'doc', seqid)
       end
 
-      def process_shardServerLayout(seqid, iprot, oprot)
-        args = read_args(iprot, ShardServerLayout_args)
-        result = ShardServerLayout_result.new()
+      def process_closeReadSession(seqid, iprot, oprot)
+        args = read_args(iprot, CloseReadSession_args)
+        result = CloseReadSession_result.new()
         begin
-          result.success = @handler.shardServerLayout(args.table)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
+          @handler.closeReadSession(args.session)
+        rescue ::Blur::BlurException => e
+          result.e = e
         end
-        write_result(result, oprot, 'shardServerLayout', seqid)
+        write_result(result, oprot, 'closeReadSession', seqid)
       end
 
-      def process_tableList(seqid, iprot, oprot)
-        args = read_args(iprot, TableList_args)
-        result = TableList_result.new()
+      def process_addDocuments(seqid, iprot, oprot)
+        args = read_args(iprot, AddDocuments_args)
+        result = AddDocuments_result.new()
         begin
-          result.success = @handler.tableList()
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
+          @handler.addDocuments(args.options, args.documents)
+        rescue ::Blur::BlurException => e
+          result.e = e
         end
-        write_result(result, oprot, 'tableList', seqid)
+        write_result(result, oprot, 'addDocuments', seqid)
       end
 
-      def process_tableListByCluster(seqid, iprot, oprot)
-        args = read_args(iprot, TableListByCluster_args)
-        result = TableListByCluster_result.new()
+      def process_deleteDocumentsByQueries(seqid, iprot, oprot)
+        args = read_args(iprot, DeleteDocumentsByQueries_args)
+        result = DeleteDocumentsByQueries_result.new()
         begin
-          result.success = @handler.tableListByCluster(args.cluster)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
+          @handler.deleteDocumentsByQueries(args.options, args.queries)
+        rescue ::Blur::BlurException => e
+          result.e = e
         end
-        write_result(result, oprot, 'tableListByCluster', seqid)
+        write_result(result, oprot, 'deleteDocumentsByQueries', seqid)
       end
 
-      def process_describe(seqid, iprot, oprot)
-        args = read_args(iprot, Describe_args)
-        result = Describe_result.new()
+      def process_deleteDocuments(seqid, iprot, oprot)
+        args = read_args(iprot, DeleteDocuments_args)
+        result = DeleteDocuments_result.new()
         begin
-          result.success = @handler.describe(args.table)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
+          @handler.deleteDocuments(args.options, args.terms)
+        rescue ::Blur::BlurException => e
+          result.e = e
         end
-        write_result(result, oprot, 'describe', seqid)
+        write_result(result, oprot, 'deleteDocuments', seqid)
       end
 
-      def process_cancelQuery(seqid, iprot, oprot)
-        args = read_args(iprot, CancelQuery_args)
-        result = CancelQuery_result.new()
+      def process_updateDocuments(seqid, iprot, oprot)
+        args = read_args(iprot, UpdateDocuments_args)
+        result = UpdateDocuments_result.new()
         begin
-          @handler.cancelQuery(args.table, args.uuid)
-        rescue ::Blur::BlurException => ex
-          result.ex = ex
+          @handler.updateDocuments(args.options, args.updatePackages)
+        rescue ::Blur::BlurException => e
+          result.e = e
         end
-        write_result(result, oprot, 'cancelQuery', seqid)
+        write_result(result, oprot, 'updateDocuments', seqid)
       end
 
-      def process_currentQueries(seqid, iprot, oprot)
-        args = read_args(iprot, CurrentQueries_args)
-        result = CurrentQueries_result.new()
+      def process_serverList(seqid, iprot, oprot)
+        args = read_args(iprot, ServerList_args)
+        result = ServerList_result.new()
         begin
-          result.success = @handler.currentQueries(args.table)
+          result.success = @handler.serverList()
         rescue ::Blur::BlurException => ex
           result.ex = ex
         end
-        write_result(result, oprot, 'currentQueries', seqid)
+        write_result(result, oprot, 'serverList', 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()
+      def process_serverLayout(seqid, iprot, oprot)
+        args = read_args(iprot, ServerLayout_args)
+        result = ServerLayout_result.new()
         begin
-          result.success = @handler.queryStatusById(args.table, args.uuid)
+          result.success = @handler.serverLayout(args.table, args.server)
         rescue ::Blur::BlurException => ex
           result.ex = ex
         end
-        write_result(result, oprot, 'queryStatusById', seqid)
+        write_result(result, oprot, 'serverLayout', seqid)
       end
 
-      def process_schema(seqid, iprot, oprot)
-        args = read_args(iprot, Schema_args)
-        result = Schema_result.new()
+      def process_tableList(seqid, iprot, oprot)
+        args = read_args(iprot, TableList_args)
+        result = TableList_result.new()
         begin
-          result.success = @handler.schema(args.table)
+          result.success = @handler.tableList()
         rescue ::Blur::BlurException => ex
           result.ex = ex
         end
-        write_result(result, oprot, 'schema', seqid)
+        write_result(result, oprot, 'tableList', seqid)
       end
 
-      def process_tableStats(seqid, iprot, oprot)
-        args = read_args(iprot, TableStats_args)
-        result = TableStats_result.new()
+      def process_isInSafeMode(seqid, iprot, oprot)
+        args = read_args(iprot, IsInSafeMode_args)
+        result = IsInSafeMode_result.new()
         begin
-          result.success = @handler.tableStats(args.table)
+          result.success = @handler.isInSafeMode()
         rescue ::Blur::BlurException => ex
           result.ex = ex
         end
-        write_result(result, oprot, 'tableStats', seqid)
+        write_result(result, oprot, 'isInSafeMode', seqid)
       end
 
       def process_createTable(seqid, iprot, oprot)
@@ -518,48 +535,118 @@ module Blur
         write_result(result, oprot, 'removeTable', seqid)
       end
 
-      def process_optimize(seqid, iprot, oprot)
-        args = read_args(iprot, Optimize_args)
-        result = Optimize_result.new()
+      def process_describe(seqid, iprot, oprot)
+        args = read_args(iprot, Describe_args)
+        result = Describe_result.new()
         begin
-          @handler.optimize(args.table, args.numberOfSegmentsPerShard)
+          result.success = @handler.describe(args.table)
         rescue ::Blur::BlurException => ex
           result.ex = ex
         end
-        write_result(result, oprot, 'optimize', seqid)
+        write_result(result, oprot, 'describe', seqid)
       end
 
-      def process_isInSafeMode(seqid, iprot, oprot)
-        args = read_args(iprot, IsInSafeMode_args)
-        result = IsInSafeMode_result.new()
+      def process_cancelQuery(seqid, iprot, oprot)
+        args = read_args(iprot, CancelQuery_args)
+        result = CancelQuery_result.new()
         begin
-          result.success = @handler.isInSafeMode(args.cluster)
+          @handler.cancelQuery(args.session, args.id)
         rescue ::Blur::BlurException => ex
           result.ex = ex
         end
-        write_result(result, oprot, 'isInSafeMode', seqid)
+        write_result(result, oprot, 'cancelQuery', seqid)
+      end
+
+      def process_queryStatusIdList(seqid, iprot, oprot)
+        args = read_args(iprot, QueryStatusIdList_args)
+        result = QueryStatusIdList_result.new()
+        begin
+          result.success = @handler.queryStatusIdList(args.session)
+        rescue ::Blur::BlurException => ex
+          result.ex = ex
+        end
+        write_result(result, oprot, 'queryStatusIdList', seqid)
       end
 
-      def process_configuration(seqid, iprot, oprot)
-        args = read_args(iprot, Configuration_args)
-        result = Configuration_result.new()
+      def process_queryStatus(seqid, iprot, oprot)
+        args = read_args(iprot, QueryStatus_args)
+        result = QueryStatus_result.new()
         begin
-          result.success = @handler.configuration()
+          result.success = @handler.queryStatus(args.session, args.id)
         rescue ::Blur::BlurException => ex
           result.ex = ex
         end
-        write_result(result, oprot, 'configuration', seqid)
+        write_result(result, oprot, 'queryStatus', 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_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
 
     end
 
     # HELPER FUNCTIONS AND STRUCTURES
 
-    class ShardClusterList_args
+    class OpenReadSession_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 OpenReadSession_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      E = 1
 
       FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::Session},
+        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
+      }
+
+      def struct_fields; FIELDS; end
 
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class Search_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SESSION = 1
+      QUERYARGS = 2
+
+      FIELDS = {
+        SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session},
+        QUERYARGS => {:type => ::Thrift::Types::STRUCT, :name => 'queryArgs', :class => ::Blur::QueryArgs}
       }
 
       def struct_fields; FIELDS; end
@@ -570,14 +657,14 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class ShardClusterList_result
+    class Search_result
       include ::Thrift::Struct, ::Thrift::Struct_Union
       SUCCESS = 0
-      EX = 1
+      E = 1
 
       FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::TopFieldDocs}},
+        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
       }
 
       def struct_fields; FIELDS; end
@@ -588,12 +675,16 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class ShardServerList_args
+    class Doc_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      CLUSTER = 1
+      SESSION = 1
+      DOCLOCATIONS = 2
+      FIELDS = 4
 
       FIELDS = {
-        CLUSTER => {:type => ::Thrift::Types::STRING, :name => 'cluster'}
+        SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session},
+        DOCLOCATIONS => {:type => ::Thrift::Types::LIST, :name => 'docLocations', :element => {:type => ::Thrift::Types::I64}},
+        FIELDS => {:type => ::Thrift::Types::SET, :name => 'fields', :element => {:type => ::Thrift::Types::STRING}}
       }
 
       def struct_fields; FIELDS; end
@@ -604,14 +695,14 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class ShardServerList_result
+    class Doc_result
       include ::Thrift::Struct, ::Thrift::Struct_Union
       SUCCESS = 0
-      EX = 1
+      E = 1
 
       FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::Document}},
+        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
       }
 
       def struct_fields; FIELDS; end
@@ -622,11 +713,28 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class ControllerServerList_args
+    class CloseReadSession_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
+      SESSION = 1
 
       FIELDS = {
+        SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session}
+      }
 
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class CloseReadSession_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      E = 1
+
+      FIELDS = {
+        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
       }
 
       def struct_fields; FIELDS; end
@@ -637,14 +745,14 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class ControllerServerList_result
+    class AddDocuments_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
+      OPTIONS = 1
+      DOCUMENTS = 2
 
       FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+        OPTIONS => {:type => ::Thrift::Types::STRUCT, :name => 'options', :class => ::Blur::MutateOptions},
+        DOCUMENTS => {:type => ::Thrift::Types::LIST, :name => 'documents', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::Document}}
       }
 
       def struct_fields; FIELDS; end
@@ -655,12 +763,12 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class ShardServerLayout_args
+    class AddDocuments_result
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
+      E = 1
 
       FIELDS = {
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
+        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
       }
 
       def struct_fields; FIELDS; end
@@ -671,14 +779,14 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class ShardServerLayout_result
+    class DeleteDocumentsByQueries_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
+      OPTIONS = 1
+      QUERIES = 2
 
       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}
+        OPTIONS => {:type => ::Thrift::Types::STRUCT, :name => 'options', :class => ::Blur::MutateOptions},
+        QUERIES => {:type => ::Thrift::Types::LIST, :name => 'queries', :element => {:type => ::Thrift::Types::STRING, :binary => true}}
       }
 
       def struct_fields; FIELDS; end
@@ -689,11 +797,30 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class TableList_args
+    class DeleteDocumentsByQueries_result
       include ::Thrift::Struct, ::Thrift::Struct_Union
+      E = 1
 
       FIELDS = {
+        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class DeleteDocuments_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      OPTIONS = 1
+      TERMS = 2
 
+      FIELDS = {
+        OPTIONS => {:type => ::Thrift::Types::STRUCT, :name => 'options', :class => ::Blur::MutateOptions},
+        TERMS => {:type => ::Thrift::Types::LIST, :name => 'terms', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::Term}}
       }
 
       def struct_fields; FIELDS; end
@@ -704,14 +831,12 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class TableList_result
+    class DeleteDocuments_result
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
+      E = 1
 
       FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
       }
 
       def struct_fields; FIELDS; end
@@ -722,12 +847,14 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class TableListByCluster_args
+    class UpdateDocuments_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      CLUSTER = 1
+      OPTIONS = 1
+      UPDATEPACKAGES = 2
 
       FIELDS = {
-        CLUSTER => {:type => ::Thrift::Types::STRING, :name => 'cluster'}
+        OPTIONS => {:type => ::Thrift::Types::STRUCT, :name => 'options', :class => ::Blur::MutateOptions},
+        UPDATEPACKAGES => {:type => ::Thrift::Types::LIST, :name => 'updatePackages', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::UpdatePackage}}
       }
 
       def struct_fields; FIELDS; end
@@ -738,14 +865,12 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class TableListByCluster_result
+    class UpdateDocuments_result
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      EX = 1
+      E = 1
 
       FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
-        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
       }
 
       def struct_fields; FIELDS; end
@@ -756,12 +881,11 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class Describe_args
+    class ServerList_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
 
       FIELDS = {
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
+
       }
 
       def struct_fields; FIELDS; end
@@ -772,13 +896,13 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class Describe_result
+    class ServerList_result
       include ::Thrift::Struct, ::Thrift::Struct_Union
       SUCCESS = 0
       EX = 1
 
       FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::TableDescriptor},
+        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
         EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
       }
 
@@ -790,14 +914,14 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class CancelQuery_args
+    class ServerLayout_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
       TABLE = 1
-      UUID = 2
+      SERVER = 2
 
       FIELDS = {
         TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        UUID => {:type => ::Thrift::Types::I64, :name => 'uuid'}
+        SERVER => {:type => ::Thrift::Types::STRING, :name => 'server'}
       }
 
       def struct_fields; FIELDS; end
@@ -808,11 +932,13 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class CancelQuery_result
+    class ServerLayout_result
       include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
       EX = 1
 
       FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::I32}},
         EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
       }
 
@@ -824,12 +950,11 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class CurrentQueries_args
+    class TableList_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
 
       FIELDS = {
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
+
       }
 
       def struct_fields; FIELDS; end
@@ -840,13 +965,13 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class CurrentQueries_result
+    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::STRUCT, :class => ::Blur::BlurQueryStatus}},
+        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
         EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
       }
 
@@ -858,12 +983,11 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class QueryStatusIdList_args
+    class IsInSafeMode_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
 
       FIELDS = {
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
+
       }
 
       def struct_fields; FIELDS; end
@@ -874,13 +998,13 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class QueryStatusIdList_result
+    class IsInSafeMode_result
       include ::Thrift::Struct, ::Thrift::Struct_Union
       SUCCESS = 0
       EX = 1
 
       FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::I64}},
+        SUCCESS => {:type => ::Thrift::Types::BOOL, :name => 'success'},
         EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
       }
 
@@ -892,14 +1016,12 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class QueryStatusById_args
+    class CreateTable_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      UUID = 2
+      TABLEDESCRIPTOR = 1
 
       FIELDS = {
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        UUID => {:type => ::Thrift::Types::I64, :name => 'uuid'}
+        TABLEDESCRIPTOR => {:type => ::Thrift::Types::STRUCT, :name => 'tableDescriptor', :class => ::Blur::TableDescriptor}
       }
 
       def struct_fields; FIELDS; end
@@ -910,13 +1032,11 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class QueryStatusById_result
+    class CreateTable_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}
       }
 
@@ -928,7 +1048,7 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class Schema_args
+    class EnableTable_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
       TABLE = 1
 
@@ -944,13 +1064,11 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class Schema_result
+    class EnableTable_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}
       }
 
@@ -962,7 +1080,7 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class TableStats_args
+    class DisableTable_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
       TABLE = 1
 
@@ -978,13 +1096,11 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class TableStats_result
+    class DisableTable_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}
       }
 
@@ -996,12 +1112,14 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class CreateTable_args
+    class RemoveTable_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLEDESCRIPTOR = 1
+      TABLE = 1
+      DELETEINDEXFILES = 2
 
       FIELDS = {
-        TABLEDESCRIPTOR => {:type => ::Thrift::Types::STRUCT, :name => 'tableDescriptor', :class => ::Blur::TableDescriptor}
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+        DELETEINDEXFILES => {:type => ::Thrift::Types::BOOL, :name => 'deleteIndexFiles'}
       }
 
       def struct_fields; FIELDS; end
@@ -1012,7 +1130,7 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class CreateTable_result
+    class RemoveTable_result
       include ::Thrift::Struct, ::Thrift::Struct_Union
       EX = 1
 
@@ -1028,7 +1146,7 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class EnableTable_args
+    class Describe_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
       TABLE = 1
 
@@ -1044,11 +1162,13 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class EnableTable_result
+    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}
       }
 
@@ -1060,12 +1180,14 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class DisableTable_args
+    class CancelQuery_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
+      SESSION = 1
+      ID = 2
 
       FIELDS = {
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
+        SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session},
+        ID => {:type => ::Thrift::Types::I64, :name => 'id'}
       }
 
       def struct_fields; FIELDS; end
@@ -1076,7 +1198,7 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class DisableTable_result
+    class CancelQuery_result
       include ::Thrift::Struct, ::Thrift::Struct_Union
       EX = 1
 
@@ -1092,14 +1214,12 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class RemoveTable_args
+    class QueryStatusIdList_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      DELETEINDEXFILES = 2
+      SESSION = 1
 
       FIELDS = {
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        DELETEINDEXFILES => {:type => ::Thrift::Types::BOOL, :name => 'deleteIndexFiles'}
+        SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session}
       }
 
       def struct_fields; FIELDS; end
@@ -1110,11 +1230,13 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class RemoveTable_result
+    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}
       }
 
@@ -1126,14 +1248,14 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class Optimize_args
+    class QueryStatus_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      TABLE = 1
-      NUMBEROFSEGMENTSPERSHARD = 2
+      SESSION = 1
+      ID = 2
 
       FIELDS = {
-        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-        NUMBEROFSEGMENTSPERSHARD => {:type => ::Thrift::Types::I32, :name => 'numberOfSegmentsPerShard'}
+        SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session},
+        ID => {:type => ::Thrift::Types::I64, :name => 'id'}
       }
 
       def struct_fields; FIELDS; end
@@ -1144,11 +1266,13 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class Optimize_result
+    class QueryStatus_result
       include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
       EX = 1
 
       FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::QueryStatus},
         EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
       }
 
@@ -1160,12 +1284,12 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class IsInSafeMode_args
+    class Schema_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      CLUSTER = 1
+      TABLE = 1
 
       FIELDS = {
-        CLUSTER => {:type => ::Thrift::Types::STRING, :name => 'cluster'}
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
       }
 
       def struct_fields; FIELDS; end
@@ -1176,13 +1300,13 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class IsInSafeMode_result
+    class Schema_result
       include ::Thrift::Struct, ::Thrift::Struct_Union
       SUCCESS = 0
       EX = 1
 
       FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::BOOL, :name => 'success'},
+        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::LiveSchema},
         EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
       }
 
@@ -1194,11 +1318,12 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class Configuration_args
+    class TableStats_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
 
       FIELDS = {
-
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
       }
 
       def struct_fields; FIELDS; end
@@ -1209,13 +1334,13 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
-    class Configuration_result
+    class TableStats_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}},
+        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::TableStats},
         EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
       }
 

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/aee531c2/interface/gen-rb/blur_types.rb
----------------------------------------------------------------------
diff --git a/interface/gen-rb/blur_types.rb b/interface/gen-rb/blur_types.rb
index ac438c4..864c44a 100644
--- a/interface/gen-rb/blur_types.rb
+++ b/interface/gen-rb/blur_types.rb
@@ -7,15 +7,6 @@
 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
@@ -37,37 +28,26 @@ module Blur
   end
 
   module SortType
-    # Sort by document score (relevance).  Sort values are Float and higher
-# values are at the front.
+    # Sort by document score (relevance).  Sort values are Float and higher values are at the front.
     SCORE = 0
-    # Sort by document number (index order).  Sort values are Integer and lower
-# values are at the front.
+    # Sort by document number (index order).  Sort values are Integer and lower values are at the front.
     DOC = 1
-    # Sort using term values as Strings.  Sort values are String and lower
-# values are at the front.
+    # Sort using term values as Strings.  Sort values are String and lower values are at the front.
     STRING = 2
-    # Sort using term values as encoded Integers.  Sort values are Integer and
-# lower values are at the front.
+    # Sort using term values as encoded Integers.  Sort values are Integer and lower values are at the front.
     INT = 3
-    # Sort using term values as encoded Floats.  Sort values are Float and
-# lower values are at the front.
+    # Sort using term values as encoded Floats.  Sort values are Float and lower values are at the front.
     FLOAT = 4
-    # Sort using term values as encoded Longs.  Sort values are Long and
-# lower values are at the front.
+    # Sort using term values as encoded Longs.  Sort values are Long and lower values are at the front.
     LONG = 5
-    # Sort using term values as encoded Doubles.  Sort values are Double and
-# lower values are at the front.
+    # Sort using term values as encoded Doubles.  Sort values are Double and lower values are at the front.
     DOUBLE = 6
-    # Sort using term values as encoded Shorts.  Sort values are Short and
-# lower values are at the front.
+    # Sort using term values as encoded Shorts.  Sort values are Short and lower values are at the front.
     SHORT = 7
-    # Sort using term values as encoded Bytes.  Sort values are Byte and
-# lower values are at the front.
+    # Sort using term values as encoded Bytes.  Sort values are Byte and lower values are at the front.
     BYTE = 8
-    # Sort using term values as Strings, but comparing by
-# value (using String.compareTo) for all comparisons.
-# This is typically slower than {@link #STRING}, which
-# uses ordinals to do the sorting.
+    # Sort using term values as Strings, but comparing by value (using String.compareTo) for all
+# comparisons. This is typically slower than {@link #STRING}, which uses ordinals to do the sorting.
     STRING_VAL = 9
     # Sort use byte[] index values.
     BYTES = 10
@@ -119,13 +99,12 @@ module Blur
   end
 
   # 
-  class BlurQueryStatus
+  class QueryStatus
     include ::Thrift::Struct, ::Thrift::Struct_Union
-    CPUTIMES = 2
-    COMPLETESHARDS = 3
-    TOTALSHARDS = 4
-    STATE = 5
-    UUID = 6
+    CPUTIMES = 1
+    COMPLETESHARDS = 2
+    TOTALSHARDS = 3
+    STATE = 4
 
     FIELDS = {
       # 
@@ -135,9 +114,7 @@ module Blur
       # 
       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'}
+      STATE => {:type => ::Thrift::Types::I32, :name => 'state', :enum_class => ::Blur::QueryState}
     }
 
     def struct_fields; FIELDS; end
@@ -154,21 +131,15 @@ module Blur
   # 
   class TableStats
     include ::Thrift::Struct, ::Thrift::Struct_Union
-    TABLENAME = 1
-    BYTES = 2
-    RECORDCOUNT = 3
-    ROWCOUNT = 4
-    QUERIES = 5
+    BYTES = 1
+    DOCUMENTCOUNT = 2
+    QUERIES = 3
 
     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'},
+      DOCUMENTCOUNT => {:type => ::Thrift::Types::I64, :name => 'documentCount'},
       # 
       QUERIES => {:type => ::Thrift::Types::I64, :name => 'queries'}
     }
@@ -182,7 +153,7 @@ module Blur
   end
 
   # 
-  class Schema
+  class LiveSchema
     include ::Thrift::Struct, ::Thrift::Struct_Union
     TABLE = 1
     COLUMNFAMILIES = 2
@@ -202,35 +173,14 @@ module Blur
     ::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
+  class ClassDefinition
     include ::Thrift::Struct, ::Thrift::Struct_Union
-    ANALYZERCLASSNAME = 1
-    FULLTEXTINDEX = 2
-    ALTERNATECOLUMNDEFINITIONS = 3
+    CLASSNAME = 1
+    ARGUMENTS = 2
 
     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}}
+      CLASSNAME => {:type => ::Thrift::Types::STRING, :name => 'className'},
+      ARGUMENTS => {:type => ::Thrift::Types::MAP, :name => 'arguments', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING, :binary => true}}
     }
 
     def struct_fields; FIELDS; end
@@ -241,17 +191,14 @@ module Blur
     ::Thrift::Struct.generate_accessors self
   end
 
-  # 
-  class ColumnFamilyDefinition
+  class AnalyzerSubType
     include ::Thrift::Struct, ::Thrift::Struct_Union
-    DEFAULTDEFINITION = 1
-    COLUMNDEFINITIONS = 2
+    FIELDNAME = 1
+    CLASSDEFINITION = 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}}
+      FIELDNAME => {:type => ::Thrift::Types::STRING, :name => 'fieldName'},
+      CLASSDEFINITION => {:type => ::Thrift::Types::STRUCT, :name => 'classDefinition', :class => ::Blur::ClassDefinition}
     }
 
     def struct_fields; FIELDS; end
@@ -262,20 +209,16 @@ module Blur
     ::Thrift::Struct.generate_accessors self
   end
 
-  # 
-  class AnalyzerDefinition
+  class AnalyzerType
     include ::Thrift::Struct, ::Thrift::Struct_Union
-    DEFAULTDEFINITION = 1
-    FULLTEXTANALYZERCLASSNAME = 2
-    COLUMNFAMILYDEFINITIONS = 3
+    FIELDNAME = 1
+    CLASSDEFINITION = 2
+    ANALYZERSUBTYPES = 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}}
+      FIELDNAME => {:type => ::Thrift::Types::STRING, :name => 'fieldName'},
+      CLASSDEFINITION => {:type => ::Thrift::Types::STRUCT, :name => 'classDefinition', :class => ::Blur::ClassDefinition},
+      ANALYZERSUBTYPES => {:type => ::Thrift::Types::LIST, :name => 'analyzerSubTypes', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::AnalyzerSubType}}
     }
 
     def struct_fields; FIELDS; end
@@ -286,14 +229,12 @@ module Blur
     ::Thrift::Struct.generate_accessors self
   end
 
-  # 
-  class ColumnPreCache
+  class Analyzer
     include ::Thrift::Struct, ::Thrift::Struct_Union
-    PRECACHECOLS = 1
+    ANALYZERTYPES = 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}}
+      ANALYZERTYPES => {:type => ::Thrift::Types::LIST, :name => 'analyzerTypes', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::AnalyzerType}}
     }
 
     def struct_fields; FIELDS; end
@@ -307,76 +248,34 @@ module Blur
   # 
   class TableDescriptor
     include ::Thrift::Struct, ::Thrift::Struct_Union
-    ISENABLED = 1
-    ANALYZERDEFINITION = 2
+    NAME = 1
+    ENABLED = 2
     SHARDCOUNT = 3
-    TABLEURI = 4
-    COMPRESSIONCLASS = 5
-    COMPRESSIONBLOCKSIZE = 6
-    CLUSTER = 7
-    NAME = 8
-    SIMILARITYCLASS = 9
-    BLOCKCACHING = 10
-    BLOCKCACHINGFILETYPES = 11
-    READONLY = 12
-    COLUMNPRECACHE = 13
+    STORAGEPATH = 4
+    ANALYZER = 5
+    READONLY = 6
+    PROPERTIES = 7
 
     FIELDS = {
       # 
-      ISENABLED => {:type => ::Thrift::Types::BOOL, :name => 'isEnabled', :default => true},
+      NAME => {:type => ::Thrift::Types::STRING, :name => 'name'},
       # 
-      ANALYZERDEFINITION => {:type => ::Thrift::Types::STRUCT, :name => 'analyzerDefinition', :class => ::Blur::AnalyzerDefinition},
+      ENABLED => {:type => ::Thrift::Types::BOOL, :name => 'enabled', :default => true},
       # 
       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'},
+      STORAGEPATH => {:type => ::Thrift::Types::STRING, :name => 'storagePath'},
       # 
-      BLOCKCACHING => {:type => ::Thrift::Types::BOOL, :name => 'blockCaching', :default => true},
+      ANALYZER => {:type => ::Thrift::Types::STRUCT, :name => 'analyzer', :class => ::Blur::Analyzer},
       # 
-      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
-
-  class Attribute
-    include ::Thrift::Struct, ::Thrift::Struct_Union
-    NAME = 1
-    VALUE = 2
-    TYPE = 3
-
-    FIELDS = {
-      NAME => {:type => ::Thrift::Types::STRING, :name => 'name'},
-      VALUE => {:type => ::Thrift::Types::STRING, :name => 'value', :binary => true},
-      TYPE => {:type => ::Thrift::Types::I32, :name => 'type', :enum_class => ::Blur::TYPE}
+      # compressionClass,compressionBlockSize,similarityClass,blockCaching = 1,blockCachingFileTypes,columnPreCache
+      PROPERTIES => {:type => ::Thrift::Types::MAP, :name => 'properties', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}
     }
 
     def struct_fields; FIELDS; end
 
     def validate
-      unless @type.nil? || ::Blur::TYPE::VALID_VALUES.include?(@type)
-        raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field type!')
-      end
     end
 
     ::Thrift::Struct.generate_accessors self
@@ -385,29 +284,9 @@ module Blur
   class Session
     include ::Thrift::Struct, ::Thrift::Struct_Union
     SESSIONID = 1
-    PROPERTIES = 2
-
-    FIELDS = {
-      SESSIONID => {:type => ::Thrift::Types::STRING, :name => 'sessionId'},
-      PROPERTIES => {:type => ::Thrift::Types::MAP, :name => 'properties', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}
-    }
-
-    def struct_fields; FIELDS; end
-
-    def validate
-    end
-
-    ::Thrift::Struct.generate_accessors self
-  end
-
-  class QuerySession
-    include ::Thrift::Struct, ::Thrift::Struct_Union
-    SESSION = 1
-    QUERYID = 2
 
     FIELDS = {
-      SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session},
-      QUERYID => {:type => ::Thrift::Types::STRING, :name => 'queryId'}
+      SESSIONID => {:type => ::Thrift::Types::STRING, :name => 'sessionId'}
     }
 
     def struct_fields; FIELDS; end
@@ -457,24 +336,6 @@ module Blur
     ::Thrift::Struct.generate_accessors self
   end
 
-  class DocLocation
-    include ::Thrift::Struct, ::Thrift::Struct_Union
-    DOC = 1
-    SHARDINDEX = 2
-
-    FIELDS = {
-      DOC => {:type => ::Thrift::Types::I32, :name => 'doc'},
-      SHARDINDEX => {:type => ::Thrift::Types::I32, :name => 'shardIndex'}
-    }
-
-    def struct_fields; FIELDS; end
-
-    def validate
-    end
-
-    ::Thrift::Struct.generate_accessors self
-  end
-
   class ScoreDoc
     include ::Thrift::Struct, ::Thrift::Struct_Union
     SCORE = 1
@@ -483,7 +344,7 @@ module Blur
 
     FIELDS = {
       SCORE => {:type => ::Thrift::Types::DOUBLE, :name => 'score'},
-      DOCLOCATION => {:type => ::Thrift::Types::STRUCT, :name => 'docLocation', :class => ::Blur::DocLocation},
+      DOCLOCATION => {:type => ::Thrift::Types::I64, :name => 'docLocation'},
       FIELDS => {:type => ::Thrift::Types::LIST, :name => 'fields', :element => {:type => ::Thrift::Types::STRING, :binary => true}}
     }
 
@@ -497,23 +358,25 @@ module Blur
 
   class QueryArgs
     include ::Thrift::Struct, ::Thrift::Struct_Union
-    AFTER = 1
-    QUERY = 2
-    FILTER = 3
-    NUMBERTOFETCH = 4
-    SORT = 5
-    DODOCSCORES = 6
-    DOMAXSCORE = 7
-    SHARDINDEXES = 8
+    ID = 1
+    AFTER = 2
+    QUERY = 3
+    FILTER = 4
+    NUMBERTOFETCH = 5
+    SORT = 6
+    DODOCSCORES = 7
+    DOMAXSCORE = 8
+    SHARDINDEXES = 9
 
     FIELDS = {
+      ID => {:type => ::Thrift::Types::I64, :name => 'id'},
       AFTER => {:type => ::Thrift::Types::STRUCT, :name => 'after', :class => ::Blur::ScoreDoc},
       QUERY => {:type => ::Thrift::Types::STRING, :name => 'query', :binary => true},
       FILTER => {:type => ::Thrift::Types::STRING, :name => 'filter', :binary => true},
-      NUMBERTOFETCH => {:type => ::Thrift::Types::I32, :name => 'numberToFetch'},
+      NUMBERTOFETCH => {:type => ::Thrift::Types::I32, :name => 'numberToFetch', :default => 100},
       SORT => {:type => ::Thrift::Types::STRUCT, :name => 'sort', :class => ::Blur::Sort},
-      DODOCSCORES => {:type => ::Thrift::Types::BOOL, :name => 'doDocScores'},
-      DOMAXSCORE => {:type => ::Thrift::Types::BOOL, :name => 'doMaxScore'},
+      DODOCSCORES => {:type => ::Thrift::Types::BOOL, :name => 'doDocScores', :default => true},
+      DOMAXSCORE => {:type => ::Thrift::Types::BOOL, :name => 'doMaxScore', :default => false},
       SHARDINDEXES => {:type => ::Thrift::Types::LIST, :name => 'shardIndexes', :element => {:type => ::Thrift::Types::I32}}
     }
 
@@ -583,7 +446,7 @@ module Blur
     FIELDS = 1
 
     FIELDS = {
-      # 
+      # This list of fields to be indexed.  The same field name can be used across fields and the order of the fields will be maintained.
       FIELDS => {:type => ::Thrift::Types::LIST, :name => 'fields', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::Field}}
     }
 
@@ -623,14 +486,14 @@ module Blur
     WRITEAHEADLOG = 4
 
     FIELDS = {
-      # 
+      # The name of the table.
       TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
-      # 
+      # The index of the shard in the table that the mutate will operate against.
       SHARDINDEX => {:type => ::Thrift::Types::I32, :name => 'shardIndex'},
-      # 
-      WAITTOBEVISIBLE => {:type => ::Thrift::Types::BOOL, :name => 'waitToBeVisible'},
-      # 
-      WRITEAHEADLOG => {:type => ::Thrift::Types::BOOL, :name => 'writeAheadLog'}
+      # Setting this to true will cause the mutate call to block until the mutates are visible.
+      WAITTOBEVISIBLE => {:type => ::Thrift::Types::BOOL, :name => 'waitToBeVisible', :default => false},
+      # Whether or not to add this mutation to the write ahead log for recovery of information during a shard server crash.
+      WRITEAHEADLOG => {:type => ::Thrift::Types::BOOL, :name => 'writeAheadLog', :default => true}
     }
 
     def struct_fields; FIELDS; end
@@ -641,15 +504,16 @@ module Blur
     ::Thrift::Struct.generate_accessors self
   end
 
+  # Contains a the delete term as well as the documents that will be added to the index shard.
   class UpdatePackage
     include ::Thrift::Struct, ::Thrift::Struct_Union
     TERM = 1
     DOCUMENTS = 2
 
     FIELDS = {
-      # 
+      # The term that will mark old Documents as deleted before adding the documents.
       TERM => {:type => ::Thrift::Types::STRUCT, :name => 'term', :class => ::Blur::Term},
-      # 
+      # The documents to be updated.
       DOCUMENTS => {:type => ::Thrift::Types::LIST, :name => 'documents', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::Document}}
     }
 

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/aee531c2/interface/gen-rb/shard_server.rb
----------------------------------------------------------------------
diff --git a/interface/gen-rb/shard_server.rb b/interface/gen-rb/shard_server.rb
deleted file mode 100644
index 6d7c00e..0000000
--- a/interface/gen-rb/shard_server.rb
+++ /dev/null
@@ -1,514 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.0)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-
-require 'thrift'
-require 'blur'
-require 'blur_types'
-
-module Blur
-  module ShardServer
-    class Client < ::Blur::Blur::Client 
-      include ::Thrift::Client
-
-      def openReadSession(table)
-        send_openReadSession(table)
-        return recv_openReadSession()
-      end
-
-      def send_openReadSession(table)
-        send_message('openReadSession', OpenReadSession_args, :table => table)
-      end
-
-      def recv_openReadSession()
-        result = receive_message(OpenReadSession_result)
-        return result.success unless result.success.nil?
-        raise result.e unless result.e.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'openReadSession failed: unknown result')
-      end
-
-      def search(session, queryArgs)
-        send_search(session, queryArgs)
-        return recv_search()
-      end
-
-      def send_search(session, queryArgs)
-        send_message('search', Search_args, :session => session, :queryArgs => queryArgs)
-      end
-
-      def recv_search()
-        result = receive_message(Search_result)
-        return result.success unless result.success.nil?
-        raise result.e unless result.e.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'search failed: unknown result')
-      end
-
-      def doc(session, docLocations, fields)
-        send_doc(session, docLocations, fields)
-        return recv_doc()
-      end
-
-      def send_doc(session, docLocations, fields)
-        send_message('doc', Doc_args, :session => session, :docLocations => docLocations, :fields => fields)
-      end
-
-      def recv_doc()
-        result = receive_message(Doc_result)
-        return result.success unless result.success.nil?
-        raise result.e unless result.e.nil?
-        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'doc failed: unknown result')
-      end
-
-      def closeReadSession(session)
-        send_closeReadSession(session)
-        recv_closeReadSession()
-      end
-
-      def send_closeReadSession(session)
-        send_message('closeReadSession', CloseReadSession_args, :session => session)
-      end
-
-      def recv_closeReadSession()
-        result = receive_message(CloseReadSession_result)
-        raise result.e unless result.e.nil?
-        return
-      end
-
-      def addDocuments(options, documents)
-        send_addDocuments(options, documents)
-        recv_addDocuments()
-      end
-
-      def send_addDocuments(options, documents)
-        send_message('addDocuments', AddDocuments_args, :options => options, :documents => documents)
-      end
-
-      def recv_addDocuments()
-        result = receive_message(AddDocuments_result)
-        raise result.e unless result.e.nil?
-        return
-      end
-
-      def deleteDocumentsByQueries(options, queries)
-        send_deleteDocumentsByQueries(options, queries)
-        recv_deleteDocumentsByQueries()
-      end
-
-      def send_deleteDocumentsByQueries(options, queries)
-        send_message('deleteDocumentsByQueries', DeleteDocumentsByQueries_args, :options => options, :queries => queries)
-      end
-
-      def recv_deleteDocumentsByQueries()
-        result = receive_message(DeleteDocumentsByQueries_result)
-        raise result.e unless result.e.nil?
-        return
-      end
-
-      def deleteDocuments(options, terms)
-        send_deleteDocuments(options, terms)
-        recv_deleteDocuments()
-      end
-
-      def send_deleteDocuments(options, terms)
-        send_message('deleteDocuments', DeleteDocuments_args, :options => options, :terms => terms)
-      end
-
-      def recv_deleteDocuments()
-        result = receive_message(DeleteDocuments_result)
-        raise result.e unless result.e.nil?
-        return
-      end
-
-      def updateDocuments(options, updatePackages)
-        send_updateDocuments(options, updatePackages)
-        recv_updateDocuments()
-      end
-
-      def send_updateDocuments(options, updatePackages)
-        send_message('updateDocuments', UpdateDocuments_args, :options => options, :updatePackages => updatePackages)
-      end
-
-      def recv_updateDocuments()
-        result = receive_message(UpdateDocuments_result)
-        raise result.e unless result.e.nil?
-        return
-      end
-
-    end
-
-    class Processor < ::Blur::Blur::Processor 
-      include ::Thrift::Processor
-
-      def process_openReadSession(seqid, iprot, oprot)
-        args = read_args(iprot, OpenReadSession_args)
-        result = OpenReadSession_result.new()
-        begin
-          result.success = @handler.openReadSession(args.table)
-        rescue ::Blur::BlurException => e
-          result.e = e
-        end
-        write_result(result, oprot, 'openReadSession', seqid)
-      end
-
-      def process_search(seqid, iprot, oprot)
-        args = read_args(iprot, Search_args)
-        result = Search_result.new()
-        begin
-          result.success = @handler.search(args.session, args.queryArgs)
-        rescue ::Blur::BlurException => e
-          result.e = e
-        end
-        write_result(result, oprot, 'search', seqid)
-      end
-
-      def process_doc(seqid, iprot, oprot)
-        args = read_args(iprot, Doc_args)
-        result = Doc_result.new()
-        begin
-          result.success = @handler.doc(args.session, args.docLocations, args.fields)
-        rescue ::Blur::BlurException => e
-          result.e = e
-        end
-        write_result(result, oprot, 'doc', seqid)
-      end
-
-      def process_closeReadSession(seqid, iprot, oprot)
-        args = read_args(iprot, CloseReadSession_args)
-        result = CloseReadSession_result.new()
-        begin
-          @handler.closeReadSession(args.session)
-        rescue ::Blur::BlurException => e
-          result.e = e
-        end
-        write_result(result, oprot, 'closeReadSession', seqid)
-      end
-
-      def process_addDocuments(seqid, iprot, oprot)
-        args = read_args(iprot, AddDocuments_args)
-        result = AddDocuments_result.new()
-        begin
-          @handler.addDocuments(args.options, args.documents)
-        rescue ::Blur::BlurException => e
-          result.e = e
-        end
-        write_result(result, oprot, 'addDocuments', seqid)
-      end
-
-      def process_deleteDocumentsByQueries(seqid, iprot, oprot)
-        args = read_args(iprot, DeleteDocumentsByQueries_args)
-        result = DeleteDocumentsByQueries_result.new()
-        begin
-          @handler.deleteDocumentsByQueries(args.options, args.queries)
-        rescue ::Blur::BlurException => e
-          result.e = e
-        end
-        write_result(result, oprot, 'deleteDocumentsByQueries', seqid)
-      end
-
-      def process_deleteDocuments(seqid, iprot, oprot)
-        args = read_args(iprot, DeleteDocuments_args)
-        result = DeleteDocuments_result.new()
-        begin
-          @handler.deleteDocuments(args.options, args.terms)
-        rescue ::Blur::BlurException => e
-          result.e = e
-        end
-        write_result(result, oprot, 'deleteDocuments', seqid)
-      end
-
-      def process_updateDocuments(seqid, iprot, oprot)
-        args = read_args(iprot, UpdateDocuments_args)
-        result = UpdateDocuments_result.new()
-        begin
-          @handler.updateDocuments(args.options, args.updatePackages)
-        rescue ::Blur::BlurException => e
-          result.e = e
-        end
-        write_result(result, oprot, 'updateDocuments', seqid)
-      end
-
-    end
-
-    # HELPER FUNCTIONS AND STRUCTURES
-
-    class OpenReadSession_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 OpenReadSession_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      E = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Blur::Session},
-        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Search_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SESSION = 1
-      QUERYARGS = 2
-
-      FIELDS = {
-        SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session},
-        QUERYARGS => {:type => ::Thrift::Types::STRUCT, :name => 'queryArgs', :class => ::Blur::QueryArgs}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Search_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      E = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::TopFieldDocs}},
-        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Doc_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SESSION = 1
-      DOCLOCATIONS = 2
-      FIELDS = 4
-
-      FIELDS = {
-        SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session},
-        DOCLOCATIONS => {:type => ::Thrift::Types::LIST, :name => 'docLocations', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::DocLocation}},
-        FIELDS => {:type => ::Thrift::Types::SET, :name => 'fields', :element => {:type => ::Thrift::Types::STRING}}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class Doc_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SUCCESS = 0
-      E = 1
-
-      FIELDS = {
-        SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::Document}},
-        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CloseReadSession_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      SESSION = 1
-
-      FIELDS = {
-        SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class CloseReadSession_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      E = 1
-
-      FIELDS = {
-        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class AddDocuments_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      OPTIONS = 1
-      DOCUMENTS = 2
-
-      FIELDS = {
-        OPTIONS => {:type => ::Thrift::Types::STRUCT, :name => 'options', :class => ::Blur::MutateOptions},
-        DOCUMENTS => {:type => ::Thrift::Types::LIST, :name => 'documents', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::Document}}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class AddDocuments_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      E = 1
-
-      FIELDS = {
-        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class DeleteDocumentsByQueries_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      OPTIONS = 1
-      QUERIES = 2
-
-      FIELDS = {
-        OPTIONS => {:type => ::Thrift::Types::STRUCT, :name => 'options', :class => ::Blur::MutateOptions},
-        QUERIES => {:type => ::Thrift::Types::LIST, :name => 'queries', :element => {:type => ::Thrift::Types::STRING, :binary => true}}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class DeleteDocumentsByQueries_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      E = 1
-
-      FIELDS = {
-        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class DeleteDocuments_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      OPTIONS = 1
-      TERMS = 2
-
-      FIELDS = {
-        OPTIONS => {:type => ::Thrift::Types::STRUCT, :name => 'options', :class => ::Blur::MutateOptions},
-        TERMS => {:type => ::Thrift::Types::LIST, :name => 'terms', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::Term}}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class DeleteDocuments_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      E = 1
-
-      FIELDS = {
-        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class UpdateDocuments_args
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      OPTIONS = 1
-      UPDATEPACKAGES = 2
-
-      FIELDS = {
-        OPTIONS => {:type => ::Thrift::Types::STRUCT, :name => 'options', :class => ::Blur::MutateOptions},
-        UPDATEPACKAGES => {:type => ::Thrift::Types::LIST, :name => 'updatePackages', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Blur::UpdatePackage}}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-    class UpdateDocuments_result
-      include ::Thrift::Struct, ::Thrift::Struct_Union
-      E = 1
-
-      FIELDS = {
-        E => {:type => ::Thrift::Types::STRUCT, :name => 'e', :class => ::Blur::BlurException}
-      }
-
-      def struct_fields; FIELDS; end
-
-      def validate
-      end
-
-      ::Thrift::Struct.generate_accessors self
-    end
-
-  end
-
-end


Mime
View raw message