org.apache.paimon.flink.source

Class FileStoreSourceSplit

java.lang.Object

org.apache.paimon.flink.source.FileStoreSourceSplit

All Implemented Interfaces:

org.apache.flink.api.connector.source.SourceSplit

public class FileStoreSourceSplit
extends Object
implements org.apache.flink.api.connector.source.SourceSplit

SourceSplit of file store.

Constructor Summary

Constructors

Constructor and Description
FileStoreSourceSplit(String id, Split split)
FileStoreSourceSplit(String id, Split split, long recordsToSkip)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()
long	recordsToSkip()
Split	split()
String	splitId()
FileStoreSourceSplit	updateWithRecordsToSkip(long recordsToSkip)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FileStoreSourceSplit

public FileStoreSourceSplit(String id,
                            Split split)

FileStoreSourceSplit

public FileStoreSourceSplit(String id,
                            Split split,
                            long recordsToSkip)

Method Detail

split

public Split split()

recordsToSkip

public long recordsToSkip()

splitId

public String splitId()

Specified by:

splitId in interface org.apache.flink.api.connector.source.SourceSplit

updateWithRecordsToSkip

public FileStoreSourceSplit updateWithRecordsToSkip(long recordsToSkip)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object