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

Class RecordV1Serializer

java.lang.Object

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

All Implemented Interfaces:

RecordSerializer

public class RecordV1Serializer
extends Object
implements RecordSerializer

Record V1 serializer. Stores records in following format:

• Record type from Enum.ordinal() incremented by 1
• WAL pointer to double check consistency
• Data
• CRC or zero padding

Field Summary

Fields

Modifier and Type	Field and Description
static int	FILE_WAL_POINTER_SIZE Length of WAL Pointer
static int	HEADER_RECORD_SIZE
static int	REC_TYPE_SIZE Length of Type

Constructor Summary

Constructors

Constructor and Description
RecordV1Serializer(GridCacheSharedContext cctx)

Method Summary

Methods

Modifier and Type	Method and Description
static void	putPosition(ByteBuffer buf, FileWALPointer ptr) Saves position, WAL pointer (requires FILE_WAL_POINTER_SIZE bytes)
static FileWALPointer	readPosition(DataInput in)
WALRecord	readRecord(FileInput in0, 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()
void	writeRecord(WALRecord record, ByteBuffer buf)

Methods inherited from class java.lang.Object

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

Field Detail

REC_TYPE_SIZE

public static final int REC_TYPE_SIZE

Length of Type

See Also:

Constant Field Values

FILE_WAL_POINTER_SIZE

public static final int FILE_WAL_POINTER_SIZE

Length of WAL Pointer

See Also:

Constant Field Values

HEADER_RECORD_SIZE

public static final int HEADER_RECORD_SIZE

See Also:

Constant Field Values

Constructor Detail

RecordV1Serializer

public RecordV1Serializer(GridCacheSharedContext cctx)

Parameters:

cctx - Cache shared context.

Method Detail

version

public int version()

Specified by:

version in interface RecordSerializer

Returns:

serializer version

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 in0,
                   WALPointer expPtr)
                     throws IOException,
                            IgniteCheckedException

Loads record from input

Specified by:

readRecord in interface RecordSerializer

Parameters:

in0 - 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

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

putPosition

public static void putPosition(ByteBuffer buf,
               FileWALPointer ptr)

Saves position, WAL pointer (requires FILE_WAL_POINTER_SIZE bytes)

Parameters:

buf - Byte buffer to serialize version to.

ptr - File WAL pointer to write.

readPosition

public static FileWALPointer readPosition(DataInput in)
                                   throws IOException

Parameters:

in - Data input to read pointer from.

Returns:

Read file WAL pointer.

Throws:

IOException - If failed to write.