Package | Description |
---|---|
org.apache.flink.api.common.state | |
org.apache.flink.contrib.streaming.state | |
org.apache.flink.migration.runtime.state | |
org.apache.flink.migration.runtime.state.filesystem | |
org.apache.flink.migration.runtime.state.memory | |
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.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.
|
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 | Class and Description |
---|---|
class |
AbstractRocksDBState<K,N,S extends State,SD extends StateDescriptor<S,V>,V>
Base class for
State implementations that store state in a RocksDB database. |
Modifier and Type | Field and Description |
---|---|
protected SD |
AbstractRocksDBState.stateDesc
State descriptor from which to create this state instance
|
Modifier and Type | Method and Description |
---|---|
protected <N,S> org.rocksdb.ColumnFamilyHandle |
RocksDBKeyedStateBackend.getColumnFamily(StateDescriptor<?,S> descriptor,
TypeSerializer<N> namespaceSerializer)
Creates a column family handle for use with a k/v state.
|
Modifier and Type | Interface and Description |
---|---|
interface |
KvStateSnapshot<K,N,S extends State,SD extends StateDescriptor<S,?>>
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractFsStateSnapshot<K,N,SV,S extends State,SD extends StateDescriptor<S,?>>
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
Modifier and Type | Field and Description |
---|---|
protected SD |
AbstractFsStateSnapshot.stateDesc
Deprecated.
StateDescriptor, for sanity checks
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMemStateSnapshot<K,N,SV,S extends State,SD extends StateDescriptor<S,?>>
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
Modifier and Type | Field and Description |
---|---|
protected SD |
AbstractMemStateSnapshot.stateDesc
Deprecated.
StateDescriptor, for sanity checks
|
Modifier and Type | Method and Description |
---|---|
<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.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractHeapMergingState<K,N,IN,OUT,SV,S extends State,SD extends StateDescriptor<S,?>>
Base class for
MergingState (InternalMergingState )
that is stored on the heap. |
class |
AbstractHeapState<K,N,SV,S extends State,SD extends StateDescriptor<S,?>>
Base class for partitioned
ListState implementations that are backed by a regular
heap hash map. |
Modifier and Type | Field and Description |
---|---|
protected SD |
AbstractHeapState.stateDesc
This holds the name of the state and can create an initial default value for the state.
|
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 |
---|---|
<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. |
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,
LegacyWindowOperatorType legacyWindowOperatorType)
Creates a new
WindowOperator based on the given policies and user functions. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.