diff options
author | Aditya Kishore <aditya@maprtech.com> | 2014-09-11 10:43:08 -0700 |
---|---|---|
committer | Aditya Kishore <aditya@maprtech.com> | 2014-09-11 19:25:28 -0700 |
commit | 676f5df6b14b10ccc3603360e0efee9c745c5b97 (patch) | |
tree | 592b02f84e8a6da2ace67f8e6c0e46d4237af20b /exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/filter | |
parent | 7ae257c42b2eb4e1db778dca9ba64e2516078b38 (diff) |
DRILL-1402: Add check-style rules for trailing space, TABs and blocks without braces
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 | 21 |
1 files changed, 12 insertions, 9 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 bf00194aa..f1fcce0d6 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 @@ -79,7 +79,7 @@ public class FilterRecordBatch extends AbstractSingleRecordBatch<Filter>{ protected void doWork() { int recordCount = incoming.getRecordCount(); filter.filterBatch(recordCount); -// for(VectorWrapper<?> v : container){ +// for (VectorWrapper<?> v : container) { // ValueVector.Mutator m = v.getValueVector().getMutator(); // m.setValueCount(recordCount); // } @@ -88,8 +88,12 @@ public class FilterRecordBatch extends AbstractSingleRecordBatch<Filter>{ @Override public void cleanup() { - if(sv2 != null) sv2.clear(); - if(sv4 != null) sv4.clear(); + if (sv2 != null) { + sv2.clear(); + } + if (sv4 != null) { + sv4.clear(); + } super.cleanup(); } @@ -100,7 +104,7 @@ public class FilterRecordBatch extends AbstractSingleRecordBatch<Filter>{ sv2.clear(); } - switch(incoming.getSchema().getSelectionVectorMode()){ + switch (incoming.getSchema().getSelectionVectorMode()) { case NONE: sv2 = new SelectionVector2(oContext.getAllocator()); this.filter = generateSV2Filterer(); @@ -137,13 +141,13 @@ public class FilterRecordBatch extends AbstractSingleRecordBatch<Filter>{ final ClassGenerator<Filterer> cg = CodeGenerator.getRoot(Filterer.TEMPLATE_DEFINITION4, context.getFunctionRegistry()); final LogicalExpression expr = ExpressionTreeMaterializer.materialize(popConfig.getExpr(), incoming, collector, context.getFunctionRegistry()); - if(collector.hasErrors()){ + if (collector.hasErrors()) { throw new SchemaChangeException(String.format("Failure while trying to materialize incoming schema. Errors:\n %s.", collector.toErrorString())); } cg.addExpr(new ReturnValueExpression(expr)); -// for(VectorWrapper<?> i : incoming){ +// for (VectorWrapper<?> i : incoming) { // ValueVector v = TypeHelper.getNewVector(i.getField(), context.getAllocator()); // container.add(v); // allocators.add(getAllocator4(v)); @@ -177,13 +181,13 @@ public class FilterRecordBatch extends AbstractSingleRecordBatch<Filter>{ final ClassGenerator<Filterer> cg = CodeGenerator.getRoot(Filterer.TEMPLATE_DEFINITION2, context.getFunctionRegistry()); final LogicalExpression expr = ExpressionTreeMaterializer.materialize(popConfig.getExpr(), incoming, collector, context.getFunctionRegistry()); - if(collector.hasErrors()){ + if (collector.hasErrors()) { throw new SchemaChangeException(String.format("Failure while trying to materialize incoming schema. Errors:\n %s.", collector.toErrorString())); } cg.addExpr(new ReturnValueExpression(expr)); - for(VectorWrapper<?> v : incoming){ + for (VectorWrapper<?> v : incoming) { TransferPair pair = v.getValueVector().getTransferPair(); container.add(pair.getTo()); transfers.add(pair); @@ -202,5 +206,4 @@ public class FilterRecordBatch extends AbstractSingleRecordBatch<Filter>{ } - } |