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

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

@@ -109 +109 @@
         @Override
         public LogQuery createQuery(String query) {
-                LogQuery lq = new LogQueryImpl(syntaxProvider, this, logStorage, tableRegistry, query);
+                LogQuery lq = new LogQueryImpl(syntaxProvider, query);
                 queries.put(lq.getId(), lq);
                 lq.registerQueryCallback(new EofReceiver(lq));