set def recordCount for explain
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/6976f92a Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/6976f92a Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/6976f92a Branch: refs/heads/master Commit: 6976f92adeaf5e82729a0ff5f8581a0c405a6fec Parents: d37d924 Author: Steven Phillips <[email protected]> Authored: Thu Mar 20 01:01:19 2014 -0700 Committer: Jacques Nadeau <[email protected]> Committed: Sat Apr 19 18:07:09 2014 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/drill/exec/work/foreman/Foreman.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/6976f92a/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java b/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java index 5d53b7d..858508b 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java @@ -228,7 +228,7 @@ public class Foreman implements Runnable, Closeable, Comparable<Object>{ QueryResult header = QueryResult.newBuilder() // .setQueryId(context.getQueryId()) // .setRowCount(1) // - .setDef(RecordBatchDef.newBuilder().addField(vector.getMetadata()).build()) // + .setDef(RecordBatchDef.newBuilder().addField(vector.getMetadata()).setRecordCount(1).build()) // .setIsLastChunk(false) // .build(); QueryWritableBatch b1 = new QueryWritableBatch(header, vector.getBuffers());
