| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.distributed.dht.colocated | |
| org.apache.ignite.internal.processors.cache.distributed.dht.preloader | |
| org.apache.ignite.internal.processors.cache.distributed.near | |
| org.apache.ignite.internal.processors.cache.persistence |
This package contain cache with persitence implementation.
|
| org.apache.ignite.internal.processors.cache.persistence.freelist | |
| org.apache.ignite.internal.processors.cache.persistence.tree.io | |
| org.apache.ignite.internal.processors.cache.query | |
| org.apache.ignite.internal.processors.cache.tree | |
| org.apache.ignite.internal.processors.cache.tree.mvcc.data | |
| org.apache.ignite.internal.processors.cache.tree.mvcc.search | |
| org.apache.ignite.internal.processors.query | |
| org.apache.ignite.internal.processors.query.schema |
| Modifier and Type | Method and Description |
|---|---|
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.find(GridCacheContext cctx,
KeyCacheObject key) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.find(GridCacheContext cctx,
KeyCacheObject key) |
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.mvccFind(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccFind(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot) |
@Nullable CacheDataRow |
IgniteCacheOffheapManager.mvccRead(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
@Nullable CacheDataRow |
IgniteCacheOffheapManagerImpl.mvccRead(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
@Nullable CacheDataRow |
IgniteCacheOffheapManager.OffheapInvokeClosure.oldRow() |
CacheDataRow |
IgniteRebalanceIterator.peek()
Return next element without moving iterator cursor to the next one.
|
@Nullable CacheDataRow |
IgniteCacheOffheapManager.read(GridCacheContext cctx,
KeyCacheObject key) |
@Nullable CacheDataRow |
IgniteCacheOffheapManagerImpl.read(GridCacheContext cctx,
KeyCacheObject key) |
@Nullable CacheDataRow |
IgniteCacheOffheapManager.read(GridCacheMapEntry entry) |
@Nullable CacheDataRow |
IgniteCacheOffheapManagerImpl.read(GridCacheMapEntry entry) |
protected @Nullable CacheDataRow |
GridCacheMapEntry.unswap(@Nullable CacheDataRow row,
boolean checkExpire)
Unswaps an entry.
|
| Modifier and Type | Method and Description |
|---|---|
GridIterator<CacheDataRow> |
IgniteCacheOffheapManager.cacheIterator(int cacheId,
boolean primary,
boolean backup,
AffinityTopologyVersion topVer,
@Nullable MvccSnapshot mvccSnapshot,
Boolean dataPageScanEnabled) |
GridIterator<CacheDataRow> |
IgniteCacheOffheapManagerImpl.cacheIterator(int cacheId,
boolean primary,
boolean backups,
AffinityTopologyVersion topVer,
@Nullable MvccSnapshot mvccSnapshot,
Boolean dataPageScanEnabled) |
GridIterator<CacheDataRow> |
IgniteCacheOffheapManager.cachePartitionIterator(int cacheId,
int part,
@Nullable MvccSnapshot mvccSnapshot,
Boolean dataPageScanEnabled) |
GridIterator<CacheDataRow> |
IgniteCacheOffheapManagerImpl.cachePartitionIterator(int cacheId,
int part,
@Nullable MvccSnapshot mvccSnapshot,
Boolean dataPageScanEnabled) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor() |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor() |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(int cacheId) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(int cacheId) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x,
MvccSnapshot snapshot) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x,
MvccSnapshot snapshot) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(int cacheId,
MvccSnapshot mvccSnapshot) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(int cacheId,
MvccSnapshot mvccSnapshot) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(MvccSnapshot mvccSnapshot) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(MvccSnapshot mvccSnapshot) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(Object x) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(Object x) |
GridCursor<CacheDataRow> |
IgniteCacheOffheapManager.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
GridCursor<CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
GridCursor<CacheDataRow> |
IgniteCacheOffheapManagerImpl.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
GridCursor<CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
GridIterator<CacheDataRow> |
IgniteCacheOffheapManager.partitionIterator(int part) |
GridIterator<CacheDataRow> |
IgniteCacheOffheapManagerImpl.partitionIterator(int part) |
GridCloseableIterator<CacheDataRow> |
IgniteCacheOffheapManager.reservedIterator(int part,
AffinityTopologyVersion topVer) |
GridCloseableIterator<CacheDataRow> |
IgniteCacheOffheapManagerImpl.reservedIterator(int part,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
boolean |
GridCacheMapEntry.initialValue(CacheObject val,
GridCacheVersion ver,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore,
CacheDataRow row)
Sets new value if current version is 0
|
boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
@Nullable MvccVersion mvccVer,
@Nullable MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore,
@Nullable CacheDataRow row)
Sets new value if current version is 0
|
protected boolean |
GridCacheMapEntry.storeValue(@Nullable CacheObject val,
long expireTime,
GridCacheVersion ver,
@Nullable IgnitePredicate<CacheDataRow> predicate,
@Nullable CacheDataRow row)
Stores value in off-heap.
|
CacheObject |
GridCacheMapEntry.unswap(CacheDataRow row) |
@Nullable CacheObject |
GridCacheEntryEx.unswap(CacheDataRow row) |
protected @Nullable CacheDataRow |
GridCacheMapEntry.unswap(@Nullable CacheDataRow row,
boolean checkExpire)
Unswaps an entry.
|
void |
IgniteCacheOffheapManager.CacheDataStore.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManager.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
@Nullable CacheDataRow oldRow) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheOffheapManager.CacheDataStore.insertRows(Collection<DataRowCacheAware> rows,
IgnitePredicateX<CacheDataRow> initPred)
Insert rows into page memory.
|
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.insertRows(Collection<DataRowCacheAware> rows,
IgnitePredicateX<CacheDataRow> initPred)
Insert rows into page memory.
|
void |
IgniteCacheOffheapManager.storeEntries(int partId,
Iterator<GridCacheEntryInfo> infos,
IgnitePredicateX<CacheDataRow> initPred)
Store entries.
|
void |
IgniteCacheOffheapManagerImpl.storeEntries(int partId,
Iterator<GridCacheEntryInfo> infos,
IgnitePredicateX<CacheDataRow> initPred)
Store entries.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable CacheDataRow |
GridDhtDetachedCacheEntry.unswap(CacheDataRow row,
boolean checkExpire)
Unswaps an entry.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable CacheDataRow |
GridDhtDetachedCacheEntry.unswap(CacheDataRow row,
boolean checkExpire)
Unswaps an entry.
|
| Modifier and Type | Method and Description |
|---|---|
CacheDataRow |
IgniteRebalanceIteratorImpl.next() |
CacheDataRow |
IgniteRebalanceIteratorImpl.nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
CacheDataRow |
IgniteRebalanceIteratorImpl.peek()
Return next element without moving iterator cursor to the next one.
|
| Modifier and Type | Method and Description |
|---|---|
Iterator<CacheDataRow> |
IgniteRebalanceIteratorImpl.iterator() |
| Constructor and Description |
|---|
IgniteRebalanceIteratorImpl(NavigableMap<Integer,GridCloseableIterator<CacheDataRow>> fullIterators,
IgniteHistoricalIterator historicalIterator) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable CacheDataRow |
GridNearCacheEntry.unswap(CacheDataRow row,
boolean checkExpire)
Unswaps an entry.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable CacheDataRow |
GridNearCacheEntry.unswap(CacheDataRow row,
boolean checkExpire)
Unswaps an entry.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CacheDataRowAdapter
Cache data row adapter.
|
class |
DataRowCacheAware
Data row implementation that can optionally hide the cache identifier and can set
null as value. |
| Modifier and Type | Field and Description |
|---|---|
static GridCursor<CacheDataRow> |
GridCacheOffheapManager.EMPTY_CURSOR |
| Modifier and Type | Method and Description |
|---|---|
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.find(GridCacheContext cctx,
KeyCacheObject key) |
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.mvccFind(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot) |
| Modifier and Type | Method and Description |
|---|---|
GridCursor<? extends CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.cursor() |
GridCursor<? extends CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.cursor(int cacheId) |
GridCursor<? extends CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper) |
GridCursor<? extends CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x) |
GridCursor<? extends CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x,
MvccSnapshot mvccSnapshot) |
GridCursor<? extends CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.cursor(int cacheId,
MvccSnapshot mvccSnapshot) |
GridCursor<? extends CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.cursor(MvccSnapshot mvccSnapshot) |
GridCursor<? extends CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.cursor(Object x) |
GridCursor<CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
| Modifier and Type | Method and Description |
|---|---|
void |
RowStore.addRow(CacheDataRow row,
IoStatisticsHolder statHolder) |
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
void |
GridCacheOffheapManager.GridCacheDataStore.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
boolean |
RowStore.updateRow(long link,
CacheDataRow row,
IoStatisticsHolder statHolder) |
| Modifier and Type | Method and Description |
|---|---|
void |
RowStore.addRows(Collection<? extends CacheDataRow> rows,
IoStatisticsHolder statHolder) |
void |
GridCacheOffheapManager.GridCacheDataStore.insertRows(Collection<DataRowCacheAware> rows,
IgnitePredicateX<CacheDataRow> initPred)
Insert rows into page memory.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CacheFreeList.insertDataRow(CacheDataRow row,
IoStatisticsHolder statHolder) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
DataPageIO.writeFragmentData(CacheDataRow row,
ByteBuffer buf,
int rowOff,
int payloadSize)
Write row data fragment.
|
protected void |
DataPageIO.writeRowData(long pageAddr,
int dataOff,
int payloadSize,
CacheDataRow row,
boolean newRow) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheQueryManager.remove(KeyCacheObject key,
@Nullable CacheDataRow prevRow) |
void |
GridCacheQueryManager.store(CacheDataRow newRow,
@Nullable CacheDataRow prevRow,
boolean prevRowAvailable) |
void |
GridCacheQueryManager.store(CacheDataRow newRow,
@Nullable CacheDataRow prevRow,
boolean prevRowAvailable) |
| Modifier and Type | Class and Description |
|---|---|
class |
DataRow |
| Modifier and Type | Method and Description |
|---|---|
CacheDataRow |
CacheDataTree.getRow(BPlusIO<CacheSearchRow> io,
long pageAddr,
int idx,
Object flags)
Get data row.
|
| Modifier and Type | Method and Description |
|---|---|
GridCursor<CacheDataRow> |
CacheDataTree.find(CacheSearchRow lower,
CacheSearchRow upper,
BPlusTree.TreeRowClosure<CacheSearchRow,CacheDataRow> c,
Object x) |
| Modifier and Type | Method and Description |
|---|---|
GridCursor<CacheDataRow> |
CacheDataTree.find(CacheSearchRow lower,
CacheSearchRow upper,
BPlusTree.TreeRowClosure<CacheSearchRow,CacheDataRow> c,
Object x) |
| Modifier and Type | Class and Description |
|---|---|
class |
MvccDataRow |
class |
MvccUpdateDataRow |
| Modifier and Type | Method and Description |
|---|---|
CacheDataRow |
MvccUpdateDataRow.oldRow() |
| Modifier and Type | Method and Description |
|---|---|
int |
MvccUpdateDataRow.visit(BPlusTree<CacheSearchRow,CacheDataRow> tree,
BPlusIO<CacheSearchRow> io,
long pageAddr,
int idx,
IgniteWriteAheadLogManager wal)
Performs inspection or operation on a specified row.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable CacheDataRow |
MvccSnapshotSearchRow.row() |
@Nullable CacheDataRow |
MvccFirstRowTreeClosure.row() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
MvccSnapshotSearchRow.apply(BPlusTree<CacheSearchRow,CacheDataRow> tree,
BPlusIO<CacheSearchRow> io,
long pageAddr,
int idx)
Performs inspection or operation on a specified row and returns true if this row is
required or matches or /operation successful (depending on the context).
|
boolean |
MvccFirstRowTreeClosure.apply(BPlusTree<CacheSearchRow,CacheDataRow> tree,
BPlusIO<CacheSearchRow> io,
long pageAddr,
int idx)
Performs inspection or operation on a specified row and returns true if this row is
required or matches or /operation successful (depending on the context).
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridQueryProcessor.remove(GridCacheContext cctx,
CacheDataRow row) |
void |
GridQueryIndexing.remove(GridCacheContext cctx,
GridQueryTypeDescriptor type,
CacheDataRow row)
Removes index entry by key.
|
void |
GridQueryProcessor.store(GridCacheContext cctx,
CacheDataRow newRow,
@Nullable CacheDataRow prevRow,
boolean prevRowAvailable) |
void |
GridQueryProcessor.store(GridCacheContext cctx,
CacheDataRow newRow,
@Nullable CacheDataRow prevRow,
boolean prevRowAvailable) |
void |
GridQueryIndexing.store(GridCacheContext cctx,
GridQueryTypeDescriptor type,
CacheDataRow row,
CacheDataRow prevRow,
boolean prevRowAvailable)
Updates index.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SchemaIndexCacheVisitorClosure.apply(CacheDataRow row)
Apply closure.
|
boolean |
SchemaIndexCacheFilter.apply(CacheDataRow row) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.8.1 Release Date : May 21 2020