| Modifier and Type | Method and Description |
|---|---|
static T2<Ignite,Boolean> |
IgnitionEx.getOrStart(IgniteConfiguration cfg)
Gets or starts new grid instance if it hasn't been started yet.
|
static T2<Ignite,Boolean> |
IgnitionEx.start(IgniteConfiguration cfg,
@Nullable GridSpringResourceContext springCtx,
boolean failIfStarted)
Starts grid with given configuration.
|
| Modifier and Type | Method and Description |
|---|---|
Map<Integer,T2<Long,Long>> |
GridMessageListenHandler.updateCounters() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridMessageListenHandler.updateCounters(AffinityTopologyVersion topVer,
Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode,
Map<Integer,T2<Long,Long>> cntrs) |
void |
GridMessageListenHandler.updateCounters(AffinityTopologyVersion topVer,
Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode,
Map<Integer,T2<Long,Long>> cntrs) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<T2<Collection<byte[]>,byte[]>> |
GridEncryptionManager.generateKeys(int keyCnt) |
| Modifier and Type | Method and Description |
|---|---|
List<T2<Integer,GroupKeyEncrypted>> |
MasterKeyChangeRecordV2.getGrpKeys() |
| Constructor and Description |
|---|
MasterKeyChangeRecordV2(String masterKeyName,
List<T2<Integer,GroupKeyEncrypted>> grpKeys) |
| Modifier and Type | Method and Description |
|---|---|
T2<CacheConfiguration,CacheConfigurationEnrichment> |
CacheConfigurationSplitter.split(CacheConfiguration ccfg)
Splits the given cache configuration into two parts
CacheConfiguration and CacheConfigurationEnrichment that are serialized separately. |
T2<CacheConfiguration,CacheConfigurationEnrichment> |
CacheConfigurationSplitterOldFormat.split(CacheConfiguration ccfg)
Splits the given cache configuration into two parts
CacheConfiguration and CacheConfigurationEnrichment that are serialized separately. |
T2<CacheConfiguration,CacheConfigurationEnrichment> |
CacheConfigurationSplitterImpl.split(CacheConfiguration ccfg)
Splits the given cache configuration into two parts
CacheConfiguration and CacheConfigurationEnrichment that are serialized separately. |
default T2<CacheConfiguration,CacheConfigurationEnrichment> |
CacheConfigurationSplitter.split(CacheGroupDescriptor desc)
Splits cache configuration associated with the given
desc into two parts
CacheConfiguration and CacheConfigurationEnrichment that are serialized separately. |
T2<CacheConfiguration,CacheConfigurationEnrichment> |
CacheConfigurationSplitterOldFormat.split(CacheGroupDescriptor desc)
Splits cache configuration associated with the given
desc into two parts
CacheConfiguration and CacheConfigurationEnrichment that are serialized separately. |
default T2<CacheConfiguration,CacheConfigurationEnrichment> |
CacheConfigurationSplitter.split(DynamicCacheDescriptor desc)
Splits cache configuration associated with the given
desc into two parts
CacheConfiguration and CacheConfigurationEnrichment that are serialized separately. |
T2<CacheConfiguration,CacheConfigurationEnrichment> |
CacheConfigurationSplitterOldFormat.split(DynamicCacheDescriptor desc)
Splits cache configuration associated with the given
desc into two parts
CacheConfiguration and CacheConfigurationEnrichment that are serialized separately. |
| Modifier and Type | Method and Description |
|---|---|
List<T2<DynamicCacheDescriptor,NearCacheConfiguration>> |
LocalJoinCachesContext.caches() |
| Modifier and Type | Method and Description |
|---|---|
static void |
GridCacheUtils.checkAttributeMismatch(IgniteLogger log,
CacheConfiguration locCfg,
CacheConfiguration rmtCfg,
UUID rmtNodeId,
T2<String,String> attr,
boolean fail)
Checks that local and remove configurations have the same value of given attribute.
|
| Constructor and Description |
|---|
LocalJoinCachesContext(List<T2<DynamicCacheDescriptor,NearCacheConfiguration>> locJoinStartCaches,
List<DynamicCacheDescriptor> locJoinInitCaches,
Map<Integer,CacheGroupDescriptor> cacheGrpDescs,
Map<String,DynamicCacheDescriptor> cacheDescs) |
| Modifier and Type | Method and Description |
|---|---|
Map<Integer,T2<Long,Long>> |
IgniteDhtPartitionCountersMap.get(int cacheId) |
static Map<Integer,T2<Long,Long>> |
CachePartitionFullCountersMap.toCountersMap(CachePartitionFullCountersMap map) |
static Map<Integer,T2<Long,Long>> |
CachePartitionPartialCountersMap.toCountersMap(CachePartitionPartialCountersMap cntrsMap) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionsFullMessage.addPartitionUpdateCounters(int grpId,
Map<Integer,T2<Long,Long>> cntrMap) |
void |
IgniteDhtPartitionCountersMap.putIfAbsent(int cacheId,
Map<Integer,T2<Long,Long>> cntrMap) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridCacheDatabaseSharedManager.reserveHistoryForPreloading(Map<T2<Integer,Integer>,Long> reservationMap)
Reserve update history for preloading.
|
boolean |
IgniteCacheDatabaseSharedManager.reserveHistoryForPreloading(Map<T2<Integer,Integer>,Long> reservationMap)
Reserve update history for preloading.
|
| Modifier and Type | Method and Description |
|---|---|
Map<Integer,T2<ReservationReason,Map<Integer,CheckpointEntry>>> |
CheckpointHistoryResult.earliestValidCheckpoints() |
ConcurrentMap<T2<Integer,Integer>,PartitionDestroyRequest> |
PartitionDestroyQueue.pendingReqs() |
| Modifier and Type | Method and Description |
|---|---|
@Nullable Map<GroupPartitionId,CheckpointEntry> |
CheckpointHistory.searchCheckpointEntry(Map<T2<Integer,Integer>,Long> searchCntrMap)
Tries to search for a WAL pointer for the given partition counter start.
|
| Constructor and Description |
|---|
CheckpointHistoryResult(Map<Integer,T2<ReservationReason,Map<Integer,CheckpointEntry>>> earliestValidCheckpoints,
CheckpointEntry reservedCheckoint)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
T2<Integer,Long>[] |
CorruptedTreeException.pages() |
| Modifier and Type | Method and Description |
|---|---|
List<T2<Integer,Long>> |
BPlusTreeRuntimeException.pages()
Pairs of (groupId, pageId).
|
| Constructor and Description |
|---|
CorruptedTreeException(String msg,
String cacheName,
String indexName,
String grpName,
@Nullable Throwable cause,
T2<Integer,Long>... pages) |
| Modifier and Type | Method and Description |
|---|---|
List<T2<Long,Long>> |
IgniteWalIteratorFactory.hasGaps(File... filesOrDirs)
Find WAL gaps, for example:
0 1 2 3 4 7 8 10 - WAL segment files in directory, this method will return
List with two tuples [(4,7),(8,10)].
|
List<T2<Long,Long>> |
IgniteWalIteratorFactory.hasGaps(@NotNull IgniteWalIteratorFactory.IteratorParametersBuilder iteratorParametersBuilder) |
List<T2<Long,Long>> |
IgniteWalIteratorFactory.hasGaps(@NotNull List<FileDescriptor> descriptors) |
List<T2<Long,Long>> |
IgniteWalIteratorFactory.hasGaps(String... filesOrDirs)
Find WAL gaps, for example:
0 1 2 3 4 7 8 10 - WAL segment files in directory, this method will return
List with two tuples [(4,7),(8,10)].
|
| Modifier and Type | Method and Description |
|---|---|
static Predicate<IgniteBiTuple<WALPointer,WALRecord>> |
WalFilters.pageOwner(Set<T2<Integer,Long>> pageOwnerIds)
Filtering all records whose pageId is contained in pageOwnerIds.
|
static Predicate<IgniteBiTuple<WALPointer,WALRecord>> |
WalFilters.partitionMetaStateUpdate(Set<T2<Integer,Integer>> partsMetaupdate)
Filtering all records whose partitionId is contained in partsMetaupdate.
|
| Modifier and Type | Method and Description |
|---|---|
Map<Integer,T2<Long,Long>> |
CacheContinuousQueryHandler.updateCounters() |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheContinuousQueryHandler.updateCounters(AffinityTopologyVersion topVer,
Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode,
Map<Integer,T2<Long,Long>> cntrs) |
void |
CacheContinuousQueryHandler.updateCounters(AffinityTopologyVersion topVer,
Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode,
Map<Integer,T2<Long,Long>> cntrs) |
| Modifier and Type | Method and Description |
|---|---|
T2<GridCacheOperation,CacheObject> |
IgniteTxEntry.entryProcessorCalculatedValue() |
| Modifier and Type | Method and Description |
|---|---|
Collection<T2<javax.cache.processor.EntryProcessor<Object,Object,Object>,Object[]>> |
IgniteTxEntry.entryProcessors() |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxEntry.entryProcessorCalculatedValue(T2<GridCacheOperation,CacheObject> entryProcessorCalcVal) |
| Constructor and Description |
|---|
TxDeadlock(List<GridCacheVersion> cycle,
Map<GridCacheVersion,T2<UUID,Long>> txs,
Map<GridCacheVersion,Set<IgniteTxKey>> txLockedKeys,
Map<IgniteTxKey,Set<GridCacheVersion>> txRequestedKeys) |
| Modifier and Type | Method and Description |
|---|---|
Map<Integer,T2<Long,Long>> |
GridContinuousHandler.updateCounters() |
Map<Integer,T2<Long,Long>> |
StartRoutineAckDiscoveryMessage.updateCounters() |
Map<UUID,Map<Integer,T2<Long,Long>>> |
StartRoutineAckDiscoveryMessage.updateCountersPerNode() |
| Modifier and Type | Method and Description |
|---|---|
void |
StartRoutineDiscoveryMessage.addUpdateCounters(UUID nodeId,
Map<Integer,T2<Long,Long>> cntrs) |
void |
GridContinuousHandler.updateCounters(AffinityTopologyVersion topVer,
Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode,
Map<Integer,T2<Long,Long>> cntrs) |
void |
GridContinuousHandler.updateCounters(AffinityTopologyVersion topVer,
Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode,
Map<Integer,T2<Long,Long>> cntrs) |
| Constructor and Description |
|---|
StartRoutineAckDiscoveryMessage(UUID routineId,
Map<UUID,IgniteCheckedException> errs,
Map<Integer,T2<Long,Long>> cntrs,
Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode) |
StartRoutineAckDiscoveryMessage(UUID routineId,
Map<UUID,IgniteCheckedException> errs,
Map<Integer,T2<Long,Long>> cntrs,
Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode) |
| Modifier and Type | Method and Description |
|---|---|
PageHistoryDiagnoster.DiagnosticPageBuilder |
PageHistoryDiagnoster.DiagnosticPageBuilder.pageIds(T2<Integer,Long>... pageIds) |
| Modifier and Type | Method and Description |
|---|---|
static T2<String,String> |
MetricUtils.fromFullName(String name)
Splits full metric name to registry name and metric name.
|
| Modifier and Type | Method and Description |
|---|---|
<T> GridCloseableIterator<T> |
GridOffHeapProcessor.iterator(@Nullable String spaceName,
CX2<T2<Long,Integer>,T2<Long,Integer>,T> c)
Gets iterator over contents of the given space.
|
<T> GridCloseableIterator<T> |
GridOffHeapProcessor.iterator(@Nullable String spaceName,
CX2<T2<Long,Integer>,T2<Long,Integer>,T> c)
Gets iterator over contents of the given space.
|
<T> GridCloseableIterator<T> |
GridOffHeapProcessor.iterator(@Nullable String spaceName,
CX2<T2<Long,Integer>,T2<Long,Integer>,T> c,
int part)
Gets iterator over contents of the given space.
|
<T> GridCloseableIterator<T> |
GridOffHeapProcessor.iterator(@Nullable String spaceName,
CX2<T2<Long,Integer>,T2<Long,Integer>,T> c,
int part)
Gets iterator over contents of the given space.
|
| Modifier and Type | Method and Description |
|---|---|
static T2<UUID,Long> |
SqlKillQueryCommand.parseGlobalQueryId(String globalQryId)
Parse global SQL query id.
|
| Modifier and Type | Method and Description |
|---|---|
T2<T,Long> |
GridCircularBuffer.get(long idx) |
| Constructor and Description |
|---|
GridConcurrentMultiPairQueue(Collection<T2<K,V[]>> items) |
| Modifier and Type | Method and Description |
|---|---|
<T> GridCloseableIterator<T> |
GridOffHeapPartitionedMap.iterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c)
Gets iterator over the whole map.
|
<T> GridCloseableIterator<T> |
GridOffHeapPartitionedMap.iterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c)
Gets iterator over the whole map.
|
<T> GridCloseableIterator<T> |
GridOffHeapPartitionedMap.iterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c,
int part)
Gets iterator over the partition.
|
<T> GridCloseableIterator<T> |
GridOffHeapPartitionedMap.iterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c,
int part)
Gets iterator over the partition.
|
| Modifier and Type | Method and Description |
|---|---|
<T> GridCloseableIterator<T> |
GridUnsafeMap.iterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c)
Gets iterator over map.
|
<T> GridCloseableIterator<T> |
GridUnsafeMap.iterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c)
Gets iterator over map.
|
<T> GridCloseableIterator<T> |
GridUnsafePartitionedMap.iterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c)
Gets iterator over the whole map.
|
<T> GridCloseableIterator<T> |
GridUnsafePartitionedMap.iterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c)
Gets iterator over the whole map.
|
<T> GridCloseableIterator<T> |
GridUnsafePartitionedMap.iterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c,
int part)
Gets iterator over the partition.
|
<T> GridCloseableIterator<T> |
GridUnsafePartitionedMap.iterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c,
int part)
Gets iterator over the partition.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<T2<UUID,ClusterMetrics>> |
TcpDiscoveryMetricsUpdateMessage.MetricsSet.clientMetrics() |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.10.0 Release Date : March 10 2021