Uses of Package
org.apache.flink.api.common.state.v2
-
Classes in org.apache.flink.api.common.state.v2 used by org.apache.flink.api.common.state.v2 Class Description AppendingState Base interface for partitioned state that supports adding elements and inspecting the current state.MergingState Extension ofAppendingState
that allows merging of state.State Interface that different types of partitioned state must implement.StateFuture StateFuture is a future that act as a return value for async state interfaces.StateIterator Asynchronous iterators allow to iterate over data that comes asynchronously, on-demand. -
Classes in org.apache.flink.api.common.state.v2 used by org.apache.flink.core.state Class Description StateFuture StateFuture is a future that act as a return value for async state interfaces. -
Classes in org.apache.flink.api.common.state.v2 used by org.apache.flink.runtime.asyncprocessing Class Description State Interface that different types of partitioned state must implement.StateFuture StateFuture is a future that act as a return value for async state interfaces.StateIterator Asynchronous iterators allow to iterate over data that comes asynchronously, on-demand. -
Classes in org.apache.flink.api.common.state.v2 used by org.apache.flink.runtime.asyncprocessing.operators Class Description State Interface that different types of partitioned state must implement. -
Classes in org.apache.flink.api.common.state.v2 used by org.apache.flink.runtime.state Class Description State Interface that different types of partitioned state must implement. -
Classes in org.apache.flink.api.common.state.v2 used by org.apache.flink.runtime.state.v2 Class Description AggregatingState State
interface for aggregating state, based on anAggregateFunction
.AppendingState Base interface for partitioned state that supports adding elements and inspecting the current state.ListState State
interface for partitioned list state in Operations.MapState State
interface for partitioned key-value state.MergingState Extension ofAppendingState
that allows merging of state.ReducingState State
interface for reducing state.State Interface that different types of partitioned state must implement.StateFuture StateFuture is a future that act as a return value for async state interfaces.StateIterator Asynchronous iterators allow to iterate over data that comes asynchronously, on-demand.ValueState State
interface for partitioned single-value state. -
Classes in org.apache.flink.api.common.state.v2 used by org.apache.flink.runtime.state.v2.adaptor Class Description AggregatingState State
interface for aggregating state, based on anAggregateFunction
.AppendingState Base interface for partitioned state that supports adding elements and inspecting the current state.ListState State
interface for partitioned list state in Operations.MapState State
interface for partitioned key-value state.MergingState Extension ofAppendingState
that allows merging of state.ReducingState State
interface for reducing state.State Interface that different types of partitioned state must implement.StateFuture StateFuture is a future that act as a return value for async state interfaces.StateIterator Asynchronous iterators allow to iterate over data that comes asynchronously, on-demand.ValueState State
interface for partitioned single-value state. -
Classes in org.apache.flink.api.common.state.v2 used by org.apache.flink.runtime.state.v2.internal Class Description AggregatingState State
interface for aggregating state, based on anAggregateFunction
.AppendingState Base interface for partitioned state that supports adding elements and inspecting the current state.ListState State
interface for partitioned list state in Operations.MapState State
interface for partitioned key-value state.MergingState Extension ofAppendingState
that allows merging of state.ReducingState State
interface for reducing state.State Interface that different types of partitioned state must implement.StateFuture StateFuture is a future that act as a return value for async state interfaces.ValueState State
interface for partitioned single-value state. -
Classes in org.apache.flink.api.common.state.v2 used by org.apache.flink.state.forst Class Description AggregatingState State
interface for aggregating state, based on anAggregateFunction
.AppendingState Base interface for partitioned state that supports adding elements and inspecting the current state.ListState State
interface for partitioned list state in Operations.MapState State
interface for partitioned key-value state.MergingState Extension ofAppendingState
that allows merging of state.ReducingState State
interface for reducing state.State Interface that different types of partitioned state must implement.StateIterator Asynchronous iterators allow to iterate over data that comes asynchronously, on-demand.ValueState State
interface for partitioned single-value state. -
Classes in org.apache.flink.api.common.state.v2 used by org.apache.flink.streaming.api.operators Class Description AggregatingState State
interface for aggregating state, based on anAggregateFunction
.ListState State
interface for partitioned list state in Operations.MapState State
interface for partitioned key-value state.ReducingState State
interface for reducing state.State Interface that different types of partitioned state must implement.ValueState State
interface for partitioned single-value state. -
Classes in org.apache.flink.api.common.state.v2 used by org.apache.flink.table.runtime.operators.join.stream.asyncprocessing.state Class Description StateFuture StateFuture is a future that act as a return value for async state interfaces. -
Classes in org.apache.flink.api.common.state.v2 used by org.apache.flink.table.runtime.operators.join.stream.utils Class Description StateFuture StateFuture is a future that act as a return value for async state interfaces.