aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical
diff options
context:
space:
mode:
authorVolodymyr Vysotskyi <vvovyk@gmail.com>2018-07-02 17:59:42 +0300
committerArina Ielchiieva <arina.yelchiyeva@gmail.com>2018-08-27 10:02:41 +0300
commit989618287559de5e87349c637cb91150ea6a5135 (patch)
treed74af368891e91f6b2dca74d199a9ea6620d2326 /exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical
parent8bcb103a0e3bcc5f85a03cbed3c6c0cea254ec4e (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')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical/DirPrunedEnumerableTableScan.java12
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/planner/logical/DrillConditions.java20
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;
};
}