org.apache.paimon.flink.sink

Class StoreSinkWriteState

java.lang.Object

org.apache.paimon.flink.sink.StoreSinkWriteState

public class StoreSinkWriteState
extends Object

States for StoreSinkWrites.

States are positioned first by table name and then by key name. This class should be initiated in a sink operator and then given to StoreSinkWrite.

Nested Class Summary

Nested Classes

Modifier and Type	Class 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.

Constructor Summary

Constructors

Constructor and Description
StoreSinkWriteState(org.apache.flink.runtime.state.StateInitializationContext context, StoreSinkWriteState.StateValueFilter stateValueFilter)

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()

Methods inherited from class java.lang.Object

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

Constructor Detail

StoreSinkWriteState

public StoreSinkWriteState(org.apache.flink.runtime.state.StateInitializationContext context,
                           StoreSinkWriteState.StateValueFilter stateValueFilter)
                    throws Exception

Throws:

Exception

Method Detail

stateValueFilter

public StoreSinkWriteState.StateValueFilter stateValueFilter()

get

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

put

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

snapshotState

public void snapshotState()
                   throws Exception

Throws:

Exception