Changeset 532:7057fc0c1459 for kraken-logdb/src/main/java/org/krakenapps/logdb/mapreduce/MapReduceQueryStatus.java

Timestamp:

11/14/11 02:31:08 (6 months ago)

Author:

xeraph

Branch:

default

Message:

added mapreduce query (not yet completed, and rpc has race condition bug)

File:

• kraken-logdb/src/main/java/org/krakenapps/logdb/mapreduce/MapReduceQueryStatus.java (modified) (2 diffs)

kraken-logdb/src/main/java/org/krakenapps/logdb/mapreduce/MapReduceQueryStatus.java

@@ -5 +5 @@
 public class MapReduceQueryStatus {
         private String guid;
-        private String owner;
         private String query;
-        private List<MapReduceQuery> mapperQueries;
-        private MapReduceQuery reducerQuery;
+        private List<RemoteMapQuery> mapQueries;
+        private ReduceQuery reduceQuery;
 
-        public MapReduceQueryStatus(String guid, String owner, String query) {
+        public MapReduceQueryStatus(String guid, String query, List<RemoteMapQuery> mapQueries, ReduceQuery reduceQuery) {
                 this.guid = guid;
-                this.owner = owner;
                 this.query = query;
+                this.mapQueries = mapQueries;
+                this.reduceQuery = reduceQuery;
         }
 
@@ -20 +20 @@
         }
 
-        public String getOwner() {
-                return owner;
-        }
-
         public String getQuery() {
                 return query;
         }
 
-        public List<MapReduceQuery> getMapperQueries() {
-                return mapperQueries;
+        public List<RemoteMapQuery> getMapQueries() {
+                return mapQueries;
         }
 
-        public void setMapperQueries(List<MapReduceQuery> mapperQueries) {
-                this.mapperQueries = mapperQueries;
+        public void setMapQueries(List<RemoteMapQuery> mapQueries) {
+                this.mapQueries = mapQueries;
         }
 
-        public MapReduceQuery getReducerQuery() {
-                return reducerQuery;
+        public ReduceQuery getReduceQuery() {
+                return reduceQuery;
         }
 
-        public void setReducerQuery(MapReduceQuery reducerQuery) {
-                this.reducerQuery = reducerQuery;
+        public void setReduceQuery(ReduceQuery reduceQuery) {
+                this.reduceQuery = reduceQuery;
         }
 
         @Override
         public String toString() {
-                return "arbiter query status: guid=" + guid + ", owner=" + owner + "query=" + query;
+                return "mapreduce query status: guid=" + guid + ", query=" + query;
         }