| Package | Description |
|---|---|
| org.apache.ignite.internal.managers.communication |
TODO.
|
| org.apache.ignite.internal.processors.cache | |
| org.apache.ignite.internal.processors.cache.distributed | |
| org.apache.ignite.internal.processors.cache.distributed.dht | |
| org.apache.ignite.internal.processors.cache.distributed.near | |
| org.apache.ignite.internal.processors.cache.transactions | |
| org.apache.ignite.internal.processors.igfs |
Contains high performance file system processer.
|
| Modifier and Type | Method and Description |
|---|---|
static GridIoPolicy |
GridIoPolicy.fromOrdinal(int ord)
Efficiently gets enumerated value from its ordinal.
|
static GridIoPolicy |
GridIoPolicy.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static GridIoPolicy[] |
GridIoPolicy.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.send(ClusterNode node,
GridTopic topic,
Message msg,
GridIoPolicy plc) |
void |
GridIoManager.send(ClusterNode node,
Object topic,
Message msg,
GridIoPolicy plc) |
void |
GridIoManager.send(Collection<? extends ClusterNode> nodes,
GridTopic topic,
Message msg,
GridIoPolicy plc) |
void |
GridIoManager.send(Collection<? extends ClusterNode> nodes,
Object topic,
Message msg,
GridIoPolicy plc) |
void |
GridIoManager.send(UUID nodeId,
GridTopic topic,
Message msg,
GridIoPolicy plc) |
void |
GridIoManager.send(UUID nodeId,
Object topic,
Message msg,
GridIoPolicy plc) |
void |
GridIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
Message msg,
GridIoPolicy plc,
long timeout,
boolean skipOnTimeout) |
void |
GridIoManager.sendOrderedMessage(Collection<? extends ClusterNode> nodes,
Object topic,
Message msg,
GridIoPolicy plc,
long timeout,
boolean skipOnTimeout) |
void |
GridIoManager.sendOrderedMessage(UUID nodeId,
Object topic,
Message msg,
GridIoPolicy plc,
long timeout,
boolean skipOnTimeout) |
| Constructor and Description |
|---|
GridIoMessage(GridIoPolicy plc,
Object topic,
int topicOrd,
Message msg,
boolean ordered,
long timeout,
boolean skipOnTimeout) |
| Modifier and Type | Method and Description |
|---|---|
GridIoPolicy |
CacheType.ioPolicy() |
GridIoPolicy |
GridCacheContext.ioPolicy() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridCacheIoManager.safeSend(Collection<? extends ClusterNode> nodes,
GridCacheMessage msg,
GridIoPolicy plc,
IgnitePredicate<ClusterNode> fallback)
Sends message and automatically accounts for lefts nodes.
|
void |
GridCacheIoManager.send(ClusterNode node,
GridCacheMessage msg,
GridIoPolicy plc)
Sends communication message.
|
void |
GridCacheIoManager.send(UUID nodeId,
GridCacheMessage msg,
GridIoPolicy plc)
Sends communication message.
|
void |
GridCacheIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
GridCacheMessage msg,
GridIoPolicy plc,
long timeout) |
| Modifier and Type | Method and Description |
|---|---|
GridIoPolicy |
GridDistributedTxPrepareRequest.policy() |
GridIoPolicy |
GridDistributedTxFinishRequest.policy() |
| Constructor and Description |
|---|
GridDistributedTxFinishRequest(GridCacheVersion xidVer,
IgniteUuid futId,
GridCacheVersion commitVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
GridIoPolicy plc,
boolean syncCommit,
boolean syncRollback,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
IgniteTxKey grpLockKey) |
GridDistributedTxRemoteAdapter(GridCacheSharedContext<?,?> ctx,
UUID nodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash) |
| Constructor and Description |
|---|
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
IgniteUuid miniId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
GridIoPolicy plc,
boolean sysInvalidate,
boolean syncCommit,
boolean syncRollback,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash) |
GridDhtTxLocal(GridCacheSharedContext cctx,
UUID nearNodeId,
GridCacheVersion nearXidVer,
IgniteUuid nearFutId,
IgniteUuid nearMiniId,
long nearThreadId,
boolean implicit,
boolean implicitSingle,
boolean sys,
boolean explicitLock,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
Map<UUID,Collection<UUID>> txNodes,
UUID subjId,
int taskNameHash) |
GridDhtTxLocalAdapter(GridCacheSharedContext cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean sys,
boolean explicitLock,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash) |
GridDhtTxRemote(GridCacheSharedContext ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash)
This constructor is meant for pessimistic transactions.
|
GridDhtTxRemote(GridCacheSharedContext ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
long rmtThreadId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
GridCacheVersion nearXidVer,
Map<UUID,Collection<UUID>> txNodes,
UUID subjId,
int taskNameHash)
This constructor is meant for optimistic transactions.
|
| Constructor and Description |
|---|
GridNearTxFinishRequest(IgniteUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
GridIoPolicy plc,
boolean syncCommit,
boolean syncRollback,
boolean explicitLock,
boolean storeEnabled,
AffinityTopologyVersion topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
UUID subjId,
int taskNameHash) |
GridNearTxLocal(GridCacheSharedContext ctx,
boolean implicit,
boolean implicitSingle,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash) |
GridNearTxRemote(GridCacheSharedContext ctx,
ClassLoader ldr,
UUID nodeId,
UUID nearNodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
Collection<IgniteTxEntry> writeEntries,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash)
This constructor is meant for optimistic transactions.
|
GridNearTxRemote(GridCacheSharedContext ctx,
UUID nodeId,
UUID nearNodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash)
This constructor is meant for pessimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
GridIoPolicy |
IgniteInternalTx.ioPolicy() |
GridIoPolicy |
IgniteTxAdapter.ioPolicy() |
| Constructor and Description |
|---|
IgniteTxAdapter(GridCacheSharedContext<?,?> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean loc,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash) |
IgniteTxAdapter(GridCacheSharedContext<?,?> cctx,
UUID nodeId,
GridCacheVersion xidVer,
GridCacheVersion startVer,
long threadId,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash) |
IgniteTxLocalAdapter(GridCacheSharedContext cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgfsContext.send(ClusterNode node,
Object topic,
IgfsCommunicationMessage msg,
GridIoPolicy plc) |
void |
IgfsContext.send(UUID nodeId,
Object topic,
IgfsCommunicationMessage msg,
GridIoPolicy plc) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.1.0-incubating Release Date : May 20 2015