diff options
| author | Timothy Chen <tnachen@gmail.com> | 2014-09-21 23:54:40 -0700 |
|---|---|---|
| committer | Steven Phillips <sphillips@maprtech.com> | 2014-09-23 22:24:21 -0700 |
| commit | 8def6e91489455c0ae670f49ef5ba51ef71b31bd (patch) | |
| tree | 1e53ac7654039b05b6a0531039aa1b317665f45a /exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter | |
| parent | 9bc71fc54b97b52ac5c7335247b6ca7887045fd2 (diff) | |
Patch for DRILL-705
Currently only supports partitioning/ordering, not yet preceding or
after offsets
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter')
| -rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java index f1fcce0d6..85f664cfc 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter/FilterRecordBatch.java @@ -76,13 +76,15 @@ public class FilterRecordBatch extends AbstractSingleRecordBatch<Filter>{ } @Override - protected void doWork() { + protected IterOutcome doWork() { int recordCount = incoming.getRecordCount(); filter.filterBatch(recordCount); // for (VectorWrapper<?> v : container) { // ValueVector.Mutator m = v.getValueVector().getMutator(); // m.setValueCount(recordCount); // } + + return IterOutcome.OK; } |