| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.distributed.dht.preloader | |
| org.apache.ignite.internal.processors.cache.distributed.dht.topology | |
| org.apache.ignite.internal.processors.cache.persistence.wal.aware | |
| org.apache.ignite.internal.processors.cache.query | |
| org.apache.ignite.internal.processors.query.schema | |
| org.apache.ignite.internal.util |
System-wide utility routine and helper classes.
|
| org.apache.ignite.internal.util.worker |
Common utility classes for threads.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridCachePartitionExchangeManager.mergeExchanges(GridDhtPartitionsExchangeFuture curFut,
GridDhtPartitionsFullMessage msg) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionsExchangeFuture.init(boolean newCrd)
Starts activity.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer,
GridDhtPartitionsExchangeFuture exchFut) |
boolean |
GridDhtPartitionTopologyImpl.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer,
GridDhtPartitionsExchangeFuture exchFut) |
void |
GridDhtPartitionTopology.updateTopologyVersion(GridDhtTopologyFuture exchFut,
DiscoCache discoCache,
long updateSeq,
boolean stopping)
Updates topology version.
|
void |
GridClientPartitionTopology.updateTopologyVersion(GridDhtTopologyFuture exchFut,
DiscoCache discoCache,
long updSeq,
boolean stopping)
Updates topology version.
|
void |
GridDhtPartitionTopologyImpl.updateTopologyVersion(GridDhtTopologyFuture exchFut,
@NotNull DiscoCache discoCache,
long updSeq,
boolean stopping)
Updates topology version.
|
| Modifier and Type | Method and Description |
|---|---|
long |
SegmentAware.awaitAvailableTruncateArchive()
Waiting for segment truncation to be available.
|
void |
SegmentAware.awaitExceedMaxArchiveSize(long max)
Waiting for exceeding the maximum WAL archive size.
|
void |
SegmentAware.awaitSegment(long absSegIdx)
Waiting until current WAL index will be greater or equal than given one.
|
void |
SegmentAware.awaitSegmentArchived(long awaitIdx)
Method will wait activation of particular WAL segment index.
|
void |
SegmentAware.markAsMovedToArchive(long toArchive)
Mark segment as moved to archive under lock.
|
long |
SegmentAware.nextAbsoluteSegmentIndex()
Calculate next segment index or wait if needed.
|
long |
SegmentAware.waitNextSegmentForArchivation()
Waiting until archivation of next segment will be allowed.
|
long |
SegmentAware.waitNextSegmentToCompress()
Pessimistically tries to reserve segment for compression in order to avoid concurrent truncation.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridCacheDistributedQueryFuture.loadAllPages()
Loads all left pages.
|
protected abstract void |
GridCacheQueryFutureAdapter.loadAllPages()
Loads all left pages.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
SchemaIndexCachePartitionWorker.body()
The implementation should provide the execution body for this runnable.
|
protected void |
SchemaOperationWorker.body()
The implementation should provide the execution body for this runnable.
|
| Modifier and Type | Method and Description |
|---|---|
void |
BasicRateLimiter.acquire(int permits)
Acquires the given number of permits from this
RateLimiter, blocking until the request
can be granted. |
static void |
IgniteUtils.acquire(Semaphore sem)
Acquires a permit from provided semaphore.
|
boolean |
GridAtomicInitializer.await()
Await for completion.
|
static void |
IgniteUtils.await(Condition cond)
Awaits for condition.
|
static boolean |
IgniteUtils.await(Condition cond,
long time,
TimeUnit unit)
Awaits for condition.
|
static void |
IgniteUtils.await(CountDownLatch latch)
Awaits for the latch.
|
static boolean |
IgniteUtils.await(CountDownLatch latch,
long timeout,
TimeUnit unit)
Awaits for the latch.
|
static <T,R> Collection<R> |
IgniteUtils.doInParallel(ExecutorService executorSvc,
Collection<T> srcDatas,
IgniteThrowableFunction<T,R> operation)
Execute operation on data in parallel.
|
static <T,R> Collection<R> |
IgniteUtils.doInParallel(int parallelismLvl,
ExecutorService executorSvc,
Collection<T> srcDatas,
IgniteThrowableFunction<T,R> operation)
Execute operation on data in parallel.
|
static <T,R> Collection<R> |
IgniteUtils.doInParallelUninterruptibly(int parallelismLvl,
ExecutorService executorSvc,
Collection<T> srcDatas,
IgniteThrowableFunction<T,R> operation)
Execute operation on data in parallel uninterruptibly.
|
static void |
IgniteUtils.join(GridWorker w)
Joins worker.
|
static void |
IgniteUtils.join(@Nullable Thread t)
Joins thread.
|
static void |
IgniteUtils.sleep(long ms)
Sleeps for given number of milliseconds.
|
static boolean |
IgniteUtils.tryAcquire(Semaphore sem,
long timeout,
TimeUnit unit)
Tries to acquire a permit from provided semaphore during
timeout. |
static void |
IgniteUtils.wait(Object mux)
Converts
InterruptedException to IgniteCheckedException. |
static void |
IgniteUtils.writeLock(ReadWriteLock lock) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
GridWorker.body()
The implementation should provide the execution body for this runnable.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.0 Release Date : September 11 2021