[flink] branch master updated (09b3061 -> 43d8a4a)

[tw...@apache.org]

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

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


    from 09b3061  [FLINK-24691][table-planner] Fix decimal precision for SUM
     add de7bf46  [hotfix][table-planner] Add comment in codegen to specify which rule generated the casting
     add e8f7713  [hotfix][table-planner] Add codegen logging
     add afc3d34  [hotfix][table-planner] Improved error messages in ExpressionTestBase
     add 43d8a4a  [FLINK-24684][table-planner] Add to-string cast rules using the new CastRule stack

No new revisions were added by this update.

Summary of changes:
 .../functions/casting/CastRuleProvider.java        |  39 ++-
 .../rules/AbstractCharacterFamilyTargetRule.java   |  11 +-
 .../rules/AbstractCodeGeneratorCastRule.java       |   6 +-
 .../AbstractNullAwareCodeGeneratorCastRule.java    |  32 +--
 .../casting/rules/ArrayToArrayCastRule.java        | 107 ++++----
 .../casting/rules/ArrayToStringCastRule.java       | 171 ++++++++++++
 ...TargetRule.java => BinaryToStringCastRule.java} |  39 +--
 ...gCastRule.java => BooleanToStringCastRule.java} |  27 +-
 .../functions/casting/rules/CastRuleUtils.java     | 154 ++++++++++-
 ...ringCastRule.java => DateToStringCastRule.java} |  27 +-
 .../functions/casting/rules/IdentityCastRule.java  |  22 +-
 ...CastRule.java => IntervalToStringCastRule.java} |  32 +--
 .../casting/rules/MapToStringCastRule.java         | 229 ++++++++++++++++
 ...yCastRule.java => NumericToStringCastRule.java} |  24 +-
 ...tringCastRule.java => RawToStringCastRule.java} |  46 ++--
 .../casting/rules/RowToStringCastRule.java         | 176 ++++++++++++
 ...ringCastRule.java => TimeToStringCastRule.java} |  29 +-
 .../casting/rules/TimestampToStringCastRule.java   |  14 +-
 .../planner/codegen/OperatorCodeGenerator.scala    |   2 +
 .../planner/codegen/calls/BuiltInMethods.scala     |   2 +-
 .../planner/codegen/calls/ScalarOperatorGens.scala | 294 +-------------------
 .../planner/functions/casting/CastRulesTest.java   | 303 ++++++++++++++++++---
 .../src/test/resources/log4j2-test.properties      |   6 +
 .../expressions/utils/ExpressionTestBase.scala     |  54 ++--
 24 files changed, 1277 insertions(+), 569 deletions(-)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/ArrayToStringCastRule.java
 copy flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/{AbstractCharacterFamilyTargetRule.java => BinaryToStringCastRule.java} (59%)
 copy flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/{TimestampToStringCastRule.java => BooleanToStringCastRule.java} (60%)
 copy flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/{TimestampToStringCastRule.java => DateToStringCastRule.java} (62%)
 copy flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/{TimestampToStringCastRule.java => IntervalToStringCastRule.java} (62%)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/MapToStringCastRule.java
 copy flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/{IdentityCastRule.java => NumericToStringCastRule.java} (59%)
 copy flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/{TimestampToStringCastRule.java => RawToStringCastRule.java} (52%)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/RowToStringCastRule.java
 copy flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/{TimestampToStringCastRule.java => TimeToStringCastRule.java} (62%)