org.gridgain.grid.persistentstore.snapshot.file

Class DigestSnapshotInputStream

java.lang.Object

org.gridgain.grid.persistentstore.snapshot.file.FileSnapshotInputStream

org.gridgain.grid.persistentstore.snapshot.file.DigestSnapshotInputStream

All Implemented Interfaces:

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

public class DigestSnapshotInputStream
extends FileSnapshotInputStream

Snapshot input stream with digest.

Field Summary

Fields

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

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	readNextPage(ByteBuffer buf) Reads data from stream and writes it into the provided buffer.
org.apache.ignite.internal.pagemem.wal.record.WALRecord	readNextRecord() Reads next WAL record from stream.

Methods inherited from class org.gridgain.grid.persistentstore.snapshot.file.FileSnapshotInputStream

consistentId, of, of, partId, terminationPageReached, toString

Methods inherited from class java.lang.Object

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

Field Detail

CORRUPTED_PART_HASH_ERROR

public static final String CORRUPTED_PART_HASH_ERROR

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

See Also:

Constant Field Values

Method Detail

readNextPage

public boolean readNextPage(ByteBuffer buf)
                     throws IOException

Reads data from stream and writes it into the provided buffer.

Specified by:

readNextPage in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotInputStream

Overrides:

readNextPage in class FileSnapshotInputStream

Parameters:

buf - Byte buffer.

Returns:

true if reading was successful

Throws:

IOException - If failed.

readNextRecord

public org.apache.ignite.internal.pagemem.wal.record.WALRecord readNextRecord()

Reads next WAL record from stream.

Specified by:

readNextRecord in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotInputStream

Overrides:

readNextRecord in class FileSnapshotInputStream

Returns:

WAL record or null if there are no records remaining.

close

public void close()
           throws IgniteCheckedException

Specified by:

close in interface AutoCloseable

Overrides:

close in class FileSnapshotInputStream

Throws:

IgniteCheckedException