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 AggregatingStateDescriptor A StateDescriptor forAggregatingState.ListStateDescriptor AStateDescriptorforListState.MapStateDescriptor AStateDescriptorforMapState.ReducingStateDescriptor StateDescriptorforReducingState.ValueStateDescriptor StateDescriptorforValueState. -
Classes in org.apache.flink.api.common.state used by org.apache.flink.api.common.functions.util Class Description AggregatingStateDescriptor A StateDescriptor forAggregatingState.ListStateDescriptor AStateDescriptorforListState.MapStateDescriptor AStateDescriptorforMapState.ReducingStateDescriptor StateDescriptorforReducingState.ValueStateDescriptor StateDescriptorforValueState. -
Classes in org.apache.flink.api.common.state used by org.apache.flink.api.common.state Class Description AggregatingStateDescriptor A StateDescriptor forAggregatingState.CheckpointListener This interface is typically only needed for transactional interaction with the "outside world", like committing external side effects on checkpoints.ListStateDescriptor AStateDescriptorforListState.MapStateDescriptor AStateDescriptorforMapState.ReducingStateDescriptor StateDescriptorforReducingState.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.ValueStateDescriptor StateDescriptorforValueState. -
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.