Uses of Class
org.apache.ignite.internal.processors.cache.transactions.IgniteTxEntry
-
Packages that use IgniteTxEntry 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 -
-
Uses of IgniteTxEntry in org.apache.ignite.internal.processors.cache
Fields in org.apache.ignite.internal.processors.cache with type parameters of type IgniteTxEntry Modifier and Type Field Description static IgnitePredicate<IgniteTxEntry>GridCacheUtils. FILTER_NEAR_CACHE_ENTRYWrite filter.static IgnitePredicate<IgniteTxEntry>GridCacheUtils. READ_FILTERRead filter.static IgnitePredicate<IgniteTxEntry>GridCacheUtils. READ_FILTER_COLOCATEDRead filter.static IgnitePredicate<IgniteTxEntry>GridCacheUtils. READ_FILTER_NEARRead filter.static IgnitePredicate<IgniteTxEntry>GridCacheUtils. WRITE_FILTERWrite filter.static IgnitePredicate<IgniteTxEntry>GridCacheUtils. WRITE_FILTER_COLOCATEDWrite filter.static IgnitePredicate<IgniteTxEntry>GridCacheUtils. WRITE_FILTER_NEARWrite filter.Methods in org.apache.ignite.internal.processors.cache that return types with arguments of type IgniteTxEntry Modifier and Type Method Description static IgnitePredicate<IgniteTxEntry>GridCacheUtils. reads()static IgnitePredicate<IgniteTxEntry>GridCacheUtils. writes()Methods in org.apache.ignite.internal.processors.cache with parameters of type IgniteTxEntry Modifier and Type Method Description @Nullable javax.cache.expiry.ExpiryPolicyGridCacheContext. expiryForTxEntry(IgniteTxEntry txEntry)voidCacheEvictionManager. touch(IgniteTxEntry txEntry, boolean loc)voidCacheOffheapEvictionManager. touch(IgniteTxEntry txEntry, boolean loc)voidGridCacheEvictionManager. touch(IgniteTxEntry txEntry, boolean loc)Method parameters in org.apache.ignite.internal.processors.cache with type arguments of type IgniteTxEntry Modifier and Type Method Description protected voidGridCacheMessage. marshalTx(Iterable<IgniteTxEntry> txEntries, GridCacheSharedContext ctx)protected voidGridCacheMessage. unmarshalTx(Iterable<IgniteTxEntry> txEntries, GridCacheSharedContext ctx, ClassLoader ldr) -
Uses of IgniteTxEntry in org.apache.ignite.internal.processors.cache.distributed
Methods in org.apache.ignite.internal.processors.cache.distributed that return IgniteTxEntry Modifier and Type Method Description IgniteTxEntryGridDistributedTxRemoteAdapter. entry(IgniteTxKey key)Methods in org.apache.ignite.internal.processors.cache.distributed that return types with arguments of type IgniteTxEntry Modifier and Type Method Description Collection<IgniteTxEntry>GridDistributedTxRemoteAdapter. allEntries()Collection<IgniteTxEntry>GridDistributedTxMapping. colocatedEntriesReads()Collection<IgniteTxEntry>GridDistributedTxMapping. colocatedEntriesWrites()Collection<IgniteTxEntry>GridDistributedTxMapping. entries()@Nullable Collection<IgniteTxEntry>GridDistributedTxMapping. nearCacheEntries()Collection<IgniteTxEntry>GridDistributedTxMapping. nearEntriesReads()Collection<IgniteTxEntry>GridDistributedTxMapping. nearEntriesWrites()Collection<IgniteTxEntry>GridDistributedTxRemoteAdapter. readEntries()Map<IgniteTxKey,IgniteTxEntry>GridDistributedTxRemoteAdapter. readMap()Collection<IgniteTxEntry>GridDistributedTxMapping. reads()Collection<IgniteTxEntry>GridDistributedTxPrepareRequest. reads()Collection<IgniteTxEntry>GridDistributedTxRemoteAdapter. writeEntries()Map<IgniteTxKey,IgniteTxEntry>GridDistributedTxRemoteAdapter. writeMap()Collection<IgniteTxEntry>GridDistributedTxMapping. writes()Collection<IgniteTxEntry>GridDistributedTxPrepareRequest. writes()Methods in org.apache.ignite.internal.processors.cache.distributed with parameters of type IgniteTxEntry Modifier and Type Method Description voidGridDistributedTxMapping. add(IgniteTxEntry entry)protected voidGridDistributedTxRemoteAdapter. addExplicit(IgniteTxEntry e)Adds explicit version if there is one.booleanGridDistributedTxMapping. removeEntry(IgniteTxEntry entry)Method parameters in org.apache.ignite.internal.processors.cache.distributed with type arguments of type IgniteTxEntry Modifier and Type Method Description protected voidGridDistributedTxPrepareRequest. reads(Collection<IgniteTxEntry> reads)protected voidGridDistributedTxPrepareRequest. writes(Collection<IgniteTxEntry> writes)Constructor parameters in org.apache.ignite.internal.processors.cache.distributed with type arguments of type IgniteTxEntry Constructor 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) -
Uses of IgniteTxEntry in org.apache.ignite.internal.processors.cache.distributed.dht
Methods in org.apache.ignite.internal.processors.cache.distributed.dht that return types with arguments of type IgniteTxEntry Modifier and Type Method Description Collection<IgniteTxEntry>GridDhtTxPrepareRequest. nearWrites()Methods in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type IgniteTxEntry Modifier and Type Method 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.voidGridDhtTxRemote. addWrite(IgniteTxEntry entry, ClassLoader ldr)protected voidGridDhtTxLocal. updateExplicitVersion(IgniteTxEntry txEntry, GridCacheEntryEx entry)Updates explicit version for tx entry based on current entry lock owner.Constructor parameters in org.apache.ignite.internal.processors.cache.distributed.dht with type arguments of type IgniteTxEntry Constructor 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, int taskNameHash, boolean addDepInfo, boolean storeWriteThrough, boolean retVal, Collection<PartitionUpdateCountersMessage> updCntrs) -
Uses of IgniteTxEntry in org.apache.ignite.internal.processors.cache.distributed.near
Methods in org.apache.ignite.internal.processors.cache.distributed.near that return types with arguments of type IgniteTxEntry Modifier and Type Method 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.Methods in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type IgniteTxEntry Modifier and Type Method Description protected IgniteInternalFuture<Boolean>GridNearTxLocal. addReader(long msgId, GridDhtCacheEntry cached, IgniteTxEntry entry, AffinityTopologyVersion topVer)Adds reader to cached entry.protected voidGridNearTxLocal. updateExplicitVersion(IgniteTxEntry txEntry, GridCacheEntryEx entry)Updates explicit version for tx entry based on current entry lock owner.Method parameters in org.apache.ignite.internal.processors.cache.distributed.near with type arguments of type IgniteTxEntry Modifier and Type Method Description voidGridNearTxRemote. addEntries(ClassLoader ldr, Iterable<IgniteTxEntry> entries)Adds entries to started near remote tx.Constructor parameters in org.apache.ignite.internal.processors.cache.distributed.near with type arguments of type IgniteTxEntry Constructor 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, 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. -
Uses of IgniteTxEntry in org.apache.ignite.internal.processors.cache.transactions
Fields in org.apache.ignite.internal.processors.cache.transactions with type parameters of type IgniteTxEntry Modifier and Type Field Description protected Map<IgniteTxKey,IgniteTxEntry>IgniteTxRemoteStateImpl. readMapRead set.protected Map<IgniteTxKey,IgniteTxEntry>IgniteTxRemoteStateImpl. writeMapWrite map.Methods in org.apache.ignite.internal.processors.cache.transactions that return IgniteTxEntry Modifier and Type Method Description IgniteTxEntryIgniteTxLocalAdapter. addEntry(GridCacheOperation op, @Nullable CacheObject val, @Nullable javax.cache.processor.EntryProcessor entryProc, 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)IgniteTxEntryIgniteTxEntry. cleanCopy(GridCacheContext<?,?> ctx)@Nullable IgniteTxEntryIgniteInternalTx. entry(IgniteTxKey key)IgniteTxEntryIgniteTxImplicitSingleStateImpl. entry(IgniteTxKey key)@Nullable IgniteTxEntryIgniteTxLocalAdapter. entry(IgniteTxKey key)IgniteTxEntryIgniteTxRemoteSingleStateImpl. entry(IgniteTxKey key)IgniteTxEntryIgniteTxRemoteStateImpl. entry(IgniteTxKey key)@Nullable IgniteTxEntryIgniteTxState. entry(IgniteTxKey key)IgniteTxEntryIgniteTxStateImpl. entry(IgniteTxKey key)@Nullable IgniteTxEntryIgniteTxMap. get(Object key)IgniteTxEntryIgniteTxMap. remove(Object key)IgniteTxEntryIgniteTxImplicitSingleStateImpl. singleWrite()@Nullable IgniteTxEntryIgniteTxRemoteSingleStateImpl. singleWrite()IgniteTxEntryIgniteTxRemoteStateImpl. singleWrite()@Nullable IgniteTxEntryIgniteTxState. singleWrite()IgniteTxEntryIgniteTxStateImpl. singleWrite()Methods in org.apache.ignite.internal.processors.cache.transactions with parameters of type IgniteTxEntry Modifier and Type Method Description voidIgniteTxImplicitSingleStateImpl. addEntry(IgniteTxEntry entry)voidIgniteTxLocalState. addEntry(IgniteTxEntry entry)voidIgniteTxStateImpl. addEntry(IgniteTxEntry entry)protected voidIgniteTxLocalAdapter. addInvokeResult(IgniteTxEntry txEntry, CacheObject cacheVal, GridCacheReturn ret, GridCacheVersion ver)voidIgniteTxRemoteSingleStateImpl. addWriteEntry(IgniteTxKey key, IgniteTxEntry e)voidIgniteTxRemoteState. addWriteEntry(IgniteTxKey key, IgniteTxEntry e)voidIgniteTxRemoteStateImpl. 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 booleanIgniteTxAdapter. evictNearEntry(IgniteTxEntry e, boolean primaryOnly)protected booleanIgniteTxAdapter. isNearLocallyMapped(IgniteTxEntry e, boolean primaryOnly)protected voidIgniteTxLocalAdapter. updateExplicitVersion(IgniteTxEntry txEntry, GridCacheEntryEx entry)Updates explicit version for tx entry based on current entry lock owner.Method parameters in org.apache.ignite.internal.processors.cache.transactions with type arguments of type IgniteTxEntry Modifier and Type Method Description protected voidIgniteTxAdapter. batchStoreCommit(Iterable<IgniteTxEntry> writeEntries)Performs batch database operations.voidIgniteTxManager. prepareTx(IgniteInternalTx tx, @Nullable Collection<IgniteTxEntry> entries)Handles prepare stage.voidIgniteTxLocalAdapter. userPrepare(@Nullable Collection<IgniteTxEntry> entries)Constructor parameters in org.apache.ignite.internal.processors.cache.transactions with type arguments of type IgniteTxEntry Constructor 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)
-