| Modifier and Type | Method and Description |
|---|---|
<R> Map<IgniteUuid,ComputeTaskFuture<R>> |
IgniteCompute.activeTaskFutures()
Gets tasks future for active tasks started on local node.
|
| Modifier and Type | Method and Description |
|---|---|
IgfsOutputStream |
IgniteFileSystem.create(IgfsPath path,
int bufSize,
boolean overwrite,
IgniteUuid affKey,
int replication,
long blockSize,
Map<String,String> props)
Creates a file and opens it for writing.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
ComputeTaskSession.getId()
Gets session ID of the task being executed.
|
IgniteUuid |
ComputeJobSibling.getJobId()
Gets ID of this grid job sibling.
|
IgniteUuid |
ComputeJobContext.getJobId()
Gets ID of the job this context belongs to.
|
| Modifier and Type | Method and Description |
|---|---|
ComputeJobSibling |
ComputeTaskSession.getJobSibling(IgniteUuid jobId)
Gets job sibling for a given ID.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
EventAdapter.id()
Gets globally unique ID of this event.
|
IgniteUuid |
Event.id()
Gets globally unique ID of this event.
|
IgniteUuid |
JobEvent.jobId()
Gets job ID.
|
IgniteUuid |
TaskEvent.taskSessionId()
Gets session ID of the task that triggered the event.
|
IgniteUuid |
JobEvent.taskSessionId()
Gets task session ID of the task that triggered this event.
|
IgniteUuid |
CacheEvent.xid()
ID of surrounding cache cache transaction or null if there is
no surrounding transaction.
|
| Modifier and Type | Method and Description |
|---|---|
void |
JobEvent.jobId(IgniteUuid jobId)
Sets job ID.
|
void |
JobEvent.taskSessionId(IgniteUuid sesId)
Sets task session ID of the task that triggered this event.
|
| Constructor and Description |
|---|
CacheEvent(String cacheName,
ClusterNode node,
ClusterNode evtNode,
String msg,
int type,
int part,
boolean near,
Object key,
IgniteUuid xid,
Object lockId,
Object newVal,
boolean hasNewVal,
Object oldVal,
boolean hasOldVal,
UUID subjId,
String cloClsName,
String taskName)
Constructs cache event.
|
TaskEvent(ClusterNode node,
String msg,
int type,
IgniteUuid sesId,
String taskName,
String taskClsName,
boolean internal,
UUID subjId)
Creates task event with given parameters.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridJobExecuteRequest.getClassLoaderId() |
IgniteUuid |
GridJobSessionImpl.getId()
Gets session ID of the task being executed.
|
IgniteUuid |
GridTaskSessionImpl.getId()
Gets session ID of the task being executed.
|
IgniteUuid |
GridJobSessionImpl.getJobId() |
IgniteUuid |
GridJobExecuteResponse.getJobId() |
IgniteUuid |
GridTaskSessionImpl.getJobId() |
IgniteUuid |
GridJobContextImpl.getJobId()
Gets ID of the job this context belongs to.
|
IgniteUuid |
GridJobSiblingImpl.getJobId()
Gets ID of this grid job sibling.
|
IgniteUuid |
GridTaskSessionInternal.getJobId() |
IgniteUuid |
GridJobExecuteRequest.getJobId() |
IgniteUuid |
GridTaskSessionRequest.getJobId() |
IgniteUuid |
GridJobExecuteResponse.getSessionId() |
IgniteUuid |
GridJobExecuteRequest.getSessionId() |
IgniteUuid |
GridTaskSessionRequest.getSessionId() |
IgniteUuid |
GridJobCancelRequest.jobId()
Gets session ID of job to be cancelled.
|
IgniteUuid |
GridJobCancelRequest.sessionId()
Gets execution ID of task to be cancelled.
|
IgniteUuid |
GridJobSiblingsRequest.sessionId() |
IgniteUuid |
GridTaskCancelRequest.sessionId()
Gets execution ID of task to be cancelled.
|
| Modifier and Type | Method and Description |
|---|---|
<R> Map<IgniteUuid,ComputeTaskFuture<R>> |
IgniteComputeImpl.activeTaskFutures()
Gets tasks future for active tasks started on local node.
|
Map<UUID,IgniteUuid> |
GridJobExecuteRequest.getLoaderParticipants() |
| Modifier and Type | Method and Description |
|---|---|
ComputeJobSibling |
GridJobSessionImpl.getJobSibling(IgniteUuid jobId)
Gets job sibling for a given ID.
|
ComputeJobSibling |
GridTaskSessionImpl.getJobSibling(IgniteUuid jobId)
Gets job sibling for a given ID.
|
Object |
GridTopic.topic(IgniteUuid id) |
Object |
GridTopic.topic(IgniteUuid id1,
long id2) |
Object |
GridTopic.topic(IgniteUuid id1,
UUID id2) |
| Constructor and Description |
|---|
GridJobCancelRequest(IgniteUuid sesId) |
GridJobCancelRequest(IgniteUuid sesId,
IgniteUuid jobId) |
GridJobCancelRequest(IgniteUuid sesId,
IgniteUuid jobId,
boolean sys) |
GridJobContextImpl(GridKernalContext ctx,
IgniteUuid jobId) |
GridJobContextImpl(GridKernalContext ctx,
IgniteUuid jobId,
Map<? extends Serializable,? extends Serializable> attrs) |
GridJobExecuteRequest(IgniteUuid sesId,
IgniteUuid jobId,
String taskName,
String userVer,
String taskClsName,
byte[] jobBytes,
ComputeJob job,
long startTaskTime,
long timeout,
Collection<UUID> top,
byte[] siblingsBytes,
Collection<ComputeJobSibling> siblings,
byte[] sesAttrsBytes,
Map<Object,Object> sesAttrs,
byte[] jobAttrsBytes,
Map<? extends Serializable,? extends Serializable> jobAttrs,
String cpSpi,
IgniteUuid clsLdrId,
DeploymentMode depMode,
boolean dynamicSiblings,
Map<UUID,IgniteUuid> ldrParticipants,
boolean forceLocDep,
boolean sesFullSup,
boolean internal,
UUID subjId) |
GridJobExecuteResponse(UUID nodeId,
IgniteUuid sesId,
IgniteUuid jobId,
byte[] gridExBytes,
IgniteException gridEx,
byte[] resBytes,
Object res,
byte[] jobAttrsBytes,
Map<Object,Object> jobAttrs,
boolean isCancelled) |
GridJobResultImpl(ComputeJob job,
IgniteUuid jobId,
ClusterNode node,
GridJobSiblingImpl sib) |
GridJobSessionImpl(GridKernalContext ctx,
GridTaskSessionImpl ses,
IgniteUuid jobId) |
GridJobSiblingImpl(IgniteUuid sesId,
IgniteUuid jobId,
UUID nodeId,
GridKernalContext ctx) |
GridJobSiblingsRequest(IgniteUuid sesId,
Object topic,
byte[] topicBytes) |
GridTaskCancelRequest(IgniteUuid sesId) |
GridTaskSessionImpl(UUID taskNodeId,
String taskName,
GridDeployment dep,
String taskClsName,
IgniteUuid sesId,
Collection<UUID> top,
long startTime,
long endTime,
Collection<ComputeJobSibling> siblings,
Map<Object,Object> attrs,
GridKernalContext ctx,
boolean fullSup,
UUID subjId) |
GridTaskSessionRequest(IgniteUuid sesId,
IgniteUuid jobId,
byte[] attrsBytes,
Map<?,?> attrs) |
| Constructor and Description |
|---|
GridJobExecuteRequest(IgniteUuid sesId,
IgniteUuid jobId,
String taskName,
String userVer,
String taskClsName,
byte[] jobBytes,
ComputeJob job,
long startTaskTime,
long timeout,
Collection<UUID> top,
byte[] siblingsBytes,
Collection<ComputeJobSibling> siblings,
byte[] sesAttrsBytes,
Map<Object,Object> sesAttrs,
byte[] jobAttrsBytes,
Map<? extends Serializable,? extends Serializable> jobAttrs,
String cpSpi,
IgniteUuid clsLdrId,
DeploymentMode depMode,
boolean dynamicSiblings,
Map<UUID,IgniteUuid> ldrParticipants,
boolean forceLocDep,
boolean sesFullSup,
boolean internal,
UUID subjId) |
| Modifier and Type | Method and Description |
|---|---|
static IgniteUuid |
BinaryUtils.readIgniteUuid(BinaryRawReader in)
Read
IgniteUuid instance. |
| Modifier and Type | Method and Description |
|---|---|
static void |
BinaryUtils.writeIgniteUuid(BinaryRawWriter out,
IgniteUuid val)
Write
IgniteUuid instance. |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
DirectMessageReader.readIgniteUuid(String name)
Reads
IgniteUuid. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
DirectMessageWriter.writeIgniteUuid(String name,
IgniteUuid val)
Writes
IgniteUuid. |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
DirectByteBufferStream.readIgniteUuid() |
| Modifier and Type | Method and Description |
|---|---|
void |
DirectByteBufferStream.writeIgniteUuid(IgniteUuid val) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
DirectByteBufferStreamImplV1.readIgniteUuid() |
| Modifier and Type | Method and Description |
|---|---|
void |
DirectByteBufferStreamImplV1.writeIgniteUuid(IgniteUuid val) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
DirectByteBufferStreamImplV2.readIgniteUuid() |
| Modifier and Type | Method and Description |
|---|---|
void |
DirectByteBufferStreamImplV2.writeIgniteUuid(IgniteUuid val) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridCheckpointRequest.getSessionId() |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteUuid> |
GridCheckpointManager.sessionIds() |
| Constructor and Description |
|---|
GridCheckpointRequest(IgniteUuid sesId,
String key,
String cpSpi) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridIoUserMessage.classLoaderId() |
| Modifier and Type | Method and Description |
|---|---|
Map<UUID,IgniteUuid> |
GridIoUserMessage.loaderParticipants() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridDeploymentInfo.classLoaderId() |
IgniteUuid |
GridDeploymentInfoBean.classLoaderId() |
IgniteUuid |
GridDeployment.classLoaderId()
Gets property clsLdrId.
|
IgniteUuid |
GridDeploymentManager.getClassLoaderId(ClassLoader ldr) |
| Modifier and Type | Method and Description |
|---|---|
Map<UUID,IgniteUuid> |
GridDeploymentInfo.participants() |
Map<UUID,IgniteUuid> |
GridDeploymentInfoBean.participants() |
Map<UUID,IgniteUuid> |
GridDeployment.participants() |
| Modifier and Type | Method and Description |
|---|---|
GridDeployment |
GridDeploymentPerLoaderStore.getDeployment(IgniteUuid ldrId)
Gets class loader based on ID.
|
GridDeployment |
GridDeploymentManager.getDeployment(IgniteUuid ldrId)
Gets any deployment by loader ID.
|
GridDeployment |
GridDeploymentStore.getDeployment(IgniteUuid ldrId)
Gets class loader based on ID.
|
GridDeployment |
GridDeploymentPerVersionStore.getDeployment(IgniteUuid ldrId)
Gets class loader based on ID.
|
GridDeployment |
GridDeploymentManager.getGlobalDeployment(DeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
IgniteUuid clsLdrId,
Map<UUID,IgniteUuid> participants,
IgnitePredicate<ClusterNode> nodeFilter) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDeploymentManager.addCacheParticipants(Map<UUID,IgniteUuid> allParticipants,
Map<UUID,IgniteUuid> addedParticipants)
Adds participants to all SHARED deployments.
|
void |
GridDeploymentManager.addCacheParticipants(Map<UUID,IgniteUuid> allParticipants,
Map<UUID,IgniteUuid> addedParticipants)
Adds participants to all SHARED deployments.
|
void |
GridDeploymentPerLoaderStore.addParticipants(Map<UUID,IgniteUuid> allParticipants,
Map<UUID,IgniteUuid> addedParticipants)
Adds participants to all deployments.
|
void |
GridDeploymentPerLoaderStore.addParticipants(Map<UUID,IgniteUuid> allParticipants,
Map<UUID,IgniteUuid> addedParticipants)
Adds participants to all deployments.
|
void |
GridDeploymentStore.addParticipants(Map<UUID,IgniteUuid> allParticipants,
Map<UUID,IgniteUuid> addedParticipants)
Adds participants to all deployments.
|
void |
GridDeploymentStore.addParticipants(Map<UUID,IgniteUuid> allParticipants,
Map<UUID,IgniteUuid> addedParticipants)
Adds participants to all deployments.
|
void |
GridDeploymentPerVersionStore.addParticipants(Map<UUID,IgniteUuid> allParticipants,
Map<UUID,IgniteUuid> addedParticipants)
Adds participants to all deployments.
|
void |
GridDeploymentPerVersionStore.addParticipants(Map<UUID,IgniteUuid> allParticipants,
Map<UUID,IgniteUuid> addedParticipants)
Adds participants to all deployments.
|
GridDeployment |
GridDeploymentManager.getGlobalDeployment(DeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
IgniteUuid clsLdrId,
Map<UUID,IgniteUuid> participants,
IgnitePredicate<ClusterNode> nodeFilter) |
| Constructor and Description |
|---|
GridDeploymentInfoBean(IgniteUuid clsLdrId,
String userVer,
DeploymentMode depMode,
Map<UUID,IgniteUuid> participants,
boolean locDepOwner) |
| Constructor and Description |
|---|
GridDeploymentInfoBean(IgniteUuid clsLdrId,
String userVer,
DeploymentMode depMode,
Map<UUID,IgniteUuid> participants,
boolean locDepOwner) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
DiscoveryCustomMessage.id() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
DynamicCacheChangeRequest.deploymentId() |
IgniteUuid |
DynamicCacheDescriptor.deploymentId() |
IgniteUuid |
GridCacheContext.dynamicDeploymentId() |
IgniteUuid |
GridCacheFuture.futureId() |
IgniteUuid |
GridCacheDeploymentManager.getClassLoaderId(ClassLoader ldr) |
IgniteUuid |
DynamicCacheChangeBatch.id() |
IgniteUuid |
CacheAffinityChangeMessage.id() |
IgniteUuid |
GridCacheSwapEntryImpl.keyClassLoaderId() |
IgniteUuid |
GridCacheSwapEntry.keyClassLoaderId() |
IgniteUuid |
GridCacheOffheapSwapEntry.keyClassLoaderId() |
IgniteUuid |
GridCacheSwapEntryImpl.valueClassLoaderId() |
IgniteUuid |
GridCacheSwapEntry.valueClassLoaderId() |
IgniteUuid |
GridCacheOffheapSwapEntry.valueClassLoaderId() |
| Modifier and Type | Method and Description |
|---|---|
Map<Integer,IgniteUuid> |
CacheAffinityChangeMessage.cacheDeploymentIds() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheEventManager.addEvent(int part,
KeyCacheObject key,
UUID evtNodeId,
IgniteUuid xid,
Object lockId,
int type,
CacheObject newVal,
boolean hasNewVal,
CacheObject oldVal,
boolean hasOldVal,
UUID subjId,
String cloClsName,
String taskName,
boolean keepBinary) |
void |
GridCacheMvccManager.addFuture(GridCacheFuture<?> fut,
IgniteUuid futId) |
void |
DynamicCacheChangeRequest.deploymentId(IgniteUuid deploymentId) |
void |
DynamicCacheDescriptor.deploymentId(IgniteUuid deploymentId) |
GridCacheFuture |
GridCacheMvccManager.future(IgniteUuid futId) |
ClassLoader |
GridCacheDeploymentManager.getClassLoader(IgniteUuid ldrId) |
GridCacheMvccFuture<?> |
GridCacheMvccManager.mvccFuture(GridCacheVersion ver,
IgniteUuid futId)
Gets future for given future ID and lock ID.
|
void |
GridCacheDeploymentManager.p2pContext(UUID sndId,
IgniteUuid ldrId,
String userVer,
DeploymentMode mode,
Map<UUID,IgniteUuid> participants,
boolean locDepOwner) |
void |
GridCacheMvccManager.removeFuture(IgniteUuid futId) |
CacheObject |
GridCacheContext.unswapCacheObject(byte type,
byte[] bytes,
IgniteUuid clsLdrId) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDeploymentManager.p2pContext(UUID sndId,
IgniteUuid ldrId,
String userVer,
DeploymentMode mode,
Map<UUID,IgniteUuid> participants,
boolean locDepOwner) |
| Constructor and Description |
|---|
DynamicCacheDescriptor(GridKernalContext ctx,
CacheConfiguration cacheCfg,
CacheType cacheType,
boolean template,
IgniteUuid deploymentId) |
GridCacheBatchSwapEntry(KeyCacheObject key,
int part,
ByteBuffer valBytes,
byte type,
GridCacheVersion ver,
long ttl,
long expireTime,
IgniteUuid keyClsLdrId,
IgniteUuid valClsLdrId)
Creates batch swap entry.
|
GridCacheSwapEntryImpl(ByteBuffer valBytes,
byte type,
GridCacheVersion ver,
long ttl,
long expireTime,
IgniteUuid keyClsLdrId,
IgniteUuid valClsLdrId) |
| Constructor and Description |
|---|
CacheAffinityChangeMessage(AffinityTopologyVersion topVer,
Map<Integer,Map<Integer,List<UUID>>> assignmentChange,
Map<Integer,IgniteUuid> cacheDeploymentIds)
Constructor used when message is created after cache rebalance finished.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CacheDataStructuresManager.removeSetData(IgniteUuid id) |
GridConcurrentHashSet<SetItemKey> |
CacheDataStructuresManager.setData(IgniteUuid id) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridDistributedLockResponse.futureId() |
IgniteUuid |
GridCacheTxRecoveryResponse.futureId() |
IgniteUuid |
GridDistributedTxFinishRequest.futureId() |
IgniteUuid |
GridCacheTxRecoveryRequest.futureId() |
IgniteUuid |
GridDistributedLockRequest.futureId() |
IgniteUuid |
GridDistributedTxFinishResponse.futureId() |
IgniteUuid |
GridCacheTxRecoveryFuture.futureId() |
IgniteUuid |
GridCacheTxRecoveryResponse.miniId() |
IgniteUuid |
GridCacheTxRecoveryRequest.miniId() |
| Constructor and Description |
|---|
GridCacheTxRecoveryRequest(IgniteInternalTx tx,
int txNum,
boolean nearTxCheck,
IgniteUuid futId,
IgniteUuid miniId,
boolean addDepInfo) |
GridCacheTxRecoveryResponse(GridCacheVersion txId,
IgniteUuid futId,
IgniteUuid miniId,
boolean success,
boolean addDepInfo) |
GridDistributedLockRequest(int cacheId,
UUID nodeId,
GridCacheVersion nearXidVer,
long threadId,
IgniteUuid futId,
GridCacheVersion lockVer,
boolean isInTx,
boolean isRead,
TransactionIsolation isolation,
boolean isInvalidate,
long timeout,
int keyCnt,
int txSize,
boolean skipStore,
boolean keepBinary,
boolean addDepInfo) |
GridDistributedLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
int cnt,
boolean addDepInfo) |
GridDistributedLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
int cnt,
Throwable err,
boolean addDepInfo) |
GridDistributedLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
Throwable err,
boolean addDepInfo) |
GridDistributedTxFinishRequest(GridCacheVersion xidVer,
IgniteUuid futId,
GridCacheVersion commitVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean syncCommit,
boolean syncRollback,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
boolean addDepInfo) |
GridDistributedTxFinishResponse(GridCacheVersion txId,
IgniteUuid futId) |
| Modifier and Type | Field and Description |
|---|---|
protected IgniteUuid |
CacheDistributedGetFutureAdapter.futId
Future ID.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridDhtTxFinishFuture.futureId() |
IgniteUuid |
GridDhtTxPrepareResponse.futureId() |
IgniteUuid |
GridPartitionedGetFuture.futureId() |
IgniteUuid |
GridDhtLockFuture.futureId() |
IgniteUuid |
GridDhtGetSingleFuture.futureId() |
IgniteUuid |
GridDhtTxPrepareFuture.futureId() |
IgniteUuid |
GridDhtTxPrepareRequest.futureId() |
IgniteUuid |
GridDhtGetFuture.futureId() |
IgniteUuid |
GridPartitionedSingleGetFuture.futureId() |
IgniteUuid |
GridDhtLockResponse.miniId() |
IgniteUuid |
GridDhtTxPrepareResponse.miniId() |
IgniteUuid |
GridDhtTxFinishResponse.miniId() |
IgniteUuid |
GridDhtLockRequest.miniId() |
IgniteUuid |
GridDhtTxPrepareRequest.miniId() |
IgniteUuid |
GridDhtTxFinishRequest.miniId() |
IgniteUuid |
GridDhtTxLocal.nearFinishFutureId() |
IgniteUuid |
GridDhtTxLocal.nearFinishMiniId() |
protected abstract IgniteUuid |
GridDhtTxLocalAdapter.nearFutureId() |
protected IgniteUuid |
GridDhtTxLocal.nearFutureId() |
IgniteUuid |
GridDhtTxPrepareFuture.nearMiniId() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtTxLocal.nearFinishFutureId(IgniteUuid nearFinFutId) |
void |
GridDhtTxLocal.nearFinishMiniId(IgniteUuid nearFinMiniId) |
void |
GridDhtTxLocal.nearFutureId(IgniteUuid nearFutId) |
IgniteInternalFuture<GridNearTxPrepareResponse> |
GridDhtTxLocal.prepareAsync(Collection<IgniteTxEntry> reads,
Collection<IgniteTxEntry> writes,
Map<IgniteTxKey,GridCacheVersion> verMap,
long msgId,
IgniteUuid nearMiniId,
Map<UUID,Collection<UUID>> txNodes,
boolean last)
Prepares next batch of entries in dht transaction.
|
| Constructor and Description |
|---|
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) |
GridDhtLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
IgniteUuid miniId,
int cnt,
boolean addDepInfo) |
GridDhtLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
IgniteUuid miniId,
Throwable err,
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) |
GridDhtTxFinishResponse(GridCacheVersion xid,
IgniteUuid futId,
IgniteUuid miniId) |
GridDhtTxLocal(GridCacheSharedContext cctx,
AffinityTopologyVersion topVer,
UUID nearNodeId,
GridCacheVersion nearXidVer,
IgniteUuid nearFutId,
IgniteUuid nearMiniId,
long nearThreadId,
boolean implicit,
boolean implicitSingle,
boolean sys,
boolean explicitLock,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
boolean onePhaseCommit,
int txSize,
Map<UUID,Collection<UUID>> txNodes,
UUID subjId,
int taskNameHash) |
GridDhtTxPrepareFuture(GridCacheSharedContext cctx,
GridDhtTxLocalAdapter tx,
IgniteUuid nearMiniId,
Map<IgniteTxKey,GridCacheVersion> dhtVerMap,
boolean last,
boolean retVal) |
GridDhtTxPrepareRequest(IgniteUuid futId,
IgniteUuid miniId,
AffinityTopologyVersion topVer,
GridDhtTxLocalAdapter tx,
Collection<IgniteTxEntry> dhtWrites,
Collection<IgniteTxEntry> nearWrites,
Map<UUID,Collection<UUID>> txNodes,
GridCacheVersion nearXidVer,
boolean last,
boolean onePhaseCommit,
UUID subjId,
int taskNameHash,
boolean addDepInfo) |
GridDhtTxPrepareResponse(GridCacheVersion xid,
IgniteUuid futId,
IgniteUuid miniId,
boolean addDepInfo) |
GridDhtTxPrepareResponse(GridCacheVersion xid,
IgniteUuid futId,
IgniteUuid miniId,
Throwable err,
boolean addDepInfo) |
GridDhtTxRemote(GridCacheSharedContext ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
GridCacheVersion nearXidVer,
Map<UUID,Collection<UUID>> txNodes,
UUID subjId,
int taskNameHash,
boolean single)
This constructor is meant for optimistic transactions.
|
GridDhtTxRemote(GridCacheSharedContext ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
GridCacheVersion nearXidVer,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
UUID subjId,
int taskNameHash)
This constructor is meant for pessimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridDhtAtomicUpdateFuture.futureId() |
IgniteUuid |
GridNearAtomicAbstractUpdateFuture.futureId() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridDhtColocatedLockFuture.futureId() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridDhtForceKeysFuture.futureId() |
IgniteUuid |
GridDhtForceKeysResponse.futureId() |
IgniteUuid |
GridDhtForceKeysRequest.futureId() |
IgniteUuid |
GridDhtForceKeysResponse.miniId() |
IgniteUuid |
GridDhtForceKeysRequest.miniId() |
| Constructor and Description |
|---|
GridDhtForceKeysResponse(int cacheId,
IgniteUuid futId,
IgniteUuid miniId,
boolean addDepInfo) |
| Modifier and Type | Field and Description |
|---|---|
protected IgniteUuid |
GridNearTxPrepareFutureAdapter.futId
Future ID.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridNearGetResponse.futureId() |
IgniteUuid |
GridNearGetRequest.futureId() |
IgniteUuid |
GridNearTxPrepareRequest.futureId() |
IgniteUuid |
GridNearGetFuture.futureId() |
IgniteUuid |
GridNearTxFinishFuture.futureId() |
IgniteUuid |
GridNearLockFuture.futureId() |
IgniteUuid |
GridNearTxPrepareResponse.futureId() |
IgniteUuid |
GridNearTxPrepareFutureAdapter.futureId() |
IgniteUuid |
GridNearGetResponse.miniId() |
IgniteUuid |
GridNearGetRequest.miniId() |
IgniteUuid |
GridNearTxPrepareRequest.miniId() |
IgniteUuid |
GridNearLockResponse.miniId() |
IgniteUuid |
GridNearTxFinishResponse.miniId() |
IgniteUuid |
GridNearTxFinishRequest.miniId() |
IgniteUuid |
GridNearLockRequest.miniId() |
IgniteUuid |
GridNearTxPrepareResponse.miniId() |
protected IgniteUuid |
GridNearTxLocal.nearFutureId() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearTxPrepareRequest.miniId(IgniteUuid miniId) |
void |
GridNearTxFinishRequest.miniId(IgniteUuid miniId) |
void |
GridNearLockRequest.miniId(IgniteUuid miniId) |
| 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) |
GridNearGetResponse(int cacheId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion ver,
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) |
GridNearLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
IgniteUuid miniId,
boolean filterRes,
int cnt,
Throwable err,
AffinityTopologyVersion clientRemapVer,
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) |
GridNearTxFinishResponse(GridCacheVersion xid,
long nearThreadId,
IgniteUuid futId,
IgniteUuid miniId,
Throwable err) |
GridNearTxPrepareRequest(IgniteUuid futId,
AffinityTopologyVersion topVer,
IgniteInternalTx tx,
Collection<IgniteTxEntry> reads,
Collection<IgniteTxEntry> writes,
boolean near,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
boolean onePhaseCommit,
boolean retVal,
boolean implicitSingle,
boolean explicitLock,
UUID subjId,
int taskNameHash,
boolean firstClientReq,
boolean addDepInfo) |
GridNearTxPrepareResponse(GridCacheVersion xid,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion dhtVer,
GridCacheVersion writeVer,
GridCacheReturn retVal,
Throwable err,
AffinityTopologyVersion clientRemapVer,
boolean addDepInfo) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridLocalLockFuture.futureId() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridCacheQueryFutureAdapter.timeoutId() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
IgniteTxAdapter.timeoutId() |
IgniteUuid |
IgniteInternalTx.xid()
Gets unique identifier for this transaction.
|
IgniteUuid |
IgniteTxAdapter.xid()
Gets unique identifier for this transaction.
|
IgniteUuid |
TransactionProxyImpl.xid()
Gets unique identifier for this transaction.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridCacheVersion.asGridUuid() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridContinuousMessage.futureId() |
IgniteUuid |
AbstractContinuousMessage.id() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
DataStreamerRequest.classLoaderId() |
| Modifier and Type | Method and Description |
|---|---|
Map<UUID,IgniteUuid> |
DataStreamerRequest.participants() |
| 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) |
| 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 | Field and Description |
|---|---|
protected IgniteUuid |
GridCacheQueueAdapter.id
Queue unique ID.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridCacheQueueAdapter.id() |
IgniteUuid |
GridCacheSetImpl.id() |
IgniteUuid |
GridCacheSetHeader.id() |
IgniteUuid |
GridCacheQueueHeader.id() |
IgniteUuid |
GridSetQueryPredicate.setId() |
IgniteUuid |
SetItemKey.setId() |
IgniteUuid |
GridCacheSetItemKey.setId() |
IgniteUuid |
CollocatedSetItemKey.setId() |
| Constructor and Description |
|---|
CollocatedQueueItemKey(IgniteUuid queueId,
String queueName,
long idx) |
CollocatedSetItemKey(String setName,
IgniteUuid setId,
Object item) |
GridCacheQueueAdapter.AddProcessor(IgniteUuid id,
int size) |
GridCacheQueueAdapter.ClearProcessor(IgniteUuid id) |
GridCacheQueueAdapter.PollProcessor(IgniteUuid id) |
GridCacheQueueAdapter.RemoveProcessor(IgniteUuid id,
Long idx) |
GridCacheQueueHeader(IgniteUuid id,
int cap,
boolean collocated,
long head,
long tail,
Set<Long> rmvIdxs) |
GridCacheSetHeader(IgniteUuid id,
boolean collocated) |
GridSetQueryPredicate(IgniteUuid setId,
boolean collocated) |
| Modifier and Type | Field and Description |
|---|---|
static IgniteUuid |
IgfsUtils.DELETE_LOCK_ID
Lock Id used to lock files being deleted from TRASH.
|
protected IgniteUuid |
IgfsEntryInfo.id
ID.
|
static IgniteUuid |
IgfsUtils.ROOT_ID
ID for the root directory.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
IgfsFileAffinityRange.affinityKey() |
IgniteUuid |
IgfsDirectoryInfo.affinityKey() |
abstract IgniteUuid |
IgfsEntryInfo.affinityKey() |
IgniteUuid |
IgfsBlockKey.affinityKey() |
IgniteUuid |
IgfsFileInfo.affinityKey() |
IgniteUuid |
IgfsFileMap.affinityKey(long blockOff,
boolean includeMoved)
Gets affinity key from file map based on block start offset.
|
IgniteUuid |
IgfsListingEntry.fileId() |
IgniteUuid |
IgfsFragmentizerRequest.fileId() |
IgniteUuid |
IgfsAckMessage.fileId() |
IgniteUuid |
IgfsBlocksMessage.fileId() |
IgniteUuid |
IgfsFragmentizerResponse.fileId() |
IgniteUuid |
IgfsFileImpl.fileId() |
IgniteUuid |
IgfsMetaManager.fileId(IgfsPath path)
Gets file ID for specified path.
|
IgniteUuid |
IgfsMetaManager.fileId(IgniteUuid parentId,
String fileName)
Gets file ID by its name from parent directory listing.
|
IgniteUuid |
IgfsBlockKey.getFileId() |
IgniteUuid |
IgfsDeleteMessage.id() |
IgniteUuid |
IgfsEntryInfo.id()
Gets this item ID.
|
IgniteUuid |
IgfsPathIds.lastExistingId()
Get ID of the last existing entry.
|
IgniteUuid |
IgfsPathIds.lastId()
Get last ID.
|
IgniteUuid |
IgfsPathIds.lastParentId()
Get last parent ID.
|
IgniteUuid |
IgfsDirectoryInfo.lockId()
Get lock ID.
|
abstract IgniteUuid |
IgfsEntryInfo.lockId()
Get lock ID.
|
IgniteUuid |
IgfsFileInfo.lockId()
Get lock ID.
|
IgniteUuid |
IgfsAsyncImpl.nextAffinityKey()
Get next affinity key.
|
IgniteUuid |
IgfsEx.nextAffinityKey()
Get next affinity key.
|
IgniteUuid |
IgfsImpl.nextAffinityKey()
Get next affinity key.
|
IgniteUuid |
IgfsDataManager.nextAffinityKey(IgniteUuid prevAffKey)
Generates next affinity key for local node based on current topology.
|
static IgniteUuid |
IgfsUtils.randomTrashId()
Get random trash ID.
|
IgniteUuid |
IgfsPathIds.surrogateId(int idx)
Get surrogate ID at the given index.
|
static IgniteUuid |
IgfsUtils.trashId(int idx)
Get trash ID for the given index.
|
| Modifier and Type | Method and Description |
|---|---|
List<IgniteUuid> |
IgfsMetaManager.fileIds(IgfsPath path)
Gets all file IDs for components of specified path.
|
Map<IgniteUuid,IgfsEntryInfo> |
IgfsMetaManager.infos(Collection<IgniteUuid> fileIds)
Gets files details by their IDs.
|
Collection<IgniteUuid> |
IgfsMetaManager.pendingDeletes()
Check whether there are any pending deletes and return collection of pending delete entry IDs.
|
| Modifier and Type | Method and Description |
|---|---|
IgfsOutputStream |
IgfsAsyncImpl.create(IgfsPath path,
int bufSize,
boolean overwrite,
IgniteUuid affKey,
int replication,
long blockSize,
Map<String,String> props)
Creates a file and opens it for writing.
|
IgfsOutputStream |
IgfsImpl.create(IgfsPath path,
int bufSize,
boolean overwrite,
IgniteUuid affKey,
int replication,
long blockSize,
Map<String,String> props)
Creates a file and opens it for writing.
|
static IgfsDirectoryInfo |
IgfsUtils.createDirectory(IgniteUuid id)
Create empty directory with the given ID.
|
static IgfsDirectoryInfo |
IgfsUtils.createDirectory(IgniteUuid id,
Map<String,IgfsListingEntry> listing,
Map<String,String> props)
Create directory.
|
static IgfsDirectoryInfo |
IgfsUtils.createDirectory(IgniteUuid id,
Map<String,IgfsListingEntry> listing,
Map<String,String> props,
long createTime,
long modificationTime)
Create directory.
|
IgfsSecondaryOutputStreamDescriptor |
IgfsMetaManager.createDual(IgfsSecondaryFileSystem fs,
IgfsPath path,
boolean simpleCreate,
Map<String,String> props,
boolean overwrite,
int bufSize,
short replication,
long blockSize,
IgniteUuid affKey)
Create the file in DUAL mode.
|
static IgfsFileInfo |
IgfsUtils.createFile(IgniteUuid id,
int blockSize,
long len,
IgniteUuid affKey,
IgniteUuid lockId,
boolean evictExclude,
Map<String,String> props,
long accessTime,
long modificationTime)
Create file.
|
Map<String,IgfsListingEntry> |
IgfsMetaManager.directoryListing(IgniteUuid fileId)
List child files for specified file ID.
|
boolean |
IgfsMetaManager.exists(IgniteUuid fileId)
Ensure that entry with the given ID exists in meta cache.
|
IgniteUuid |
IgfsMetaManager.fileId(IgniteUuid parentId,
String fileName)
Gets file ID by its name from parent directory listing.
|
boolean |
IgfsDirectoryInfo.hasChild(String name,
IgniteUuid expId) |
abstract boolean |
IgfsEntryInfo.hasChild(String name,
IgniteUuid expId) |
boolean |
IgfsFileInfo.hasChild(String name,
IgniteUuid expId) |
IgfsEntryInfo |
IgfsMetaManager.info(IgniteUuid fileId)
Gets file info by its ID.
|
static boolean |
IgfsUtils.isRootId(IgniteUuid id)
Check whether provided ID is root ID.
|
static boolean |
IgfsUtils.isRootOrTrashId(IgniteUuid id)
Check whether provided ID is either root ID or trash ID.
|
IgfsEntryInfo |
IgfsDirectoryInfo.lock(IgniteUuid lockId)
Lock file.
|
abstract IgfsEntryInfo |
IgfsEntryInfo.lock(IgniteUuid lockId)
Lock file.
|
IgfsFileInfo |
IgfsFileInfo.lock(IgniteUuid lockId)
Lock file.
|
IgfsEntryInfo |
IgfsMetaManager.lock(IgniteUuid fileId,
boolean del)
Lock the file explicitly outside of transaction.
|
IgniteUuid |
IgfsDataManager.nextAffinityKey(IgniteUuid prevAffKey)
Generates next affinity key for local node based on current topology.
|
IgfsEntryInfo |
IgfsMetaManager.reserveSpace(IgfsPath path,
IgniteUuid fileId,
long space,
IgfsFileAffinityRange affRange)
Reserve space for file.
|
IgfsEntryInfo |
IgfsMetaManager.updateInfo(IgniteUuid fileId,
javax.cache.processor.EntryProcessor<IgniteUuid,IgfsEntryInfo,IgfsEntryInfo> proc)
Update file info in cache.
|
IgfsEntryInfo |
IgfsMetaManager.updateProperties(IgniteUuid fileId,
Map<String,String> props)
Update file info (file properties) in cache.
|
void |
IgfsMetaManager.updateTimes(IgniteUuid parentId,
IgniteUuid fileId,
String fileName,
long accessTime,
long modificationTime)
Updates last access and last modification times.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgfsPathIds.addExistingIds(Collection<IgniteUuid> col,
boolean relaxed)
Add existing IDs to provided collection.
|
void |
IgfsPathIds.addSurrogateIds(Collection<IgniteUuid> col)
Add surrogate IDs to provided collection potentially creating them on demand.
|
IgfsEntryInfo |
IgfsMetaManager.fileForFragmentizer(Collection<IgniteUuid> exclude)
Gets first available file info for fragmentizer.
|
Map<IgniteUuid,IgfsEntryInfo> |
IgfsMetaManager.infos(Collection<IgniteUuid> fileIds)
Gets files details by their IDs.
|
IgfsEntryInfo |
IgfsMetaManager.updateInfo(IgniteUuid fileId,
javax.cache.processor.EntryProcessor<IgniteUuid,IgfsEntryInfo,IgfsEntryInfo> proc)
Update file info in cache.
|
boolean |
IgfsPathIds.verifyIntegrity(Map<IgniteUuid,IgfsEntryInfo> infos,
boolean relaxed)
Verify that observed paths are found in provided infos in the right order.
|
| Constructor and Description |
|---|
IgfsAckMessage(IgniteUuid fileId,
long id,
IgniteCheckedException err) |
IgfsBlockKey(IgniteUuid fileId,
IgniteUuid affKey,
boolean evictExclude,
long blockId)
Constructs file's binary data block key.
|
IgfsBlocksMessage(IgniteUuid fileId,
long id,
Map<IgfsBlockKey,byte[]> blocks)
Constructor.
|
IgfsDeleteMessage(IgniteUuid id)
Constructor.
|
IgfsDeleteMessage(IgniteUuid id,
IgniteCheckedException err)
Constructor.
|
IgfsEntryInfo(IgniteUuid id,
Map<String,String> props,
long accessTime,
long modificationTime)
Constructor.
|
IgfsFragmentizerRequest(IgniteUuid fileId,
Collection<IgfsFileAffinityRange> fragmentRanges) |
IgfsFragmentizerResponse(IgniteUuid fileId) |
IgfsListingEntry(IgniteUuid id,
boolean dir)
Constructor.
|
IgfsPathIds(IgfsPath path,
String[] parts,
IgniteUuid[] ids)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
Void |
IgfsMetaDirectoryListingRemoveProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> e,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileRangeUpdateProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
Void |
IgfsMetaUpdateTimesProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaDirectoryCreateProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
Void |
IgfsMetaDirectoryListingAddProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> e,
Object... args) |
Void |
IgfsMetaFileUnlockProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileRangeDeleteProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileReserveSpaceProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
Void |
IgfsMetaDirectoryListingReplaceProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> e,
Object... args) |
IgfsEntryInfo |
IgfsMetaUpdatePropertiesProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileLockProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
IgfsEntryInfo |
IgfsMetaFileCreateProcessor.process(javax.cache.processor.MutableEntry<IgniteUuid,IgfsEntryInfo> entry,
Object... args) |
| Constructor and Description |
|---|
IgfsMetaDirectoryListingRemoveProcessor(String fileName,
IgniteUuid fileId)
Constructor.
|
IgfsMetaDirectoryListingReplaceProcessor(String name,
IgniteUuid id)
Constructor.
|
IgfsMetaFileCreateProcessor(long createTime,
Map<String,String> props,
int blockSize,
IgniteUuid affKey,
IgniteUuid lockId,
boolean evictExclude)
Constructor.
|
IgfsMetaFileLockProcessor(IgniteUuid lockId)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridJobWorker.getJobId() |
IgniteUuid |
GridJobWorker.timeoutId() |
| Modifier and Type | Method and Description |
|---|---|
GridJobWorker |
GridJobProcessor.activeJob(IgniteUuid jobId)
Gets active job.
|
void |
GridJobProcessor.cancelJob(IgniteUuid sesId,
IgniteUuid jobId,
boolean sys) |
void |
GridJobProcessor.masterLeaveLocal(IgniteUuid sesId)
Notify processor that master leave aware handler must be invoked on all jobs with the given session ID.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
PlatformUtils.writeIgniteUuid(BinaryRawWriterEx writer,
IgniteUuid val)
Writes IgniteUuid to a writer.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridTaskResultRequest.taskId() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridTaskResultRequest.taskId(IgniteUuid taskId) |
| Modifier and Type | Method and Description |
|---|---|
GridTaskSessionImpl |
GridTaskSessionProcessor.createTaskSession(IgniteUuid sesId,
UUID taskNodeId,
String taskName,
GridDeployment dep,
String taskClsName,
Collection<UUID> top,
long startTime,
long endTime,
Collection<ComputeJobSibling> siblings,
Map<Object,Object> attrs,
boolean fullSup,
UUID subjId) |
GridTaskSessionImpl |
GridTaskSessionProcessor.getSession(IgniteUuid sesId) |
boolean |
GridTaskSessionProcessor.removeSession(IgniteUuid sesId)
Removes session for a given session ID.
|
| Modifier and Type | Method and Description |
|---|---|
<R> Map<IgniteUuid,ComputeTaskFuture<R>> |
GridTaskProcessor.taskFutures() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridTaskProcessor.onCancelled(IgniteUuid sesId)
Handles user cancellation.
|
<R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.taskFuture(IgniteUuid sesId) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridTimeoutObject.timeoutId() |
IgniteUuid |
GridTimeoutObjectAdapter.timeoutId() |
IgniteUuid |
GridTimeoutProcessor.CancelableTask.timeoutId() |
IgniteUuid |
GridSpiTimeoutObject.timeoutId() |
| Constructor and Description |
|---|
GridTimeoutObjectAdapter(IgniteUuid id,
long timeout) |
| Modifier and Type | Method and Description |
|---|---|
static IgniteUuid |
IgniteUtils.bytesToIgniteUuid(byte[] in,
int off)
Converts bytes to GridUuid.
|
static IgniteUuid |
IgniteUtils.readGridUuid(byte[] arr,
long off) |
static IgniteUuid |
IgniteUtils.readGridUuid(DataInput in)
Reads
IgniteUuid from input stream. |
static IgniteUuid |
IgniteUtils.readGridUuid(long ptr) |
| Modifier and Type | Method and Description |
|---|---|
static List<IgniteUuid> |
IgniteUtils.readGridUuids(DataInput in)
Reads Grid UUIDs from input stream.
|
| Modifier and Type | Method and Description |
|---|---|
static String |
IgniteUtils.id8(IgniteUuid id)
Gets 8-character substring of
IgniteUuid (for terse logging). |
static byte[] |
IgniteUtils.igniteUuidToBytes(IgniteUuid uuid)
Converts GridUuid to bytes.
|
static void |
IgniteUtils.igniteUuidToBytes(IgniteUuid uuid,
byte[] out,
int off)
Converts GridUuid to bytes.
|
static long |
IgniteUtils.writeGridUuid(byte[] arr,
long off,
IgniteUuid uid) |
static void |
IgniteUtils.writeGridUuid(DataOutput out,
IgniteUuid uid)
Writes
IgniteUuid to output stream. |
| Modifier and Type | Method and Description |
|---|---|
static void |
IgniteUtils.writeGridUuids(DataOutput out,
Collection<IgniteUuid> col)
Writes Grid UUIDs to output stream.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
VisorCache.dynamicDeploymentId() |
| Modifier and Type | Method and Description |
|---|---|
protected Map<IgniteUuid,VisorCacheConfiguration> |
VisorCacheConfigurationCollectorJob.run(Collection<IgniteUuid> arg)
Execution logic of concrete job.
|
| Modifier and Type | Method and Description |
|---|---|
protected VisorCacheConfigurationCollectorJob |
VisorCacheConfigurationCollectorTask.job(Collection<IgniteUuid> arg) |
protected Map<IgniteUuid,VisorCacheConfiguration> |
VisorCacheConfigurationCollectorJob.run(Collection<IgniteUuid> arg)
Execution logic of concrete job.
|
| Constructor and Description |
|---|
VisorCacheConfigurationCollectorJob(Collection<IgniteUuid> arg,
boolean debug)
Create job with given argument.
|
| Modifier and Type | Method and Description |
|---|---|
protected org.apache.ignite.internal.visor.compute.VisorComputeCancelSessionsTask.VisorComputeCancelSessionsJob |
VisorComputeCancelSessionsTask.job(Map<UUID,Set<IgniteUuid>> arg) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
VisorGridEvent.id() |
IgniteUuid |
VisorGridJobEvent.jobId() |
IgniteUuid |
VisorGridJobEvent.taskSessionId() |
IgniteUuid |
VisorGridTaskEvent.taskSessionId() |
| Constructor and Description |
|---|
VisorGridDeploymentEvent(int typeId,
IgniteUuid id,
String name,
UUID nid,
long ts,
String msg,
String shortDisplay,
String alias)
Create event with given parameters.
|
VisorGridDiscoveryEvent(int typeId,
IgniteUuid id,
String name,
UUID nid,
long ts,
String msg,
String shortDisplay,
UUID evtNodeId,
String addr,
boolean isDaemon)
Create event with given parameters.
|
VisorGridEvent(int typeId,
IgniteUuid id,
String name,
UUID nid,
long ts,
String msg,
String shortDisplay)
Create event with given parameters.
|
VisorGridJobEvent(int typeId,
IgniteUuid id,
String name,
UUID nid,
long ts,
String msg,
String shortDisplay,
String taskName,
String taskClsName,
IgniteUuid taskSesId,
IgniteUuid jobId)
Create event with given parameters.
|
VisorGridTaskEvent(int typeId,
IgniteUuid id,
String name,
UUID nid,
long ts,
String msg,
String shortDisplay,
String taskName,
String taskClsName,
IgniteUuid taskSesId,
boolean internal)
Create event with given parameters.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
VisorNodeEventsCollectorTask.VisorNodeEventsCollectorTaskArg.taskSessionId() |
| Modifier and Type | Method and Description |
|---|---|
static VisorNodeEventsCollectorTask.VisorNodeEventsCollectorTaskArg |
VisorNodeEventsCollectorTask.VisorNodeEventsCollectorTaskArg.createTasksArg(Long timeArg,
String taskName,
IgniteUuid taskSesId) |
| Constructor and Description |
|---|
VisorNodeEventsCollectorTask.VisorNodeEventsCollectorTaskArg(String keyOrder,
int[] typeArg,
Long timeArg,
String taskName,
IgniteUuid taskSesId) |
| Modifier and Type | Method and Description |
|---|---|
protected VisorGridEvent |
VisorEventMapper.map(Event evt,
int type,
IgniteUuid id,
String name,
UUID nid,
long ts,
String msg,
String shortDisplay)
Map grid event to Visor data transfer object.
|
| Modifier and Type | Method and Description |
|---|---|
static IgniteUuid |
IgniteUuid.fromString(String s)
Converts string into
GridUuid. |
static IgniteUuid |
IgniteUuid.fromUuid(UUID id)
Constructs new
GridUuid based on global and local ID portions. |
static IgniteUuid |
IgniteUuid.randomUuid()
Creates new pseudo-random ID.
|
| Modifier and Type | Method and Description |
|---|---|
GridIterator<IgniteUuid> |
IgniteUuid.iterator() |
| Modifier and Type | Method and Description |
|---|---|
int |
IgniteUuid.compareTo(IgniteUuid o) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
MessageReader.readIgniteUuid(String name)
Reads
IgniteUuid. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
MessageWriter.writeIgniteUuid(String name,
IgniteUuid val)
Writes
IgniteUuid. |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
IgniteSpiTimeoutObject.id() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
TcpDiscoveryNodeAddedMessage.discardedCustomMessageId()
Gets discarded custom message ID.
|
IgniteUuid |
TcpDiscoveryNodeAddedMessage.discardedMessageId()
Gets discarded message ID.
|
IgniteUuid |
TcpDiscoveryAbstractMessage.id()
Gets message ID.
|
IgniteUuid |
TcpDiscoveryClientReconnectMessage.lastMessageId() |
IgniteUuid |
TcpDiscoveryClientAckResponse.messageId() |
IgniteUuid |
TcpDiscoveryDiscardMessage.msgId()
Gets message ID to discard (this and all preceding).
|
| Modifier and Type | Method and Description |
|---|---|
void |
TcpDiscoveryNodeAddedMessage.messages(Collection<TcpDiscoveryAbstractMessage> msgs,
IgniteUuid discardMsgId,
IgniteUuid discardCustomMsgId)
Sets pending messages to send to new node.
|
| Constructor and Description |
|---|
TcpDiscoveryClientAckResponse(UUID creatorNodeId,
IgniteUuid msgId) |
TcpDiscoveryClientReconnectMessage(UUID creatorNodeId,
UUID routerNodeId,
IgniteUuid lastMsgId) |
TcpDiscoveryDiscardMessage(UUID creatorNodeId,
IgniteUuid msgId,
boolean customMsgDiscard)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
Transaction.xid()
Gets unique identifier for this transaction.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.6.0 Release Date : May 18 2016