This is an automated email from the ASF dual-hosted git repository.
pvary pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 0f657edf12 Flink: Fix LICENSE/NOTICE compliance for all versions of
flink-runtime (1.20, 2.0, 2.1) (#16216)
add 05b2df1bd2 Flink: Backport add Nanosecond Precision Support for
Flink-Iceberg Integration (#16183)
No new revisions were added by this update.
Summary of changes:
flink/v2.0/build.gradle | 1 +
.../org/apache/iceberg/flink/FlinkTypeToType.java | 6 ++
.../org/apache/iceberg/flink/RowDataWrapper.java | 36 +++++--
.../apache/iceberg/flink/data/FlinkOrcReader.java | 7 ++
.../apache/iceberg/flink/data/FlinkOrcWriter.java | 7 ++
.../apache/iceberg/flink/data/FlinkOrcWriters.java | 37 ++++++++
.../org/apache/iceberg/flink/data/RowDataUtil.java | 2 +
.../apache/iceberg/flink/data/StructRowData.java | 48 +++++++++-
.../formats/avro/AvroToRowDataConverters.java | 0
.../iceberg/flink/formats/avro/JodaConverter.java | 0
.../formats/avro/RowDataToAvroConverters.java | 0
.../avro/typeutils/AvroSchemaConverter.java | 0
.../sink/AvroGenericRecordToRowDataMapper.java | 4 +-
.../RowDataToAvroGenericRecordConverter.java | 4 +-
.../source/reader/AvroGenericRecordConverter.java | 4 +-
.../org/apache/iceberg/flink/DataGenerators.java | 105 +++++++++++++++++++--
.../apache/iceberg/flink/TestRowDataWrapper.java | 13 ---
.../flink/data/TestFlinkOrcReaderWriter.java | 5 +
.../iceberg/flink/data/TestRowDataProjection.java | 21 +++--
19 files changed, 249 insertions(+), 51 deletions(-)
copy flink/{v2.1 =>
v2.0}/flink/src/main/java/org/apache/iceberg/flink/formats/avro/AvroToRowDataConverters.java
(100%)
copy flink/{v2.1 =>
v2.0}/flink/src/main/java/org/apache/iceberg/flink/formats/avro/JodaConverter.java
(100%)
copy flink/{v2.1 =>
v2.0}/flink/src/main/java/org/apache/iceberg/flink/formats/avro/RowDataToAvroConverters.java
(100%)
copy flink/{v2.1 =>
v2.0}/flink/src/main/java/org/apache/iceberg/flink/formats/avro/typeutils/AvroSchemaConverter.java
(100%)
