| Modifier and Type | Method and Description |
|---|---|
static GridUuid |
GridUuid.fromString(String s)
Converts string into
GridUuid. |
static GridUuid |
GridUuid.fromUuid(UUID id)
Constructs new
GridUuid based on global and local ID portions. |
static GridUuid |
GridUuid.randomUuid()
Creates new pseudo-random ID.
|
| Modifier and Type | Method and Description |
|---|---|
GridIterator<GridUuid> |
GridUuid.iterator() |
| Modifier and Type | Method and Description |
|---|---|
int |
GridUuid.compareTo(GridUuid o) |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridCacheTx.xid()
Gets unique identifier for this transaction.
|
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridComputeTaskSession.getId()
Gets session ID of the task being executed.
|
GridUuid |
GridComputeJobSibling.getJobId()
Gets ID of this grid job sibling.
|
GridUuid |
GridComputeJobContext.getJobId()
Gets ID of the job this context belongs to.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCompute.cancelJob(GridUuid jobId)
Cancels job with the given job ID, if it is currently running inside this projection.
|
void |
GridCompute.cancelTask(GridUuid sesId)
Cancels task with the given execution session ID, if it currently running inside this projection.
|
GridComputeJobSibling |
GridComputeTaskSession.getJobSibling(GridUuid jobId)
Gets job sibling for a given ID.
|
<R> GridComputeTaskFuture<R> |
GridCompute.taskFuture(GridUuid sesId)
Gets task future based on execution session ID.
|
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridDrStateTransferDescriptor.id()
Gets unique state transfer ID.
|
| Constructor and Description |
|---|
GridDrStateTransferDescriptor(GridUuid id,
Collection<Byte> dataCenterIds)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridEventAdapter.id()
Gets globally unique ID of this event.
|
GridUuid |
GridEvent.id()
Gets globally unique ID of this event.
|
GridUuid |
GridJobEvent.jobId()
Gets job ID.
|
GridUuid |
GridJobEvent.taskSessionId()
Gets task session ID of the task that triggered this event.
|
GridUuid |
GridTaskEvent.taskSessionId()
Gets session ID of the task that triggered the event.
|
GridUuid |
GridCacheEvent.xid()
ID of surrounding cache cache transaction or null if there is
no surrounding transaction.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridJobEvent.jobId(GridUuid jobId)
Sets job ID.
|
void |
GridJobEvent.taskSessionId(GridUuid sesId)
Sets task session ID of the task that triggered this event.
|
| Constructor and Description |
|---|
GridCacheEvent(String cacheName,
GridNode node,
GridNode evtNode,
String msg,
int type,
int part,
boolean near,
Object key,
GridUuid xid,
Object lockId,
Object newVal,
boolean hasNewVal,
Object oldVal,
boolean hasOldVal,
UUID subjId)
Constructs cache event.
|
GridTaskEvent(GridNode node,
String msg,
int type,
GridUuid sesId,
String taskName,
String taskClsName,
boolean internal,
UUID subjId)
Creates task event with given parameters.
|
| Modifier and Type | Method and Description |
|---|---|
GridGgfsOutputStream |
GridGgfs.create(GridGgfsPath path,
int bufSize,
boolean overwrite,
GridUuid affKey,
int replication,
long blockSize,
Map<String,String> props)
Creates a file and opens it for writing.
|
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridJobExecuteRequest.getClassLoaderId() |
GridUuid |
GridJobSessionImpl.getId()
Gets session ID of the task being executed.
|
GridUuid |
GridTaskSessionImpl.getId()
Gets session ID of the task being executed.
|
GridUuid |
GridJobSessionImpl.getJobId() |
GridUuid |
GridJobExecuteResponse.getJobId() |
GridUuid |
GridTaskSessionImpl.getJobId() |
GridUuid |
GridJobContextImpl.getJobId()
Gets ID of the job this context belongs to.
|
GridUuid |
GridTaskSessionInternal.getJobId() |
GridUuid |
GridTaskSessionRequest.getJobId() |
GridUuid |
GridJobExecuteRequest.getJobId() |
GridUuid |
GridJobSiblingImpl.getJobId()
Gets ID of this grid job sibling.
|
GridUuid |
GridJobExecuteResponse.getSessionId() |
GridUuid |
GridTaskMessage.getSessionId() |
GridUuid |
GridTaskSessionRequest.getSessionId() |
GridUuid |
GridJobExecuteRequest.getSessionId() |
GridUuid |
GridJobCancelRequest.jobId()
Gets session ID of job to be cancelled.
|
GridUuid |
GridJobCancelRequest.sessionId()
Gets execution ID of task to be cancelled.
|
GridUuid |
GridJobSiblingsRequest.sessionId() |
GridUuid |
GridTaskCancelRequest.sessionId()
Gets execution ID of task to be cancelled.
|
| Modifier and Type | Method and Description |
|---|---|
Map<UUID,GridUuid> |
GridJobExecuteRequest.getLoaderParticipants() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridComputeImpl.cancelJob(GridUuid jobId)
Cancels job with the given job ID, if it is currently running inside this projection.
|
void |
GridComputeImpl.cancelTask(GridUuid sesId)
Cancels task with the given execution session ID, if it currently running inside this projection.
|
GridComputeJobSibling |
GridJobSessionImpl.getJobSibling(GridUuid jobId)
Gets job sibling for a given ID.
|
GridComputeJobSibling |
GridTaskSessionImpl.getJobSibling(GridUuid jobId)
Gets job sibling for a given ID.
|
<R> GridComputeTaskFuture<R> |
GridComputeImpl.taskFuture(GridUuid sesId)
Gets task future based on execution session ID.
|
Object |
GridTopic.topic(GridUuid id) |
Object |
GridTopic.topic(GridUuid id1,
long id2) |
Object |
GridTopic.topic(GridUuid id1,
UUID id2) |
| Constructor and Description |
|---|
GridJobCancelRequest(GridUuid sesId) |
GridJobCancelRequest(GridUuid sesId,
GridUuid jobId) |
GridJobCancelRequest(GridUuid sesId,
GridUuid jobId,
boolean sys) |
GridJobContextImpl(GridKernalContext ctx,
GridUuid jobId) |
GridJobContextImpl(GridKernalContext ctx,
GridUuid jobId,
Map<? extends Serializable,? extends Serializable> attrs) |
GridJobExecuteRequest(GridUuid sesId,
GridUuid jobId,
String taskName,
String userVer,
String taskClsName,
byte[] jobBytes,
GridComputeJob job,
long startTaskTime,
long timeout,
Collection<UUID> top,
byte[] siblingsBytes,
Collection<GridComputeJobSibling> siblings,
byte[] sesAttrsBytes,
Map<Object,Object> sesAttrs,
byte[] jobAttrsBytes,
Map<? extends Serializable,? extends Serializable> jobAttrs,
String cpSpi,
GridUuid clsLdrId,
GridDeploymentMode depMode,
boolean dynamicSiblings,
Map<UUID,GridUuid> ldrParticipants,
boolean forceLocDep,
boolean sesFullSup,
boolean internal) |
GridJobExecuteResponse(UUID nodeId,
GridUuid sesId,
GridUuid jobId,
byte[] gridExBytes,
GridException gridEx,
byte[] resBytes,
Object res,
byte[] jobAttrsBytes,
Map<Object,Object> jobAttrs,
boolean isCancelled) |
GridJobResultImpl(GridComputeJob job,
GridUuid jobId,
GridNode node,
GridJobSiblingImpl sib) |
GridJobSessionImpl(GridKernalContext ctx,
GridTaskSessionImpl ses,
GridUuid jobId) |
GridJobSiblingImpl(GridUuid sesId,
GridUuid jobId,
UUID nodeId,
GridKernalContext ctx) |
GridJobSiblingsRequest(GridUuid sesId,
Object topic,
byte[] topicBytes) |
GridTaskCancelRequest(GridUuid sesId) |
GridTaskSessionImpl(UUID taskNodeId,
String taskName,
GridDeployment dep,
String taskClsName,
GridUuid sesId,
Collection<UUID> top,
long startTime,
long endTime,
Collection<GridComputeJobSibling> siblings,
Map<Object,Object> attrs,
GridKernalContext ctx,
boolean fullSup) |
GridTaskSessionRequest(GridUuid sesId,
GridUuid jobId,
byte[] attrsBytes,
Map<?,?> attrs) |
| Constructor and Description |
|---|
GridJobExecuteRequest(GridUuid sesId,
GridUuid jobId,
String taskName,
String userVer,
String taskClsName,
byte[] jobBytes,
GridComputeJob job,
long startTaskTime,
long timeout,
Collection<UUID> top,
byte[] siblingsBytes,
Collection<GridComputeJobSibling> siblings,
byte[] sesAttrsBytes,
Map<Object,Object> sesAttrs,
byte[] jobAttrsBytes,
Map<? extends Serializable,? extends Serializable> jobAttrs,
String cpSpi,
GridUuid clsLdrId,
GridDeploymentMode depMode,
boolean dynamicSiblings,
Map<UUID,GridUuid> ldrParticipants,
boolean forceLocDep,
boolean sesFullSup,
boolean internal) |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridCheckpointRequest.getSessionId() |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridUuid> |
GridCheckpointManager.sessionIds() |
| Constructor and Description |
|---|
GridCheckpointRequest(GridUuid sesId,
String key,
String cpSpi) |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridIoUserMessage.classLoaderId() |
| Modifier and Type | Method and Description |
|---|---|
Map<UUID,GridUuid> |
GridIoUserMessage.loaderParticipants() |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridDeployment.classLoaderId()
Gets property clsLdrId.
|
GridUuid |
GridDeploymentInfo.classLoaderId() |
GridUuid |
GridDeploymentInfoBean.classLoaderId() |
GridUuid |
GridDeploymentManager.getClassLoaderId(ClassLoader ldr) |
| Modifier and Type | Method and Description |
|---|---|
Map<UUID,GridUuid> |
GridDeployment.participants() |
Map<UUID,GridUuid> |
GridDeploymentInfo.participants() |
Map<UUID,GridUuid> |
GridDeploymentInfoBean.participants() |
| Modifier and Type | Method and Description |
|---|---|
GridDeployment |
GridDeploymentPerVersionStore.getDeployment(GridUuid ldrId)
Gets class loader based on ID.
|
GridDeployment |
GridDeploymentManager.getDeployment(GridUuid ldrId)
Gets any deployment by loader ID.
|
GridDeployment |
GridDeploymentPerLoaderStore.getDeployment(GridUuid ldrId)
Gets class loader based on ID.
|
GridDeployment |
GridDeploymentStore.getDeployment(GridUuid ldrId)
Gets class loader based on ID.
|
GridDeployment |
GridDeploymentManager.getGlobalDeployment(GridDeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
GridUuid clsLdrId,
Map<UUID,GridUuid> participants,
GridPredicate<GridNode> nodeFilter) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDeploymentManager.addCacheParticipants(Map<UUID,GridUuid> allParticipants,
Map<UUID,GridUuid> addedParticipants)
Adds participants to all SHARED deployments.
|
void |
GridDeploymentManager.addCacheParticipants(Map<UUID,GridUuid> allParticipants,
Map<UUID,GridUuid> addedParticipants)
Adds participants to all SHARED deployments.
|
void |
GridDeploymentPerVersionStore.addParticipants(Map<UUID,GridUuid> allParticipants,
Map<UUID,GridUuid> addedParticipants)
Adds participants to all deployments.
|
void |
GridDeploymentPerVersionStore.addParticipants(Map<UUID,GridUuid> allParticipants,
Map<UUID,GridUuid> addedParticipants)
Adds participants to all deployments.
|
void |
GridDeploymentPerLoaderStore.addParticipants(Map<UUID,GridUuid> allParticipants,
Map<UUID,GridUuid> addedParticipants)
Adds participants to all deployments.
|
void |
GridDeploymentPerLoaderStore.addParticipants(Map<UUID,GridUuid> allParticipants,
Map<UUID,GridUuid> addedParticipants)
Adds participants to all deployments.
|
void |
GridDeploymentStore.addParticipants(Map<UUID,GridUuid> allParticipants,
Map<UUID,GridUuid> addedParticipants)
Adds participants to all deployments.
|
void |
GridDeploymentStore.addParticipants(Map<UUID,GridUuid> allParticipants,
Map<UUID,GridUuid> addedParticipants)
Adds participants to all deployments.
|
GridDeployment |
GridDeploymentManager.getGlobalDeployment(GridDeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
GridUuid clsLdrId,
Map<UUID,GridUuid> participants,
GridPredicate<GridNode> nodeFilter) |
| Constructor and Description |
|---|
GridDeploymentInfoBean(GridUuid clsLdrId,
String userVer,
GridDeploymentMode depMode,
Map<UUID,GridUuid> participants,
boolean locDepOwner) |
| Constructor and Description |
|---|
GridDeploymentInfoBean(GridUuid clsLdrId,
String userVer,
GridDeploymentMode depMode,
Map<UUID,GridUuid> participants,
boolean locDepOwner) |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridCacheVersion.asGridUuid() |
GridUuid |
GridCacheFuture.futureId() |
GridUuid |
GridCacheDeploymentManager.getClassLoaderId(ClassLoader ldr) |
GridUuid |
GridCacheSwapEntry.keyClassLoaderId() |
GridUuid |
GridCacheTxAdapter.timeoutId() |
GridUuid |
GridCacheSwapEntry.valueClassLoaderId() |
GridUuid |
GridCacheTxAdapter.xid()
Gets unique identifier for this transaction.
|
GridUuid |
GridCacheTxProxyImpl.xid()
Gets unique identifier for this transaction.
|
| Modifier and Type | Method and Description |
|---|---|
static GridClosure<GridCacheTx,GridUuid> |
GridCacheUtils.tx2xid() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheEventManager.addEvent(int part,
K key,
UUID evtNodeId,
GridUuid xid,
Object lockId,
int type,
V newVal,
boolean hasNewVal,
V oldVal,
boolean hasOldVal,
UUID subjId) |
<T> GridCacheFuture<T> |
GridCacheMvccManager.future(GridCacheVersion ver,
GridUuid futId)
Gets future for given future ID and lock ID.
|
ClassLoader |
GridCacheDeploymentManager.getClassLoader(GridUuid ldrId) |
void |
GridCacheDeploymentManager.p2pContext(UUID sndId,
GridUuid ldrId,
String userVer,
GridDeploymentMode mode,
Map<UUID,GridUuid> participants,
boolean locDepOwner) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDeploymentManager.p2pContext(UUID sndId,
GridUuid ldrId,
String userVer,
GridDeploymentMode mode,
Map<UUID,GridUuid> participants,
boolean locDepOwner) |
| Constructor and Description |
|---|
GridCacheBatchSwapEntry(K key,
byte[] keyBytes,
int keyHash,
int part,
byte[] valBytes,
boolean valIsByteArr,
GridCacheVersion ver,
long ttl,
long expireTime,
GridUuid keyClsLdrId,
GridUuid valClsLdrId)
Creates batch swap entry.
|
GridCacheSwapEntry(int keyHash,
byte[] valBytes,
boolean valIsByteArr,
GridCacheVersion ver,
long ttl,
long expireTime,
GridUuid keyClsLdrId,
GridUuid valClsLdrId) |
| Modifier and Type | Field and Description |
|---|---|
protected GridUuid |
GridCacheQueueAdapter.id
Queue unique ID.
|
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridCacheSetHeader.id() |
GridUuid |
GridCacheQueueHeader.id() |
GridUuid |
GridCacheSetItemKey.setId() |
GridUuid |
GridSetQueryPredicate.setId() |
| Modifier and Type | Method and Description |
|---|---|
GridConcurrentHashSet<GridCacheSetItemKey> |
GridCacheDataStructuresManager.setData(GridUuid id) |
| Constructor and Description |
|---|
GridCacheQueueAdapter.AddClosure(GridUuid id,
int size) |
GridCacheQueueAdapter.ClearClosure(GridUuid id) |
GridCacheQueueAdapter.PollClosure(GridUuid id) |
GridCacheQueueAdapter.RemoveClosure(GridUuid id,
Long idx) |
GridCacheQueueHeader(GridUuid id,
int cap,
boolean collocated,
long head,
long tail,
Set<Long> rmvIdxs) |
GridCacheSetHeader(GridUuid id,
boolean collocated) |
GridSetQueryPredicate(GridUuid setId,
boolean collocated) |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridDistributedTxFinishRequest.futureId() |
GridUuid |
GridDistributedLockRequest.futureId() |
GridUuid |
GridCacheOptimisticCheckPreparedTxResponse.futureId() |
GridUuid |
GridCachePessimisticCheckCommittedTxFuture.futureId() |
GridUuid |
GridDistributedLockResponse.futureId() |
GridUuid |
GridCachePessimisticCheckCommittedTxResponse.futureId() |
GridUuid |
GridCacheOptimisticCheckPreparedTxFuture.futureId() |
GridUuid |
GridDistributedTxFinishResponse.futureId() |
GridUuid |
GridCacheOptimisticCheckPreparedTxRequest.futureId() |
GridUuid |
GridCachePessimisticCheckCommittedTxRequest.futureId() |
GridUuid |
GridCacheOptimisticCheckPreparedTxResponse.miniId() |
GridUuid |
GridCachePessimisticCheckCommittedTxResponse.miniId() |
GridUuid |
GridCacheOptimisticCheckPreparedTxRequest.miniId() |
GridUuid |
GridCachePessimisticCheckCommittedTxRequest.miniId() |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridDhtTxPrepareFuture.futureId() |
GridUuid |
GridDhtTxPrepareResponse.futureId() |
GridUuid |
GridPartitionedGetFuture.futureId() |
GridUuid |
GridDhtLockFuture.futureId() |
GridUuid |
GridDhtGetFuture.futureId() |
GridUuid |
GridDhtTxPrepareRequest.futureId() |
GridUuid |
GridDhtTxFinishFuture.futureId() |
GridUuid |
GridDhtTxPrepareResponse.miniId() |
GridUuid |
GridDhtTxFinishResponse.miniId() |
GridUuid |
GridDhtLockRequest.miniId() |
GridUuid |
GridDhtTxPrepareRequest.miniId() |
GridUuid |
GridDhtTxFinishRequest.miniId() |
GridUuid |
GridDhtLockResponse.miniId() |
GridUuid |
GridDhtTxLocal.nearFinishFutureId() |
GridUuid |
GridDhtTxLocal.nearFinishMiniId() |
protected abstract GridUuid |
GridDhtTxLocalAdapter.nearFutureId() |
protected GridUuid |
GridDhtTxLocal.nearFutureId() |
GridUuid |
GridDhtTxPrepareFuture.nearMiniId() |
protected abstract GridUuid |
GridDhtTxLocalAdapter.nearMiniId() |
protected GridUuid |
GridDhtTxLocal.nearMiniId() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtTxLocal.nearFinishFutureId(GridUuid nearFinFutId) |
void |
GridDhtTxLocal.nearFinishMiniId(GridUuid nearFinMiniId) |
GridFuture<GridCacheTxEx<K,V>> |
GridDhtTxLocal.prepareAsync(Iterable<GridCacheTxEntry<K,V>> reads,
Iterable<GridCacheTxEntry<K,V>> writes,
Map<K,GridCacheVersion> verMap,
long msgId,
GridUuid nearMiniId,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
Collection<UUID> lastBackups)
Prepares next batch of entries in dht transaction.
|
| Constructor and Description |
|---|
GridDhtLockRequest(UUID nodeId,
GridCacheVersion nearXidVer,
long threadId,
GridUuid futId,
GridUuid miniId,
GridCacheVersion lockVer,
long topVer,
boolean isInTx,
boolean isRead,
GridCacheTxIsolation isolation,
boolean isInvalidate,
long timeout,
int dhtCnt,
int nearCnt,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
GridDhtLockResponse(GridCacheVersion lockVer,
GridUuid futId,
GridUuid miniId,
int cnt) |
GridDhtLockResponse(GridCacheVersion lockVer,
GridUuid futId,
GridUuid miniId,
Throwable err) |
GridDhtTxFinishRequest(UUID nearNodeId,
GridUuid futId,
GridUuid miniId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
GridCacheTxIsolation isolation,
boolean commit,
boolean invalidate,
boolean sysInvalidate,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
Collection<GridCacheTxEntry<K,V>> writes,
Collection<GridCacheTxEntry<K,V>> nearWrites,
Collection<GridCacheTxEntry<K,V>> recoverWrites,
boolean reply,
boolean onePhaseCommit,
Object grpLockKey,
UUID subjId) |
GridDhtTxFinishResponse(GridCacheVersion xid,
GridUuid futId,
GridUuid miniId) |
GridDhtTxPrepareFuture(GridCacheContext<K,V> cctx,
GridDhtTxLocalAdapter<K,V> tx,
GridUuid nearMiniId,
Map<K,GridCacheVersion> dhtVerMap,
boolean last,
Collection<UUID> lastBackups) |
GridDhtTxPrepareRequest(GridUuid futId,
GridUuid miniId,
long topVer,
GridDhtTxLocalAdapter<K,V> tx,
Collection<GridCacheTxEntry<K,V>> dhtWrites,
Collection<GridCacheTxEntry<K,V>> nearWrites,
Object grpLockKey,
boolean partLock,
Map<UUID,Collection<UUID>> txNodes,
GridCacheVersion nearXidVer,
boolean last,
UUID subjId) |
GridDhtTxPrepareResponse(GridCacheVersion xid,
GridUuid futId,
GridUuid miniId) |
GridDhtTxPrepareResponse(GridCacheVersion xid,
GridUuid futId,
GridUuid miniId,
Throwable err) |
GridDhtTxRemote(UUID nearNodeId,
GridUuid rmtFutId,
UUID nodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
UUID subjId)
This constructor is meant for pessimistic transactions.
|
GridDhtTxRemote(UUID nearNodeId,
GridUuid rmtFutId,
UUID nodeId,
long rmtThreadId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
GridCacheVersion nearXidVer,
Map<UUID,Collection<UUID>> txNodes,
UUID subjId)
This constructor is meant for optimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridNearAtomicUpdateFuture.futureId() |
GridUuid |
GridDhtAtomicUpdateFuture.futureId() |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridDhtColocatedTxPrepareFuture.futureId() |
GridUuid |
GridDhtColocatedTxFinishFuture.futureId() |
GridUuid |
GridDhtColocatedLockFuture.futureId() |
protected GridUuid |
GridDhtColocatedTxLocal.nearFutureId() |
protected GridUuid |
GridDhtColocatedTxLocal.nearMiniId() |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridDhtForceKeysResponse.futureId() |
GridUuid |
GridDhtForceKeysFuture.futureId() |
GridUuid |
GridDhtForceKeysRequest.futureId() |
GridUuid |
GridDhtForceKeysResponse.miniId() |
GridUuid |
GridDhtForceKeysRequest.miniId() |
| Constructor and Description |
|---|
GridDhtForceKeysResponse(GridUuid futId,
GridUuid miniId) |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridNearTxFinishFuture.futureId() |
GridUuid |
GridNearLockFuture.futureId() |
GridUuid |
GridNearTxPrepareFuture.futureId() |
GridUuid |
GridNearTxPrepareRequest.futureId() |
GridUuid |
GridNearGetResponse.futureId() |
GridUuid |
GridNearTxPrepareResponse.futureId() |
GridUuid |
GridNearGetRequest.futureId() |
GridUuid |
GridNearGetFuture.futureId() |
GridUuid |
GridNearTxPrepareRequest.miniId() |
GridUuid |
GridNearGetResponse.miniId() |
GridUuid |
GridNearTxPrepareResponse.miniId() |
GridUuid |
GridNearLockResponse.miniId() |
GridUuid |
GridNearGetRequest.miniId() |
GridUuid |
GridNearTxFinishRequest.miniId() |
GridUuid |
GridNearTxFinishResponse.miniId() |
GridUuid |
GridNearLockRequest.miniId() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearTxPrepareRequest.miniId(GridUuid miniId) |
void |
GridNearTxFinishRequest.miniId(GridUuid miniId) |
void |
GridNearLockRequest.miniId(GridUuid miniId) |
| Constructor and Description |
|---|
GridNearGetRequest(GridUuid futId,
GridUuid miniId,
GridCacheVersion ver,
LinkedHashMap<K,Boolean> keys,
boolean reload,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId) |
GridNearGetResponse(GridUuid futId,
GridUuid miniId,
GridCacheVersion ver) |
GridNearLockRequest(long topVer,
UUID nodeId,
long threadId,
GridUuid futId,
GridCacheVersion lockVer,
boolean isInTx,
boolean implicitTx,
boolean implicitSingleTx,
boolean isRead,
GridCacheTxIsolation isolation,
boolean isInvalidate,
long timeout,
boolean syncCommit,
boolean syncRollback,
int keyCnt,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
GridNearLockResponse(GridCacheVersion lockVer,
GridUuid futId,
GridUuid miniId,
boolean filterRes,
int cnt,
Throwable err) |
GridNearTxFinishRequest(GridUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean explicitLock,
long topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
Collection<GridCacheTxEntry<K,V>> writeEntries,
Collection<GridCacheTxEntry<K,V>> recoverEntries,
boolean reply,
UUID subjId) |
GridNearTxFinishResponse(GridCacheVersion xid,
long nearThreadId,
GridUuid futId,
GridUuid miniId,
Throwable err) |
GridNearTxPrepareRequest(GridUuid futId,
long topVer,
GridCacheTxEx<K,V> tx,
Collection<GridCacheTxEntry<K,V>> reads,
Collection<GridCacheTxEntry<K,V>> writes,
Object grpLockKey,
boolean partLock,
boolean syncCommit,
boolean syncRollback,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
Collection<UUID> lastBackups,
UUID subjId) |
GridNearTxPrepareResponse(GridCacheVersion xid,
GridUuid futId,
GridUuid miniId,
GridCacheVersion dhtVer,
Collection<Integer> invalidParts,
Throwable err) |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridLocalLockFuture.futureId() |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridCacheQueryFutureAdapter.timeoutId() |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridDataLoadRequest.classLoaderId() |
| Modifier and Type | Method and Description |
|---|---|
Map<UUID,GridUuid> |
GridDataLoadRequest.participants() |
| Constructor and Description |
|---|
GridDataLoadRequest(long reqId,
byte[] resTopicBytes,
String cacheName,
byte[] updaterBytes,
byte[] colBytes,
boolean ignoreDepOwnership,
GridDeploymentMode depMode,
String sampleClsName,
String userVer,
Map<UUID,GridUuid> ldrParticipants,
GridUuid clsLdrId,
boolean forceLocDep) |
| Constructor and Description |
|---|
GridDataLoadRequest(long reqId,
byte[] resTopicBytes,
String cacheName,
byte[] updaterBytes,
byte[] colBytes,
boolean ignoreDepOwnership,
GridDeploymentMode depMode,
String sampleClsName,
String userVer,
Map<UUID,GridUuid> ldrParticipants,
GridUuid clsLdrId,
boolean forceLocDep) |
| Modifier and Type | Method and Description |
|---|---|
static GridTuple4<GridUuid,String,Integer,Integer> |
GridDrUtils.batchRequestHeader(byte[] data)
Get batch request header.
|
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridDrExternalBatchRequest.requestId() |
GridUuid |
GridDrExternalBatchResponse.requestId() |
| Constructor and Description |
|---|
GridDrExternalBatchRequest(GridUuid reqId,
String cacheName,
byte dataCenterId,
int entryCnt,
byte[] dataBytes) |
GridDrExternalBatchResponse(GridUuid reqId,
String errMsg) |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridJobWorker.getJobId() |
GridUuid |
GridJobWorker.timeoutId() |
| Modifier and Type | Method and Description |
|---|---|
GridJobWorker |
GridJobProcessor.activeJob(GridUuid jobId)
Gets active job.
|
void |
GridJobProcessor.cancelJob(GridUuid sesId,
GridUuid jobId,
boolean sys) |
void |
GridJobProcessor.masterLeaveLocal(GridUuid 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 |
|---|---|
GridUuid |
GridTaskResultRequest.taskId() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridTaskResultRequest.taskId(GridUuid taskId) |
| Modifier and Type | Method and Description |
|---|---|
GridTaskSessionImpl |
GridTaskSessionProcessor.createTaskSession(GridUuid sesId,
UUID taskNodeId,
String taskName,
GridDeployment dep,
String taskClsName,
Collection<UUID> top,
long startTime,
long endTime,
Collection<GridComputeJobSibling> siblings,
Map<Object,Object> attrs,
boolean fullSup) |
GridTaskSessionImpl |
GridTaskSessionProcessor.getSession(GridUuid sesId) |
boolean |
GridTaskSessionProcessor.removeSession(GridUuid sesId)
Removes session for a given session ID.
|
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridStreamerCancelRequest.cancelledFutureId() |
GridUuid |
GridStreamerExecutionRequest.classLoaderId() |
GridUuid |
GridStreamerExecutionBatch.executionId() |
GridUuid |
GridStreamerResponse.futureId() |
GridUuid |
GridStreamerExecutionBatch.futureId() |
GridUuid |
GridStreamerStageExecutionFuture.id() |
GridUuid |
GridStreamerStageExecutionFuture.parentFutureId()
If not root future, will return parent future ID.
|
| Modifier and Type | Method and Description |
|---|---|
Map<UUID,GridUuid> |
GridStreamerExecutionRequest.loaderParticipants() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridStreamerImpl.cancelled(GridUuid futId)
Checks if cancel request was received for this future ID.
|
| Constructor and Description |
|---|
GridStreamerCancelRequest(GridUuid cancelledFutId) |
GridStreamerExecutionBatch(GridUuid execId,
long execStartTs,
GridUuid futId,
Collection<UUID> execNodeIds,
String stageName,
Collection<Object> evts)
Execution batch.
|
GridStreamerExecutionRequest(boolean forceLocDep,
byte[] batchBytes,
GridDeploymentMode depMode,
String sampleClsName,
String userVer,
Map<UUID,GridUuid> ldrParticipants,
GridUuid clsLdrId) |
GridStreamerResponse(GridUuid futId,
byte[] errBytes) |
GridStreamerStageExecutionFuture(GridStreamerEx streamer,
GridUuid execId,
int failoverAttemptCnt,
long execStartTs,
GridUuid parentFutId,
Collection<UUID> prevExecNodes,
String stageName,
Collection<?> evts) |
| Constructor and Description |
|---|
GridStreamerExecutionRequest(boolean forceLocDep,
byte[] batchBytes,
GridDeploymentMode depMode,
String sampleClsName,
String userVer,
Map<UUID,GridUuid> ldrParticipants,
GridUuid clsLdrId) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridTaskProcessor.onCancelled(GridUuid sesId)
Handles user cancellation.
|
<R> GridComputeTaskFuture<R> |
GridTaskProcessor.taskFuture(GridUuid sesId) |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridTimeoutObject.timeoutId() |
GridUuid |
GridTimeoutObjectAdapter.timeoutId() |
| Constructor and Description |
|---|
GridTimeoutObjectAdapter(GridUuid id,
long timeout) |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
VisorGridEvent.id() |
GridUuid |
VisorGridJobEvent.jobId() |
GridUuid |
VisorGridJobEvent.taskSessionId() |
GridUuid |
VisorGridTaskEvent.taskSessionId() |
| Constructor and Description |
|---|
VisorGridDeploymentEvent(int typeId,
GridUuid id,
String name,
UUID nid,
long timestamp,
String message,
String shortDisplay,
String alias)
Create event with given parameters.
|
VisorGridEvent(int typeId,
GridUuid id,
String name,
UUID nid,
long timestamp,
String message,
String shortDisplay)
Create event with given parameters.
|
VisorGridJobEvent(int typeId,
GridUuid id,
String name,
UUID nid,
long timestamp,
String message,
String shortDisplay,
String taskName,
String taskClassName,
GridUuid taskSessionId,
GridUuid jobId)
Create event with given parameters.
|
VisorGridLicenseEvent(int typeId,
GridUuid id,
String name,
UUID nid,
long timestamp,
String message,
String shortDisplay,
UUID licenseId)
Create event with given parameters.
|
VisorGridTaskEvent(int typeId,
GridUuid id,
String name,
UUID nid,
long timestamp,
String message,
String shortDisplay,
String taskName,
String taskClassName,
GridUuid taskSessionId,
boolean internal)
Create event with given parameters.
|
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
VisorEventsCollectTask.VisorEventsCollectArgs.taskSessionId() |
| Modifier and Type | Method and Description |
|---|---|
static VisorEventsCollectTask.VisorEventsCollectArgs |
VisorEventsCollectTask.VisorEventsCollectArgs.createTasksArg(Long timeArg,
String taskName,
GridUuid taskSessionId) |
| Constructor and Description |
|---|
VisorEventsCollectTask.VisorEventsCollectArgs(String keyOrder,
int[] typeArg,
Long timeArg,
String taskName,
GridUuid taskSessionId) |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridTcpDiscoveryAbstractMessage.id()
Gets message ID.
|
GridUuid |
GridTcpDiscoveryDiscardMessage.msgId()
Gets message ID to discard (this and all preceding).
|
| Constructor and Description |
|---|
GridTcpDiscoveryDiscardMessage(UUID creatorNodeId,
GridUuid msgId)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
static GridUuid |
GridUtils.bytesToGridUuid(byte[] in,
int off)
Converts bytes to GridUuid.
|
static GridUuid |
GridUtils.readGridUuid(DataInput in)
Reads
GridUuid from input stream. |
| Modifier and Type | Method and Description |
|---|---|
static List<GridUuid> |
GridUtils.readGridUuids(DataInput in)
Reads Grid UUIDs from input stream.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
GridUtils.gridUuidToBytes(GridUuid uuid,
byte[] out,
int off)
Converts GridUuid to bytes.
|
static String |
GridUtils.id8(GridUuid id)
Gets 8-character substring of
GridUuid (for terse logging). |
static void |
GridUtils.writeGridUuid(DataOutput out,
GridUuid uid)
Writes
GridUuid to output stream. |
| Modifier and Type | Method and Description |
|---|---|
static void |
GridUtils.writeGridUuids(DataOutput out,
Collection<GridUuid> col)
Writes Grid UUIDs to output stream.
|
| Modifier and Type | Field and Description |
|---|---|
static GridUuid |
GridTcpCommunicationMessageAdapter.GRID_UUID_NOT_READ |
| Modifier and Type | Method and Description |
|---|---|
GridUuid |
GridTcpCommunicationMessageState.getGridUuid() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridTcpCommunicationMessageState.putGridUuid(GridUuid uuid) |
| Modifier and Type | Method and Description |
|---|---|
static GridPredicate<GridEvent> |
GridFunc.eventId(GridUuid... ids)
Gets event predicate that returns
true only if event id is one of the given. |
Copyright © 2014. All rights reserved.