org.apache.flink.statefun.sdk.state

Class ApiExtension

java.lang.Object

org.apache.flink.statefun.sdk.state.ApiExtension

public class ApiExtension
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ApiExtension()

Method Summary

Modifier and Type	Method and Description
static void	bindPersistedStateRegistry(PersistedStateRegistry persistedStateRegistry, StateBinder stateBinder)
static <E> void	setPersistedAppendingBufferAccessor(PersistedAppendingBuffer<E> persistedAppendingBuffer, AppendingBufferAccessor<E> accessor)
static <K,V> void	setPersistedTableAccessor(PersistedTable<K,V> persistedTable, TableAccessor<K,V> accessor)
static <T> void	setPersistedValueAccessor(PersistedValue<T> persistedValue, Accessor<T> accessor)
static void	setRemotePersistedValueAccessor(RemotePersistedValue remotePersistedValue, Accessor<byte[]> accessor)

Methods inherited from class java.lang.Object

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

Constructor Detail

ApiExtension

public ApiExtension()

Method Detail

setPersistedValueAccessor

public static <T> void setPersistedValueAccessor(PersistedValue<T> persistedValue,
                                                 Accessor<T> accessor)

setPersistedTableAccessor

public static <K,V> void setPersistedTableAccessor(PersistedTable<K,V> persistedTable,
                                                   TableAccessor<K,V> accessor)

setPersistedAppendingBufferAccessor

public static <E> void setPersistedAppendingBufferAccessor(PersistedAppendingBuffer<E> persistedAppendingBuffer,
                                                           AppendingBufferAccessor<E> accessor)

setRemotePersistedValueAccessor

public static void setRemotePersistedValueAccessor(RemotePersistedValue remotePersistedValue,
                                                   Accessor<byte[]> accessor)

bindPersistedStateRegistry

public static void bindPersistedStateRegistry(PersistedStateRegistry persistedStateRegistry,
                                              StateBinder stateBinder)