public class TxCounters extends Object
| Constructor and Description |
|---|
TxCounters() |
| Modifier and Type | Method and Description |
|---|---|
Map<Integer,Map<Integer,AtomicLong>> |
accumulatedUpdateCounters() |
void |
accumulateSizeDelta(int cacheId,
int part,
long delta)
Accumulates size change for cache partition.
|
void |
decrementUpdateCounter(int cacheId,
int part) |
Long |
generateNextCounter(int cacheId,
int partId) |
void |
incrementLockCounter()
Increments lock counter.
|
void |
incrementUpdateCounter(int cacheId,
int part) |
int |
lockCounter() |
Map<Integer,Map<Integer,AtomicLong>> |
sizeDeltas() |
@Nullable Collection<PartitionUpdateCountersMessage> |
updateCounters() |
void |
updateCounters(Collection<PartitionUpdateCountersMessage> updCntrs) |
public void accumulateSizeDelta(int cacheId,
int part,
long delta)
cacheId - Cache id.part - Partition id.delta - Size delta.public Map<Integer,Map<Integer,AtomicLong>> sizeDeltas()
public void updateCounters(Collection<PartitionUpdateCountersMessage> updCntrs)
updCntrs - Final update counters.@Nullable public @Nullable Collection<PartitionUpdateCountersMessage> updateCounters()
public Map<Integer,Map<Integer,AtomicLong>> accumulatedUpdateCounters()
public void incrementUpdateCounter(int cacheId,
int part)
cacheId - Cache id.part - Partition number.public void decrementUpdateCounter(int cacheId,
int part)
cacheId - Cache id.part - Partition number.public void incrementLockCounter()
public int lockCounter()
public Long generateNextCounter(int cacheId, int partId)
cacheId - Cache id.partId - Partition id.null if cache partition has not updates.
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.10.0 Release Date : March 10 2021