org.gridgain.grid.persistentstore.snapshot.file

Class FileSnapshotSession

java.lang.Object

org.gridgain.grid.persistentstore.snapshot.file.FileSnapshotSession

All Implemented Interfaces:

AutoCloseable, org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotSession

public class FileSnapshotSession
extends Object
implements org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotSession

File-based snapshot session.

Field Summary

Fields

Modifier and Type	Field and Description
static String	SAVE_REGISTRY_ERROR Error message when writing snapshot digest registry file.

Method Summary

Modifier and Type	Method and Description
void	cancel() Marks this snapshot session as invalid.
void	close() Closes all resources associated with the session.
org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream	getOrOpenForFile(int grpId, int partId)
Runnable	onPartitionFinished(org.apache.ignite.internal.processors.cache.persistence.partstate.GroupPartitionId groupPartitionId) Method invoked on snapshot completion of partition.
org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotEncryptionOptions	snapshotEncryptionOptions() Returns an encryption options for snapshot.
void	writeMetadata(ByteBuffer metadata)
void	writeRegistry(ByteBuffer registry)

Methods inherited from class java.lang.Object

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

Field Detail

SAVE_REGISTRY_ERROR

public static final String SAVE_REGISTRY_ERROR

Error message when writing snapshot digest registry file.

See Also:

Constant Field Values

Method Detail

snapshotEncryptionOptions

public org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotEncryptionOptions snapshotEncryptionOptions()

Returns an encryption options for snapshot.

Specified by:

snapshotEncryptionOptions in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotSession

Returns:

Encryption options.

getOrOpenForFile

public org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream getOrOpenForFile(int grpId,
                                                                                                           int partId)
                                                                                                    throws IgniteCheckedException

Specified by:

getOrOpenForFile in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotSession

Parameters:

grpId - Cache group ID.

partId - Partition ID.

Returns:

Snapshot stream.

Throws:

IgniteCheckedException

writeMetadata

public void writeMetadata(ByteBuffer metadata)
                   throws IgniteCheckedException

Specified by:

writeMetadata in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotSession

Parameters:

metadata - Serialized metadata

Throws:

IgniteCheckedException - If failed.

writeRegistry

public void writeRegistry(ByteBuffer registry)
                   throws IgniteCheckedException

Specified by:

writeRegistry in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotSession

Parameters:

registry - Serialized snapshot content registry.

Throws:

IgniteCheckedException - If failed.

cancel

public void cancel()
            throws IgniteException

Marks this snapshot session as invalid.

Specified by:

cancel in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotSession

Throws:

IgniteException

close

public void close()
           throws IgniteException

Closes all resources associated with the session.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotSession

Throws:

IgniteException - If close failed.

onPartitionFinished

public Runnable onPartitionFinished(org.apache.ignite.internal.processors.cache.persistence.partstate.GroupPartitionId groupPartitionId)
                             throws IgniteCheckedException

Method invoked on snapshot completion of partition.

Specified by:

onPartitionFinished in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotSession

Parameters:

groupPartitionId - GroupPartitionId.

Returns:

Runnable task to process partition.

Throws:

IgniteCheckedException