Uses of Interface
org.apache.flink.api.common.state.AggregatingState

Packages that use AggregatingState

Package	Description
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.state
org.apache.flink.contrib.streaming.state
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.internal	This package holds the classes of the internal state type hierarchy.
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.

Uses of AggregatingState in org.apache.flink.api.common.functions

Methods in org.apache.flink.api.common.functions that return AggregatingState

Modifier and Type	Method and Description
<IN,ACC,OUT> AggregatingState<IN,OUT>	RuntimeContext.getAggregatingState(AggregatingStateDescriptor<IN,ACC,OUT> stateProperties) Gets a handle to the system's key/value aggregating state.

Uses of AggregatingState in org.apache.flink.api.common.functions.util

Methods in org.apache.flink.api.common.functions.util that return AggregatingState

Modifier and Type	Method and Description
<IN,ACC,OUT> AggregatingState<IN,OUT>	AbstractRuntimeUDFContext.getAggregatingState(AggregatingStateDescriptor<IN,ACC,OUT> stateProperties)

Uses of AggregatingState in org.apache.flink.api.common.state

Methods in org.apache.flink.api.common.state that return AggregatingState

Modifier and Type	Method and Description
AggregatingState<IN,OUT>	AggregatingStateDescriptor.bind(StateBinder stateBinder)
<IN,ACC,OUT> AggregatingState<IN,OUT>	StateBinder.createAggregatingState(AggregatingStateDescriptor<IN,ACC,OUT> stateDesc) Creates and returns a new AggregatingState.
<IN,ACC,OUT> AggregatingState<IN,OUT>	KeyedStateStore.getAggregatingState(AggregatingStateDescriptor<IN,ACC,OUT> stateProperties) Gets a handle to the system's key/value folding state.

Uses of AggregatingState in org.apache.flink.contrib.streaming.state

Classes in org.apache.flink.contrib.streaming.state that implement AggregatingState

Modifier and Type	Class and Description
class	RocksDBAggregatingState<K,N,T,ACC,R> An AggregatingState implementation that stores state in RocksDB.

Uses of AggregatingState in org.apache.flink.queryablestate.client.state

Classes in org.apache.flink.queryablestate.client.state that implement AggregatingState

Modifier and Type	Class and Description
class	ImmutableAggregatingState<IN,OUT> A read-only AggregatingState that does not allow for modifications.

Methods in org.apache.flink.queryablestate.client.state that return AggregatingState

Modifier and Type	Method and Description
<IN,ACC,OUT> AggregatingState<IN,OUT>	ImmutableStateBinder.createAggregatingState(AggregatingStateDescriptor<IN,ACC,OUT> stateDesc)

Uses of AggregatingState in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state that return AggregatingState

Modifier and Type	Method and Description
<IN,ACC,OUT> AggregatingState<IN,OUT>	DefaultKeyedStateStore.getAggregatingState(AggregatingStateDescriptor<IN,ACC,OUT> stateProperties)

Uses of AggregatingState in org.apache.flink.runtime.state.heap

Classes in org.apache.flink.runtime.state.heap that implement AggregatingState

Modifier and Type	Class and Description
class	HeapAggregatingState<K,N,IN,ACC,OUT> Heap-backed partitioned AggregatingState that is snapshotted into files.

Uses of AggregatingState in org.apache.flink.runtime.state.internal

Subinterfaces of AggregatingState in org.apache.flink.runtime.state.internal

Modifier and Type	Interface and Description
interface	InternalAggregatingState<K,N,IN,SV,OUT> The peer to the AggregatingState in the internal state type hierarchy.

Uses of AggregatingState in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return AggregatingState

Modifier and Type	Method and Description
<IN,ACC,OUT> AggregatingState<IN,OUT>	StreamingRuntimeContext.getAggregatingState(AggregatingStateDescriptor<IN,ACC,OUT> stateProperties)

Uses of AggregatingState in org.apache.flink.streaming.runtime.operators.windowing

Methods in org.apache.flink.streaming.runtime.operators.windowing that return AggregatingState

Modifier and Type	Method and Description
<IN,ACC,OUT> AggregatingState<IN,OUT>	WindowOperator.MergingWindowStateStore.getAggregatingState(AggregatingStateDescriptor<IN,ACC,OUT> stateProperties)