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

Class RowStore

java.lang.Object

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

Direct Known Subclasses:

CacheDataRowStore

public class RowStore
extends Object

Data store for H2 rows.

Field Summary

Fields

Modifier and Type	Field and Description
protected CacheObjectContext	coctx
protected CacheGroupContext	grp
protected PageMemory	pageMem

Constructor Summary

Constructors

Constructor and Description
RowStore(CacheGroupContext grp, FreeList freeList)

Method Summary

Modifier and Type	Method and Description
void	addRow(CacheDataRow row, IoStatisticsHolder statHolder)
void	addRows(Collection<? extends CacheDataRow> rows, IoStatisticsHolder statHolder)
FreeList	freeList()
void	removeRow(long link, IoStatisticsHolder statHolder)
void	setRowCacheCleaner(GridQueryRowCacheCleaner rowCacheCleaner) Inject rows cache cleaner.
<S,R> void	updateDataRow(long link, PageHandler<S,R> pageHnd, S arg, IoStatisticsHolder statHolder) Run page handler operation over the row.
boolean	updateRow(long link, CacheDataRow row, IoStatisticsHolder statHolder)

Methods inherited from class java.lang.Object

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

Field Detail

pageMem

protected final PageMemory pageMem

coctx

protected final CacheObjectContext coctx

grp

protected final CacheGroupContext grp

Constructor Detail

RowStore

public RowStore(CacheGroupContext grp,
                FreeList freeList)

Parameters:

grp - Cache group.

freeList - Free list.

Method Detail

removeRow

public void removeRow(long link,
                      IoStatisticsHolder statHolder)
               throws IgniteCheckedException

Parameters:

link - Row link.

Throws:

IgniteCheckedException - If failed.

addRow

public void addRow(CacheDataRow row,
                   IoStatisticsHolder statHolder)
            throws IgniteCheckedException

Parameters:

row - Row.

Throws:

IgniteCheckedException - If failed.

addRows

public void addRows(Collection<? extends CacheDataRow> rows,
                    IoStatisticsHolder statHolder)
             throws IgniteCheckedException

Parameters:

rows - Rows.

statHolder - Statistics holder to track IO operations.

Throws:

IgniteCheckedException - If failed.

updateRow

public boolean updateRow(long link,
                         CacheDataRow row,
                         IoStatisticsHolder statHolder)
                  throws IgniteCheckedException

Parameters:

link - Row link.

row - New row data.

Returns:

True if was able to update row.

Throws:

IgniteCheckedException - If failed.

updateDataRow

public <S,R> void updateDataRow(long link,
                                PageHandler<S,R> pageHnd,
                                S arg,
                                IoStatisticsHolder statHolder)
                         throws IgniteCheckedException

Run page handler operation over the row.

Parameters:

link - Row link.

pageHnd - Page handler.

arg - Page handler argument.

Throws:

IgniteCheckedException - If failed.

freeList

public FreeList freeList()

Returns:

Free list.

setRowCacheCleaner

public void setRowCacheCleaner(GridQueryRowCacheCleaner rowCacheCleaner)

Inject rows cache cleaner.

Parameters:

rowCacheCleaner - Rows cache cleaner.