| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.distributed | |
| org.apache.ignite.internal.processors.cache.distributed.dht | |
| org.apache.ignite.internal.processors.cache.distributed.near | |
| org.apache.ignite.internal.processors.cache.transactions |
| Modifier and Type | Method and Description |
|---|---|
static IgnitePredicate<IgniteTxEntry> |
GridCacheUtils.reads() |
static IgnitePredicate<IgniteTxEntry> |
GridCacheUtils.writes() |
| Modifier and Type | Method and Description |
|---|---|
@Nullable javax.cache.expiry.ExpiryPolicy |
GridCacheContext.expiryForTxEntry(IgniteTxEntry txEntry) |
void |
CacheOffheapEvictionManager.touch(IgniteTxEntry txEntry,
boolean loc) |
void |
CacheEvictionManager.touch(IgniteTxEntry txEntry,
boolean loc) |
void |
GridCacheEvictionManager.touch(IgniteTxEntry txEntry,
boolean loc) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridCacheMessage.marshalTx(Iterable<IgniteTxEntry> txEntries,
GridCacheSharedContext ctx) |
protected void |
GridCacheMessage.unmarshalTx(Iterable<IgniteTxEntry> txEntries,
boolean near,
GridCacheSharedContext ctx,
ClassLoader ldr) |
| Modifier and Type | Method and Description |
|---|---|
IgniteTxEntry |
GridDistributedTxRemoteAdapter.entry(IgniteTxKey key) |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteTxEntry> |
GridDistributedTxRemoteAdapter.allEntries() |
Collection<IgniteTxEntry> |
GridDistributedTxMapping.colocatedEntriesReads() |
Collection<IgniteTxEntry> |
GridDistributedTxMapping.colocatedEntriesWrites() |
Collection<IgniteTxEntry> |
GridDistributedTxMapping.entries() |
Collection<IgniteTxEntry> |
GridDistributedTxMapping.nearEntriesReads() |
Collection<IgniteTxEntry> |
GridDistributedTxMapping.nearEntriesWrites() |
Collection<IgniteTxEntry> |
GridDistributedTxRemoteAdapter.readEntries() |
Map<IgniteTxKey,IgniteTxEntry> |
GridDistributedTxRemoteAdapter.readMap() |
Collection<IgniteTxEntry> |
GridDistributedTxPrepareRequest.reads() |
Collection<IgniteTxEntry> |
GridDistributedTxMapping.reads() |
Collection<IgniteTxEntry> |
GridDistributedTxRemoteAdapter.writeEntries() |
Map<IgniteTxKey,IgniteTxEntry> |
GridDistributedTxRemoteAdapter.writeMap() |
Collection<IgniteTxEntry> |
GridDistributedTxPrepareRequest.writes() |
Collection<IgniteTxEntry> |
GridDistributedTxMapping.writes() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedTxMapping.add(IgniteTxEntry entry) |
protected void |
GridDistributedTxRemoteAdapter.addExplicit(IgniteTxEntry e)
Adds explicit version if there is one.
|
boolean |
GridDistributedTxMapping.removeEntry(IgniteTxEntry entry) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridDistributedTxPrepareRequest.reads(Collection<IgniteTxEntry> reads) |
protected void |
GridDistributedTxPrepareRequest.writes(Collection<IgniteTxEntry> writes) |
| Constructor and Description |
|---|
GridDistributedTxPrepareRequest(IgniteInternalTx tx,
long timeout,
@Nullable Collection<IgniteTxEntry> reads,
Collection<IgniteTxEntry> writes,
Map<UUID,Collection<UUID>> txNodes,
boolean retVal,
boolean last,
boolean onePhaseCommit,
boolean addDepInfo) |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteTxEntry> |
GridDhtTxPrepareRequest.nearWrites() |
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteInternalFuture<Boolean> |
GridDhtTxLocalAdapter.addEntry(long msgId,
IgniteTxEntry e) |
protected @Nullable IgniteInternalFuture<Boolean> |
GridDhtTxLocal.addReader(long msgId,
GridDhtCacheEntry cached,
IgniteTxEntry entry,
AffinityTopologyVersion topVer)
Adds reader to cached entry.
|
protected abstract @Nullable IgniteInternalFuture<Boolean> |
GridDhtTxLocalAdapter.addReader(long msgId,
GridDhtCacheEntry cached,
IgniteTxEntry entry,
AffinityTopologyVersion topVer)
Adds reader to cached entry.
|
void |
GridDhtTxRemote.addWrite(IgniteTxEntry entry,
ClassLoader ldr) |
protected void |
GridDhtTxLocal.updateExplicitVersion(IgniteTxEntry txEntry,
GridCacheEntryEx entry)
Updates explicit version for tx entry based on current entry lock owner.
|
| Constructor and Description |
|---|
GridDhtTxPrepareRequest(IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridDhtTxLocalAdapter tx,
long timeout,
Collection<IgniteTxEntry> dhtWrites,
Collection<IgniteTxEntry> nearWrites,
Map<UUID,Collection<UUID>> txNodes,
GridCacheVersion nearXidVer,
boolean last,
boolean onePhaseCommit,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean storeWriteThrough,
boolean retVal,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
GridDhtTxPrepareRequest(IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridDhtTxLocalAdapter tx,
long timeout,
Collection<IgniteTxEntry> dhtWrites,
Collection<IgniteTxEntry> nearWrites,
Map<UUID,Collection<UUID>> txNodes,
GridCacheVersion nearXidVer,
boolean last,
boolean onePhaseCommit,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean storeWriteThrough,
boolean retVal,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteTxEntry> |
GridNearTxLocal.optimisticLockEntries()
Gets a list of entries that needs to be locked on the next step of prepare stage of
optimistic transaction.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgniteInternalFuture<Boolean> |
GridNearTxLocal.addReader(long msgId,
GridDhtCacheEntry cached,
IgniteTxEntry entry,
AffinityTopologyVersion topVer)
Adds reader to cached entry.
|
protected void |
GridNearTxLocal.updateExplicitVersion(IgniteTxEntry txEntry,
GridCacheEntryEx entry)
Updates explicit version for tx entry based on current entry lock owner.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearTxRemote.addEntries(ClassLoader ldr,
Iterable<IgniteTxEntry> entries)
Adds entries to started near remote tx.
|
| Constructor and Description |
|---|
GridNearTxPrepareRequest(IgniteUuid futId,
AffinityTopologyVersion topVer,
GridNearTxLocal tx,
long timeout,
Collection<IgniteTxEntry> reads,
Collection<IgniteTxEntry> writes,
boolean near,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
boolean onePhaseCommit,
boolean retVal,
boolean implicitSingle,
boolean explicitLock,
@Nullable UUID subjId,
int taskNameHash,
boolean firstClientReq,
boolean allowWaitTopFut,
boolean addDepInfo,
boolean recovery) |
GridNearTxPrepareRequest(IgniteUuid futId,
AffinityTopologyVersion topVer,
GridNearTxLocal tx,
long timeout,
Collection<IgniteTxEntry> reads,
Collection<IgniteTxEntry> writes,
boolean near,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
boolean onePhaseCommit,
boolean retVal,
boolean implicitSingle,
boolean explicitLock,
@Nullable UUID subjId,
int taskNameHash,
boolean firstClientReq,
boolean allowWaitTopFut,
boolean addDepInfo,
boolean recovery) |
GridNearTxRemote(GridCacheSharedContext ctx,
AffinityTopologyVersion topVer,
ClassLoader ldr,
UUID nodeId,
UUID nearNodeId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
Collection<IgniteTxEntry> writeEntries,
int txSize,
@Nullable UUID subjId,
int taskNameHash,
@Nullable String txLbl)
This constructor is meant for optimistic transactions.
|
| Modifier and Type | Field and Description |
|---|---|
protected Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxRemoteStateImpl.readMap
Read set.
|
protected Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxStateImpl.txMap
Per-transaction read map.
|
protected Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxRemoteStateImpl.writeMap
Write map.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteTxEntry |
IgniteTxLocalAdapter.addEntry(GridCacheOperation op,
@Nullable CacheObject val,
@Nullable javax.cache.processor.EntryProcessor entryProcessor,
Object[] invokeArgs,
GridCacheEntryEx entry,
@Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
boolean filtersSet,
long drTtl,
long drExpireTime,
@Nullable GridCacheVersion drVer,
boolean skipStore,
boolean keepBinary,
boolean addReader) |
IgniteTxEntry |
IgniteTxEntry.cleanCopy(GridCacheContext<?,?> ctx) |
IgniteTxEntry |
IgniteTxRemoteStateImpl.entry(IgniteTxKey key) |
@Nullable IgniteTxEntry |
IgniteInternalTx.entry(IgniteTxKey key) |
IgniteTxEntry |
IgniteTxRemoteSingleStateImpl.entry(IgniteTxKey key) |
@Nullable IgniteTxEntry |
IgniteTxLocalAdapter.entry(IgniteTxKey key) |
IgniteTxEntry |
IgniteTxStateImpl.entry(IgniteTxKey key) |
IgniteTxEntry |
IgniteTxImplicitSingleStateImpl.entry(IgniteTxKey key) |
@Nullable IgniteTxEntry |
IgniteTxState.entry(IgniteTxKey key) |
@Nullable IgniteTxEntry |
IgniteTxMap.get(Object key) |
IgniteTxEntry |
IgniteTxMap.remove(Object key) |
IgniteTxEntry |
IgniteTxRemoteStateImpl.singleWrite() |
@Nullable IgniteTxEntry |
IgniteTxRemoteSingleStateImpl.singleWrite() |
IgniteTxEntry |
IgniteTxStateImpl.singleWrite() |
IgniteTxEntry |
IgniteTxImplicitSingleStateImpl.singleWrite() |
@Nullable IgniteTxEntry |
IgniteTxState.singleWrite() |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxStateImpl.addEntry(IgniteTxEntry entry) |
void |
IgniteTxImplicitSingleStateImpl.addEntry(IgniteTxEntry entry) |
void |
IgniteTxLocalState.addEntry(IgniteTxEntry entry) |
protected void |
IgniteTxLocalAdapter.addInvokeResult(IgniteTxEntry txEntry,
CacheObject cacheVal,
GridCacheReturn ret,
GridCacheVersion ver) |
void |
IgniteTxRemoteStateImpl.addWriteEntry(IgniteTxKey key,
IgniteTxEntry e) |
void |
IgniteTxRemoteSingleStateImpl.addWriteEntry(IgniteTxKey key,
IgniteTxEntry e) |
void |
IgniteTxRemoteState.addWriteEntry(IgniteTxKey key,
IgniteTxEntry e) |
protected IgniteBiTuple<GridCacheOperation,CacheObject> |
IgniteTxAdapter.applyTransformClosures(IgniteTxEntry txEntry,
boolean metrics,
@Nullable GridCacheReturn ret) |
protected IgniteBiTuple<GridCacheOperation,GridCacheVersionConflictContext> |
IgniteTxAdapter.conflictResolve(GridCacheOperation op,
IgniteTxEntry txEntry,
CacheObject newVal,
GridCacheVersion newVer,
GridCacheEntryEx old)
Resolve DR conflict.
|
protected boolean |
IgniteTxAdapter.evictNearEntry(IgniteTxEntry e,
boolean primaryOnly) |
protected boolean |
IgniteTxAdapter.isNearLocallyMapped(IgniteTxEntry e,
boolean primaryOnly) |
protected void |
IgniteTxLocalAdapter.updateExplicitVersion(IgniteTxEntry txEntry,
GridCacheEntryEx entry)
Updates explicit version for tx entry based on current entry lock owner.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
IgniteTxAdapter.batchStoreCommit(Iterable<IgniteTxEntry> writeEntries)
Performs batch database operations.
|
| Constructor and Description |
|---|
IgniteTxMap(Map<IgniteTxKey,IgniteTxEntry> txMap,
IgnitePredicate<IgniteTxEntry> filter) |
IgniteTxMap(Map<IgniteTxKey,IgniteTxEntry> txMap,
IgnitePredicate<IgniteTxEntry> filter) |
IgniteTxRemoteStateImpl(Map<IgniteTxKey,IgniteTxEntry> readMap,
Map<IgniteTxKey,IgniteTxEntry> writeMap) |
IgniteTxRemoteStateImpl(Map<IgniteTxKey,IgniteTxEntry> readMap,
Map<IgniteTxKey,IgniteTxEntry> writeMap) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.1 Release Date : December 9 2020