org.gridgain.grid.persistentstore.snapshot.file

Class SnapshotOutputStreamFactory

java.lang.Object

org.gridgain.grid.persistentstore.snapshot.file.SnapshotOutputStreamFactory

public class SnapshotOutputStreamFactory
extends Object

Factory of SnapshotOutputStream, creates either compressed or uncompressed input stream depending on configuration.

Constructor Summary

Constructors

Constructor and Description

SnapshotOutputStreamFactory(Predicate<Integer> postponedCompression, org.gridgain.grid.internal.processors.cache.database.snapshot.CompressionOption compressionOption, int compressionLevel, @Nullable MessageDigestFactory msgDigestFactory, @Nullable org.gridgain.grid.internal.processors.cache.database.SnapshotMetricsMXBeanImpl snapshotMetricsMXBean, @Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotEncryptionOptions encryptionOptions, EncryptionSpi encryptionSpi, int pageSize)

Method Summary

Modifier and Type	Method and Description
org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream	makeOutputStream(org.gridgain.grid.internal.processors.cache.database.snapshot.file.FsSnapshotPath path) Creates a stream for writing the snapshot file.
org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream	makeOutputStream(org.gridgain.grid.internal.processors.cache.database.snapshot.file.FsSnapshotPath path, Integer grpId) Creates opened SnapshotOutputStream.

Methods inherited from class java.lang.Object

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

Constructor Detail

SnapshotOutputStreamFactory

public SnapshotOutputStreamFactory(Predicate<Integer> postponedCompression,
                                   org.gridgain.grid.internal.processors.cache.database.snapshot.CompressionOption compressionOption,
                                   int compressionLevel,
                                   @Nullable
                                   @Nullable MessageDigestFactory msgDigestFactory,
                                   @Nullable
                                   @Nullable org.gridgain.grid.internal.processors.cache.database.SnapshotMetricsMXBeanImpl snapshotMetricsMXBean,
                                   @Nullable
                                   @Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotEncryptionOptions encryptionOptions,
                                   EncryptionSpi encryptionSpi,
                                   int pageSize)

Parameters:

compressionOption - Compression parameter of SnapshotOutputStream.

msgDigestFactory - Message digest factory.

snapshotMetricsMXBean - MXBean to gather snapshot file statistics.

Method Detail

makeOutputStream

public org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream makeOutputStream(org.gridgain.grid.internal.processors.cache.database.snapshot.file.FsSnapshotPath path)
                                                                                                    throws IOException

Creates a stream for writing the snapshot file.

Parameters:

path - Snapshot file path.

Returns:

Snapshot file output stream.

Throws:

IOException - If something goes wrong when open stream for the snapshot file.

makeOutputStream

public org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream makeOutputStream(org.gridgain.grid.internal.processors.cache.database.snapshot.file.FsSnapshotPath path,
                                                                                                           Integer grpId)
                                                                                                    throws IOException

Creates opened SnapshotOutputStream.

Throws:

IOException