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

Class CacheDataRowAdapter

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.CacheDataRowAdapter

All Implemented Interfaces:

MvccUpdateVersionAware, MvccVersionAware, CacheDataRow, CacheSearchRow, Storable

Direct Known Subclasses:

DataRow

public class CacheDataRowAdapter
extends Object
implements CacheDataRow

Cache data row adapter.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CacheDataRowAdapter.RowData

Field Summary

Fields

Modifier and Type	Field and Description
protected int	cacheId
protected long	expireTime
protected KeyCacheObject	key
protected long	link
protected CacheObject	val
protected GridCacheVersion	ver
protected boolean	verReady Whether version is ready.

Constructor Summary

Constructors

Constructor and Description
CacheDataRowAdapter(KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime)
CacheDataRowAdapter(long link)

Method Summary

Modifier and Type	Method and Description
int	cacheId()
long	expireTime()
int	hash()
int	headerSize()
void	initFromDataPage(DataPageIO io, long pageAddr, int itemId, @Nullable CacheGroupContext grp, GridCacheSharedContext<?,?> sharedCtx, PageMemory pageMem, CacheDataRowAdapter.RowData rowData, boolean skipVer)
void	initFromLink(CacheGroupContext grp, CacheDataRowAdapter.RowData rowData) Read row from data pages.
void	initFromLink(CacheGroupContext grp, CacheDataRowAdapter.RowData rowData, boolean skipVer) Read row from data pages.
void	initFromLink(@Nullable CacheGroupContext grp, GridCacheSharedContext<?,?> sharedCtx, PageMemory pageMem, CacheDataRowAdapter.RowData rowData, boolean skipVer) Read row from data pages.
boolean	isReady()
KeyCacheObject	key()
void	key(KeyCacheObject key)
long	link()
void	link(long link)
long	mvccCoordinatorVersion()
long	mvccCounter()
int	mvccOperationCounter()
byte	mvccTxState()
long	newMvccCoordinatorVersion()
long	newMvccCounter()
int	newMvccOperationCounter()
byte	newMvccTxState()
int	partition()
protected IncompleteObject<?>	readFragment(GridCacheSharedContext<?,?> sharedCtx, CacheObjectContext coctx, ByteBuffer buf, boolean keyOnly, boolean readCacheId, IncompleteObject<?> incomplete, boolean skipVer)
protected void	readFullRow(GridCacheSharedContext<?,?> sharedCtx, CacheObjectContext coctx, long addr, CacheDataRowAdapter.RowData rowData, boolean readCacheId, boolean skipVer)
protected int	readHeader(GridCacheSharedContext<?,?> sharedCtx, long addr, int off, CacheDataRowAdapter.RowData rowData) Reads row header (i.e.
protected IncompleteObject<?>	readIncompleteCacheId(ByteBuffer buf, IncompleteObject<?> incomplete)
protected IncompleteObject<?>	readIncompleteExpireTime(ByteBuffer buf, IncompleteObject<?> incomplete)
protected IncompleteCacheObject	readIncompleteKey(CacheObjectContext coctx, ByteBuffer buf, IncompleteCacheObject incomplete)
protected IncompleteCacheObject	readIncompleteValue(CacheObjectContext coctx, ByteBuffer buf, IncompleteCacheObject incomplete)
protected IncompleteObject<?>	readIncompleteVersion(ByteBuffer buf, IncompleteObject<?> incomplete, boolean skip)
int	size()
String	toString()
CacheObject	value()
GridCacheVersion	version()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.cache.persistence.CacheDataRow

ioVersions

Methods inherited from interface org.apache.ignite.internal.processors.cache.mvcc.MvccUpdateVersionAware

newMvccVersion, newMvccVersion, newMvccVersion, newMvccVersion

Methods inherited from interface org.apache.ignite.internal.processors.cache.mvcc.MvccVersionAware

mvccVersion, mvccVersion, mvccVersion, mvccVersion

Field Detail

link

@GridToStringExclude
protected long link

key

@GridToStringInclude
protected KeyCacheObject key

val

@GridToStringInclude
protected CacheObject val

expireTime

@GridToStringInclude
protected long expireTime

ver

@GridToStringInclude
protected GridCacheVersion ver

verReady

protected boolean verReady

Whether version is ready.

cacheId

@GridToStringInclude
protected int cacheId

Constructor Detail

CacheDataRowAdapter

public CacheDataRowAdapter(long link)

Parameters:

link - Link.

CacheDataRowAdapter

public CacheDataRowAdapter(KeyCacheObject key,
                           CacheObject val,
                           GridCacheVersion ver,
                           long expireTime)

Parameters:

key - Key.

val - Value.

expireTime - Expire time.

ver - Version.

Method Detail

initFromLink

public final void initFromLink(CacheGroupContext grp,
                               CacheDataRowAdapter.RowData rowData)
                        throws IgniteCheckedException

Read row from data pages.

Parameters:

grp - Cache group.

rowData - Required row data.

Throws:

IgniteCheckedException - If failed.

initFromLink

public final void initFromLink(CacheGroupContext grp,
                               CacheDataRowAdapter.RowData rowData,
                               boolean skipVer)
                        throws IgniteCheckedException

Read row from data pages.

Parameters:

grp - Cache group.

rowData - Required row data.

skipVer - Whether version read should be skipped.

Throws:

IgniteCheckedException - If failed.

initFromLink

public final void initFromLink(@Nullable
                               @Nullable CacheGroupContext grp,
                               GridCacheSharedContext<?,?> sharedCtx,
                               PageMemory pageMem,
                               CacheDataRowAdapter.RowData rowData,
                               boolean skipVer)
                        throws IgniteCheckedException

Read row from data pages. Can be called with cctx == null, if cache instance is unknown, but its ID is stored in the data row.

Parameters:

grp - Cache group.

sharedCtx - Shared context.

pageMem - Page memory.

rowData - Row data.

skipVer - Whether version read should be skipped.

Throws:

IgniteCheckedException - If failed.

initFromDataPage

public final void initFromDataPage(DataPageIO io,
                                   long pageAddr,
                                   int itemId,
                                   @Nullable
                                   @Nullable CacheGroupContext grp,
                                   GridCacheSharedContext<?,?> sharedCtx,
                                   PageMemory pageMem,
                                   CacheDataRowAdapter.RowData rowData,
                                   boolean skipVer)
                            throws IgniteCheckedException

Parameters:

io - Data page IO.

pageAddr - Data page address.

itemId - Row item Id.

grp - Cache group.

sharedCtx - Cache shared context.

pageMem - Page memory.

rowData - Required row data.

skipVer - Whether version read should be skipped.

Throws:

IgniteCheckedException - If failed.

readHeader

protected int readHeader(GridCacheSharedContext<?,?> sharedCtx,
                         long addr,
                         int off,
                         CacheDataRowAdapter.RowData rowData)

Reads row header (i.e. MVCC info) which should be located on the very first page od data.

Parameters:

sharedCtx - Shared context.

addr - Address.

off - Offset

rowData - Required row data.

Returns:

Number of bytes read.

readFragment

protected IncompleteObject<?> readFragment(GridCacheSharedContext<?,?> sharedCtx,
                                           CacheObjectContext coctx,
                                           ByteBuffer buf,
                                           boolean keyOnly,
                                           boolean readCacheId,
                                           IncompleteObject<?> incomplete,
                                           boolean skipVer)
                                    throws IgniteCheckedException

Parameters:

sharedCtx - Cache shared context.

coctx - Cache object context.

buf - Buffer.

keyOnly - true If need to read only key object.

readCacheId - true If need to read cache ID.

incomplete - Incomplete object.

skipVer - Whether version read should be skipped.

Returns:

Read object.

Throws:

IgniteCheckedException - If failed.

readFullRow

protected void readFullRow(GridCacheSharedContext<?,?> sharedCtx,
                           CacheObjectContext coctx,
                           long addr,
                           CacheDataRowAdapter.RowData rowData,
                           boolean readCacheId,
                           boolean skipVer)
                    throws IgniteCheckedException

Parameters:

sharedCtx - Cache shared context.

coctx - Cache object context.

addr - Address.

rowData - Required row data.

readCacheId - true If need to read cache ID.

skipVer - Whether version read should be skipped.

Throws:

IgniteCheckedException - If failed.

readIncompleteCacheId

protected IncompleteObject<?> readIncompleteCacheId(ByteBuffer buf,
                                                    IncompleteObject<?> incomplete)

Parameters:

buf - Buffer.

incomplete - Incomplete.

readIncompleteKey

protected IncompleteCacheObject readIncompleteKey(CacheObjectContext coctx,
                                                  ByteBuffer buf,
                                                  IncompleteCacheObject incomplete)
                                           throws IgniteCheckedException

Parameters:

coctx - Cache object context.

buf - Buffer.

incomplete - Incomplete object.

Returns:

Incomplete object.

Throws:

IgniteCheckedException - If failed.

readIncompleteValue

protected IncompleteCacheObject readIncompleteValue(CacheObjectContext coctx,
                                                    ByteBuffer buf,
                                                    IncompleteCacheObject incomplete)
                                             throws IgniteCheckedException

Parameters:

coctx - Cache object context.

buf - Buffer.

incomplete - Incomplete object.

Returns:

Incomplete object.

Throws:

IgniteCheckedException - If failed.

readIncompleteExpireTime

protected IncompleteObject<?> readIncompleteExpireTime(ByteBuffer buf,
                                                       IncompleteObject<?> incomplete)

Parameters:

buf - Buffer.

incomplete - Incomplete object.

Returns:

Incomplete object.

readIncompleteVersion

protected IncompleteObject<?> readIncompleteVersion(ByteBuffer buf,
                                                    IncompleteObject<?> incomplete,
                                                    boolean skip)
                                             throws IgniteCheckedException

Parameters:

buf - Buffer.

incomplete - Incomplete object.

skip - Whether version should be skipped.

Returns:

Incomplete object.

Throws:

IgniteCheckedException - If failed.

isReady

public boolean isReady()

Returns:

True if entry is ready.

key

public KeyCacheObject key()

Specified by:

key in interface CacheSearchRow

Returns:

Cache key.

key

public void key(KeyCacheObject key)

Specified by:

key in interface CacheDataRow

Parameters:

key - Key.

cacheId

public int cacheId()

Specified by:

cacheId in interface CacheSearchRow

Returns:

Cache ID or 0 if cache ID is not defined.

value

public CacheObject value()

Specified by:

value in interface CacheDataRow

Returns:

Cache value.

version

public GridCacheVersion version()

Specified by:

version in interface CacheDataRow

Returns:

Cache entry version.

expireTime

public long expireTime()

Specified by:

expireTime in interface CacheDataRow

Returns:

Expire time.

partition

public int partition()

Specified by:

partition in interface CacheDataRow

Specified by:

partition in interface Storable

Returns:

Partition for this key.

link

public long link()

Specified by:

link in interface CacheSearchRow

Specified by:

link in interface Storable

Returns:

Link for this row.

link

public void link(long link)

Specified by:

link in interface CacheDataRow

Specified by:

link in interface Storable

Parameters:

link - Link for this row.

hash

public int hash()

Specified by:

hash in interface CacheSearchRow

Returns:

Key hash code.

size

public int size()
         throws IgniteCheckedException

Specified by:

size in interface Storable

Returns:

Row size in page.

Throws:

IgniteCheckedException - If failed.

headerSize

public int headerSize()

Specified by:

headerSize in interface Storable

Returns:

Row header size in page. Header is indivisible part of row which is entirely available on the very first page followed by the row link.

mvccCoordinatorVersion

public long mvccCoordinatorVersion()

Specified by:

mvccCoordinatorVersion in interface MvccVersionAware

Returns:

Mvcc coordinator version.

mvccCounter

public long mvccCounter()

Specified by:

mvccCounter in interface MvccVersionAware

Returns:

Mvcc counter.

mvccOperationCounter

public int mvccOperationCounter()

Specified by:

mvccOperationCounter in interface MvccVersionAware

Returns:

Mvcc operation counter.

mvccTxState

public byte mvccTxState()

Specified by:

mvccTxState in interface MvccVersionAware

Returns:

Tx state hint for 'created' mvcc version.

newMvccCoordinatorVersion

public long newMvccCoordinatorVersion()

Specified by:

newMvccCoordinatorVersion in interface MvccUpdateVersionAware

Returns:

New mvcc coordinator version.

newMvccCounter

public long newMvccCounter()

Specified by:

newMvccCounter in interface MvccUpdateVersionAware

Returns:

New mvcc counter.

newMvccOperationCounter

public int newMvccOperationCounter()

Specified by:

newMvccOperationCounter in interface MvccUpdateVersionAware

Returns:

New mvcc operation counter.

newMvccTxState

public byte newMvccTxState()

Specified by:

newMvccTxState in interface MvccUpdateVersionAware

Returns:

New Tx state.

toString

public String toString()

Overrides:

toString in class Object