swuferhong commented on code in PR #21490:
URL: https://github.com/apache/flink/pull/21490#discussion_r1057402776
##########
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRelMdUtil.scala:
##########
@@ -247,6 +248,77 @@ object FlinkRelMdUtil {
RexUtil.composeConjunction(rexBuilder, pushable, true)
}
+ /**
+ * This method is copied from calcite RelMdUtil. This method should be
removed once CALCITE-4351
+ * is fixed. See CALCITE-4351 and FLINK-19780.
+ *
+ * Computes the number of distinct rows for a set of keys returned from a
join. Also known as NDV
+ * (number of distinct values).
+ *
Review Comment:
> please also mark which lines are changed
Done!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
