You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@vxquery.apache.org by pr...@apache.org on 2014/01/20 23:49:02 UTC
git commit: Updated the cli to include the variable name to help with
readability of the code.
Updated Branches:
refs/heads/master c35839ec4 -> cca368e82
Updated the cli to include the variable name to help with readability of the code.
Project: http://git-wip-us.apache.org/repos/asf/incubator-vxquery/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-vxquery/commit/cca368e8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-vxquery/tree/cca368e8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-vxquery/diff/cca368e8
Branch: refs/heads/master
Commit: cca368e8250fc9fe5a3698ac721872777edc6efe
Parents: c35839e
Author: Preston Carman <pr...@apache.org>
Authored: Mon Jan 20 14:49:07 2014 -0800
Committer: Preston Carman <pr...@apache.org>
Committed: Mon Jan 20 14:49:07 2014 -0800
----------------------------------------------------------------------
vxquery-cli/src/main/java/org/apache/vxquery/cli/VXQuery.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-vxquery/blob/cca368e8/vxquery-cli/src/main/java/org/apache/vxquery/cli/VXQuery.java
----------------------------------------------------------------------
diff --git a/vxquery-cli/src/main/java/org/apache/vxquery/cli/VXQuery.java b/vxquery-cli/src/main/java/org/apache/vxquery/cli/VXQuery.java
index b3ebb3a..cddff1b 100644
--- a/vxquery-cli/src/main/java/org/apache/vxquery/cli/VXQuery.java
+++ b/vxquery-cli/src/main/java/org/apache/vxquery/cli/VXQuery.java
@@ -279,8 +279,9 @@ public class VXQuery {
* @throws Exception
*/
private void runJob(JobSpecification spec, PrintWriter writer) throws Exception {
+ int nReaders = 1;
if (hds == null) {
- hds = new HyracksDataset(hcc, spec.getFrameSize(), 1);
+ hds = new HyracksDataset(hcc, spec.getFrameSize(), nReaders);
}
JobId jobId = hcc.startJob(spec, EnumSet.of(JobFlag.PROFILE_RUNTIME));