org.apache.ignite.internal.processors.cache

Class PartitionUpdateCounterMvccImpl

java.lang.Object

org.apache.ignite.internal.processors.cache.PartitionUpdateCounterTrackingImpl

org.apache.ignite.internal.processors.cache.PartitionUpdateCounterMvccImpl

All Implemented Interfaces:

Iterable<long[]>, PartitionUpdateCounter

public class PartitionUpdateCounterMvccImpl
extends PartitionUpdateCounterTrackingImpl

Update counter implementation for MVCC mode.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.PartitionUpdateCounterTrackingImpl

cntr, first, grp, initCntr, MAX_MISSED_UPDATES, queue, reserveCntr

Constructor Summary

Constructors

Constructor and Description
PartitionUpdateCounterMvccImpl(CacheGroupContext grp)

Method Summary

Modifier and Type	Method and Description
PartitionUpdateCounter	copy()
protected PartitionUpdateCounterTrackingImpl	createInstance()
long	reserve(long delta) Increment HWM by delta.
long	reserved() Returns HWM.

Methods inherited from class org.apache.ignite.internal.processors.cache.PartitionUpdateCounterTrackingImpl

context, empty, equals, finalizeUpdateCounters, get, getBytes, highestAppliedCounter, init, initial, iterator, next, next, reset, resetInitialCounter, sequential, toString, update, update, updateInitial

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

PartitionUpdateCounterMvccImpl

public PartitionUpdateCounterMvccImpl(CacheGroupContext grp)

Parameters:

grp - Group.

Method Detail

reserve

public long reserve(long delta)

Increment HWM by delta.

Specified by:

reserve in interface PartitionUpdateCounter

Overrides:

reserve in class PartitionUpdateCounterTrackingImpl

Parameters:

delta - Delta.

Returns:

New HWM.

reserved

public long reserved()

Returns HWM.

Specified by:

reserved in interface PartitionUpdateCounter

Overrides:

reserved in class PartitionUpdateCounterTrackingImpl

Returns:

Current HWM.

createInstance

protected PartitionUpdateCounterTrackingImpl createInstance()

Overrides:

createInstance in class PartitionUpdateCounterTrackingImpl

copy

public PartitionUpdateCounter copy()

Specified by:

copy in interface PartitionUpdateCounter

Overrides:

copy in class PartitionUpdateCounterTrackingImpl

Returns:

A deep copy of current instance.