This is an automated email from the ASF dual-hosted git repository.
jqin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from b1a111c85c1 [hotfix][tests] Decrease the network memory size to make
HybridShuffleITCase more stable
add 5be4688e8b8 [FLINK-20767][table planner] Support filter push down on
nested fields (#23313)
No new revisions were added by this update.
Summary of changes:
.../utils/ApiExpressionDefaultVisitor.java | 6 ++
.../utils/ResolvedExpressionDefaultVisitor.java | 6 ++
.../expressions/ExpressionDefaultVisitor.java | 5 ++
.../flink/table/expressions/ExpressionVisitor.java | 4 +
...on.java => NestedFieldReferenceExpression.java} | 73 ++++++++---------
.../expressions/converter/ExpressionConverter.java | 12 +++
.../plan/abilities/source/FilterPushDownSpec.java | 7 +-
.../table/planner/plan/utils/FlinkRexUtil.scala | 3 +-
.../planner/plan/utils/RexNodeExtractor.scala | 48 ++++++++++-
.../table/planner/factories/TestValuesCatalog.java | 2 +-
.../planner/factories/TestValuesTableFactory.java | 15 +++-
.../PushFilterIntoTableSourceScanRuleTest.java | 63 +++++++++++++++
.../flink/table/planner/utils/FilterUtils.java | 45 +++++++++--
.../PushFilterIntoTableSourceScanRuleTest.xml | 92 ++++++++++++++++++++++
.../runtime/batch/sql/TableSourceITCase.scala | 38 +++++++++
.../runtime/stream/sql/TableSourceITCase.scala | 54 +++++++++++++
16 files changed, 421 insertions(+), 52 deletions(-)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/{FieldReferenceExpression.java
=> NestedFieldReferenceExpression.java} (53%)
