Package | Description |
---|---|
org.apache.flink.api.common.state | |
org.apache.flink.queryablestate.client.state | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.internal |
This package holds the classes of the internal state type hierarchy.
|
org.apache.flink.streaming.api.operators.util | |
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.triggers |
Modifier and Type | Interface and Description |
---|---|
interface |
AggregatingState<IN,OUT>
State interface for aggregating state, based on an AggregateFunction . |
interface |
ListState<T>
State interface for partitioned list state in Operations. |
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 |
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 | Class and Description |
---|---|
class |
PartitionableListState<S>
Implementation of operator list state.
|
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 |
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. |
Modifier and Type | Class and Description |
---|---|
class |
SimpleVersionedListState<T>
|
Modifier and Type | Method and Description |
---|---|
<S extends MergingState<?,?>> |
Trigger.OnMergeContext.mergePartitionedState(StateDescriptor<S,?> stateDescriptor) |
Modifier and Type | Method and Description |
---|---|
<S extends MergingState<?,?>> |
WindowOperator.Context.mergePartitionedState(StateDescriptor<S,?> stateDescriptor) |
Modifier and Type | Method and Description |
---|---|
<S extends MergingState<?,?>> |
Trigger.OnMergeContext.mergePartitionedState(StateDescriptor<S,?> stateDescriptor) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.