org.apache.flink.contrib.streaming.state.snapshot

类 RocksDBFullSnapshotResources<K>

java.lang.Object

org.apache.flink.contrib.streaming.state.snapshot.RocksDBFullSnapshotResources<K>

所有已实现的接口:

org.apache.flink.runtime.state.FullSnapshotResources<K>, org.apache.flink.runtime.state.SnapshotResources

public class RocksDBFullSnapshotResources<K>
extends Object
implements org.apache.flink.runtime.state.FullSnapshotResources<K>

A FullSnapshotResources for the RocksDB backend.

构造器概要

构造器

构造器和说明

RocksDBFullSnapshotResources(org.apache.flink.util.ResourceGuard.Lease lease, org.rocksdb.Snapshot snapshot, List<RocksDBKeyedStateBackend.RocksDbKvStateInfo> metaDataCopy, List<org.apache.flink.runtime.state.heap.HeapPriorityQueueStateSnapshot<?>> heapPriorityQueuesSnapshots, List<org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot> stateMetaInfoSnapshots, org.rocksdb.RocksDB db, int keyGroupPrefixBytes, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, org.apache.flink.runtime.state.StreamCompressionDecorator streamCompressionDecorator)

方法概要

限定符和类型	方法和说明
static <K> RocksDBFullSnapshotResources<K>	create(LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, Map<String,org.apache.flink.runtime.state.heap.HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, org.rocksdb.RocksDB db, org.apache.flink.util.ResourceGuard rocksDBResourceGuard, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int keyGroupPrefixBytes, org.apache.flink.runtime.state.StreamCompressionDecorator keyGroupCompressionDecorator)
org.apache.flink.runtime.state.KeyValueStateIterator	createKVStateIterator()
org.apache.flink.runtime.state.KeyGroupRange	getKeyGroupRange()
org.apache.flink.api.common.typeutils.TypeSerializer<K>	getKeySerializer()
List<org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot>	getMetaInfoSnapshots()
org.apache.flink.runtime.state.StreamCompressionDecorator	getStreamCompressionDecorator()
void	release()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

RocksDBFullSnapshotResources

public RocksDBFullSnapshotResources(org.apache.flink.util.ResourceGuard.Lease lease,
                                    org.rocksdb.Snapshot snapshot,
                                    List<RocksDBKeyedStateBackend.RocksDbKvStateInfo> metaDataCopy,
                                    List<org.apache.flink.runtime.state.heap.HeapPriorityQueueStateSnapshot<?>> heapPriorityQueuesSnapshots,
                                    List<org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot> stateMetaInfoSnapshots,
                                    org.rocksdb.RocksDB db,
                                    int keyGroupPrefixBytes,
                                    org.apache.flink.runtime.state.KeyGroupRange keyGroupRange,
                                    org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer,
                                    org.apache.flink.runtime.state.StreamCompressionDecorator streamCompressionDecorator)

方法详细资料

create

public static <K> RocksDBFullSnapshotResources<K> create(LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
                                                         Map<String,org.apache.flink.runtime.state.heap.HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates,
                                                         org.rocksdb.RocksDB db,
                                                         org.apache.flink.util.ResourceGuard rocksDBResourceGuard,
                                                         org.apache.flink.runtime.state.KeyGroupRange keyGroupRange,
                                                         org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer,
                                                         int keyGroupPrefixBytes,
                                                         org.apache.flink.runtime.state.StreamCompressionDecorator keyGroupCompressionDecorator)
                                                  throws IOException

抛出:

IOException

createKVStateIterator

public org.apache.flink.runtime.state.KeyValueStateIterator createKVStateIterator()
                                                                           throws IOException

指定者:

createKVStateIterator 在接口中 org.apache.flink.runtime.state.FullSnapshotResources<K>

抛出:

IOException

getMetaInfoSnapshots

public List<org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot> getMetaInfoSnapshots()

指定者:

getMetaInfoSnapshots 在接口中 org.apache.flink.runtime.state.FullSnapshotResources<K>

getKeyGroupRange

public org.apache.flink.runtime.state.KeyGroupRange getKeyGroupRange()

指定者:

getKeyGroupRange 在接口中 org.apache.flink.runtime.state.FullSnapshotResources<K>

getKeySerializer

public org.apache.flink.api.common.typeutils.TypeSerializer<K> getKeySerializer()

指定者:

getKeySerializer 在接口中 org.apache.flink.runtime.state.FullSnapshotResources<K>

getStreamCompressionDecorator

public org.apache.flink.runtime.state.StreamCompressionDecorator getStreamCompressionDecorator()

指定者:

getStreamCompressionDecorator 在接口中 org.apache.flink.runtime.state.FullSnapshotResources<K>

release

public void release()

指定者:

release 在接口中 org.apache.flink.runtime.state.SnapshotResources