| Modifier and Type | Method and Description |
|---|---|
int |
IgfsRangeInputStream.read(byte[] b,
int off,
int len) |
| Modifier and Type | Method and Description |
|---|---|
String |
BinaryReaderExImpl.readUTF() |
| 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) |
| 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,
boolean sndNodeIds) |
GridDhtGetFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
IgniteTxLocalEx tx,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals) |
GridDhtGetSingleFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
KeyCacheObject key,
Boolean addRdr,
boolean readThrough,
IgniteTxLocalEx tx,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals) |
GridDhtLockFuture(GridCacheContext<?,?> cctx,
UUID nearNodeId,
GridCacheVersion nearLockVer,
AffinityTopologyVersion topVer,
int cnt,
boolean read,
boolean needReturnVal,
long timeout,
GridDhtTxLocalAdapter tx,
long threadId,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore,
boolean keepBinary) |
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,
UUID subjId,
int taskNameHash,
long accessTtl,
boolean skipStore,
boolean keepBinary,
boolean addDepInfo) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
IgniteUuid miniId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
boolean syncCommit,
boolean syncRollback,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
IgniteUuid miniId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
boolean syncCommit,
boolean syncRollback,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
Collection<Long> updateIdxs) |
| Constructor and Description |
|---|
GridDhtAtomicUpdateRequest(int cacheId,
UUID nodeId,
GridCacheVersion futVer,
GridCacheVersion writeVer,
CacheWriteSynchronizationMode syncMode,
AffinityTopologyVersion topVer,
boolean forceTransformBackups,
UUID subjId,
int taskNameHash,
Object[] invokeArgs,
boolean addDepInfo,
boolean keepBinary,
boolean skipStore)
Constructor.
|
GridNearAtomicUpdateRequest(int cacheId,
UUID nodeId,
GridCacheVersion futVer,
boolean fastMap,
GridCacheVersion updateVer,
AffinityTopologyVersion topVer,
boolean topLocked,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
boolean retval,
javax.cache.expiry.ExpiryPolicy expiryPlc,
Object[] invokeArgs,
CacheEntryPredicate[] filter,
UUID subjId,
int taskNameHash,
boolean skipStore,
boolean keepBinary,
boolean clientReq,
boolean addDepInfo,
int maxEntryCnt)
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,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long accessTtl,
boolean skipVals,
boolean addDepInfo) |
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,
UUID subjId,
int taskNameHash,
long accessTtl,
boolean skipStore,
boolean keepBinary,
boolean firstClientReq,
boolean addDepInfo) |
GridNearSingleGetRequest(int cacheId,
long futId,
KeyCacheObject key,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long accessTtl,
boolean skipVals,
boolean addReader,
boolean needVer,
boolean addDepInfo) |
GridNearTxFinishRequest(IgniteUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
boolean explicitLock,
boolean storeEnabled,
AffinityTopologyVersion topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo) |
| Constructor and Description |
|---|
DataStreamerRequest(long reqId,
byte[] resTopicBytes,
String cacheName,
byte[] updaterBytes,
Collection<DataStreamerEntry> entries,
boolean ignoreDepOwnership,
boolean skipStore,
boolean keepBinary,
DeploymentMode depMode,
String sampleClsName,
String userVer,
Map<UUID,IgniteUuid> ldrParticipants,
IgniteUuid clsLdrId,
boolean forceLocDep,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
Condition |
GridCacheLockImpl.newCondition() |
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 |
|---|---|
Lock |
StripedCompositeReadWriteLock.readLock() |
Lock |
StripedCompositeReadWriteLock.writeLock() |
| 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) |
int |
IgniteProductVersion.compareToIgnoreTimestamp(IgniteProductVersion o) |
| Modifier and Type | Method and Description |
|---|---|
void |
TcpDiscoveryCustomEventMessage.message(DiscoverySpiCustomMessage msg,
byte[] msgBytes) |
DiscoverySpiCustomMessage |
TcpDiscoveryCustomEventMessage.message(Marshaller marsh,
ClassLoader ldr) |
| Constructor and Description |
|---|
TcpDiscoveryCustomEventMessage(UUID creatorNodeId,
DiscoverySpiCustomMessage msg,
byte[] msgBytes) |
| Modifier and Type | Method and Description |
|---|---|
<T> List<Future<T>> |
IgniteStripedThreadPoolExecutor.invokeAll(Collection<? extends Callable<T>> tasks) |
<T> List<Future<T>> |
IgniteStripedThreadPoolExecutor.invokeAll(Collection<? extends Callable<T>> tasks,
long timeout,
TimeUnit unit) |
<T> T |
IgniteStripedThreadPoolExecutor.invokeAny(Collection<? extends Callable<T>> tasks) |
<T> Future<T> |
IgniteStripedThreadPoolExecutor.submit(Callable<T> task) |
Future<?> |
IgniteStripedThreadPoolExecutor.submit(Runnable task) |
<T> Future<T> |
IgniteStripedThreadPoolExecutor.submit(Runnable task,
T res) |
| Modifier and Type | Method and Description |
|---|---|
Thread |
IgniteThreadFactory.newThread(Runnable r) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.6.0 Release Date : May 18 2016