diff options
author | Volodymyr Vysotskyi <vvovyk@gmail.com> | 2018-07-02 17:59:42 +0300 |
---|---|---|
committer | Arina Ielchiieva <arina.yelchiyeva@gmail.com> | 2018-08-27 10:02:41 +0300 |
commit | 989618287559de5e87349c637cb91150ea6a5135 (patch) | |
tree | d74af368891e91f6b2dca74d199a9ea6620d2326 /exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical | |
parent | 8bcb103a0e3bcc5f85a03cbed3c6c0cea254ec4e (diff) |
DRILL-6647: Update Calcite version to 1.17.0
closes #1425
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical')
2 files changed, 9 insertions, 23 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical/DirPrunedEnumerableTableScan.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical/DirPrunedEnumerableTableScan.java index 2202986a4..7fd348faf 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical/DirPrunedEnumerableTableScan.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical/DirPrunedEnumerableTableScan.java @@ -17,14 +17,12 @@ */ package org.apache.drill.exec.planner.logical; -import com.google.common.base.Supplier; import com.google.common.collect.ImmutableList; import org.apache.calcite.adapter.enumerable.EnumerableConvention; import org.apache.calcite.adapter.enumerable.EnumerableTableScan; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptTable; import org.apache.calcite.plan.RelTraitSet; -import org.apache.calcite.rel.RelCollation; import org.apache.calcite.rel.RelCollationTraitDef; import org.apache.calcite.rel.RelNode; import org.apache.calcite.rel.RelWriter; @@ -62,13 +60,11 @@ public class DirPrunedEnumerableTableScan extends EnumerableTableScan { final RelTraitSet traitSet = cluster.traitSetOf(EnumerableConvention.INSTANCE) .replaceIfs(RelCollationTraitDef.INSTANCE, - new Supplier<List<RelCollation>>() { - public List<RelCollation> get() { - if (table != null) { - return table.getStatistic().getCollations(); - } - return ImmutableList.of(); + () -> { + if (table != null) { + return table.getStatistic().getCollations(); } + return ImmutableList.of(); }); return new DirPrunedEnumerableTableScan(cluster, traitSet, relOptTable, elementType, digestFromSelection); } diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical/DrillConditions.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical/DrillConditions.java index 266ce64b3..1341be10b 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical/DrillConditions.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical/DrillConditions.java @@ -19,24 +19,14 @@ package org.apache.drill.exec.planner.logical; import org.apache.calcite.rel.rules.PushProjector; import org.apache.calcite.rex.RexCall; -import org.apache.calcite.rex.RexNode; public final class DrillConditions { - public static PushProjector.ExprCondition PRESERVE_ITEM = new PushProjector.ExprCondition() { - - @Override - public boolean apply(RexNode rexNode) { - return false; - } - - @Override - public boolean test(RexNode expr) { - if (expr instanceof RexCall) { - RexCall call = (RexCall)expr; - return "item".equals(call.getOperator().getName().toLowerCase()); - } - return false; + public static final PushProjector.ExprCondition PRESERVE_ITEM = expr -> { + if (expr instanceof RexCall) { + RexCall call = (RexCall) expr; + return "item".equals(call.getOperator().getName().toLowerCase()); } + return false; }; } |