| Package | Description |
|---|---|
| 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 | |
| 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 |
|---|---|
void |
GridDhtPartitionTopology.initPartitions(GridDhtPartitionsExchangeFuture exchFut) |
void |
GridDhtPartitionTopologyImpl.initPartitions(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,
DiscoCache discoCache,
long updSeq,
boolean stopping)
Updates topology version.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionsExchangeFuture.init()
Starts activity.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridCacheDatabaseSharedManager.Checkpointer.body()
The implementation should provide the execution body for this runnable.
|
| 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 |
SchemaOperationWorker.body()
The implementation should provide the execution body for this runnable.
|
| Modifier and Type | Method and Description |
|---|---|
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 void |
IgniteUtils.join(GridWorker w)
Joins worker.
|
static void |
IgniteUtils.join(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 Fabric : ver. 2.1.0 Release Date : July 20 2017