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

Modifier and Type	Method and 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.