You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by ao...@apache.org on 2021/09/20 05:08:23 UTC
[iceberg] branch master updated (6faed7e -> 42e338d)
This is an automated email from the ASF dual-hosted git repository.
aokolnychyi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git.
from 6faed7e Spark: Implement invalidateTable for SparkSessionCatalog (#3072)
add 42e338d Core: Add FileWriter interface (#3149)
No new revisions were added by this update.
Summary of changes:
.../iceberg/deletes/EqualityDeleteWriter.java | 28 +++++++-
.../iceberg/deletes/PositionDeleteWriter.java | 41 ++++++++++--
.../DataWriteResult.java} | 30 +++++----
.../java/org/apache/iceberg/io/DataWriter.java | 20 +++++-
.../org/apache/iceberg/io/DeleteWriteResult.java | 64 +++++++++++++++++++
.../java/org/apache/iceberg/io/FileWriter.java | 74 ++++++++++++++++++++++
.../{WriterFactory.java => FileWriterFactory.java} | 2 +-
.../apache/iceberg/io/SortedPosDeleteWriter.java | 27 +++++++-
...iterFactory.java => BaseFileWriterFactory.java} | 12 ++--
...iterFactory.java => TestFileWriterFactory.java} | 33 +++++-----
.../org/apache/iceberg/io/TestWriterMetrics.java | 2 +-
...terFactory.java => FlinkFileWriterFactory.java} | 18 +++---
...actory.java => TestFlinkFileWriterFactory.java} | 15 +++--
.../iceberg/flink/sink/TestFlinkWriterMetrics.java | 6 +-
...terFactory.java => SparkFileWriterFactory.java} | 18 +++---
...actory.java => TestSparkFileWriterFactory.java} | 16 ++---
.../spark/source/TestSparkWriterMetrics.java | 6 +-
17 files changed, 322 insertions(+), 90 deletions(-)
copy core/src/main/java/org/apache/iceberg/{hadoop/HiddenPathFilter.java => io/DataWriteResult.java} (57%)
create mode 100644 core/src/main/java/org/apache/iceberg/io/DeleteWriteResult.java
create mode 100644 core/src/main/java/org/apache/iceberg/io/FileWriter.java
rename core/src/main/java/org/apache/iceberg/io/{WriterFactory.java => FileWriterFactory.java} (98%)
rename data/src/main/java/org/apache/iceberg/data/{BaseWriterFactory.java => BaseFileWriterFactory.java} (94%)
rename data/src/test/java/org/apache/iceberg/io/{TestWriterFactory.java => TestFileWriterFactory.java} (91%)
rename flink/src/main/java/org/apache/iceberg/flink/sink/{FlinkWriterFactory.java => FlinkFileWriterFactory.java} (92%)
rename flink/src/test/java/org/apache/iceberg/flink/sink/{TestFlinkWriterFactory.java => TestFlinkFileWriterFactory.java} (78%)
rename spark/src/main/java/org/apache/iceberg/spark/source/{SparkWriterFactory.java => SparkFileWriterFactory.java} (92%)
rename spark/src/test/java/org/apache/iceberg/spark/source/{TestSparkWriterFactory.java => TestSparkFileWriterFactory.java} (78%)