ChangelogScanTask

All Superinterfaces:: ScanTask, Serializable

All Known Subinterfaces:: AddedRowsScanTask, DeletedDataFileScanTask, DeletedRowsScanTask

public interface ChangelogScanTask extends ScanTask

A changelog scan task.

Method Summary

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. insert/delete).

Methods inherited from interface org.apache.iceberg.ScanTask
asCombinedScanTask, asDataTask, asFileScanTask, estimatedRowsCount, filesCount, isDataTask, isFileScanTask, sizeBytes

Method Details
- 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.