org.apache.paimon.flink.source.align

Class PlaceholderSplit

java.lang.Object

org.apache.paimon.table.source.DataSplit

org.apache.paimon.flink.source.align.PlaceholderSplit

All Implemented Interfaces:

Serializable, Split

public class PlaceholderSplit
extends DataSplit

Used as a placeholder for an empty snapshot, indicating that the current snapshot does not contain any Split.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.paimon.table.source.DataSplit

DataSplit.Builder

Constructor Summary

Constructors

Constructor and Description
PlaceholderSplit(DataSplit dataSplit)
PlaceholderSplit(long snapshotId)

Method Summary

Modifier and Type	Method and Description
List<DataFileMeta>	beforeFiles()
int	bucket()
List<DataFileMeta>	dataFiles()
static PlaceholderSplit	deserialize(DataInputView in)
boolean	equals(Object o)
int	hashCode()
boolean	isStreaming()
BinaryRow	partition()
long	rowCount()
void	serialize(DataOutputView out)
long	snapshotId()

Methods inherited from class org.apache.paimon.table.source.DataSplit

beforeDeletionFiles, bucketPath, builder, convertToRawFiles, deletionFiles, earliestFileCreationEpochMillis, indexFiles, latestFileCreationEpochMillis, rawConvertible

Methods inherited from class java.lang.Object

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

Constructor Detail

PlaceholderSplit

public PlaceholderSplit(long snapshotId)

PlaceholderSplit

public PlaceholderSplit(DataSplit dataSplit)

Method Detail

snapshotId

public long snapshotId()

Overrides:

snapshotId in class DataSplit

partition

public BinaryRow partition()

Overrides:

partition in class DataSplit

bucket

public int bucket()

Overrides:

bucket in class DataSplit

beforeFiles

public List<DataFileMeta> beforeFiles()

Overrides:

beforeFiles in class DataSplit

dataFiles

public List<DataFileMeta> dataFiles()

Overrides:

dataFiles in class DataSplit

isStreaming

public boolean isStreaming()

Overrides:

isStreaming in class DataSplit

rowCount

public long rowCount()

Specified by:

rowCount in interface Split

Overrides:

rowCount in class DataSplit

equals

public boolean equals(Object o)

Overrides:

equals in class DataSplit

hashCode

public int hashCode()

Overrides:

hashCode in class DataSplit

serialize

public void serialize(DataOutputView out)
               throws IOException

Overrides:

serialize in class DataSplit

Throws:

IOException

deserialize

public static PlaceholderSplit deserialize(DataInputView in)
                                    throws IOException

Throws:

IOException