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

Class PartitionMetaStorageImpl<T extends Storable>

java.lang.Object

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

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

org.apache.ignite.internal.processors.cache.persistence.freelist.AbstractFreeList<T>

org.apache.ignite.internal.processors.cache.persistence.partstorage.PartitionMetaStorageImpl<T>

All Implemented Interfaces:

FreeList<T>, PartitionMetaStorage<T>, ReuseList

public class PartitionMetaStorageImpl<T extends Storable>
extends AbstractFreeList<T>
implements PartitionMetaStorage<T>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.persistence.freelist.PagesList

PagesList.PagesCache, PagesList.Stripe

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.persistence.freelist.PagesList

bucketsSize, changed, log, name

Fields inherited from class org.apache.ignite.internal.processors.cache.persistence.DataStructure

grpId, grpName, lockLsnr, NOOP_LSNR, pageMem, reuseList, rnd, wal

Constructor Summary

Constructors

Constructor and Description
PartitionMetaStorageImpl(int cacheId, String name, DataRegionMetricsImpl memMetrics, DataRegion memPlc, ReuseList reuseList, IgniteWriteAheadLogManager wal, long metaPageId, boolean initNew, PageLockListener lsnr, GridKernalContext ctx, AtomicLong pageListCacheLimit)

Method Summary

Modifier and Type	Method and Description
byte[]	readRow(long link) Read row as byte array from data pages.

Methods inherited from class org.apache.ignite.internal.processors.cache.persistence.freelist.AbstractFreeList

addForRecycle, casBucket, dumpStatistics, emptyDataPages, freeSpace, getBucket, getBucketCache, getBucketIndex, insertDataRow, insertDataRows, isReuseBucket, recycledPagesCount, removeDataRowByLink, takeRecycledPage, toString, updateDataRow, updateDataRow

Methods inherited from class org.apache.ignite.internal.processors.cache.persistence.freelist.PagesList

bucketsCount, bucketSize, cachedPagesCount, init, initReusedPage, name, put, removeDataPage, saveMetadata, storedPagesCount, stripesCount, takeEmptyPage

Methods inherited from class org.apache.ignite.internal.processors.cache.persistence.DataStructure

acquirePage, allocatePage, allocatePage, allocatePageNoReuse, groupId, init, needWalDeltaRecord, pageSize, randomInt, read, read, readLock, readUnlock, recyclePage, releasePage, tryWriteLock, write, write, write, write, writeLock, writeUnlock, writeUnlock

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.partstorage.PartitionMetaStorage

insertDataRow, removeDataRowByLink, saveMetadata

Constructor Detail

PartitionMetaStorageImpl

public PartitionMetaStorageImpl(int cacheId,
                                String name,
                                DataRegionMetricsImpl memMetrics,
                                DataRegion memPlc,
                                ReuseList reuseList,
                                IgniteWriteAheadLogManager wal,
                                long metaPageId,
                                boolean initNew,
                                PageLockListener lsnr,
                                GridKernalContext ctx,
                                AtomicLong pageListCacheLimit)
                         throws IgniteCheckedException

Parameters:

cacheId - Cache id.

name - Name.

memMetrics - Mem metrics.

memPlc - Mem policy.

reuseList - Reuse list.

wal - Wal.

metaPageId - Meta page id.

initNew - Initialize new.

Throws:

IgniteCheckedException

Method Detail

readRow

public final byte[] readRow(long link)
                     throws IgniteCheckedException

Read row as byte array from data pages.

Specified by:

readRow in interface PartitionMetaStorage<T extends Storable>

Parameters:

link - Link.

Throws:

IgniteCheckedException - If failed.