Package | Description |
---|---|
org.apache.flink.api.common.state | |
org.apache.flink.contrib.streaming.state | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.filesystem | |
org.apache.flink.runtime.state.memory | |
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 |
FoldingStateDescriptor<T,ACC>
|
class |
ListStateDescriptor<T>
A
StateDescriptor for ListState . |
class |
ReducingStateDescriptor<T>
|
class |
ValueStateDescriptor<T>
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractRocksDBState<K,N,S extends State,SD extends StateDescriptor<S,?>>
Base class for
State implementations that store state in a RocksDB database. |
Modifier and Type | Method and Description |
---|---|
protected org.rocksdb.ColumnFamilyHandle |
RocksDBStateBackend.getColumnFamily(StateDescriptor descriptor)
Creates a column family handle for use with a k/v state.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractHeapState<K,N,SV,S extends State,SD extends StateDescriptor<S,?>,Backend extends AbstractStateBackend>
Base class for partitioned
ListState implementations that are backed by a regular
heap hash map. |
class |
AsynchronousKvStateSnapshot<K,N,S extends State,SD extends StateDescriptor<S,?>,Backend extends AbstractStateBackend>
KvStateSnapshot that asynchronously materializes the state that it represents. |
interface |
KvState<K,N,S extends State,SD extends StateDescriptor<S,?>,Backend extends AbstractStateBackend>
Key/Value state implementation for user-defined state.
|
interface |
KvStateSnapshot<K,N,S extends State,SD extends StateDescriptor<S,?>,Backend extends AbstractStateBackend>
This class represents a snapshot of the
KvState , taken for a checkpoint. |
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.
|
Modifier and Type | Method and Description |
---|---|
<N,S extends State> |
AbstractStateBackend.getPartitionedState(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor)
Creates or retrieves a partitioned state backed by this state backend.
|
<N,S extends MergingState<?,?>> |
AbstractStateBackend.mergePartitionedStates(N target,
Collection<N> sources,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFsState<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. |
class |
AbstractFsStateSnapshot<K,N,SV,S extends State,SD extends StateDescriptor<S,?>>
A snapshot of a heap key/value state stored in a file.
|
Modifier and Type | Field and Description |
---|---|
protected SD |
AbstractFsStateSnapshot.stateDesc
StateDescriptor, for sanity checks
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMemState<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. |
class |
AbstractMemStateSnapshot<K,N,SV,S extends State,SD extends StateDescriptor<S,?>>
A snapshot of a
MemValueState for a checkpoint. |
Modifier and Type | Field and Description |
---|---|
protected SD |
AbstractMemStateSnapshot.stateDesc
StateDescriptor, for sanity checks
|
Modifier and Type | Method and Description |
---|---|
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 | Field and Description |
---|---|
protected StateDescriptor<? extends AppendingState<IN,ACC>,?> |
WindowOperator.windowStateDescriptor |
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) |
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)
Creates a new
WindowOperator based on the given policies and user functions. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.