| Package | Description |
|---|---|
| org.apache.ignite.igfs.mapreduce |
Contains APIs for In-Memory MapReduce over IGFS.
|
| org.apache.ignite.internal.client.impl | |
| org.apache.ignite.internal.processors.affinity |
Data affinity processor.
|
| org.apache.ignite.internal.processors.cache | |
| org.apache.ignite.internal.processors.cache.distributed.dht | |
| org.apache.ignite.internal.processors.cache.distributed.dht.atomic | |
| org.apache.ignite.internal.processors.cache.distributed.dht.preloader | |
| org.apache.ignite.internal.processors.cache.distributed.near | |
| org.apache.ignite.internal.processors.datastructures | |
| org.apache.ignite.internal.processors.igfs |
Contains high performance file system processer.
|
| org.apache.ignite.internal.util |
System-wide utility routine and helper classes.
|
| org.apache.ignite.lang |
Contains general language constructs and functional APIs for distributed computations.
|
| org.apache.ignite.thread |
Contains threads-related utility classes.
|
| Modifier and Type | Method and Description |
|---|---|
int |
IgfsRangeInputStream.read(byte[] b,
int off,
int len) |
| Modifier and Type | Method and Description |
|---|---|
Thread |
GridClientThreadFactory.newThread(Runnable r) |
| Constructor and Description |
|---|
GridAffinityFunctionContextImpl(List<ClusterNode> topSnapshot,
List<List<ClusterNode>> prevAssignment,
DiscoveryEvent discoEvt,
AffinityTopologyVersion topVer,
int backups) |
| Modifier and Type | Method and Description |
|---|---|
static RuntimeException |
GridCacheUtils.convertToCacheException(IgniteCheckedException e) |
GridCacheProxyImpl<K,V> |
IgniteCacheProxy.legacyProxy() |
| Modifier and Type | Method and Description |
|---|---|
int |
GridDhtLocalPartition.compareTo(GridDhtLocalPartition part) |
| Constructor and Description |
|---|
GridDhtAffinityAssignmentRequest(int cacheId,
AffinityTopologyVersion topVer) |
GridDhtAffinityAssignmentResponse(int cacheId,
AffinityTopologyVersion topVer,
List<List<ClusterNode>> affAssignment) |
GridDhtGetFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
LinkedHashMap<KeyCacheObject,Boolean> keys,
boolean readThrough,
boolean reload,
IgniteTxLocalEx tx,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals) |
GridDhtLockFuture(GridCacheContext<K,V> cctx,
UUID nearNodeId,
GridCacheVersion nearLockVer,
AffinityTopologyVersion topVer,
int cnt,
boolean read,
boolean needReturnValue,
long timeout,
GridDhtTxLocalAdapter tx,
long threadId,
long accessTtl,
CacheEntryPredicate[] filter) |
GridDhtLockRequest(int cacheId,
UUID nodeId,
GridCacheVersion nearXidVer,
long threadId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion lockVer,
AffinityTopologyVersion topVer,
boolean isInTx,
boolean isRead,
TransactionIsolation isolation,
boolean isInvalidate,
long timeout,
int dhtCnt,
int nearCnt,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash,
long accessTtl) |
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) |
| Constructor and Description |
|---|
GridDhtAtomicUpdateRequest(int cacheId,
UUID nodeId,
GridCacheVersion futVer,
GridCacheVersion writeVer,
CacheWriteSynchronizationMode syncMode,
AffinityTopologyVersion topVer,
boolean forceTransformBackups,
UUID subjId,
int taskNameHash,
Object[] invokeArgs)
Constructor.
|
GridNearAtomicUpdateRequest(int cacheId,
UUID nodeId,
GridCacheVersion futVer,
boolean fastMap,
GridCacheVersion updateVer,
AffinityTopologyVersion topVer,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
boolean retval,
boolean forceTransformBackups,
javax.cache.expiry.ExpiryPolicy expiryPlc,
Object[] invokeArgs,
CacheEntryPredicate[] filter,
UUID subjId,
int taskNameHash)
Constructor.
|
| Constructor and Description |
|---|
GridDhtPartitionExchangeId(UUID nodeId,
int evt,
AffinityTopologyVersion topVer) |
GridDhtPartitionsFullMessage(GridDhtPartitionExchangeId id,
GridCacheVersion lastVer,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearGetResponse.invalidPartitions(Collection<Integer> invalidParts,
AffinityTopologyVersion topVer) |
| Constructor and Description |
|---|
GridNearGetRequest(int cacheId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion ver,
LinkedHashMap<KeyCacheObject,Boolean> keys,
boolean readThrough,
boolean reload,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long accessTtl,
boolean skipVals) |
GridNearLockRequest(int cacheId,
AffinityTopologyVersion topVer,
UUID nodeId,
long threadId,
IgniteUuid futId,
GridCacheVersion lockVer,
boolean isInTx,
boolean implicitTx,
boolean implicitSingleTx,
boolean isRead,
boolean retVal,
TransactionIsolation isolation,
boolean isInvalidate,
long timeout,
int keyCnt,
int txSize,
boolean syncCommit,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash,
long accessTtl) |
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) |
| Modifier and Type | Method and Description |
|---|---|
Object[] |
GridCacheSetProxy.toArray() |
<T1> T1[] |
GridCacheSetProxy.toArray(T1[] a) |
| Modifier and Type | Method and Description |
|---|---|
int |
IgfsBlockKey.compareTo(IgfsBlockKey o) |
int |
IgfsInputStreamImpl.read(byte[] b,
int off,
int len) |
| Modifier and Type | Method and Description |
|---|---|
static byte[] |
IgniteUtils.calculateMD5Digest(InputStream in)
Calculate MD5 digits.
|
| Modifier and Type | Method and Description |
|---|---|
int |
IgniteProductVersion.compareTo(IgniteProductVersion o) |
| Modifier and Type | Method and Description |
|---|---|
Thread |
IgniteThreadFactory.newThread(Runnable r) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0 Release Date : March 31 2015