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

Class StaticMvccQueryTracker

java.lang.Object

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

All Implemented Interfaces:

MvccQueryTracker

public class StaticMvccQueryTracker
extends Object
implements MvccQueryTracker

Simple MVCC tracker used only as an Mvcc snapshot holder.

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
StaticMvccQueryTracker(GridCacheContext cctx, MvccSnapshot snapshot)

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()

Methods inherited from class java.lang.Object

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

Constructor Detail

StaticMvccQueryTracker

public StaticMvccQueryTracker(GridCacheContext cctx,
                              MvccSnapshot snapshot)

Parameters:

cctx - Cache context.

snapshot - Mvcc snapshot.

Method Detail

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.

id

public long id()

Specified by:

id in interface MvccQueryTracker

Returns:

Tracker id.