Package org.apache.iceberg
Interface ChangelogScanTask
-
- All Superinterfaces:
ScanTask
,java.io.Serializable
- All Known Subinterfaces:
AddedRowsScanTask
,DeletedDataFileScanTask
,DeletedRowsScanTask
public interface ChangelogScanTask extends ScanTask
A changelog scan task.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description int
changeOrdinal()
Returns the ordinal of changes produced by this task.long
commitSnapshotId()
Returns the snapshot ID in which the changes were committed.ChangelogOperation
operation()
Returns the type of changes produced by this task (i.e.-
Methods inherited from interface org.apache.iceberg.ScanTask
asCombinedScanTask, asDataTask, asFileScanTask, estimatedRowsCount, filesCount, isDataTask, isFileScanTask, sizeBytes
-
-
-
-
Method Detail
-
operation
ChangelogOperation operation()
Returns the type of changes produced by this task (i.e. insert/delete).
-
changeOrdinal
int changeOrdinal()
Returns the ordinal of changes produced by this task. This number indicates the order in which changes produced by this scan must be applied. Operations with a lower ordinal must be applied first.
-
commitSnapshotId
long commitSnapshotId()
Returns the snapshot ID in which the changes were committed.
-
-