Skip to content

Commit 0ec8d1f

Browse files
committed
remove uneccessary casts
1 parent ab8be70 commit 0ec8d1f

File tree

2 files changed

+3
-6
lines changed

2 files changed

+3
-6
lines changed

wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangAggregateVisitor.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,16 +20,15 @@
2020

2121
import java.util.HashSet;
2222
import java.util.List;
23-
import java.util.Set;
2423

25-
import org.apache.calcite.rel.core.Aggregate;
2624
import org.apache.calcite.rel.core.AggregateCall;
2725

2826
import org.apache.wayang.api.sql.calcite.converter.functions.AggregateAddCols;
2927
import org.apache.wayang.api.sql.calcite.converter.functions.AggregateFunction;
3028
import org.apache.wayang.api.sql.calcite.converter.functions.AggregateKeyExtractor;
3129
import org.apache.wayang.api.sql.calcite.converter.functions.AggregateGetResult;
3230
import org.apache.wayang.api.sql.calcite.rel.WayangAggregate;
31+
3332
import org.apache.wayang.basic.data.Record;
3433
import org.apache.wayang.basic.operators.GlobalReduceOperator;
3534
import org.apache.wayang.basic.operators.MapOperator;
@@ -49,7 +48,7 @@ public class WayangAggregateVisitor extends WayangRelNodeVisitor<WayangAggregate
4948
Operator visit(final WayangAggregate wayangRelNode) {
5049
final Operator childOp = wayangRelConverter.convert(wayangRelNode.getInput(0));
5150

52-
final List<AggregateCall> aggregateCalls = ((Aggregate) wayangRelNode).getAggCallList();
51+
final List<AggregateCall> aggregateCalls = wayangRelNode.getAggCallList();
5352
final HashSet<Integer> groupingFields = new HashSet<>(wayangRelNode.getGroupSet().asSet());
5453

5554
final MapOperator<Record, Record> mapOperator = new MapOperator<>(
@@ -76,6 +75,5 @@ Operator visit(final WayangAggregate wayangRelNode) {
7675
Record.class);
7776
aggregateOperator.connectTo(0, mapOperator2, 0);
7877
return mapOperator2;
79-
8078
}
8179
}

wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangFilterVisitor.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,8 +38,7 @@ public class WayangFilterVisitor extends WayangRelNodeVisitor<WayangFilter> {
3838
@Override
3939
Operator visit(final WayangFilter wayangRelNode) {
4040
final Operator childOp = wayangRelConverter.convert(wayangRelNode.getInput(0));
41-
42-
final RexNode condition = ((Filter) wayangRelNode).getCondition();
41+
final RexNode condition = wayangRelNode.getCondition();
4342

4443
final FilterOperator<Record> filter = new FilterOperator<>(
4544
new FilterPredicateImpl(condition),

0 commit comments

Comments
 (0)