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 ad066f5 [FLINK-24580][Connectors/Kinesis] Make
ConnectTimeoutException recoverable (#17785)
add 419eb1e [FLINK-25051][table-planner] Port raw <-> binary logic to
CastRule
add 3ab9802 [FLINK-24419][table-planner] Trim to length when casting to
BINARY/VARBINARY
No new revisions were added by this update.
Summary of changes:
...ngCastRule.java => BinaryToBinaryCastRule.java} | 53 ++++++----
.../functions/casting/CastRuleProvider.java | 3 +
.../planner/functions/casting/CastRuleUtils.java | 4 +
.../functions/casting/RawToBinaryCastRule.java | 113 +++++++++++++++++++++
.../functions/casting/StringToBinaryCastRule.java | 64 +++++++++++-
.../planner/codegen/calls/ScalarOperatorGens.scala | 7 --
.../planner/functions/CastFunctionITCase.java | 21 ++--
.../planner/functions/CastFunctionMiscITCase.java | 18 +++-
.../planner/functions/casting/CastRulesTest.java | 32 ++++--
9 files changed, 259 insertions(+), 56 deletions(-)
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/{TimestampToStringCastRule.java
=> BinaryToBinaryCastRule.java} (50%)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/RawToBinaryCastRule.java
