org.apache.flink.statefun.flink.core.state

Interface State

All Known Implementing Classes:

FlinkState

public interface State

Method Summary

Modifier and Type	Method and Description
Accessor<byte[]>	createFlinkRemoteStateAccessor(FunctionType functionType, RemotePersistedValue remotePersistedValue)
<T> Accessor<T>	createFlinkStateAccessor(FunctionType functionType, PersistedValue<T> persistedValue)
<E> AppendingBufferAccessor<E>	createFlinkStateAppendingBufferAccessor(FunctionType functionType, PersistedAppendingBuffer<E> persistedAppendingBuffer)
<K,V> TableAccessor<K,V>	createFlinkStateTableAccessor(FunctionType functionType, PersistedTable<K,V> persistedTable)
void	setCurrentKey(Address address)

Method Detail

createFlinkStateAccessor

<T> Accessor<T> createFlinkStateAccessor(FunctionType functionType,
                                         PersistedValue<T> persistedValue)

createFlinkStateTableAccessor

<K,V> TableAccessor<K,V> createFlinkStateTableAccessor(FunctionType functionType,
                                                       PersistedTable<K,V> persistedTable)

createFlinkStateAppendingBufferAccessor

<E> AppendingBufferAccessor<E> createFlinkStateAppendingBufferAccessor(FunctionType functionType,
                                                                       PersistedAppendingBuffer<E> persistedAppendingBuffer)

createFlinkRemoteStateAccessor

Accessor<byte[]> createFlinkRemoteStateAccessor(FunctionType functionType,
                                                RemotePersistedValue remotePersistedValue)

setCurrentKey

void setCurrentKey(Address address)