首页

org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.java

所属路径:/com/alibaba/blink/flink-runtime_2.11/{}/flink-runtime_2.11-{}.jar     关联版本:blink-3.6.4,blink-3.3.0,1.5.1,blink-3.2.1,blink-3.2.4,blink-3.7.0,blink-3.2.2,blink-3.2.0,blink-3.4.0,blink-3.2.3
依赖类列表
  • org.apache.flink.annotation.VisibleForTesting
  • org.apache.flink.api.common.ExecutionConfig
  • org.apache.flink.api.common.state.AggregatingStateDescriptor
  • org.apache.flink.api.common.state.FoldingStateDescriptor
  • org.apache.flink.api.common.state.ListStateDescriptor
  • org.apache.flink.api.common.state.MapStateDescriptor
  • org.apache.flink.api.common.state.ReducingStateDescriptor
  • org.apache.flink.api.common.state.State
  • org.apache.flink.api.common.state.StateDescriptor
  • org.apache.flink.api.common.state.ValueStateDescriptor
  • org.apache.flink.api.common.typeutils.CompatibilityUtil
  • org.apache.flink.api.common.typeutils.TypeSerializer
  • org.apache.flink.api.common.typeutils.UnloadableDummyTypeSerializer
  • org.apache.flink.api.java.tuple.Tuple2
  • org.apache.flink.core.fs.FSDataInputStream
  • org.apache.flink.core.memory.DataInputViewStreamWrapper
  • org.apache.flink.core.memory.DataOutputViewStreamWrapper
  • org.apache.flink.runtime.checkpoint.CheckpointOptions
  • org.apache.flink.runtime.io.async.AbstractAsyncCallableWithResources
  • org.apache.flink.runtime.io.async.AsyncStoppableTaskWithCallback
  • org.apache.flink.runtime.query.TaskKvStateRegistry
  • org.apache.flink.runtime.state.AbstractKeyedStateBackend
  • org.apache.flink.runtime.state.CheckpointStreamFactory
  • org.apache.flink.runtime.state.CheckpointStreamWithResultProvider
  • org.apache.flink.runtime.state.CheckpointedStateScope
  • org.apache.flink.runtime.state.DoneFuture
  • org.apache.flink.runtime.state.KeyGroupRange
  • org.apache.flink.runtime.state.KeyGroupRangeOffsets
  • org.apache.flink.runtime.state.KeyGroupsStateHandle
  • org.apache.flink.runtime.state.KeyedBackendSerializationProxy
  • org.apache.flink.runtime.state.KeyedStateFunction
  • org.apache.flink.runtime.state.KeyedStateHandle
  • org.apache.flink.runtime.state.LocalRecoveryConfig
  • org.apache.flink.runtime.state.RegisteredKeyedBackendStateMetaInfo
  • org.apache.flink.runtime.state.SnappyStreamCompressionDecorator
  • org.apache.flink.runtime.state.SnapshotResult
  • org.apache.flink.runtime.state.SnapshotStrategy
  • org.apache.flink.runtime.state.StreamCompressionDecorator
  • org.apache.flink.runtime.state.StreamStateHandle
  • org.apache.flink.runtime.state.UncompressedStreamCompressionDecorator
  • org.apache.flink.runtime.state.internal.InternalAggregatingState
  • org.apache.flink.runtime.state.internal.InternalFoldingState
  • org.apache.flink.runtime.state.internal.InternalListState
  • org.apache.flink.runtime.state.internal.InternalMapState
  • org.apache.flink.runtime.state.internal.InternalReducingState
  • org.apache.flink.runtime.state.internal.InternalValueState
  • org.apache.flink.util.Preconditions
  • org.apache.flink.util.StateMigrationException
  • org.apache.flink.util.function.SupplierWithException
  • org.apache.commons.io.IOUtils
  • org.slf4j.Logger
  • org.slf4j.LoggerFactory
  • javax.annotation.Nonnull
    • 包列表
  • /com/alibaba/blink/flink-runtime_2.11/blink-3.7.0/flink-runtime_2.11-blink-3.7.0.jar
    • pom文件
  •   <dependency>
  •       <groupId>com.alibaba.blink</groupId>
  •       <artifactId>flink-runtime_2.11</artifactId>
  •       <version>blink-3.7.0</version>
  •   </dependency>