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/02/04 21:50:06 UTC
[incubator-iceberg] branch master updated (722f4c3 -> a0ff334)
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/incubator-iceberg.git.
from 722f4c3 Make GenericManifestFile compatible with Kryo (#775)
add a0ff334 Add SnapshotManager to roll back and cherry-pick snapshots (#695)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iceberg/ManageSnapshots.java | 83 +++
api/src/main/java/org/apache/iceberg/Rollback.java | 5 +-
api/src/main/java/org/apache/iceberg/Table.java | 8 +
...java => CherrypickAncestorCommitException.java} | 19 +-
...ption.java => DuplicateWAPCommitException.java} | 12 +-
.../java/org/apache/iceberg/BaseMetadataTable.java | 5 +
.../main/java/org/apache/iceberg/BaseTable.java | 5 +
.../java/org/apache/iceberg/BaseTransaction.java | 5 +
.../org/apache/iceberg/RollbackToSnapshot.java | 48 +-
.../java/org/apache/iceberg/SnapshotManager.java | 218 +++++++
.../java/org/apache/iceberg/SnapshotProducer.java | 17 +-
.../java/org/apache/iceberg/SnapshotSummary.java | 3 +
.../java/org/apache/iceberg/TableMetadata.java | 12 +-
.../main/java/org/apache/iceberg/util/WapUtil.java | 68 ++
.../java/org/apache/iceberg/TestWapWorkflow.java | 687 +++++++++++++++++++++
.../org/apache/iceberg/spark/source/Writer.java | 3 +-
16 files changed, 1132 insertions(+), 66 deletions(-)
create mode 100644 api/src/main/java/org/apache/iceberg/ManageSnapshots.java
copy api/src/main/java/org/apache/iceberg/exceptions/{RuntimeIOException.java => CherrypickAncestorCommitException.java} (56%)
copy api/src/main/java/org/apache/iceberg/exceptions/{NotFoundException.java => DuplicateWAPCommitException.java} (69%)
create mode 100644 core/src/main/java/org/apache/iceberg/SnapshotManager.java
create mode 100644 core/src/main/java/org/apache/iceberg/util/WapUtil.java
create mode 100644 core/src/test/java/org/apache/iceberg/TestWapWorkflow.java