| Package | Description |
|---|---|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.processors.cache | |
| org.apache.ignite.internal.processors.cache.distributed.dht | |
| org.apache.ignite.internal.processors.cache.distributed.dht.preloader | |
| org.apache.ignite.internal.processors.cache.persistence | |
| org.apache.ignite.internal.processors.cache.query.continuous | |
| org.apache.ignite.internal.processors.cache.transactions | |
| org.apache.ignite.internal.processors.continuous | |
| org.apache.ignite.internal.processors.igfs |
Contains high performance file system processor.
|
| org.apache.ignite.internal.processors.offheap | |
| org.apache.ignite.internal.util |
System-wide utility routine and helper classes.
|
| org.apache.ignite.internal.util.offheap | |
| org.apache.ignite.internal.util.offheap.unsafe | |
| org.apache.ignite.spi.discovery.tcp.messages |
Contains implementation messages.
|
| 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,
GridSpringResourceContext springCtx,
boolean failIfStarted)
Starts grid with given configuration.
|
| 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 |
|---|---|
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,
Map<Integer,CacheGroupDescriptor> cacheGrpDescs,
Map<String,DynamicCacheDescriptor> cacheDescs) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtTxRemote.addWrite(GridCacheContext cacheCtx,
GridCacheOperation op,
IgniteTxKey key,
CacheObject val,
Collection<T2<javax.cache.processor.EntryProcessor<Object,Object,Object>,Object[]>> entryProcessors,
long ttl,
boolean skipStore,
boolean keepBinary) |
| Modifier and Type | Method and Description |
|---|---|
Map<Integer,T2<Long,Long>> |
IgniteDhtPartitionCountersMap.get(int cacheId) |
Map<T2<Integer,Integer>,Long> |
IgniteDhtPartitionHistorySuppliersMap.getReservations(UUID nodeId) |
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 |
|---|---|
List<T2<Long,WALPointer>> |
GridCacheDatabaseSharedManager.nodeStartedPointers() |
Map<T2<Integer,Integer>,T2<Long,WALPointer>> |
GridCacheDatabaseSharedManager.reservedForPreloading()
For debugging only.
|
Map<T2<Integer,Integer>,T2<Long,WALPointer>> |
GridCacheDatabaseSharedManager.reservedForPreloading()
For debugging only.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDatabaseSharedManager.applyUpdatesOnRecovery(WALIterator it,
IgnitePredicate<IgniteBiTuple<WALPointer,WALRecord>> recPredicate,
IgnitePredicate<DataEntry> entryPredicate,
Map<T2<Integer,Integer>,T2<Integer,Long>> partStates)
Apply update from some iterator and with specific filters.
|
void |
GridCacheDatabaseSharedManager.applyUpdatesOnRecovery(WALIterator it,
IgnitePredicate<IgniteBiTuple<WALPointer,WALRecord>> recPredicate,
IgnitePredicate<DataEntry> entryPredicate,
Map<T2<Integer,Integer>,T2<Integer,Long>> partStates)
Apply update from some iterator and with specific filters.
|
| 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) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxEntry.entryProcessors(Collection<T2<javax.cache.processor.EntryProcessor<Object,Object,Object>,Object[]>> entryProcessorsCol) |
| 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>> |
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 |
|---|---|
static ArrayList<T2<IgfsPath,IgfsMode>> |
IgfsUtils.preparePathModes(IgfsMode dfltMode,
List<T2<IgfsPath,IgfsMode>> modes,
Set<IgfsPath> dualParentsContainingPrimaryChildren)
Checks, filters and sorts the modes.
|
| Modifier and Type | Method and Description |
|---|---|
static ArrayList<T2<IgfsPath,IgfsMode>> |
IgfsUtils.preparePathModes(IgfsMode dfltMode,
List<T2<IgfsPath,IgfsMode>> modes,
Set<IgfsPath> dualParentsContainingPrimaryChildren)
Checks, filters and sorts the modes.
|
| Constructor and Description |
|---|
IgfsModeResolver(IgfsMode dfltMode,
ArrayList<T2<IgfsPath,IgfsMode>> modes)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
<T> GridCloseableIterator<T> |
GridOffHeapProcessor.iterator(String spaceName,
CX2<T2<Long,Integer>,T2<Long,Integer>,T> c)
Gets iterator over contents of the given space.
|
<T> GridCloseableIterator<T> |
GridOffHeapProcessor.iterator(String spaceName,
CX2<T2<Long,Integer>,T2<Long,Integer>,T> c)
Gets iterator over contents of the given space.
|
<T> GridCloseableIterator<T> |
GridOffHeapProcessor.iterator(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(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 |
|---|---|
T2<T,Long> |
GridCircularBuffer.get(long idx) |
| 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> |
GridOffHeapMap.iterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c)
Gets iterator over map.
|
<T> GridCloseableIterator<T> |
GridOffHeapMap.iterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c)
Gets iterator over 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 Fabric : ver. 2.5.0 Release Date : May 23 2018