| Package | Description |
|---|---|
| org.apache.ignite.internal.managers.discovery |
TODO.
|
| org.apache.ignite.internal.processors.affinity |
Data affinity processor.
|
| org.apache.ignite.internal.processors.cache | |
| org.apache.ignite.internal.processors.cache.distributed.dht.topology | |
| org.apache.ignite.internal.processors.cache.mvcc |
| Modifier and Type | Method and Description |
|---|---|
MvccCoordinator |
DiscoCache.mvccCoordinator() |
| Modifier and Type | Method and Description |
|---|---|
MvccCoordinator |
HistoryAffinityAssignment.mvccCoordinator() |
MvccCoordinator |
GridAffinityAssignment.mvccCoordinator() |
MvccCoordinator |
AffinityAssignment.mvccCoordinator() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridAffinityAssignmentCache.initialize(AffinityTopologyVersion topVer,
List<List<ClusterNode>> affAssignment,
MvccCoordinator mvccCrd)
Initializes affinity with given topology version and assignment.
|
| Modifier and Type | Method and Description |
|---|---|
MvccCoordinator |
GridCacheAffinityManager.mvccCoordinator(AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
MvccCoordinator |
GridClientPartitionTopology.mvccCoordinator() |
MvccCoordinator |
GridDhtPartitionTopology.mvccCoordinator() |
MvccCoordinator |
GridDhtPartitionTopologyImpl.mvccCoordinator() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridClientPartitionTopology.updateTopologyVersion(GridDhtTopologyFuture exchFut,
DiscoCache discoCache,
MvccCoordinator mvccCrd,
long updSeq,
boolean stopping)
Updates topology version.
|
void |
GridDhtPartitionTopology.updateTopologyVersion(GridDhtTopologyFuture exchFut,
DiscoCache discoCache,
MvccCoordinator mvccCrd,
long updateSeq,
boolean stopping)
Updates topology version.
|
void |
GridDhtPartitionTopologyImpl.updateTopologyVersion(GridDhtTopologyFuture exchFut,
DiscoCache discoCache,
MvccCoordinator mvccCrd,
long updSeq,
boolean stopping)
Updates topology version.
|
| Modifier and Type | Method and Description |
|---|---|
MvccCoordinator |
MvccProcessorImpl.assignedCoordinator() |
MvccCoordinator |
MvccProcessor.assignedCoordinator() |
MvccCoordinator |
MvccDiscoveryData.coordinator() |
MvccCoordinator |
MvccProcessorImpl.currentCoordinator() |
MvccCoordinator |
MvccProcessor.currentCoordinator() |
MvccCoordinator |
MvccProcessorImpl.currentCoordinator(AffinityTopologyVersion topVer)
Check that the given topology is greater or equals to coordinator's one and returns current coordinator.
|
MvccCoordinator |
MvccProcessor.currentCoordinator(AffinityTopologyVersion topVer)
Check that the given topology is greater or equals to coordinator's one and returns current coordinator.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MvccProcessorImpl.onExchangeStart(MvccCoordinator mvccCrd,
ExchangeContext exchCtx,
ClusterNode exchCrd)
Exchange start callback.
|
void |
MvccProcessor.onExchangeStart(MvccCoordinator mvccCrd,
ExchangeContext exchCtx,
ClusterNode exchCrd)
Exchange start callback.
|
long |
MvccQueryTracker.onMvccCoordinatorChange(MvccCoordinator newCrd)
Mvcc coordinator change callback.
|
long |
StaticMvccQueryTracker.onMvccCoordinatorChange(MvccCoordinator newCrd)
Mvcc coordinator change callback.
|
long |
MvccQueryTrackerImpl.onMvccCoordinatorChange(MvccCoordinator newCrd)
Mvcc coordinator change callback.
|
void |
MvccProcessorImpl.updateCoordinator(MvccCoordinator curCrd) |
void |
MvccProcessor.updateCoordinator(MvccCoordinator curCrd) |
| Constructor and Description |
|---|
MvccDiscoveryData(MvccCoordinator crd) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.5 Release Date : June 4 2019