| 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) |
| Modifier and Type | Method and Description |
|---|---|
String |
PortableReaderExImpl.readUTF() |
| 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) |
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<?,?> 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) |
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) |
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) |
| 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,
boolean topLocked,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
boolean retval,
javax.cache.expiry.ExpiryPolicy expiryPlc,
Object[] invokeArgs,
CacheEntryPredicate[] filter,
UUID subjId,
int taskNameHash,
boolean skipStore,
boolean clientReq)
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,
UUID subjId,
int taskNameHash,
long accessTtl,
boolean skipStore,
boolean firstClientReq) |
GridNearTxFinishRequest(IgniteUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte 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) |
| Constructor and Description |
|---|
DataStreamerRequest(long reqId,
byte[] resTopicBytes,
String cacheName,
byte[] updaterBytes,
Collection<DataStreamerEntry> entries,
boolean ignoreDepOwnership,
boolean skipStore,
DeploymentMode depMode,
String sampleClsName,
String userVer,
Map<UUID,IgniteUuid> ldrParticipants,
IgniteUuid clsLdrId,
boolean forceLocDep,
AffinityTopologyVersion topVer) |
| 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 |
|---|---|
void |
TcpDiscoveryCustomEventMessage.message(DiscoverySpiCustomMessage msg,
byte[] msgBytes) |
DiscoverySpiCustomMessage |
TcpDiscoveryCustomEventMessage.message(Marshaller marsh) |
| Constructor and Description |
|---|
TcpDiscoveryCustomEventMessage(UUID creatorNodeId,
DiscoverySpiCustomMessage msg,
byte[] msgBytes) |
| Modifier and Type | Method and Description |
|---|---|
Thread |
IgniteThreadFactory.newThread(Runnable r) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.4.0 Release Date : September 24 2015