org.gridgain.grid.persistentstore.snapshot.file

Class ByteChannelSnapshotOutputStream

java.lang.Object

org.gridgain.grid.persistentstore.snapshot.file.ByteChannelSnapshotOutputStream

All Implemented Interfaces:

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

Direct Known Subclasses:

SnapshotEncryptionOutputStream

public class ByteChannelSnapshotOutputStream
extends Object
implements org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream

WritableByteChannel based implementation of SnapshotOutputStream. Safe usage of this class requires to create single instance of ByteChannelSnapshotOutputStream per underlying stream. Class is thread safe.

Method Summary

Modifier and Type	Method and Description
void	close() Close method.
void	plainWrite(ByteBuffer data) Writes plain data to stream.
long	position() Returns this stream's position.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream

write

Method Detail

plainWrite

public void plainWrite(ByteBuffer data)
                throws IgniteCheckedException

Writes plain data to stream. It is used for writing a WAL record.

Specified by:

plainWrite in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream

Parameters:

data - Plain data.

Throws:

IgniteCheckedException - If IO exception has happened.

close

public void close()
           throws IgniteCheckedException

Close method.

Specified by:

close in interface AutoCloseable

Specified by:

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

Throws:

IgniteCheckedException - in case of IO failure.

position

public long position()

Returns this stream's position.

Specified by:

position in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream

Returns:

This stream's position, a non-negative integer counting the number of bytes written to the stream.