You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@drill.apache.org by ja...@apache.org on 2014/04/20 03:18:18 UTC
[10/51] [abbrv] git commit: set def recordCount for explain
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 <sp...@maprtech.com>
Authored: Thu Mar 20 01:01:19 2014 -0700
Committer: Jacques Nadeau <ja...@apache.org>
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());