public interface AddedRowsScanTask extends ChangelogScanTask, ContentScanTask<DataFile>
Note that added data files may have matching delete files. This may happen if a matching position delete file is committed in the same snapshot or if changes for multiple snapshots are squashed together.
Suppose snapshot S1 adds data files F1, F2, F3 and a position delete file, D1, that marks particular records in F1 as deleted. A scan for changes generated by S1 should include the following tasks:
Readers consuming these tasks should produce added records with metadata like change ordinal and commit snapshot ID.
Modifier and Type | Method and Description |
---|---|
java.util.List<DeleteFile> |
deletes()
A list of
delete files to apply when reading the data file in this task. |
default int |
filesCount()
The number of files that will be opened by this scan task.
|
default ChangelogOperation |
operation()
Returns the type of changes produced by this task (i.e.
|
default long |
sizeBytes()
The number of bytes that should be read by this scan task.
|
changeOrdinal, commitSnapshotId
estimatedRowsCount, file, length, partition, residual, start
spec
asCombinedScanTask, asDataTask, asFileScanTask, isDataTask, isFileScanTask
java.util.List<DeleteFile> deletes()
delete files
to apply when reading the data file in this task.default ChangelogOperation operation()
ChangelogScanTask
operation
in interface ChangelogScanTask
default long sizeBytes()
ScanTask
default int filesCount()
ScanTask
filesCount
in interface ScanTask