Changeset 532:7057fc0c1459 for kraken-logdb/src/main/java/org/krakenapps/logdb/query/LogQueryImpl.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/query/LogQueryImpl.java (modified) (2 diffs)

kraken-logdb/src/main/java/org/krakenapps/logdb/query/LogQueryImpl.java

@@ -30 +30 @@
 import org.krakenapps.logdb.LogQueryCallback;
 import org.krakenapps.logdb.LogQueryCommand;
-import org.krakenapps.logdb.LogQueryService;
 import org.krakenapps.logdb.SyntaxProvider;
-import org.krakenapps.logstorage.LogStorage;
-import org.krakenapps.logstorage.LogTableRegistry;
 import org.krakenapps.logdb.LogQueryCommand.Status;
 import org.krakenapps.logdb.LogTimelineCallback;
@@ -51 +48 @@
         private Set<LogTimelineCallback> timelineCallbacks = new HashSet<LogTimelineCallback>();
 
-        public LogQueryImpl(SyntaxProvider syntaxProvider, LogQueryService service, LogStorage logStorage,
-                        LogTableRegistry tableRegistry, String query) {
-                this.queryString = query;
+        public LogQueryImpl(SyntaxProvider syntaxProvider, String queryString) {
+                this.queryString = queryString;
 
                 for (String q : queryString.split("\\|")) {