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

Class MvccQueryTrackerImpl

java.lang.Object

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

All Implemented Interfaces:

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.MvccQueryTracker

ID_CNTR, MVCC_TRACKER_ID_NA

Constructor Summary

Constructors

Constructor and Description
MvccQueryTrackerImpl(GridCacheContext cctx)
MvccQueryTrackerImpl(GridCacheContext cctx, boolean canRemap)

Method Summary

Modifier and Type	Method and Description
GridCacheContext	context()
long	id()
void	onDone() Marks tracker as done.
IgniteInternalFuture<Void>	onDone(GridNearTxLocal tx, boolean commit) Marks tracker as done.
long	onMvccCoordinatorChange(MvccCoordinator newCrd) Mvcc coordinator change callback.
IgniteInternalFuture<MvccSnapshot>	requestSnapshot() Requests version on coordinator.
IgniteInternalFuture<MvccSnapshot>	requestSnapshot(AffinityTopologyVersion topVer) Requests version on coordinator.
void	requestSnapshot(AffinityTopologyVersion topVer, MvccSnapshotResponseListener lsnr) 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.

MvccQueryTrackerImpl

public MvccQueryTrackerImpl(GridCacheContext cctx,
                            boolean canRemap)

Parameters:

cctx - Cache context.

canRemap - True if tracker can remap on coordinator fail.

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.

requestSnapshot

public IgniteInternalFuture<MvccSnapshot> requestSnapshot(@NotNull
                                                          AffinityTopologyVersion topVer)

Requests version on coordinator.

Specified by:

requestSnapshot in interface MvccQueryTracker

Parameters:

topVer - Topology version.

Returns:

Future to wait for result.

requestSnapshot

public void requestSnapshot(@NotNull
                            AffinityTopologyVersion topVer,
                            @NotNull
                            MvccSnapshotResponseListener lsnr)

Requests version on coordinator.

Specified by:

requestSnapshot in interface MvccQueryTracker

Parameters:

topVer - Topology version.

lsnr - Response listener.

onDone

public void onDone()

Marks tracker as done.

Specified by:

onDone in interface MvccQueryTracker

onDone

public IgniteInternalFuture<Void> onDone(@NotNull
                                         GridNearTxLocal tx,
                                         boolean commit)

Marks tracker as done.

Specified by:

onDone in interface MvccQueryTracker

Parameters:

tx - Transaction.

commit - Commit flag.

Returns:

Acknowledge future.

onMvccCoordinatorChange

public long onMvccCoordinatorChange(MvccCoordinator newCrd)

Mvcc coordinator change callback.

Specified by:

onMvccCoordinatorChange in interface MvccQueryTracker

Parameters:

newCrd - New mvcc coordinator.

Returns:

Query id if exists.

toString

public String toString()

Overrides:

toString in class Object