Interface OverwriteFiles
-
- All Superinterfaces:
PendingUpdate<Snapshot>
,SnapshotUpdate<OverwriteFiles>
- All Known Implementing Classes:
BaseOverwriteFiles
public interface OverwriteFiles extends SnapshotUpdate<OverwriteFiles>
API for overwriting files in a table.This API accumulates file additions and produces a new
Snapshot
of the table by replacing all the deleted files with the set of additions. This operation is used to implement idempotent writes that always replace a section of a table with new data or update/delete operations that eagerly overwrite files.Overwrites can be validated. The default validation mode is idempotent, meaning the overwrite is correct and should be committed out regardless of other concurrent changes to the table. For example, this can be used for replacing all the data for day D with query results. Alternatively, this API can be configured for overwriting certain files with their filtered versions while ensuring no new data that would need to be filtered has been added.
When committing, these changes will be applied to the latest table snapshot. Commit conflicts will be resolved by applying the changes to the new latest snapshot and reattempting the commit.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Deprecated Methods Modifier and Type Method Description OverwriteFiles
addFile(DataFile file)
Add aDataFile
to the table.OverwriteFiles
caseSensitive(boolean caseSensitive)
Enables or disables case sensitive expression binding for validations that accept expressions.OverwriteFiles
conflictDetectionFilter(Expression conflictDetectionFilter)
Sets a conflict detection filter used to validate concurrently added data and delete files.OverwriteFiles
deleteFile(DataFile file)
Delete aDataFile
from the table.OverwriteFiles
overwriteByRowFilter(Expression expr)
Delete files that match anExpression
on data rows from the table.OverwriteFiles
validateAddedFilesMatchOverwriteFilter()
Signal that each file added to the table must match the overwrite expression.OverwriteFiles
validateFromSnapshot(long snapshotId)
Set the snapshot ID used in any reads for this operation.default OverwriteFiles
validateNoConflictingAppends(Expression conflictDetectionFilter)
Deprecated.since 0.13.0, will be removed in 0.14.0; useconflictDetectionFilter(Expression)
andvalidateNoConflictingData()
instead.OverwriteFiles
validateNoConflictingData()
Enables validation that data added concurrently does not conflict with this commit's operation.OverwriteFiles
validateNoConflictingDeletes()
Enables validation that deletes that happened concurrently do not conflict with this commit's operation.-
Methods inherited from interface org.apache.iceberg.PendingUpdate
apply, commit, updateEvent
-
Methods inherited from interface org.apache.iceberg.SnapshotUpdate
deleteWith, set, stageOnly
-
-
-
-
Method Detail
-
overwriteByRowFilter
OverwriteFiles overwriteByRowFilter(Expression expr)
Delete files that match anExpression
on data rows from the table.A file is selected to be deleted by the expression if it could contain any rows that match the expression (candidate files are selected using an
inclusive projection
). These candidate files are deleted if all of the rows in the file must match the expression (the partition data matches the expression'sProjections.strict(PartitionSpec)
strict projection}). This guarantees that files are deleted if and only if all rows in the file must match the expression.Files that may contain some rows that match the expression and some rows that do not will result in a
ValidationException
.- Parameters:
expr
- an expression on rows in the table- Returns:
- this for method chaining
- Throws:
ValidationException
- If a file can contain both rows that match and rows that do not
-
addFile
OverwriteFiles addFile(DataFile file)
Add aDataFile
to the table.- Parameters:
file
- a data file- Returns:
- this for method chaining
-
deleteFile
OverwriteFiles deleteFile(DataFile file)
Delete aDataFile
from the table.- Parameters:
file
- a data file- Returns:
- this for method chaining
-
validateAddedFilesMatchOverwriteFilter
OverwriteFiles validateAddedFilesMatchOverwriteFilter()
Signal that each file added to the table must match the overwrite expression.If this method is called, each added file is validated on commit to ensure that it matches the overwrite row filter. This is used to ensure that writes are idempotent: that files cannot be added during a commit that would not be removed if the operation were run a second time.
- Returns:
- this for method chaining
-
validateFromSnapshot
OverwriteFiles validateFromSnapshot(long snapshotId)
Set the snapshot ID used in any reads for this operation.Validations will check changes after this snapshot ID. If the from snapshot is not set, all ancestor snapshots through the table's initial snapshot are validated.
- Parameters:
snapshotId
- a snapshot ID- Returns:
- this for method chaining
-
caseSensitive
OverwriteFiles caseSensitive(boolean caseSensitive)
Enables or disables case sensitive expression binding for validations that accept expressions.- Parameters:
caseSensitive
- whether expression binding should be case sensitive- Returns:
- this for method chaining
-
validateNoConflictingAppends
@Deprecated default OverwriteFiles validateNoConflictingAppends(Expression conflictDetectionFilter)
Deprecated.since 0.13.0, will be removed in 0.14.0; useconflictDetectionFilter(Expression)
andvalidateNoConflictingData()
instead.Enables validation that data files added concurrently do not conflict with this commit's operation.This method should be called while committing non-idempotent overwrite operations. If a concurrent operation commits a new file after the data was read and that file might contain rows matching the specified conflict detection filter, the overwrite operation will detect this and fail.
Calling this method with a correct conflict detection filter is required to maintain serializable isolation for overwrite operations. Otherwise, the isolation level will be snapshot isolation.
Validation applies to files added to the table since the snapshot passed to
validateFromSnapshot(long)
.- Parameters:
conflictDetectionFilter
- an expression on rows in the table- Returns:
- this for method chaining
-
conflictDetectionFilter
OverwriteFiles conflictDetectionFilter(Expression conflictDetectionFilter)
Sets a conflict detection filter used to validate concurrently added data and delete files.- Parameters:
conflictDetectionFilter
- an expression on rows in the table- Returns:
- this for method chaining
-
validateNoConflictingData
OverwriteFiles validateNoConflictingData()
Enables validation that data added concurrently does not conflict with this commit's operation.This method should be called while committing non-idempotent overwrite operations. If a concurrent operation commits a new file after the data was read and that file might contain rows matching the specified conflict detection filter, the overwrite operation will detect this and fail.
Calling this method with a correct conflict detection filter is required to maintain isolation for non-idempotent overwrite operations.
Validation uses the conflict detection filter passed to
conflictDetectionFilter(Expression)
and applies to operations that happened after the snapshot passed tovalidateFromSnapshot(long)
. If the conflict detection filter is not set, any new data added concurrently will fail this overwrite operation.- Returns:
- this for method chaining
-
validateNoConflictingDeletes
OverwriteFiles validateNoConflictingDeletes()
Enables validation that deletes that happened concurrently do not conflict with this commit's operation.Validating concurrent deletes is required during non-idempotent overwrite operations. If a concurrent operation deletes data in one of the files being overwritten, the overwrite operation must be aborted as it may undelete rows that were removed concurrently.
Calling this method with a correct conflict detection filter is required to maintain isolation for non-idempotent overwrite operations.
Validation uses the conflict detection filter passed to
conflictDetectionFilter(Expression)
and applies to operations that happened after the snapshot passed tovalidateFromSnapshot(long)
. If the conflict detection filter is not set, this operation will use the row filter provided inoverwriteByRowFilter(Expression)
to check for new delete files and will ensure there are no conflicting deletes for data files removed viadeleteFile(DataFile)
.- Returns:
- this for method chaining
-
-