public class FileStoreSourceSplit extends Object implements org.apache.flink.api.connector.source.SourceSplit
SourceSplit
of file store.Constructor and Description |
---|
FileStoreSourceSplit(String id,
Split split) |
FileStoreSourceSplit(String id,
Split split,
long recordsToSkip) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
long |
recordsToSkip() |
Split |
split() |
String |
splitId() |
FileStoreSourceSplit |
updateWithRecordsToSkip(long recordsToSkip) |
public Split split()
public long recordsToSkip()
public String splitId()
splitId
in interface org.apache.flink.api.connector.source.SourceSplit
public FileStoreSourceSplit updateWithRecordsToSkip(long recordsToSkip)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.