org.apache.ignite.internal.processors.cache.persistence.wal.serializer

Class RecordDataV1Serializer

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.wal.serializer.RecordDataV1Serializer

All Implemented Interfaces:

RecordDataSerializer

public class RecordDataV1Serializer
extends Object
implements RecordDataSerializer

Record data V1 serializer.

Constructor Summary

Constructors

Constructor and Description
RecordDataV1Serializer(GridCacheSharedContext cctx)

Method Summary

Modifier and Type	Method and Description
GridCacheSharedContext	cctx() Return shared cache context.
WALRecord	readRecord(WALRecord.RecordType type, ByteBufferBackedDataInput in) Reads record data of type from buffer in.
int	size(WALRecord record) Calculates size of record data.
void	writeRecord(WALRecord rec, ByteBuffer buf) Writes record data to buffer buf.

Methods inherited from class java.lang.Object

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

Constructor Detail

RecordDataV1Serializer

public RecordDataV1Serializer(GridCacheSharedContext cctx)

Parameters:

cctx - Cache shared context.

Method Detail

size

public int size(WALRecord record)
         throws IgniteCheckedException

Calculates size of record data.

Specified by:

size in interface RecordDataSerializer

Parameters:

record - WAL record.

Returns:

Size of record in bytes.

Throws:

IgniteCheckedException - If it's unable to calculate record data size.

readRecord

public WALRecord readRecord(WALRecord.RecordType type,
                            ByteBufferBackedDataInput in)
                     throws IOException,
                            IgniteCheckedException

Reads record data of type from buffer in.

Specified by:

readRecord in interface RecordDataSerializer

Parameters:

type - Record type.

in - Buffer to read.

Returns:

WAL record.

Throws:

IOException - In case of I/O problems.

IgniteCheckedException - If it's unable to read record.

writeRecord

public void writeRecord(WALRecord rec,
                        ByteBuffer buf)
                 throws IgniteCheckedException

Writes record data to buffer buf.

Specified by:

writeRecord in interface RecordDataSerializer

Parameters:

rec - WAL record.

buf - Buffer to write.

Throws:

IgniteCheckedException - If it's unable to write record.

cctx

public GridCacheSharedContext cctx()

Return shared cache context.

Returns:

Shared cache context.