com.orientechnologies.orient.core.storage.impl.local.paginated.wal

Class OWALPageChangesPortion

java.lang.Object

com.orientechnologies.orient.core.storage.impl.local.paginated.wal.OWALPageChangesPortion

All Implemented Interfaces:

OWALChanges

public class OWALPageChangesPortion
extends Object
implements OWALChanges

Since:

8/17/2015

Author:

Andrey Lomakin .

Field Summary

Fields

Modifier and Type	Field and Description
static int	CHUNK_SIZE
static int	PORTION_BYTES
static int	PORTION_SIZE

Constructor Summary

Constructors

Constructor and Description
OWALPageChangesPortion()
OWALPageChangesPortion(int pageSize)

Method Summary

Modifier and Type	Method and Description
void	applyChanges(ByteBuffer pointer) Apply the changes to a page.
int	fromStream(int offset, byte[] stream) Read changes from a stream.
byte[]	getBinaryValue(ByteBuffer pointer, int offset, int len)
byte	getByteValue(ByteBuffer pointer, int offset)
int	getIntValue(ByteBuffer pointer, int offset)
long	getLongValue(ByteBuffer pointer, int offset)
short	getShortValue(ByteBuffer pointer, int offset)
boolean	hasChanges()
OWALChanges	inverse(ByteBuffer buffer)
void	moveData(ByteBuffer pointer, int from, int to, int len)
int	serializedSize() Return the size needed in a buffer in case of serialization.
void	setBinaryValue(ByteBuffer pointer, byte[] value, int offset)
void	setByteValue(ByteBuffer pointer, byte value, int offset)
void	setIntValue(ByteBuffer pointer, int value, int offset)
void	setLongValue(ByteBuffer pointer, long value, int offset)
void	setShortValue(ByteBuffer pointer, short value, int offset)
int	toStream(int offset, byte[] stream) Serialize the changes to a stream.

Methods inherited from class java.lang.Object

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

Field Detail

CHUNK_SIZE

public static final int CHUNK_SIZE

See Also:

Constant Field Values

PORTION_SIZE

public static final int PORTION_SIZE

See Also:

Constant Field Values

PORTION_BYTES

public static final int PORTION_BYTES

See Also:

Constant Field Values

Constructor Detail

OWALPageChangesPortion

public OWALPageChangesPortion()

OWALPageChangesPortion

public OWALPageChangesPortion(int pageSize)

Method Detail

setLongValue

public void setLongValue(ByteBuffer pointer,
                         long value,
                         int offset)

Specified by:

setLongValue in interface OWALChanges

setIntValue

public void setIntValue(ByteBuffer pointer,
                        int value,
                        int offset)

Specified by:

setIntValue in interface OWALChanges

setShortValue

public void setShortValue(ByteBuffer pointer,
                          short value,
                          int offset)

setByteValue

public void setByteValue(ByteBuffer pointer,
                         byte value,
                         int offset)

Specified by:

setByteValue in interface OWALChanges

setBinaryValue

public void setBinaryValue(ByteBuffer pointer,
                           byte[] value,
                           int offset)

Specified by:

setBinaryValue in interface OWALChanges

moveData

public void moveData(ByteBuffer pointer,
                     int from,
                     int to,
                     int len)

Specified by:

moveData in interface OWALChanges

getLongValue

public long getLongValue(ByteBuffer pointer,
                         int offset)

Specified by:

getLongValue in interface OWALChanges

getIntValue

public int getIntValue(ByteBuffer pointer,
                       int offset)

Specified by:

getIntValue in interface OWALChanges

getShortValue

public short getShortValue(ByteBuffer pointer,
                           int offset)

Specified by:

getShortValue in interface OWALChanges

getByteValue

public byte getByteValue(ByteBuffer pointer,
                         int offset)

Specified by:

getByteValue in interface OWALChanges

getBinaryValue

public byte[] getBinaryValue(ByteBuffer pointer,
                             int offset,
                             int len)

Specified by:

getBinaryValue in interface OWALChanges

applyChanges

public void applyChanges(ByteBuffer pointer)

Description copied from interface: OWALChanges

Apply the changes to a page.

Specified by:

applyChanges in interface OWALChanges

Parameters:

pointer - Presents page where apply the changes.

serializedSize

public int serializedSize()

Description copied from interface: OWALChanges

Return the size needed in a buffer in case of serialization.

Specified by:

serializedSize in interface OWALChanges

Returns:

the required size.

toStream

public int toStream(int offset,
                    byte[] stream)

Description copied from interface: OWALChanges

Serialize the changes to a stream. needed for write the changes to the WAL

Specified by:

toStream in interface OWALChanges

Parameters:

offset - starting writing offset for the provided buffer.

stream - buffer where write the content, should be of minimal size of offset+ @{link @serializedSize()}

Returns:

the number of written bytes + the offset, can be used as offset of the next operation.

fromStream

public int fromStream(int offset,
                      byte[] stream)

Description copied from interface: OWALChanges

Read changes from a stream. Needed from restore from WAL.

Specified by:

fromStream in interface OWALChanges

Parameters:

offset - the offest in the buffer where start to read.

stream - the buffer to read.

Returns:

the offset+read bytes.

inverse

public OWALChanges inverse(ByteBuffer buffer)

Specified by:

inverse in interface OWALChanges

hasChanges

public boolean hasChanges()

Specified by:

hasChanges in interface OWALChanges