This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from e9a7f39661 Flink: Support Lookup Join using full in-memory lookup
cache (#18144)
add e3d031483c Flink: Resolve the record serializer without loading the
table (#18525)
No new revisions were added by this update.
Summary of changes:
...namicRecordSerializerDeserializerBenchmark.java | 7 +-
.../flink/sink/dynamic/DynamicIcebergSink.java | 12 +-
.../dynamic/DynamicRecordInternalSerializer.java | 26 ++---
.../sink/dynamic/DynamicRecordInternalType.java | 10 +-
.../flink/sink/dynamic/DynamicRecordProcessor.java | 6 +-
.../flink/sink/dynamic/TableSerializerCache.java | 95 ++++++++++------
.../DynamicRecordInternalSerializerTestBase.java | 2 +-
.../TestDynamicRecordInternalSerializer.java | 52 ++++++++-
.../sink/dynamic/TestDynamicRecordProcessor.java | 2 +-
.../sink/dynamic/TestTableSerializerCache.java | 122 ++++++++++++++++++---
10 files changed, 263 insertions(+), 71 deletions(-)
