You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by bl...@apache.org on 2020/06/29 17:56:55 UTC
[iceberg] branch master updated (4e282c3 -> edb8d77)
This is an automated email from the ASF dual-hosted git repository.
blue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git.
from 4e282c3 ORC: Fix date metrics (#1127)
add edb8d77 Flink: Add Parquet value reader, writer implementations (#1125)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iceberg/util/RandomUtil.java | 37 ++++++
build.gradle | 3 +
.../data/parquet/GenericParquetReaders.java | 36 +++---
.../iceberg/data/parquet/GenericParquetWriter.java | 16 ++-
.../org/apache/iceberg/data/RandomGenericData.java | 39 ++++--
.../iceberg/flink/data/FlinkParquetReaders.java | 114 +++++++++++++++++
.../iceberg/flink/data/FlinkParquetWriters.java | 62 ++++++++++
.../org/apache/iceberg/flink/data/RandomData.java | 136 +++++++++++++++++++++
.../flink/data/TestFlinkParquetReaderWriter.java | 54 +++++---
.../org/apache/iceberg/spark/data/RandomData.java | 42 +------
10 files changed, 449 insertions(+), 90 deletions(-)
create mode 100644 flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetReaders.java
create mode 100644 flink/src/main/java/org/apache/iceberg/flink/data/FlinkParquetWriters.java
create mode 100644 flink/src/test/java/org/apache/iceberg/flink/data/RandomData.java
copy spark/src/test/java/org/apache/iceberg/spark/data/TestSparkParquetWriter.java => flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkParquetReaderWriter.java (67%)