org.apache.paimon.operation

Class FileStoreWrite.State<T>

java.lang.Object

org.apache.paimon.operation.FileStoreWrite.State<T>

Enclosing interface:

FileStoreWrite<T>

public static class FileStoreWrite.State<T>
extends Object

Recoverable state of FileStoreWrite.

Field Summary

Fields

Modifier and Type	Field and Description
protected long	baseSnapshotId
protected int	bucket
protected CommitIncrement	commitIncrement
protected List<DataFileMeta>	dataFiles
protected DeletionVectorsMaintainer	deletionVectorsMaintainer
protected IndexMaintainer<T>	indexMaintainer
protected long	lastModifiedCommitIdentifier
protected long	maxSequenceNumber
protected BinaryRow	partition

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	State(BinaryRow partition, int bucket, long baseSnapshotId, long lastModifiedCommitIdentifier, Collection<DataFileMeta> dataFiles, long maxSequenceNumber, IndexMaintainer<T> indexMaintainer, DeletionVectorsMaintainer deletionVectorsMaintainer, CommitIncrement commitIncrement)

Method Summary

Modifier and Type	Method and Description
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

partition

protected final BinaryRow partition

bucket

protected final int bucket

baseSnapshotId

protected final long baseSnapshotId

lastModifiedCommitIdentifier

protected final long lastModifiedCommitIdentifier

dataFiles

protected final List<DataFileMeta> dataFiles

maxSequenceNumber

protected final long maxSequenceNumber

indexMaintainer

@Nullable
protected final IndexMaintainer<T> indexMaintainer

deletionVectorsMaintainer

@Nullable
protected final DeletionVectorsMaintainer deletionVectorsMaintainer

commitIncrement

protected final CommitIncrement commitIncrement

Constructor Detail

State

protected State(BinaryRow partition,
                int bucket,
                long baseSnapshotId,
                long lastModifiedCommitIdentifier,
                Collection<DataFileMeta> dataFiles,
                long maxSequenceNumber,
                @Nullable
                IndexMaintainer<T> indexMaintainer,
                @Nullable
                DeletionVectorsMaintainer deletionVectorsMaintainer,
                CommitIncrement commitIncrement)

Method Detail

toString

public String toString()

Overrides:

toString in class Object