Constructor and Description |
---|
FlinkState(org.apache.flink.api.common.functions.RuntimeContext runtimeContext,
org.apache.flink.runtime.state.KeyedStateBackend<java.lang.Object> keyedStateBackend,
DynamicallyRegisteredTypes types) |
Modifier and Type | Method and Description |
---|---|
<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) |
public FlinkState(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, org.apache.flink.runtime.state.KeyedStateBackend<java.lang.Object> keyedStateBackend, DynamicallyRegisteredTypes types)
public <T> Accessor<T> createFlinkStateAccessor(FunctionType functionType, PersistedValue<T> persistedValue)
createFlinkStateAccessor
in interface State
public <K,V> TableAccessor<K,V> createFlinkStateTableAccessor(FunctionType functionType, PersistedTable<K,V> persistedTable)
createFlinkStateTableAccessor
in interface State
public <E> AppendingBufferAccessor<E> createFlinkStateAppendingBufferAccessor(FunctionType functionType, PersistedAppendingBuffer<E> persistedAppendingBuffer)
createFlinkStateAppendingBufferAccessor
in interface State
public void setCurrentKey(Address address)
setCurrentKey
in interface State
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.