IcebergSourceSplit

java.lang.Object

org.apache.iceberg.flink.source.split.IcebergSourceSplit

All Implemented Interfaces:: Serializable, org.apache.flink.api.connector.source.SourceSplit

@Internal public class IcebergSourceSplit extends Object implements org.apache.flink.api.connector.source.SourceSplit, Serializable

See Also:

Method Summary

Modifier and Type

Method

Description

int

fileOffset()

static IcebergSourceSplit

fromCombinedScanTask(CombinedScanTask combinedScanTask)

static IcebergSourceSplit

fromCombinedScanTask(CombinedScanTask combinedScanTask, int fileOffset, long recordOffset)

long

recordOffset()

String

splitId()

CombinedScanTask

task()

String

toString()

void

updatePosition(int newFileOffset, long newRecordOffset)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Details
- fromCombinedScanTask
  
  public static IcebergSourceSplit fromCombinedScanTask(CombinedScanTask combinedScanTask)
- fromCombinedScanTask
  
  public static IcebergSourceSplit fromCombinedScanTask(CombinedScanTask combinedScanTask, int fileOffset, long recordOffset)
- task
  
  public CombinedScanTask task()
- fileOffset
  
  public int fileOffset()
- recordOffset
  
  public long recordOffset()
- splitId
  
  public String splitId()
  
  Specified by:
  
  splitId in interface org.apache.flink.api.connector.source.SourceSplit
- updatePosition
  
  public void updatePosition(int newFileOffset, long newRecordOffset)
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Object