Package org.apache.ignite.internal.processors.cache.transactions

Class TxCounters

java.lang.Object

org.apache.ignite.internal.processors.cache.transactions.TxCounters

public class TxCounters
extends Object

Values which should be tracked during transaction execution and applied on commit.

Constructor Summary

Constructors

Constructor	Description
TxCounters()

Method Summary

Modifier and Type	Method	Description
Map<Integer,Map<Integer,AtomicLong>>	accumulatedUpdateCounters()
Long	generateNextCounter(int cacheId, int partId)
void	incrementUpdateCounter(int cacheId, int part)
Map<Integer,Map<Integer,AtomicLong>>	sizeDeltas()
@Nullable Collection<PartitionUpdateCountersMessage>	updateCounters()
void	updateCounters(Collection<PartitionUpdateCountersMessage> updCntrs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TxCounters

public TxCounters()

Method Detail

sizeDeltas

public Map<Integer,Map<Integer,AtomicLong>> sizeDeltas()

Returns:

Map of size changes for cache partitions made by transaction.

updateCounters

public void updateCounters(Collection<PartitionUpdateCountersMessage> updCntrs)

Parameters:

updCntrs - Final update counters.

updateCounters

@Nullable
public @Nullable Collection<PartitionUpdateCountersMessage> updateCounters()

Returns:

Final update counters.

accumulatedUpdateCounters

public Map<Integer,Map<Integer,AtomicLong>> accumulatedUpdateCounters()

Returns:

Accumulated update counters.

incrementUpdateCounter

public void incrementUpdateCounter(int cacheId,
                                   int part)

Parameters:

cacheId - Cache id.

part - Partition number.

generateNextCounter

public Long generateNextCounter(int cacheId,
                                int partId)

Parameters:

cacheId - Cache id.

partId - Partition id.

Returns:

Counter or null if cache partition has not updates.