Initialize and pass the result reader client API to Aql compiler from the Java client API.
git-svn-id: https://asterixdb.googlecode.com/svn/branches/asterix_stabilization_result_distribution@1147 eaa15691-b419-025a-1212-ee371bd00084
diff --git a/asterix-app/src/main/java/edu/uci/ics/asterix/api/aqlj/server/APIClientThread.java b/asterix-app/src/main/java/edu/uci/ics/asterix/api/aqlj/server/APIClientThread.java
index 9879a2d..ed52257 100644
--- a/asterix-app/src/main/java/edu/uci/ics/asterix/api/aqlj/server/APIClientThread.java
+++ b/asterix-app/src/main/java/edu/uci/ics/asterix/api/aqlj/server/APIClientThread.java
@@ -41,6 +41,7 @@
import edu.uci.ics.asterix.metadata.MetadataManager;
import edu.uci.ics.asterix.metadata.api.IAsterixStateProxy;
import edu.uci.ics.asterix.metadata.bootstrap.AsterixProperties;
+import edu.uci.ics.asterix.result.ResultReader;
import edu.uci.ics.hyracks.algebricks.common.exceptions.AlgebricksException;
import edu.uci.ics.hyracks.api.application.ICCApplicationContext;
import edu.uci.ics.hyracks.api.client.IHyracksClientConnection;
@@ -222,10 +223,13 @@
SessionConfig pc = new SessionConfig(AsterixHyracksIntegrationUtil.DEFAULT_HYRACKS_CC_CLIENT_PORT, true,
false, false, false, false, false, true, false);
+ ResultReader resultReader = new ResultReader(hcc, out);
+ new Thread(resultReader).start();
+
MetadataManager.INSTANCE.init();
if (statements != null && statements.size() > 0) {
AqlTranslator translator = new AqlTranslator(statements, out, pc, DisplayFormat.TEXT);
- executionResults = translator.compileAndExecute(hcc);
+ executionResults = translator.compileAndExecute(hcc, resultReader);
}
} catch (ParseException e) {
e.printStackTrace();
@@ -240,7 +244,7 @@
e.printStackTrace();
sendError(e.getMessage());
}
- return executionResults.get(0).getResultPath();
+ return null;
}