IgniteTxImplicitSingleStateImpl (Ignite 2.8.0)

java.lang.Object
- org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalStateAdapter
- - org.apache.ignite.internal.processors.cache.transactions.IgniteTxImplicitSingleStateImpl

All Implemented Interfaces:: IgniteTxLocalState, IgniteTxState

public class IgniteTxImplicitSingleStateImpl
extends IgniteTxLocalStateAdapter

Constructor Summary

Constructors
Constructor and Description

IgniteTxImplicitSingleStateImpl()

Constructors
Constructor and Description
`IgniteTxImplicitSingleStateImpl()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addActiveCache(GridCacheContext ctx, boolean recovery, IgniteTxAdapter tx)`
`void`	`addEntry(IgniteTxEntry entry)`
`Collection<IgniteTxEntry>`	`allEntries()`
`void`	`awaitLastFuture(GridCacheSharedContext ctx)`
`@Nullable GridIntList`	`cacheIds()` Gets caches ids affected with current tx.
`boolean`	`empty()`
`IgniteTxEntry`	`entry(IgniteTxKey key)`
`@Nullable Integer`	`firstCacheId()`
`boolean`	`hasInterceptor(GridCacheSharedContext cctx)`
`boolean`	`hasWriteKey(IgniteTxKey key)`
`boolean`	`implicitSingle()`
`boolean`	`init(int txSize)`
`boolean`	`initialized()`
`boolean`	`mvccEnabled()`
`void`	`onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)`
`Collection<IgniteTxEntry>`	`readEntries()`
`Map<IgniteTxKey,IgniteTxEntry>`	`readMap()`
`Set<IgniteTxKey>`	`readSet()`
`boolean`	`recovery()`
`void`	`removeEntry(IgniteTxKey key)`
`void`	`seal()`
`@Nullable GridCacheContext`	`singleCacheContext(GridCacheSharedContext cctx)`
`IgniteTxEntry`	`singleWrite()`
`Collection<CacheStoreManager>`	`stores(GridCacheSharedContext cctx)`
`boolean`	`storeWriteThrough(GridCacheSharedContext cctx)`
`CacheWriteSynchronizationMode`	`syncMode(GridCacheSharedContext cctx)`
`GridDhtTopologyFuture`	`topologyReadLock(GridCacheSharedContext cctx, GridFutureAdapter<?> fut)`
`void`	`topologyReadUnlock(GridCacheSharedContext cctx)`
`String`	`toString()`
`void`	`unwindEvicts(GridCacheSharedContext cctx)` Unwind evicts for caches involved in this transaction.
`boolean`	`useMvccCaching(int cacheId)`
`IgniteCheckedException`	`validateTopology(GridCacheSharedContext cctx, boolean read, GridDhtTopologyFuture topFut)`
`Collection<IgniteTxEntry>`	`writeEntries()`
`Map<IgniteTxKey,IgniteTxEntry>`	`writeMap()`
`Set<IgniteTxKey>`	`writeSet()`

Methods inherited from class org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalStateAdapter
onTxEnd, touchedPartitions, touchPartition

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - IgniteTxImplicitSingleStateImpl
```
public IgniteTxImplicitSingleStateImpl()
```
- Method Detail
  - addActiveCache
```
public void addActiveCache(GridCacheContext ctx,
                           boolean recovery,
                           IgniteTxAdapter tx)
                    throws IgniteCheckedException
```
    Parameters:
    
    ctx - Context.
    
    tx - Transaction.
    
    Throws:
    
    IgniteCheckedException - If cache check failed.
  - cacheIds
```
@Nullable
public @Nullable GridIntList cacheIds()
```
    Gets caches ids affected with current tx.
    
    Returns:
    
    tx cache ids.
  - singleCacheContext
```
@Nullable
public @Nullable GridCacheContext singleCacheContext(GridCacheSharedContext cctx)
```
    Parameters:
    
    cctx - Context.
    
    Returns:
    
    cctx Non-null cache context if tx has only one active cache.
  - firstCacheId
```
@Nullable
public @Nullable Integer firstCacheId()
```
    Returns:
    
    First tx cache id.
  - unwindEvicts
```
public void unwindEvicts(GridCacheSharedContext cctx)
```
    Unwind evicts for caches involved in this transaction.
    
    Parameters:
    
    cctx - Grid cache shared context.
  - awaitLastFuture
```
public void awaitLastFuture(GridCacheSharedContext ctx)
```
    Parameters:
    
    ctx - Awaits for previous async operations on active caches to be completed.
  - implicitSingle
```
public boolean implicitSingle()
```
    Returns:
    
    Flag indicating whether transaction is implicit with only one key.
  - validateTopology
```
public IgniteCheckedException validateTopology(GridCacheSharedContext cctx,
                                               boolean read,
                                               GridDhtTopologyFuture topFut)
```
    Parameters:
    
    cctx - Context.
    
    read - True if validating for a read operation, false for write.
    
    topFut - Topology future.
    
    Returns:
    
    Error if validation failed.
  - syncMode
```
public CacheWriteSynchronizationMode syncMode(GridCacheSharedContext cctx)
```
    Parameters:
    
    cctx - Context.
    
    Returns:
    
    Write synchronization mode.
  - topologyReadLock
```
public GridDhtTopologyFuture topologyReadLock(GridCacheSharedContext cctx,
                                              GridFutureAdapter<?> fut)
```
    Parameters:
    
    cctx - Context.
    
    fut - Future to finish with error if some cache is stopping.
    
    Returns:
    
    Topology future.
  - topologyReadUnlock
```
public void topologyReadUnlock(GridCacheSharedContext cctx)
```
    Parameters:
    
    cctx - Context.
  - storeWriteThrough
```
public boolean storeWriteThrough(GridCacheSharedContext cctx)
```
    Parameters:
    
    cctx - Context.
    
    Returns:
    
    True if transaction is allowed to use store and transactions spans one or more caches with store enabled.
  - hasInterceptor
```
public boolean hasInterceptor(GridCacheSharedContext cctx)
```
    Parameters:
    
    cctx - Context.
    
    Returns:
    
    True if transaction spans one or more caches with configured interceptor.
  - stores
```
public Collection<CacheStoreManager> stores(GridCacheSharedContext cctx)
```
    Parameters:
    
    cctx - Context.
    
    Returns:
    
    Configured stores for active caches.
  - onTxEnd
```
public void onTxEnd(GridCacheSharedContext cctx,
                    IgniteInternalTx tx,
                    boolean commit)
```
    Parameters:
    
    cctx - Context.
    
    tx - Transaction.
    
    commit - Commit flag.
  - entry
```
public IgniteTxEntry entry(IgniteTxKey key)
```
    Parameters:
    
    key - Key.
    
    Returns:
    
    Entry.
  - hasWriteKey
```
public boolean hasWriteKey(IgniteTxKey key)
```
    Parameters:
    
    key - Key.
    
    Returns:
    
    True if tx has write key.
  - readSet
```
public Set<IgniteTxKey> readSet()
```
    Returns:
    
    Read entries keys.
  - writeSet
```
public Set<IgniteTxKey> writeSet()
```
    Returns:
    
    Write entries keys.
  - writeEntries
```
public Collection<IgniteTxEntry> writeEntries()
```
    Returns:
    
    Write entries.
  - readEntries
```
public Collection<IgniteTxEntry> readEntries()
```
    Returns:
    
    Read entries.
  - writeMap
```
public Map<IgniteTxKey,IgniteTxEntry> writeMap()
```
    Returns:
    
    Write entries map.
  - readMap
```
public Map<IgniteTxKey,IgniteTxEntry> readMap()
```
    Returns:
    
    Read entries map.
  - empty
```
public boolean empty()
```
    Returns:
    
    True if transaction is empty.
  - allEntries
```
public Collection<IgniteTxEntry> allEntries()
```
    Returns:
    
    All entries.
  - init
```
public boolean init(int txSize)
```
    Parameters:
    
    txSize - Transaction size.
    
    Returns:
    
    True if transaction was successfully started.
  - initialized
```
public boolean initialized()
```
    Returns:
    
    True if init method was called.
  - addEntry
```
public void addEntry(IgniteTxEntry entry)
```
    Parameters:
    
    entry - Entry.
  - removeEntry
```
public void removeEntry(IgniteTxKey key)
```
    Parameters:
    
    key - Key.
  - seal
```
public void seal()
```
  - singleWrite
```
public IgniteTxEntry singleWrite()
```
    Returns:
    
    Non-null entry if tx has only one write entry.
  - mvccEnabled
```
public boolean mvccEnabled()
```
    Returns:
    
    True if MVCC mode is enabled for transaction.
  - useMvccCaching
```
public boolean useMvccCaching(int cacheId)
```
    Parameters:
    
    cacheId - Cache id.
    
    Returns:
    
    True if it is need to store in the heap updates made by the current TX for the given cache. These updates will be used for CQ and DR. See MvccCachingManager.
  - recovery
```
public boolean recovery()
```
    Returns:
    
    Recovery mode flag.
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object

Class IgniteTxImplicitSingleStateImpl

Constructor Summary

Method Summary

Methods inherited from class org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalStateAdapter

Methods inherited from class java.lang.Object

Constructor Detail

IgniteTxImplicitSingleStateImpl

Method Detail

addActiveCache

cacheIds

singleCacheContext

firstCacheId

unwindEvicts

awaitLastFuture

implicitSingle

validateTopology

syncMode

topologyReadLock

topologyReadUnlock

storeWriteThrough

hasInterceptor

stores

onTxEnd

entry

hasWriteKey

readSet

writeSet

writeEntries

readEntries

writeMap

readMap

empty

allEntries

init

initialized

addEntry

removeEntry

seal

singleWrite

mvccEnabled

useMvccCaching

recovery

toString