Impala Public Jenkins has posted comments on this change. ( 
http://gerrit.cloudera.org:8080/23666 )

Change subject: WIP: do not review, Calcite patch with most fixes for v1 for 
full Jenkins run
......................................................................


Patch Set 5:

(83 comments)

gerrit-auto-critic failed. You can reproduce it locally using command:

  python3 bin/jenkins/critique-gerrit-review.py --dryrun

To run it, you might need a virtual env with Python3's venv installed.

http://gerrit.cloudera.org:8080/#/c/23666/5/fe/src/main/java/org/apache/impala/planner/PlanNode.java
File fe/src/main/java/org/apache/impala/planner/PlanNode.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/fe/src/main/java/org/apache/impala/planner/PlanNode.java@424
PS5, Line 424:       expBuilder.append(getCalciteCardinalityString());
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/23666/5/fe/src/main/java/org/apache/impala/planner/PlanNode.java@1412
PS5, Line 1412:   public String getCalciteCardinalityString() {
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/23666/5/fe/src/main/java/org/apache/impala/planner/Planner.java
File fe/src/main/java/org/apache/impala/planner/Planner.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/fe/src/main/java/org/apache/impala/planner/Planner.java@833
PS5, Line 833:   public static boolean isInvertedJoinCheaper(JoinNode joinNode, 
boolean isLocalPlan, PlannerContext ctx) {
line too long (107 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/operators/ImpalaRexBuilder.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/operators/ImpalaRexBuilder.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/operators/ImpalaRexBuilder.java@46
PS5, Line 46:  * Impala provides, not the default type.
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaAggRel.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaAggRel.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaAggRel.java@249
PS5, Line 249:         firstPhaseAgg.calciteCardinality_ = 
getCluster().getMetadataQuery().getRowCount(this);
line too long (94 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaAggRel.java@268
PS5, Line 268:           secondPhaseAgg.calciteCardinality_ = 
getCluster().getMetadataQuery().getRowCount(this);
line too long (97 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaAggRel.java@283
PS5, Line 283:       transposePhaseAgg.calciteCardinality_ = 
getCluster().getMetadataQuery().getRowCount(this);
line too long (96 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaHdfsScanRel.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaHdfsScanRel.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaHdfsScanRel.java@123
PS5, Line 123:         RelNode rowCountRelNode = context.parentFilter_ == null 
? this : context.parentFilter_;
line too long (95 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaHdfsScanRel.java@124
PS5, Line 124:         Double calciteCardinality = 
getCluster().getMetadataQuery().getRowCount(rowCountRelNode);
line too long (97 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaJoinRel.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaJoinRel.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaJoinRel.java@176
PS5, Line 176:       if (a.calciteCardinality_ != null && a.calciteCardinality_ 
>= 5000.0 && a.calciteCardinality_ <= 6000.0) {
line too long (112 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaProjectRel.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaProjectRel.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/ImpalaProjectRel.java@231
PS5, Line 231:
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/NodeCreationUtils.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/NodeCreationUtils.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/NodeCreationUtils.java@100
PS5, Line 100:     ImpalaUnionNode unionNode = new ImpalaUnionNode(nodeId, 
tupleDesc.getId(), outputExprs,
line too long (91 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/node/NodeCreationUtils.java@106
PS5, Line 106:       unionNode.calciteCardinality_ = 
unionRel.getCluster().getMetadataQuery().getRowCount(unionRel);
line too long (101 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaAggNode.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaAggNode.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaAggNode.java@36
PS5, Line 36:   protected static final Logger LOG = 
LoggerFactory.getLogger(ImpalaAggNode.class.getName());
line too long (93 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaHashJoinNode.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaHashJoinNode.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaHashJoinNode.java@40
PS5, Line 40:   protected static final Logger LOG = 
LoggerFactory.getLogger(ImpalaHashJoinNode.class.getName());
line too long (98 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaHashJoinNode.java@68
PS5, Line 68:         throw new RuntimeException("TEMP HASH JOIN EXCEPTION FOR 
NOT MATCHING CARDINALITY");
line too long (92 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaHdfsScanNode.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaHdfsScanNode.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaHdfsScanNode.java@39
PS5, Line 39:   protected static final Logger LOG = 
LoggerFactory.getLogger(ImpalaHdfsScanNode.class.getName());
line too long (98 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaNestedLoopJoinNode.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaNestedLoopJoinNode.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaNestedLoopJoinNode.java@40
PS5, Line 40:   protected static final Logger LOG = 
LoggerFactory.getLogger(ImpalaNestedLoopJoinNode.class.getName());
line too long (104 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaNestedLoopJoinNode.java@66
PS5, Line 66:       LOG.info("SJC: NESTED JOIN FOUND A CARDINALITY, CALCITE IS: 
" + calciteCardinality_);
line too long (91 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaNestedLoopJoinNode.java@71
PS5, Line 71:         throw new RuntimeException("TEMP NESTED JOIN EXCEPTION 
FOR NOT MATCHING CARDINALITY");
line too long (94 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaUnionNode.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaUnionNode.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/phys/ImpalaUnionNode.java@34
PS5, Line 34:   protected static final Logger LOG = 
LoggerFactory.getLogger(ImpalaUnionNode.class.getName());
line too long (95 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/util/CreateExprVisitor.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/util/CreateExprVisitor.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/util/CreateExprVisitor.java@162
PS5, Line 162:       RexNode expandedOperand = 
ImpalaRexUtil.expandSearch(visitor.getRexBuilder(), operand);
line too long (93 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/util/PrunedPartitionHelper.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/util/PrunedPartitionHelper.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/util/PrunedPartitionHelper.java@110
PS5, Line 110:     nonPartitionedCalciteConjunct_ = RexUtil.flatten(rexBuilder, 
simplifier.simplify(tmpCalciteConjunct));
line too long (106 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaIntersectToDistinctRule.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaIntersectToDistinctRule.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaIntersectToDistinctRule.java@44
PS5, Line 44:  *
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@153
PS5, Line 153:   protected static final Logger LOG = 
LoggerFactory.getLogger(ImpalaLoptOptimizeJoinRule.class.getName());
line too long (106 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2101
PS5, Line 2101:   private static boolean experiment(RelMetadataQuery mq, 
LoptMultiJoin multiJoin, LoptJoinTree leftTree, LoptJoinTree rightTree, RexNode 
condition, RexBuilder rexBuilder, boolean adjust) {
line too long (188 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2103
PS5, Line 2103:     RuntimeFilterInfo runtimeFilterInfo = 
multiJoinRel.getCluster().getPlanner().getContext().unwrap(RuntimeFilterInfo.class);
line too long (126 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2121
PS5, Line 2121:     for (RexNode andCondition : andConditions) {
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2122
PS5, Line 2122:       
runtimeFilterInfo.reductionMap_.putAll(createRuntimeFilterReductionContext(andCondition,
 adjust,
line too long (102 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2142
PS5, Line 2142:       leftTotalReduction = 
RuntimeFilterReductionContext.getTotalReduction(leftReductionList);
line too long (94 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2146
PS5, Line 2146:       rightTotalReduction = 
RuntimeFilterReductionContext.getTotalReduction(rightReductionList);
line too long (96 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2151
PS5, Line 2151: //    Double totalLeftReduction = leftTable.getRowCount() - 
leftTable.getRowCount() * leftReduction;
line too long (100 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2152
PS5, Line 2152: //    Double totalRightReduction = rightTable.getRowCount() - 
rightTable.getRowCount() * rightReduction;
line too long (104 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2172
PS5, Line 2172:     RelOptCost totalPreJoinNonSwapCost = 
leftSideWithFilterCost.plus(rightSideWithoutFilterCost);
line too long (97 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2173
PS5, Line 2173:     RelOptCost totalPreJoinSwapCost = 
leftSideWithoutFilterCost.plus(rightSideWithFilterCost);
line too long (94 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2175
PS5, Line 2175:     RelOptCost totalJoinNonSwapCost = 
totalPreJoinNonSwapCost.plus(ImpalaRelMdNonCumulativeCost.getJoinCost(leftSide, 
rightSide, mq));
line too long (134 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2176
PS5, Line 2176:     RelOptCost totalJoinSwapCost = 
totalPreJoinSwapCost.plus(ImpalaRelMdNonCumulativeCost.getJoinCost(rightSide, 
leftSide, mq));
line too long (128 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2202
PS5, Line 2202:   private static boolean swapBitSides(ImmutableBitSet bitSet, 
boolean adjust, LoptJoinTree rightTree, MultiJoin multiJoin) {
line too long (124 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2215
PS5, Line 2215:       startOfRightSideFields += 
multiJoin.getInputs().get(i).getRowType().getFieldList().size();
line too long (96 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2217
PS5, Line 2217:     int endOfRightSideFields = startOfRightSideFields + 
multiJoin.getInputs().get(factor).getRowType().getFieldList().size();
line too long (125 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2219
PS5, Line 2219:     return bitSet.nth(0) >= startOfRightSideFields && 
bitSet.nth(0) < endOfRightSideFields;
line too long (91 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2222
PS5, Line 2222:   private static Set<Integer> 
getLeftPreAdjustedIndexList(ImmutableBitSet bitSet, Set<Integer> 
rightPreAdjustedIndexList) {
line too long (123 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2515
PS5, Line 2515:     }
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2529
PS5, Line 2529:     }
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2533
PS5, Line 2533:   private static Map<TableScan, 
List<RuntimeFilterReductionContext>> createRuntimeFilterReductionContext(
line too long (105 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2554
PS5, Line 2554:     int rightIndex = adjust ? getAdjustedIndex(multiJoinRel, 
rightBit) : rightBit - leftSide.getRowType().getFieldList().size();
line too long (128 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2555
PS5, Line 2555: //    Set<Integer> rightPreAdjustedIndexList = 
getRightPreAdjustedIndexList(bitSet, adjust, rightTree, multiJoinRel);
line too long (117 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2556
PS5, Line 2556: //    Set<Integer> leftPreAdjustedIndexList = 
getLeftPreAdjustedIndexList(bitSet, rightPreAdjustedIndexList);
line too long (109 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2557
PS5, Line 2557:     ImpalaRelColumnOrigin leftOrigin = (ImpalaRelColumnOrigin) 
mq.getColumnOrigin(leftSide, leftIndex);
line too long (103 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2558
PS5, Line 2558:     ImpalaRelColumnOrigin rightOrigin = (ImpalaRelColumnOrigin) 
mq.getColumnOrigin(rightSide, rightIndex);
line too long (106 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2563
PS5, Line 2563:       rightReduction = mq.getDistinctRowCount(leftSide, 
leftBitSet, null) / leftTableColumn.getStats().getNumDistinctValues();
line too long (126 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2571
PS5, Line 2571:       Column rightTableColumn = 
rightTable.getColumn(rightOrigin.getOriginColumnOrdinal());
line too long (91 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2573
PS5, Line 2573:       leftReduction = mq.getDistinctRowCount(rightSide, 
rightBitSet, null) / rightTableColumn.getStats().getNumDistinctValues();
line too long (128 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2580
PS5, Line 2580:            
reductionMap.computeIfAbsent(rightOrigin.getTableScan(), k -> new 
ArrayList<>());
line too long (92 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2581
PS5, Line 2581:       contextList.add(new 
RuntimeFilterReductionContext(joinRelNodes, rightOrigin.getTableScan(), 
rightReduction, false, false));
line too long (129 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2585
PS5, Line 2585:            
reductionMap.computeIfAbsent(leftOrigin.getTableScan(), k -> new ArrayList<>());
line too long (91 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2586
PS5, Line 2586:       contextList.add(new 
RuntimeFilterReductionContext(joinRelNodes, leftOrigin.getTableScan(), 
leftReduction, true, false));
line too long (126 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2592
PS5, Line 2592:     RuntimeFilterInfo runtimeFilterInfo = 
rel.getCluster().getPlanner().getContext().unwrap(RuntimeFilterInfo.class);
line too long (117 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2593
PS5, Line 2593:     runtimeFilterInfo.inputRefs_ = getInputRefsForContext(rel, 
runtimeFilterInfo.inputRefs_, 0);
line too long (96 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2603
PS5, Line 2603:     RuntimeFilterInfo runtimeFilterInfo = 
rel.getCluster().getPlanner().getContext().unwrap(RuntimeFilterInfo.class);
line too long (117 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2609
PS5, Line 2609:       runtimeFilterInfo.inputRefs_ = 
getInputRefsForContext(rel, runtimeFilterInfo.inputRefs_, i);
line too long (98 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2623
PS5, Line 2623:   private static ImmutableBitSet getInputRefsForContext(RelNode 
rel, ImmutableBitSet currentSet, int i) {
line too long (105 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2628
PS5, Line 2628:         return 
ImmutableBitSet.range(rel.getInputs().get(0).getRowType().getFieldList().size());
line too long (96 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2640
PS5, Line 2640:         return 
currentSet.union(RelOptUtil.InputFinder.bits(((Filter) rel).getCondition()));
line too long (92 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2642
PS5, Line 2642:         throw new RuntimeException("Unknown RelNodeType: " + 
ImpalaPlanRel.getRelNodeType(rel));
line too long (96 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2657
PS5, Line 2657:
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaLoptOptimizeJoinRule.java@2669
PS5, Line 2669:     public final Map<TableScan, 
List<RuntimeFilterReductionContext>> reductionMap_ = new HashMap<>();
line too long (101 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaSortRemoveConstantKeysRule.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaSortRemoveConstantKeysRule.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaSortRemoveConstantKeysRule.java@92
PS5, Line 92:       return false;
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelColumnOrigin.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelColumnOrigin.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelColumnOrigin.java@27
PS5, Line 27:   private final TableScan tableScan_;
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelMdColumnOrigins.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelMdColumnOrigins.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelMdColumnOrigins.java@69
PS5, Line 69:   protected static final Logger LOG = 
LoggerFactory.getLogger(ImpalaRelMdColumnOrigins.class.getName());
line too long (104 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelMdColumnOrigins.java@88
PS5, Line 88:       return mq.getColumnOrigins(rel.getInput(), 
rel.getGroupSet().asList().get(iOutputColumn));
line too long (96 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelMdColumnOrigins.java@206
PS5, Line 206:   public @Nullable Set<RelColumnOrigin> 
getColumnOrigins(TableModify rel, RelMetadataQuery mq,
line too long (94 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelMdColumnOrigins.java@314
PS5, Line 314:   private static @Nullable Set<RelColumnOrigin> 
getMultipleColumns(RexNode rexNode, RelNode input,
line too long (98 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelMdNonCumulativeCost.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelMdNonCumulativeCost.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelMdNonCumulativeCost.java@34
PS5, Line 34: import 
org.apache.impala.calcite.rules.ImpalaLoptOptimizeJoinRule.RuntimeFilterReductionContext;
line too long (96 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelMdNonCumulativeCost.java@84
PS5, Line 84:
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelMdNonCumulativeCost.java@115
PS5, Line 115:     RuntimeFilterInfo runtimeFilterInfo = 
scan.getCluster().getPlanner().getContext().unwrap(RuntimeFilterInfo.class);
line too long (118 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelMdNonCumulativeCost.java@119
PS5, Line 119:         reductionPercentage = 
RuntimeFilterReductionContext.getTotalReductionPercentage(runtimeFilterInfo.useLeft_,
 runtimeFilterInfo.reductionMap_.get(scan));
line too long (159 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/JoinRelationInfo.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/JoinRelationInfo.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/JoinRelationInfo.java@117
PS5, Line 117:       LOG.info("SJC: RET WITH ZERO IS: " + (conj0.lhsNumRows_ * 
conj0.rhsNumRows_ / getDistinctRows0()));
line too long (105 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/JoinRelationInfo.java@118
PS5, Line 118:       LOG.info("SJC: RET WITH ONE IS: " + (conj0.lhsNumRows_ * 
conj0.rhsNumRows_ / getDistinctRows1()));
line too long (104 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/service/CalciteRelNodeConverter.java
File 
java/calcite-planner/src/main/java/org/apache/impala/calcite/service/CalciteRelNodeConverter.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/service/CalciteRelNodeConverter.java@93
PS5, Line 93:     this.planner_ = new VolcanoPlanner(new 
ImpalaLoptOptimizeJoinRule.RuntimeFilterInfo());
line too long (91 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/service/CalciteRelNodeConverter.java@107
PS5, Line 107:     this.planner_ = new VolcanoPlanner(new 
ImpalaLoptOptimizeJoinRule.RuntimeFilterInfo());
line too long (91 > 90)


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/main/java/org/apache/impala/calcite/service/CalciteRelNodeConverter.java@178
PS5, Line 178:     RelOptCluster newCluster = RelOptCluster.create(planner_, 
rexBuilder);
line has trailing whitespace


http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/test/java/org/apache/impala/planner/TestReduceExprShuttle.java
File 
java/calcite-planner/src/test/java/org/apache/impala/planner/TestReduceExprShuttle.java:

http://gerrit.cloudera.org:8080/#/c/23666/5/java/calcite-planner/src/test/java/org/apache/impala/planner/TestReduceExprShuttle.java@69
PS5, Line 69:   protected static final Logger LOG = 
LoggerFactory.getLogger(TestReduceExprShuttle.class.getName());
line too long (101 > 90)



--
To view, visit http://gerrit.cloudera.org:8080/23666
To unsubscribe, visit http://gerrit.cloudera.org:8080/settings

Gerrit-Project: Impala-ASF
Gerrit-Branch: master
Gerrit-MessageType: comment
Gerrit-Change-Id: I4af2efcf8d8a6038ad67aa7ef5da57d8d0f8a2bc
Gerrit-Change-Number: 23666
Gerrit-PatchSet: 5
Gerrit-Owner: Steve Carlin <[email protected]>
Gerrit-Reviewer: Impala Public Jenkins <[email protected]>
Gerrit-Comment-Date: Sat, 20 Dec 2025 19:18:48 +0000
Gerrit-HasComments: Yes

Reply via email to