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

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)