Uses of Package
org.apache.flink.api.common.state
-
Classes in org.apache.flink.api.common.state used by org.apache.flink.api.common.functions Class Description AggregatingState Stateinterface for aggregating state, based on anAggregateFunction.AggregatingStateDescriptor A StateDescriptor forAggregatingState.ListState Stateinterface for partitioned list state in Operations.ListStateDescriptor AStateDescriptorforListState.MapState Stateinterface for partitioned key-value state.MapStateDescriptor AStateDescriptorforMapState.ReducingState Stateinterface for reducing state.ReducingStateDescriptor ValueState Stateinterface for partitioned single-value state.ValueStateDescriptor -
Classes in org.apache.flink.api.common.state used by org.apache.flink.api.common.functions.util Class Description AggregatingState Stateinterface for aggregating state, based on anAggregateFunction.AggregatingStateDescriptor A StateDescriptor forAggregatingState.ListState Stateinterface for partitioned list state in Operations.ListStateDescriptor AStateDescriptorforListState.MapState Stateinterface for partitioned key-value state.MapStateDescriptor AStateDescriptorforMapState.ReducingState Stateinterface for reducing state.ReducingStateDescriptor ValueState Stateinterface for partitioned single-value state.ValueStateDescriptor -
Classes in org.apache.flink.api.common.state used by org.apache.flink.api.common.state Class Description AggregatingState Stateinterface for aggregating state, based on anAggregateFunction.AggregatingStateDescriptor A StateDescriptor forAggregatingState.AppendingState Base interface for partitioned state that supports adding elements and inspecting the current state.BroadcastState A type of state that can be created to store the state of aBroadcastStream.CheckpointListener This interface is typically only needed for transactional interaction with the "outside world", like committing external side effects on checkpoints.ListState Stateinterface for partitioned list state in Operations.ListStateDescriptor AStateDescriptorforListState.MapState Stateinterface for partitioned key-value state.MapStateDescriptor AStateDescriptorforMapState.MergingState Extension ofAppendingStatethat allows merging of state.ReadOnlyBroadcastState A read-only view of theBroadcastState.ReducingState Stateinterface for reducing state.ReducingStateDescriptor State Interface that different types of partitioned state must implement.StateDescriptor Base class for state descriptors.StateDescriptor.Type An enumeration of the types of supported states.StateTtlConfig Configuration of state TTL logic.StateTtlConfig.Builder Builder for theStateTtlConfig.StateTtlConfig.CleanupStrategies TTL cleanup strategies.StateTtlConfig.IncrementalCleanupStrategy Configuration of cleanup strategy while taking the full snapshot.StateTtlConfig.RocksdbCompactFilterCleanupStrategy Configuration of cleanup strategy using custom compaction filter in RocksDB.StateTtlConfig.StateVisibility This option configures whether expired user value can be returned or not.StateTtlConfig.TtlTimeCharacteristic This option configures time scale to use for ttl.StateTtlConfig.UpdateType This option value configures when to update last access timestamp which prolongs state TTL.ValueState Stateinterface for partitioned single-value state.ValueStateDescriptor -
Classes in org.apache.flink.api.common.state used by org.apache.flink.api.connector.source Class Description CheckpointListener This interface is typically only needed for transactional interaction with the "outside world", like committing external side effects on checkpoints. -
Classes in org.apache.flink.api.common.state used by org.apache.flink.api.connector.source.lib.util Class Description CheckpointListener This interface is typically only needed for transactional interaction with the "outside world", like committing external side effects on checkpoints. -
Classes in org.apache.flink.api.common.state used by org.apache.flink.api.connector.source.util.ratelimit Class Description CheckpointListener This interface is typically only needed for transactional interaction with the "outside world", like committing external side effects on checkpoints.