Package | Description |
---|---|
org.apache.flink.api.common.state | |
org.apache.flink.queryablestate.client.state | |
org.apache.flink.runtime.state.internal |
This package holds the classes of the internal state type hierarchy.
|
org.apache.flink.streaming.api.functions.query | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
Modifier and Type | Interface and Description |
---|---|
interface |
AggregatingState<IN,OUT>
State interface for aggregating state, based on an
AggregateFunction . |
interface |
FoldingState<T,ACC>
Deprecated.
will be removed in a future version in favor of
AggregatingState |
interface |
ListState<T>
State interface for partitioned list state in Operations. |
interface |
MergingState<IN,OUT>
Extension of
AppendingState that allows merging of state. |
interface |
ReducingState<T>
State interface for reducing state. |
Modifier and Type | Class and Description |
---|---|
class |
ImmutableAggregatingState<IN,OUT>
A read-only
AggregatingState that does not allow for modifications. |
class |
ImmutableFoldingState<IN,ACC>
Deprecated.
|
class |
ImmutableListState<V>
A read-only
ListState that does not allow for modifications. |
class |
ImmutableReducingState<V>
A read-only
ReducingState that does not allow for modifications. |
Modifier and Type | Interface and Description |
---|---|
interface |
InternalAggregatingState<K,N,IN,SV,OUT>
The peer to the
AggregatingState in the internal state type hierarchy. |
interface |
InternalAppendingState<K,N,IN,SV,OUT>
The peer to the
AppendingState in the internal state type hierarchy. |
interface |
InternalFoldingState<K,N,T,ACC>
Deprecated.
will be removed in a future version
|
interface |
InternalListState<K,N,T>
The peer to the
ListState in the internal state type hierarchy. |
interface |
InternalMergingState<K,N,IN,SV,OUT>
The peer to the
MergingState in the internal state type hierarchy. |
interface |
InternalReducingState<K,N,T>
The peer to the
ReducingState in the internal state type hierarchy. |
Constructor and Description |
---|
QueryableAppendingStateOperator(String registrationName,
StateDescriptor<? extends AppendingState<IN,?>,?> stateDescriptor) |
Modifier and Type | Method and Description |
---|---|
StateDescriptor<? extends AppendingState<IN,ACC>,?> |
WindowOperator.getStateDescriptor() |
StateDescriptor<? extends AppendingState<IN,Iterable<IN>>,?> |
EvictingWindowOperator.getStateDescriptor() |
Constructor and Description |
---|
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. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.