Github user vdiravka commented on a diff in the pull request: https://github.com/apache/drill/pull/1059#discussion_r162293231 --- Diff: exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java --- @@ -535,4 +541,8 @@ public void close() { } super.close(); } + + private boolean isFurtherProcessingRequired(IterOutcome upStream) { --- End diff -- It will be good to have here a small java-doc
---