You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by lz...@apache.org on 2023/01/03 03:44:47 UTC
[flink-table-store] branch master updated (dea8ac80 -> dcae4c28)
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
from dea8ac80 [hotfix] Remove incorrect check in FullChangelogStoreSinkWrite
add dcae4c28 [FLINK-30423] Introduce generated codes for CastExecutor
No new revisions were added by this update.
Summary of changes:
.../flink/table/store/utils/DateTimeUtils.java | 22 ++
.../CastExecutor.java} | 31 +-
.../table/store/file/casting/CastExecutors.java | 293 +++++++++++++++++++
.../table/store/file/casting/CastExecutorTest.java | 319 +++++++++++++++++++++
4 files changed, 649 insertions(+), 16 deletions(-)
copy flink-table-store-core/src/main/java/org/apache/flink/table/store/file/{schema/KeyValueFieldsExtractor.java => casting/CastExecutor.java} (57%)
create mode 100644 flink-table-store-core/src/main/java/org/apache/flink/table/store/file/casting/CastExecutors.java
create mode 100644 flink-table-store-core/src/test/java/org/apache/flink/table/store/file/casting/CastExecutorTest.java