Github user vdiravka commented on a diff in the pull request: https://github.com/apache/drill/pull/1059#discussion_r162293578 --- Diff: exec/java-exec/src/main/java/org/apache/drill/exec/record/AbstractRecordBatch.java --- @@ -228,4 +228,20 @@ public WritableBatch getWritableBatch() { public VectorContainer getOutgoingContainer() { throw new UnsupportedOperationException(String.format(" You should not call getOutgoingContainer() for class %s", this.getClass().getCanonicalName())); } + + public void drainStream(IterOutcome stream, int input, RecordBatch batch) { --- End diff -- Please add java-doc for this method
---