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 b1a409e [FLINK-24678][runtime/metrics] Correct the metric name of map
state contains latency
add 0046a1c [hotfix][table-runtime] Fix ArrayDataSerializer null fields
writing
add 2bb4012 [FLINK-24462][table] Introduce CastRule interface to
reorganize casting code
No new revisions were added by this update.
Summary of changes:
.../flink/table/data/utils/CastExecutor.java | 43 ++
.../planner/functions/casting/CastCodeBlock.java | 75 ++
.../table/planner/functions/casting/CastRule.java | 69 ++
.../functions/casting/CastRulePredicate.java | 151 ++++
.../functions/casting/CastRuleProvider.java | 183 +++++
.../functions/casting/CodeGeneratorCastRule.java | 64 ++
.../functions/casting/rules/AbstractCastRule.java | 39 +
.../rules/AbstractCharacterFamilyTargetRule.java | 56 ++
.../rules/AbstractCodeGeneratorCastRule.java | 226 ++++++
.../AbstractExpressionCodeGeneratorCastRule.java | 112 +++
.../AbstractNullAwareCodeGeneratorCastRule.java | 97 +++
.../casting/rules/ArrayToArrayCastRule.java | 158 +++++
.../functions/casting/rules/CastRuleUtils.java | 39 +
.../rules/CodeGeneratedExpressionCastExecutor.java | 59 ++
.../functions/casting/rules/IdentityCastRule.java | 48 ++
.../casting/rules/TimestampToStringCastRule.java | 64 ++
.../casting/rules/UpcastToBigIntCastRule.java | 51 ++
.../flink/table/planner/codegen/CodeGenUtils.scala | 26 +-
.../planner/codegen/EqualiserCodeGenerator.scala | 4 +-
.../table/planner/codegen/GenerateUtils.scala | 10 +-
.../table/planner/codegen/JsonGenerateUtils.scala | 8 +-
.../planner/codegen/LongHashJoinGenerator.scala | 2 +-
.../planner/codegen/calls/BuiltInMethods.scala | 8 +
.../planner/codegen/calls/ScalarOperatorGens.scala | 789 +++++++++++----------
.../planner/functions/CastFunctionITCase.java | 22 +
.../planner/functions/casting/CastRulesTest.java | 204 ++++++
.../table/runtime/generated/CompileUtils.java | 92 +++
.../table/runtime/generated/GeneratedClass.java | 2 +-
.../runtime/typeutils/ArrayDataSerializer.java | 4 +-
.../table/runtime/generated/CompileUtilsTest.java | 28 +
.../runtime/typeutils/ArrayDataSerializerTest.java | 5 +-
31 files changed, 2339 insertions(+), 399 deletions(-)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/utils/CastExecutor.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/CastCodeBlock.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/CastRule.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/CastRulePredicate.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/CastRuleProvider.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/CodeGeneratorCastRule.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/AbstractCastRule.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/AbstractCharacterFamilyTargetRule.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/AbstractCodeGeneratorCastRule.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/AbstractExpressionCodeGeneratorCastRule.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/AbstractNullAwareCodeGeneratorCastRule.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/ArrayToArrayCastRule.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/CastRuleUtils.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/CodeGeneratedExpressionCastExecutor.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/IdentityCastRule.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/TimestampToStringCastRule.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/UpcastToBigIntCastRule.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/casting/CastRulesTest.java
