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

Class RecordV2Serializer

java.lang.Object

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

All Implemented Interfaces:

RecordSerializer

public class RecordV2Serializer
extends Object
implements RecordSerializer

Record V2 serializer. Stores records in following format:

• Record type from WALRecord.RecordType.index() incremented by 1
• WAL pointer to double check consistency
• Record length
• Data
• CRC or zero padding

Constructor Summary

Constructors

Constructor	Description
RecordV2Serializer(RecordDataV2Serializer dataSerializer, boolean writePointer, boolean marshalledMode, boolean skipPositionCheck, IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordFilter)	Create an instance of Record V2 serializer.

Method Summary

Modifier and Type	Method	Description
WALRecord	readRecord(FileInput in, WALPointer expPtr)	Loads record from input
int	size(WALRecord record)	Calculates record size in byte including expected wal pointer, CRC and type field
int	version()
boolean	writePointer()	Flag to write (or not) wal pointer to record
void	writeRecord(WALRecord record, ByteBuffer buf)

Methods inherited from class java.lang.Object

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

Constructor Detail

RecordV2Serializer

public RecordV2Serializer(RecordDataV2Serializer dataSerializer,
                          boolean writePointer,
                          boolean marshalledMode,
                          boolean skipPositionCheck,
                          IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordFilter)

Create an instance of Record V2 serializer.

Parameters:

dataSerializer - V2 data serializer.

marshalledMode - Marshalled mode.

skipPositionCheck - Skip position check mode.

recordFilter - Record type filter. FilteredRecord is deserialized instead of original record.

Method Detail

version

public int version()

Specified by:

version in interface RecordSerializer

Returns:

serializer version

writePointer

public boolean writePointer()

Flag to write (or not) wal pointer to record

Specified by:

writePointer in interface RecordSerializer

size

public int size(WALRecord record)
         throws IgniteCheckedException

Calculates record size in byte including expected wal pointer, CRC and type field

Specified by:

size in interface RecordSerializer

Parameters:

record - Record.

Returns:

Size in bytes.

Throws:

IgniteCheckedException

writeRecord

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

Specified by:

writeRecord in interface RecordSerializer

Parameters:

record - Entry to write.

buf - Buffer.

Throws:

IgniteCheckedException

readRecord

public WALRecord readRecord(FileInput in,
                            WALPointer expPtr)
                     throws IOException,
                            IgniteCheckedException

Loads record from input

Specified by:

readRecord in interface RecordSerializer

Parameters:

in - Data input to read data from.

expPtr - expected WAL pointer for record. Used to validate actual position against expected from the file

Returns:

Read entry.

Throws:

IOException

IgniteCheckedException