This is an automated email from the ASF dual-hosted git repository.
stevenwu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 3def7f1d4f API, Core, Flink, Parquet, Spark: Use enhanced for loop
(#6476)
add bd1abcc92b Flink: add support of writing Avro GenericRecord DataStream
to Iceberg (#6557)
No new revisions were added by this update.
Summary of changes:
docs/flink-getting-started.md | 35 ++
flink/v1.16/build.gradle | 1 +
.../sink/AvroGenericRecordToRowDataMapper.java | 61 ++++
.../flink/AvroGenericRecordConverterBase.java | 90 +++++
.../org/apache/iceberg/flink/DataGenerator.java | 4 +
.../org/apache/iceberg/flink/DataGenerators.java | 369 ++++++++++++++++++++-
.../sink/TestAvroGenericRecordToRowDataMapper.java | 21 +-
7 files changed, 576 insertions(+), 5 deletions(-)
create mode 100644
flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/sink/AvroGenericRecordToRowDataMapper.java
create mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/AvroGenericRecordConverterBase.java
copy api/src/main/java/org/apache/iceberg/events/Listener.java =>
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestAvroGenericRecordToRowDataMapper.java
(50%)
