Package org.apache.iceberg
Interface SnapshotUpdate<ThisT>
- Type Parameters:
ThisT
- the child Java API class, returned by method chaining.
- All Superinterfaces:
PendingUpdate<Snapshot>
- All Known Subinterfaces:
AppendFiles
,DeleteFiles
,OverwriteFiles
,ReplacePartitions
,RewriteFiles
,RewriteManifests
,RowDelta
- All Known Implementing Classes:
BaseOverwriteFiles
,BaseReplacePartitions
,BaseRewriteManifests
,StreamingDelete
API for table changes that produce snapshots. This interface contains common methods for all
updates that create a new table
Snapshot
.-
Method Summary
Modifier and TypeMethodDescriptiondeleteWith
(Consumer<String> deleteFunc) Set a callback to delete files instead of the table's default.scanManifestsWith
(ExecutorService executorService) Use a particular executor to scan manifests.Set a summary property in the snapshot produced by this update.Called to stage a snapshot in table metadata, but not update the current snapshot id.default ThisT
Perform operations on a particular branchMethods inherited from interface org.apache.iceberg.PendingUpdate
apply, commit, updateEvent
-
Method Details
-
set
Set a summary property in the snapshot produced by this update.- Parameters:
property
- a String property namevalue
- a String property value- Returns:
- this for method chaining
-
deleteWith
Set a callback to delete files instead of the table's default.- Parameters:
deleteFunc
- a String consumer used to delete locations.- Returns:
- this for method chaining
-
stageOnly
ThisT stageOnly()Called to stage a snapshot in table metadata, but not update the current snapshot id.- Returns:
- this for method chaining
-
scanManifestsWith
Use a particular executor to scan manifests. The default worker pool will be used by default.- Parameters:
executorService
- the provided executor- Returns:
- this for method chaining
-
toBranch
Perform operations on a particular branch- Parameters:
branch
- which is name of SnapshotRef of type branch.
-