org.gridgain.grid.persistentstore.snapshot.file

Class SnapshotEncryptionOutputStream

java.lang.Object

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

org.gridgain.grid.persistentstore.snapshot.file.SnapshotEncryptionOutputStream

All Implemented Interfaces:

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

public class SnapshotEncryptionOutputStream
extends ByteChannelSnapshotOutputStream

Encryption output stream.

Constructor Summary

Constructors

Constructor and Description
SnapshotEncryptionOutputStream(OutputStream target, org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStreamListener listener, org.apache.ignite.internal.managers.encryption.GroupKey encryptionKey, EncryptionSpi encSpi, int pageSize)

Method Summary

Modifier and Type	Method and Description
void	plainWrite(ByteBuffer data) Writes plain data to stream.
void	write(ByteBuffer data) Writes the given page.

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

close, position

Methods inherited from class java.lang.Object

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

Constructor Detail

SnapshotEncryptionOutputStream

public SnapshotEncryptionOutputStream(OutputStream target,
                                      org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStreamListener listener,
                                      org.apache.ignite.internal.managers.encryption.GroupKey encryptionKey,
                                      EncryptionSpi encSpi,
                                      int pageSize)

Parameters:

target - Target stream.

listener - Listener.

encryptionKey - TDE key.

encSpi - Encryption SPI.

pageSize - Page size.

Method Detail

write

public void write(ByteBuffer data)
           throws IgniteCheckedException

Writes the given page.

Parameters:

data - Page data or metadata.

Throws:

IgniteCheckedException - Exception in case of write.

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

Overrides:

plainWrite in class ByteChannelSnapshotOutputStream

Parameters:

data - Plain data.

Throws:

IgniteCheckedException - If IO exception has happened.