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
sizeBytes
in interface ContentScanTask<DataFile>
sizeBytes
in interface ScanTask
default int filesCount()
ScanTask
filesCount
in interface ScanTask