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/08/20 16:17:29 UTC
[iceberg] branch master updated (6cb2db7 -> 311f2a1)
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 6cb2db7 Flink: Read Parquet as RowData using a schema visitor (#1266)
add 311f2a1 Flink: Add Orc reader, writer implementations (#1255)
No new revisions were added by this update.
Summary of changes:
.../apache/iceberg/data/orc/GenericOrcWriter.java | 2 +-
.../apache/iceberg/data/orc/GenericOrcWriters.java | 44 ++-
.../iceberg/flink/RowDataTaskWriterFactory.java | 12 +-
.../apache/iceberg/flink/data/FlinkOrcReader.java | 129 ++++++++
.../apache/iceberg/flink/data/FlinkOrcReaders.java | 262 ++++++++++++++++
.../apache/iceberg/flink/data/FlinkOrcWriter.java | 133 ++++++++
.../apache/iceberg/flink/data/FlinkOrcWriters.java | 333 +++++++++++++++++++++
.../iceberg/flink/data/FlinkSchemaVisitor.java | 106 +++++++
.../org/apache/iceberg/flink/RowDataConverter.java | 13 +-
.../iceberg/flink/TestIcebergStreamWriter.java | 10 +-
.../org/apache/iceberg/flink/TestTaskWriters.java | 10 +-
.../flink/data/TestFlinkOrcReaderWriter.java | 105 +++++++
12 files changed, 1143 insertions(+), 16 deletions(-)
create mode 100644 flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReader.java
create mode 100644 flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcReaders.java
create mode 100644 flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriter.java
create mode 100644 flink/src/main/java/org/apache/iceberg/flink/data/FlinkOrcWriters.java
create mode 100644 flink/src/main/java/org/apache/iceberg/flink/data/FlinkSchemaVisitor.java
create mode 100644 flink/src/test/java/org/apache/iceberg/flink/data/TestFlinkOrcReaderWriter.java