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
