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

Class FlinkState

java.lang.Object

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

All Implemented Interfaces:

State

public final class FlinkState
extends java.lang.Object
implements State

Constructor Summary

Constructors

Constructor and Description
FlinkState(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, org.apache.flink.runtime.state.KeyedStateBackend<java.lang.Object> keyedStateBackend, DynamicallyRegisteredTypes types)

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)
static java.lang.String	flinkStateName(FunctionType functionType, java.lang.String name)
void	setCurrentKey(Address address)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkState

public FlinkState(org.apache.flink.api.common.functions.RuntimeContext runtimeContext,
                  org.apache.flink.runtime.state.KeyedStateBackend<java.lang.Object> keyedStateBackend,
                  DynamicallyRegisteredTypes types)

Method Detail

createFlinkStateAccessor

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

Specified by:

createFlinkStateAccessor in interface State

createFlinkStateTableAccessor

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

Specified by:

createFlinkStateTableAccessor in interface State

createFlinkStateAppendingBufferAccessor

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

Specified by:

createFlinkStateAppendingBufferAccessor in interface State

createFlinkRemoteStateAccessor

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

Specified by:

createFlinkRemoteStateAccessor in interface State

setCurrentKey

public void setCurrentKey(Address address)

Specified by:

setCurrentKey in interface State

flinkStateName

public static java.lang.String flinkStateName(FunctionType functionType,
                                              java.lang.String name)