public final class FileStoreSourceSplitState extends Object
FileStoreSourceSplit
. Has a
records-to-skip-count.Constructor and Description |
---|
FileStoreSourceSplitState(FileStoreSourceSplit split) |
Modifier and Type | Method and Description |
---|---|
long |
recordsToSkip() |
void |
setPosition(org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData> position) |
FileStoreSourceSplit |
toSourceSplit() |
public FileStoreSourceSplitState(FileStoreSourceSplit split)
public void setPosition(org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData> position)
public long recordsToSkip()
public FileStoreSourceSplit toSourceSplit()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.