public class StoreSinkWriteStateImpl extends Object implements StoreSinkWriteState
StoreSinkWriteState
.
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
.
StoreSinkWriteState.StateValue, StoreSinkWriteState.StateValueFilter
Constructor and Description |
---|
StoreSinkWriteStateImpl(org.apache.flink.runtime.state.StateInitializationContext context,
StoreSinkWriteState.StateValueFilter stateValueFilter) |
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() |
public StoreSinkWriteStateImpl(org.apache.flink.runtime.state.StateInitializationContext context, StoreSinkWriteState.StateValueFilter stateValueFilter) throws Exception
Exception
public StoreSinkWriteState.StateValueFilter stateValueFilter()
stateValueFilter
in interface StoreSinkWriteState
@Nullable public List<StoreSinkWriteState.StateValue> get(String tableName, String key)
get
in interface StoreSinkWriteState
public void put(String tableName, String key, List<StoreSinkWriteState.StateValue> stateValues)
put
in interface StoreSinkWriteState
public void snapshotState() throws Exception
snapshotState
in interface StoreSinkWriteState
Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.