lincoln-lil commented on code in PR #22918:
URL: https://github.com/apache/flink/pull/22918#discussion_r1253997411
##########
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdSelectivity.scala:
##########
@@ -256,6 +257,13 @@ class FlinkRelMdSelectivity private extends
MetadataHandler[BuiltInMetadata.Sele
}
}
+ def getSelectivity(
+ rel: CommonPhysicalWindowTableFunction,
+ mq: RelMetadataQuery,
+ predicate: RexNode): JDouble = {
+ estimateSelectivity(rel, mq, predicate)
+ }
+
Review Comment:
For this particular case, what we're missing is the identification of the
new node `WindowTableFunction`, and it's probably not a good time to modify the
default processing logic as to whether the exact same default processing as the
batch is used on the stream, WDYT?
--
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]
