Package org.apache.iceberg

Class SnapshotChanges

java.lang.Object

org.apache.iceberg.SnapshotChanges

public class SnapshotChanges
extends Object

Helper class for retrieving file changes in a snapshot with caching.

This class caches the results of file change detection operations, making it efficient to query multiple file change types for the same snapshot. By default, manifests are read single-threaded. Use SnapshotChanges.Builder.executeWith(ExecutorService) to enable parallel manifest reading.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SnapshotChanges.Builder

Method Summary

Modifier and Type	Method	Description
Iterable<DataFile>	addedDataFiles()	Returns all data files added to the table in this snapshot
Iterable<DeleteFile>	addedDeleteFiles()	Returns all delete files added to the table in this snapshot.
static SnapshotChanges.Builder	builderFor(Table table)	Create a builder for SnapshotChanges using the table's current snapshot.
Iterable<DataFile>	removedDataFiles()	Returns all data files removed from the table in this snapshot.
Iterable<DeleteFile>	removedDeleteFiles()	Returns all delete files removed from the table in this snapshot.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

builderFor

public static SnapshotChanges.Builder builderFor(Table table)

Create a builder for SnapshotChanges using the table's current snapshot.

Parameters:

table - the table to detect file changes for

Returns:

a new Builder

addedDataFiles

public Iterable<DataFile> addedDataFiles()

Returns all data files added to the table in this snapshot

removedDataFiles

public Iterable<DataFile> removedDataFiles()

Returns all data files removed from the table in this snapshot.

addedDeleteFiles

public Iterable<DeleteFile> addedDeleteFiles()

Returns all delete files added to the table in this snapshot.

removedDeleteFiles

public Iterable<DeleteFile> removedDeleteFiles()

Returns all delete files removed from the table in this snapshot.