org.gridgain.grid.persistentstore.snapshot.file

Class SnapshotInputStreamFactory

java.lang.Object

org.gridgain.grid.persistentstore.snapshot.file.SnapshotInputStreamFactory

public class SnapshotInputStreamFactory
extends Object

Factory of snapshot input streams.

Field Summary

Fields

Modifier and Type	Field and Description
static String	MISSING_PART_HASH_ERROR Error message when data or index partition hash is missing in snapshot digest registry.

Constructor Summary

Constructors

Constructor and Description

SnapshotInputStreamFactory(IgniteConfiguration igCfg, long id, org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath snapshotDir, MessageDigestFactory msgDigestFactory, SnapshotRegistryTransformer transformer, SnapshotSecurityLevel securityLevel, @Nullable org.apache.ignite.internal.processors.cache.persistence.wal.serializer.RecordSerializerFactory recordSerializerFactory, @Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotEncryptionOptions encryptionOptions, EncryptionSpi encryptionSpi)

Method Summary

Modifier and Type	Method and Description
SnapshotDigestRegistryCache	getRegistryCache()
org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotInputStream	makeInputStream(org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath file, int cacheGrpId, int partId, int pageSize, String constId, boolean initWALFileInput)

Methods inherited from class java.lang.Object

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

Field Detail

MISSING_PART_HASH_ERROR

public static final String MISSING_PART_HASH_ERROR

Error message when data or index partition hash is missing in snapshot digest registry.

See Also:

Constant Field Values

Constructor Detail

SnapshotInputStreamFactory

public SnapshotInputStreamFactory(IgniteConfiguration igCfg,
                                  long id,
                                  org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath snapshotDir,
                                  MessageDigestFactory msgDigestFactory,
                                  SnapshotRegistryTransformer transformer,
                                  SnapshotSecurityLevel securityLevel,
                                  @Nullable
                                  @Nullable org.apache.ignite.internal.processors.cache.persistence.wal.serializer.RecordSerializerFactory recordSerializerFactory,
                                  @Nullable
                                  @Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotEncryptionOptions encryptionOptions,
                                  EncryptionSpi encryptionSpi)

Parameters:

igCfg - Ignite configuration.

id - Snapshot id.

snapshotDir - Snapshot directory.

msgDigestFactory - Message digest factory.

transformer - Snapshot registry transformer.

securityLevel - Snapshot security level.

recordSerializerFactory - Record serializer factory, that is used to read WAL records from snapshot input stream.

Method Detail

getRegistryCache

public SnapshotDigestRegistryCache getRegistryCache()

Returns:

Snapshot digest registry cache.

makeInputStream

public org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotInputStream makeInputStream(org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath file,
                                                                                                         int cacheGrpId,
                                                                                                         int partId,
                                                                                                         int pageSize,
                                                                                                         String constId,
                                                                                                         boolean initWALFileInput)

Parameters:

file - Partition file.

cacheGrpId - Cache group id.

partId - Partition.

pageSize - Page size.

constId - Consistent id of the node.

initWALFileInput - Whether to init WAL file input. It causes additional memory usage.

Returns:

Snapshot input stream.