org.apache.paimon.flink.sink

Interface StoreSinkWriteState

All Known Implementing Classes:

NoopStoreSinkWriteState, StoreSinkWriteStateImpl

public interface StoreSinkWriteState

States for StoreSinkWrites. It's a wrapper to conveniently modify states for each table stored in Flink states.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	StoreSinkWriteState.StateValue A state value for StoreSinkWrite.
static interface	StoreSinkWriteState.StateValueFilter Given the table name, partition and bucket of a StoreSinkWriteState.StateValue in a union list state, decide whether to keep this StoreSinkWriteState.StateValue in this subtask.

Method Summary

Modifier and Type	Method and Description
List<StoreSinkWriteState.StateValue>	get(String tableName, String key)
void	put(String tableName, String key, List<StoreSinkWriteState.StateValue> stateValues)
void	snapshotState()
StoreSinkWriteState.StateValueFilter	stateValueFilter()

Method Detail

stateValueFilter

StoreSinkWriteState.StateValueFilter stateValueFilter()

get

@Nullable
List<StoreSinkWriteState.StateValue> get(String tableName,
                                                   String key)

put

void put(String tableName,
         String key,
         List<StoreSinkWriteState.StateValue> stateValues)

snapshotState

void snapshotState()
            throws Exception

Throws:

Exception