Return-Path: 
 <drill-commits-return-1021-apmail-incubator-drill-commits-archive=incubator.apache.org@incubator.apache.org>
X-Original-To: apmail-incubator-drill-commits-archive@minotaur.apache.org
Delivered-To: apmail-incubator-drill-commits-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id C7FCB17C8E
	for <apmail-incubator-drill-commits-archive@minotaur.apache.org>;
 Wed, 12 Nov 2014 04:11:19 +0000 (UTC)
Received: (qmail 258 invoked by uid 500); 12 Nov 2014 04:11:19 -0000
Delivered-To: apmail-incubator-drill-commits-archive@incubator.apache.org
Received: (qmail 177 invoked by uid 500); 12 Nov 2014 04:11:19 -0000
Mailing-List: contact drill-commits-help@incubator.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:drill-commits-help@incubator.apache.org>
List-Unsubscribe: <mailto:drill-commits-unsubscribe@incubator.apache.org>
List-Post: <mailto:drill-commits@incubator.apache.org>
List-Id: <drill-commits.incubator.apache.org>
Reply-To: drill-commits@incubator.apache.org
Delivered-To: mailing list drill-commits@incubator.apache.org
Received: (qmail 99920 invoked by uid 99); 12 Nov 2014 04:11:19 -0000
Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org)
 (140.211.11.114)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 12 Nov 2014 04:11:19 +0000
Received: by tyr.zones.apache.org (Postfix, from userid 65534)
	id 87FABA0F1A9; Wed, 12 Nov 2014 04:11:18 +0000 (UTC)
Content-Type: text/plain; charset="us-ascii"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
From: jacques@apache.org
To: drill-commits@incubator.apache.org
Date: Wed, 12 Nov 2014 04:11:27 -0000
Message-Id: <e806ce95aff549b4a05e6ae7282356a0@git.apache.org>
In-Reply-To: <18cba4a1b9fa4c32b36b75130cb6c4bc@git.apache.org>
References: <18cba4a1b9fa4c32b36b75130cb6c4bc@git.apache.org>
X-Mailer: ASF-Git Admin Mailer
Subject: [10/16] incubator-drill git commit: DRILL-1674: Set schema in
 WriterRecordBatch

DRILL-1674: Set schema in WriterRecordBatch


Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/0085ffb9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/0085ffb9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/0085ffb9

Branch: refs/heads/master
Commit: 0085ffb95d0d4cc7e603c93fc7773de73aa4016f
Parents: 836d38a
Author: Steven Phillips <sphillips@maprtech.com>
Authored: Tue Oct 28 18:47:16 2014 -0700
Committer: Jacques Nadeau <jacques@apache.org>
Committed: Tue Nov 11 16:48:45 2014 -0800

----------------------------------------------------------------------
 .../apache/drill/exec/physical/impl/WriterRecordBatch.java    | 7 +++++++
 1 file changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/0085ffb9/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/WriterRecordBatch.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/WriterRecordBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/WriterRecordBatch.java
index 07302d1..cb0de02 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/WriterRecordBatch.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/WriterRecordBatch.java
@@ -51,6 +51,7 @@ public class WriterRecordBatch extends AbstractRecordBatch<Writer> {
   private final RecordBatch incoming;
   private boolean processed = false;
   private String fragmentUniqueId;
+  private BatchSchema schema;
 
   public WriterRecordBatch(Writer writer, RecordBatch incoming, FragmentContext context, RecordWriter recordWriter) throws OutOfMemoryException {
     super(writer, context);
@@ -72,6 +73,11 @@ public class WriterRecordBatch extends AbstractRecordBatch<Writer> {
   }
 
   @Override
+  public BatchSchema getSchema() {
+    return schema;
+  }
+
+  @Override
   public IterOutcome buildSchema() throws SchemaChangeException {
     incoming.buildSchema();
     try {
@@ -174,6 +180,7 @@ public class WriterRecordBatch extends AbstractRecordBatch<Writer> {
 
     eventBasedRecordWriter = new EventBasedRecordWriter(incoming, recordWriter);
     container.buildSchema(SelectionVectorMode.NONE);
+    schema = container.getSchema();
   }
 
   @Override