Package 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	Description
protected CacheObjectContext	coctx
protected CacheGroupContext	grp
protected PageMemory	pageMem

Constructor Summary

Constructors

Constructor	Description
RowStore(CacheGroupContext grp, FreeList freeList)

Method Summary

Modifier and Type	Method	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(Supplier<GridQueryRowCacheCleaner> rowCacheCleaner)	Inject rows cache cleaner.
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.

freeList

public FreeList freeList()

Returns:

Free list.

setRowCacheCleaner

public void setRowCacheCleaner(Supplier<GridQueryRowCacheCleaner> rowCacheCleaner)

Inject rows cache cleaner.

Parameters:

rowCacheCleaner - Rows cache cleaner.