Package | Description |
---|---|
org.apache.flink.api.common.state | |
org.apache.flink.contrib.streaming.state | |
org.apache.flink.contrib.streaming.state.ttl | |
org.apache.flink.queryablestate.client | |
org.apache.flink.queryablestate.client.state | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.heap |
This package contains the classes for key/value state backends that store the state
on the JVM heap as objects.
|
org.apache.flink.runtime.state.ttl | |
org.apache.flink.state.api.runtime | |
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.functions.co | |
org.apache.flink.streaming.api.functions.query | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.windowing.triggers | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
org.apache.flink.table.runtime.operators.window.internal | |
org.apache.flink.table.runtime.operators.window.triggers |
Modifier and Type | Class and Description |
---|---|
class |
AggregatingStateDescriptor<IN,ACC,OUT>
A StateDescriptor for
AggregatingState . |
class |
FoldingStateDescriptor<T,ACC>
Deprecated.
will be removed in a future version in favor of
AggregatingStateDescriptor |
class |
ListStateDescriptor<T>
A
StateDescriptor for ListState . |
class |
MapStateDescriptor<UK,UV>
A
StateDescriptor for MapState . |
class |
ReducingStateDescriptor<T>
|
class |
ValueStateDescriptor<T>
|
Modifier and Type | Method and Description |
---|---|
void |
RocksDBKeyedStateBackend.compactState(StateDescriptor<?,?> stateDesc) |
<N,SV,SEV,S extends State,IS extends S> |
RocksDBKeyedStateBackend.createInternalState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc,
StateSnapshotTransformer.StateSnapshotTransformFactory<SEV> snapshotTransformFactory) |
Modifier and Type | Method and Description |
---|---|
void |
RocksDbTtlCompactFiltersManager.configCompactFilter(StateDescriptor<?,?> stateDesc,
TypeSerializer<?> stateSerializer) |
Modifier and Type | Method and Description |
---|---|
<K,S extends State,V> |
QueryableStateClient.getKvState(JobID jobId,
String queryableStateName,
K key,
TypeHint<K> keyTypeHint,
StateDescriptor<S,V> stateDescriptor)
Returns a future holding the request result.
|
<K,S extends State,V> |
QueryableStateClient.getKvState(JobID jobId,
String queryableStateName,
K key,
TypeInformation<K> keyTypeInfo,
StateDescriptor<S,V> stateDescriptor)
Returns a future holding the request result.
|
Modifier and Type | Method and Description |
---|---|
static <ACC,S extends State> |
ImmutableFoldingState.createState(StateDescriptor<S,ACC> stateDescriptor,
byte[] serializedState)
Deprecated.
|
static <OUT,ACC,S extends State> |
ImmutableAggregatingState.createState(StateDescriptor<S,ACC> stateDescriptor,
byte[] serializedState) |
static <K,V,T,S extends State> |
ImmutableMapState.createState(StateDescriptor<S,T> stateDescriptor,
byte[] serializedState) |
static <V,T,S extends State> |
ImmutableListState.createState(StateDescriptor<S,T> stateDescriptor,
byte[] serializedState) |
static <V,S extends State> |
ImmutableReducingState.createState(StateDescriptor<S,V> stateDescriptor,
byte[] serializedState) |
static <V,S extends State> |
ImmutableValueState.createState(StateDescriptor<S,V> stateDescriptor,
byte[] serializedState) |
Modifier and Type | Method and Description |
---|---|
<N,S extends State,T> |
KeyedStateBackend.applyToAllKeys(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor,
KeyedStateFunction<K,S> function)
Applies the provided
KeyedStateFunction to the state with the provided
StateDescriptor of all the currently active keys. |
<N,S extends State,T> |
AbstractKeyedStateBackend.applyToAllKeys(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor,
KeyedStateFunction<K,S> function) |
void |
RegisteredKeyValueStateBackendMetaInfo.checkStateMetaInfo(StateDescriptor<?,?> stateDesc) |
default <N,SV,S extends State,IS extends S> |
KeyedStateFactory.createInternalState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc)
Creates and returns a new
InternalKvState . |
<N,SV,SEV,S extends State,IS extends S> |
KeyedStateFactory.createInternalState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc,
StateSnapshotTransformer.StateSnapshotTransformFactory<SEV> snapshotTransformFactory)
Creates and returns a new
InternalKvState . |
<N,S extends State,T> |
KeyedStateBackend.getOrCreateKeyedState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor)
Creates or retrieves a keyed state backed by this state backend.
|
<N,S extends State,V> |
AbstractKeyedStateBackend.getOrCreateKeyedState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,V> stateDescriptor) |
<N,S extends State> |
KeyedStateBackend.getPartitionedState(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor)
Creates or retrieves a partitioned state backed by this state backend.
|
<N,S extends State> |
AbstractKeyedStateBackend.getPartitionedState(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor)
TODO: NOTE: This method does a lot of work caching / retrieving states just to update the namespace.
|
protected <S extends State> |
DefaultKeyedStateStore.getPartitionedState(StateDescriptor<S,?> stateDescriptor) |
Modifier and Type | Method and Description |
---|---|
<N,S extends State,T> |
HeapKeyedStateBackend.applyToAllKeys(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor,
KeyedStateFunction<K,S> function) |
<N,SV,SEV,S extends State,IS extends S> |
HeapKeyedStateBackend.createInternalState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc,
StateSnapshotTransformer.StateSnapshotTransformFactory<SEV> snapshotTransformFactory) |
Modifier and Type | Method and Description |
---|---|
static <K,N,SV,TTLSV,S extends State,IS extends S> |
TtlStateFactory.createStateAndWrapWithTtlIfEnabled(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc,
KeyedStateBackend<K> stateBackend,
TtlTimeProvider timeProvider) |
Modifier and Type | Method and Description |
---|---|
List<StateDescriptor<?,?>> |
SavepointRuntimeContext.getStateDescriptors() |
Modifier and Type | Method and Description |
---|---|
StateDescriptor<?,V> |
QueryableStateStream.getStateDescriptor()
Returns the state descriptor for the queryable state instance.
|
Constructor and Description |
---|
QueryableStateStream(String queryableStateName,
StateDescriptor<?,V> stateDescriptor,
TypeSerializer<K> keySerializer)
Creates a queryable state stream.
|
Modifier and Type | Method and Description |
---|---|
abstract <VS,S extends State> |
KeyedBroadcastProcessFunction.Context.applyToKeyedState(StateDescriptor<S,VS> stateDescriptor,
KeyedStateFunction<KS,S> function)
Applies the provided
function to the state
associated with the provided state descriptor . |
Constructor and Description |
---|
QueryableAppendingStateOperator(String registrationName,
StateDescriptor<? extends AppendingState<IN,?>,?> stateDescriptor) |
QueryableValueStateOperator(String registrationName,
StateDescriptor<ValueState<IN>,IN> stateDescriptor) |
Modifier and Type | Method and Description |
---|---|
protected <N,S extends State,T> |
AbstractStreamOperator.getOrCreateKeyedState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor) |
protected <S extends State,N> |
AbstractStreamOperator.getPartitionedState(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor)
Creates a partitioned state handle, using the state backend configured for this task.
|
protected <S extends State> |
AbstractStreamOperator.getPartitionedState(StateDescriptor<S,?> stateDescriptor)
Creates a partitioned state handle, using the state backend configured for this task.
|
Modifier and Type | Method and Description |
---|---|
<S extends State> |
Trigger.TriggerContext.getPartitionedState(StateDescriptor<S,?> stateDescriptor)
Retrieves a
State object that can be used to interact with
fault-tolerant state that is scoped to the window and key of the current
trigger invocation. |
<S extends MergingState<?,?>> |
Trigger.OnMergeContext.mergePartitionedState(StateDescriptor<S,?> stateDescriptor) |
Modifier and Type | Method and Description |
---|---|
StateDescriptor<? extends AppendingState<IN,ACC>,?> |
WindowOperator.getStateDescriptor() |
StateDescriptor<? extends AppendingState<IN,Iterable<IN>>,?> |
EvictingWindowOperator.getStateDescriptor() |
Modifier and Type | Method and Description |
---|---|
protected <S extends State> |
WindowOperator.PerWindowStateStore.getPartitionedState(StateDescriptor<S,?> stateDescriptor) |
<S extends State> |
WindowOperator.Context.getPartitionedState(StateDescriptor<S,?> stateDescriptor) |
<S extends MergingState<?,?>> |
WindowOperator.Context.mergePartitionedState(StateDescriptor<S,?> stateDescriptor) |
Constructor and Description |
---|
EvictingWindowOperator(WindowAssigner<? super IN,W> windowAssigner,
TypeSerializer<W> windowSerializer,
KeySelector<IN,K> keySelector,
TypeSerializer<K> keySerializer,
StateDescriptor<? extends ListState<StreamRecord<IN>>,?> windowStateDescriptor,
InternalWindowFunction<Iterable<IN>,OUT,K,W> windowFunction,
Trigger<? super IN,? super W> trigger,
Evictor<? super IN,? super W> evictor,
long allowedLateness,
OutputTag<IN> lateDataOutputTag) |
WindowOperator(WindowAssigner<? super IN,W> windowAssigner,
TypeSerializer<W> windowSerializer,
KeySelector<IN,K> keySelector,
TypeSerializer<K> keySerializer,
StateDescriptor<? extends AppendingState<IN,ACC>,?> windowStateDescriptor,
InternalWindowFunction<ACC,OUT,K,W> windowFunction,
Trigger<? super IN,? super W> trigger,
long allowedLateness,
OutputTag<IN> lateDataOutputTag)
Creates a new
WindowOperator based on the given policies and user functions. |
Modifier and Type | Method and Description |
---|---|
<S extends State> |
InternalWindowProcessFunction.Context.getPartitionedState(StateDescriptor<S,?> stateDescriptor)
Creates a partitioned state handle, using the state backend configured for this task.
|
Modifier and Type | Method and Description |
---|---|
<S extends State> |
Trigger.TriggerContext.getPartitionedState(StateDescriptor<S,?> stateDescriptor)
Retrieves a
State object that can be used to interact with
fault-tolerant state that is scoped to the window and key of the current
trigger invocation. |
<S extends MergingState<?,?>> |
Trigger.OnMergeContext.mergePartitionedState(StateDescriptor<S,?> stateDescriptor) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.