Package org.apache.iceberg
Interface IncrementalScan<ThisT,T extends ScanTask,G extends ScanTaskGroup<T>>
-
- All Superinterfaces:
Scan<ThisT,T,G>
- All Known Subinterfaces:
IncrementalAppendScan
,IncrementalChangelogScan
public interface IncrementalScan<ThisT,T extends ScanTask,G extends ScanTaskGroup<T>> extends Scan<ThisT,T,G>
API for configuring an incremental scan.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description ThisT
fromSnapshotExclusive(long fromSnapshotId)
Instructs this scan to look for changes starting from a particular snapshot (exclusive).default ThisT
fromSnapshotExclusive(java.lang.String ref)
Instructs this scan to look for changes starting from a particular snapshot (exclusive).ThisT
fromSnapshotInclusive(long fromSnapshotId)
Instructs this scan to look for changes starting from a particular snapshot (inclusive).default ThisT
fromSnapshotInclusive(java.lang.String ref)
Instructs this scan to look for changes starting from a particular snapshot (inclusive).ThisT
toSnapshot(long toSnapshotId)
Instructs this scan to look for changes up to a particular snapshot (inclusive).default ThisT
toSnapshot(java.lang.String ref)
Instructs this scan to look for changes up to a particular snapshot ref (inclusive).default ThisT
useBranch(java.lang.String branch)
Use the specified branch-
Methods inherited from interface org.apache.iceberg.Scan
caseSensitive, filter, filter, ignoreResiduals, includeColumnStats, includeColumnStats, isCaseSensitive, metricsReporter, option, planFiles, planTasks, planWith, project, schema, select, select, splitLookback, splitOpenFileCost, targetSplitSize
-
-
-
-
Method Detail
-
fromSnapshotInclusive
ThisT fromSnapshotInclusive(long fromSnapshotId)
Instructs this scan to look for changes starting from a particular snapshot (inclusive).If the start snapshot is not configured, it defaults to the oldest ancestor of the end snapshot (inclusive).
- Parameters:
fromSnapshotId
- the start snapshot ID (inclusive)- Returns:
- this for method chaining
- Throws:
java.lang.IllegalArgumentException
- if the start snapshot is not an ancestor of the end snapshot
-
fromSnapshotInclusive
default ThisT fromSnapshotInclusive(java.lang.String ref)
Instructs this scan to look for changes starting from a particular snapshot (inclusive).If the start snapshot is not configured, it defaults to the oldest ancestor of the end snapshot (inclusive).
- Parameters:
ref
- the start ref name that points to a particular snapshot ID (inclusive)- Returns:
- this for method chaining
- Throws:
java.lang.IllegalArgumentException
- if the start snapshot is not an ancestor of the end snapshot
-
fromSnapshotExclusive
ThisT fromSnapshotExclusive(long fromSnapshotId)
Instructs this scan to look for changes starting from a particular snapshot (exclusive).If the start snapshot is not configured, it defaults to the oldest ancestor of the end snapshot (inclusive).
- Parameters:
fromSnapshotId
- the start snapshot ID (exclusive)- Returns:
- this for method chaining
- Throws:
java.lang.IllegalArgumentException
- if the start snapshot is not an ancestor of the end snapshot
-
fromSnapshotExclusive
default ThisT fromSnapshotExclusive(java.lang.String ref)
Instructs this scan to look for changes starting from a particular snapshot (exclusive).If the start snapshot is not configured, it defaults to the oldest ancestor of the end snapshot (inclusive).
- Parameters:
ref
- the start ref name that points to a particular snapshot ID (exclusive)- Returns:
- this for method chaining
- Throws:
java.lang.IllegalArgumentException
- if the start snapshot is not an ancestor of the end snapshot
-
toSnapshot
ThisT toSnapshot(long toSnapshotId)
Instructs this scan to look for changes up to a particular snapshot (inclusive).If the end snapshot is not configured, it defaults to the current table snapshot (inclusive).
- Parameters:
toSnapshotId
- the end snapshot ID (inclusive)- Returns:
- this for method chaining
-
toSnapshot
default ThisT toSnapshot(java.lang.String ref)
Instructs this scan to look for changes up to a particular snapshot ref (inclusive).If the end snapshot is not configured, it defaults to the current table snapshot (inclusive).
- Parameters:
ref
- the end snapshot Ref (inclusive)- Returns:
- this for method chaining
-
useBranch
default ThisT useBranch(java.lang.String branch)
Use the specified branch- Parameters:
branch
- the branch name- Returns:
- this for method chaining
-
-