[flink] branch master updated (3367c23 -> 2c1e24b)

[go...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 3367c23  [FLINK-19748] [test] Adjust raw keyed state test to only write some key groups
     add 2c1e24b  [FLINK-19282][table-planner] Support watermark push down in planner

No new revisions were added by this update.

Summary of changes:
 .../ProjectWatermarkAssignerTransposeRule.java     | 129 +++++++++++
 .../PushProjectIntoTableSourceScanRule.java        |   2 +-
 ...WatermarkIntoTableSourceScanAcrossCalcRule.java | 115 ++++++++++
 .../PushWatermarkIntoTableSourceScanRule.java      |  57 +++++
 .../PushWatermarkIntoTableSourceScanRuleBase.java  | 196 ++++++++++++++++
 .../table/planner/sources/DynamicSourceUtils.java  |  20 --
 .../table/planner/codegen/ExprCodeGenerator.scala  |  18 +-
 .../codegen/WatermarkGeneratorCodeGenerator.scala  |  82 ++++++-
 .../planner/codegen/calls/ScalarOperatorGens.scala |  16 +-
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |   6 +
 .../planner/plan/utils/NestedProjectionUtil.scala  |  27 ++-
 .../factories/TestValuesRuntimeFunctions.java      | 120 ++++++++++
 .../planner/factories/TestValuesTableFactory.java  | 172 +++++++++++---
 .../ProjectWatermarkAssignerTransposeRuleTest.java | 165 ++++++++++++++
 .../PushWatermarkIntoTableSourceScanRuleTest.java  | 211 ++++++++++++++++++
 .../table/planner/catalog/JavaCatalogTableTest.xml |  10 +-
 .../ProjectWatermarkAssignerTransposeRuleTest.xml  | 247 +++++++++++++++++++++
 .../PushWatermarkIntoTableSourceScanRuleTest.xml   | 159 +++++++++++++
 .../plan/stream/sql/MiniBatchIntervalInferTest.xml |  68 ++----
 .../plan/stream/sql/SourceWatermarkTest.xml        |  96 ++++++++
 .../planner/plan/stream/sql/TableSourceTest.xml    |  17 +-
 .../plan/stream/sql/join/TemporalJoinTest.xml      |   3 +-
 .../planner/plan/stream/table/TableSourceTest.xml  |  13 +-
 .../codegen/WatermarkGeneratorCodeGenTest.scala    |  93 ++++++--
 .../plan/stream/sql/SourceWatermarkTest.scala      | 136 ++++++++++++
 .../runtime/stream/sql/SourceWatermarkITCase.scala | 192 ++++++++++++++++
 26 files changed, 2211 insertions(+), 159 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/ProjectWatermarkAssignerTransposeRule.java
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushWatermarkIntoTableSourceScanAcrossCalcRule.java
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushWatermarkIntoTableSourceScanRule.java
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushWatermarkIntoTableSourceScanRuleBase.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/rules/logical/ProjectWatermarkAssignerTransposeRuleTest.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/rules/logical/PushWatermarkIntoTableSourceScanRuleTest.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/ProjectWatermarkAssignerTransposeRuleTest.xml
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/PushWatermarkIntoTableSourceScanRuleTest.xml
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/SourceWatermarkTest.xml
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/SourceWatermarkTest.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/SourceWatermarkITCase.scala