Class IcebergSourceSplit
- java.lang.Object
-
- org.apache.iceberg.flink.source.split.IcebergSourceSplit
-
- All Implemented Interfaces:
java.io.Serializable
,org.apache.flink.api.connector.source.SourceSplit
@Internal public class IcebergSourceSplit extends java.lang.Object implements org.apache.flink.api.connector.source.SourceSplit, java.io.Serializable
- See Also:
- Serialized Form
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description int
fileOffset()
static IcebergSourceSplit
fromCombinedScanTask(CombinedScanTask combinedScanTask)
static IcebergSourceSplit
fromCombinedScanTask(CombinedScanTask combinedScanTask, int fileOffset, long recordOffset)
long
recordOffset()
java.lang.String
splitId()
CombinedScanTask
task()
java.lang.String
toString()
void
updatePosition(int newFileOffset, long newRecordOffset)
-
-
-
Method Detail
-
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 java.lang.String splitId()
- Specified by:
splitId
in interfaceorg.apache.flink.api.connector.source.SourceSplit
-
updatePosition
public void updatePosition(int newFileOffset, long newRecordOffset)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-