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

kraken-logdb/src/main/java/org/krakenapps/logdb/impl/LogDBScript.java

@@ -215 +215 @@
 
                 context.println(q);
+
+                LogQuery lq = q.getReduceQuery().getQuery();
+                do {
+                        try {
+                                Thread.sleep(100);
+                        } catch (InterruptedException e) {
+                        }
+                } while (!lq.isEnd());
+
+                List<Map<String, Object>> results = lq.getResult();
+                for (Map<String, Object> m : results)
+                        printMap(m);
+                ((FileBufferList<Map<String, Object>>) results).close();
+
+                qs.removeQuery(lq.getId());
         }