org.apache.ignite.internal.processors.cache.mvcc

Class MvccQueryTrackerImpl

java.lang.Object

org.apache.ignite.internal.processors.cache.mvcc.MvccQueryTrackerImpl

All Implemented Interfaces:

MvccCoordinatorChangeAware, MvccQueryTracker

public class MvccQueryTrackerImpl
extends Object
implements MvccQueryTracker

Tracker used for an optimistic tx and not-in-tx queries.

Field Summary

Fields inherited from interface org.apache.ignite.internal.processors.cache.mvcc.MvccCoordinatorChangeAware

ID_CNTR, ID_FILTER, MVCC_TRACKER_ID_NA

Constructor Summary

Constructors

Constructor and Description
MvccQueryTrackerImpl(GridCacheContext cctx)

Method Summary

Modifier and Type	Method and Description
GridCacheContext	context()
long	id()
void	onDone() Marks tracker as done.
long	onMvccCoordinatorChange(@NotNull MvccCoordinator newCrd) Mvcc coordinator change callback.
IgniteInternalFuture<MvccSnapshot>	requestSnapshot() Requests version on coordinator.
MvccSnapshot	snapshot()
AffinityTopologyVersion	topologyVersion()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

MvccQueryTrackerImpl

public MvccQueryTrackerImpl(GridCacheContext cctx)

Parameters:

cctx - Cache context.

Method Detail

id

public long id()

Specified by:

id in interface MvccQueryTracker

Returns:

Tracker id.

snapshot

public MvccSnapshot snapshot()

Specified by:

snapshot in interface MvccQueryTracker

Returns:

Requested MVCC snapshot.

context

public GridCacheContext context()

Specified by:

context in interface MvccQueryTracker

Returns:

Cache context.

topologyVersion

public AffinityTopologyVersion topologyVersion()

Specified by:

topologyVersion in interface MvccQueryTracker

Returns:

Topology version.

requestSnapshot

public IgniteInternalFuture<MvccSnapshot> requestSnapshot()

Requests version on coordinator.

Specified by:

requestSnapshot in interface MvccQueryTracker

Returns:

Future to wait for result.

onDone

public void onDone()

Marks tracker as done.

Specified by:

onDone in interface MvccQueryTracker

onMvccCoordinatorChange

public long onMvccCoordinatorChange(@NotNull
                                    @NotNull MvccCoordinator newCrd)

Mvcc coordinator change callback.

Specified by:

onMvccCoordinatorChange in interface MvccCoordinatorChangeAware

Parameters:

newCrd - New mvcc coordinator.

Returns:

Query id if exists.

toString

public String toString()

Overrides:

toString in class Object