| 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 |
|---|---|
IgniteUuid |
ComputeTaskSession.getId()
Gets session ID of the task being executed.
|
IgniteUuid |
ComputeJobContext.getJobId()
Gets ID of the job this context belongs to.
|
IgniteUuid |
ComputeJobSibling.getJobId()
Gets ID of this grid job sibling.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable ComputeJobSibling |
ComputeTaskSession.getJobSibling(IgniteUuid jobId)
Gets job sibling for a given ID.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
Event.id()
Gets globally unique ID of this event.
|
IgniteUuid |
EventAdapter.id()
Gets globally unique ID of this event.
|
IgniteUuid |
JobEvent.jobId()
Gets job ID.
|
IgniteUuid |
JobEvent.taskSessionId()
Gets task session ID of the task that triggered this event.
|
IgniteUuid |
TaskEvent.taskSessionId()
Gets session ID of the task that triggered the event.
|
IgniteUuid |
CacheEvent.xid()
ID of surrounding 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,
@Nullable ClusterNode evtNode,
String msg,
int type,
int part,
boolean near,
Object key,
IgniteUuid xid,
String txLbl,
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,
@Nullable 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 |
GridTaskSessionRequest.getJobId() |
@Nullable IgniteUuid |
GridTaskSessionImpl.getJobId() |
IgniteUuid |
GridJobExecuteResponse.getJobId() |
@Nullable IgniteUuid |
GridTaskSessionInternal.getJobId() |
IgniteUuid |
GridJobExecuteRequest.getJobId() |
IgniteUuid |
GridJobContextImpl.getJobId()
Gets ID of the job this context belongs to.
|
IgniteUuid |
GridJobSiblingImpl.getJobId()
Gets ID of this grid job sibling.
|
IgniteUuid |
GridTaskSessionRequest.getSessionId() |
IgniteUuid |
GridJobExecuteResponse.getSessionId() |
IgniteUuid |
GridJobExecuteRequest.getSessionId() |
@Nullable IgniteUuid |
GridJobCancelRequest.jobId()
Gets session ID of job to be cancelled.
|
IgniteUuid |
GridTaskCancelRequest.sessionId()
Gets execution ID of task to be cancelled.
|
IgniteUuid |
GridJobSiblingsRequest.sessionId() |
@Nullable IgniteUuid |
GridJobCancelRequest.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 |
|---|---|
void |
ComputeMXBeanImpl.cancel(IgniteUuid sesId)
Kills compute task by the session idenitifier.
|
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(@Nullable IgniteUuid sesId,
@Nullable IgniteUuid jobId) |
GridJobCancelRequest(@Nullable IgniteUuid sesId,
@Nullable IgniteUuid jobId) |
GridJobCancelRequest(@Nullable IgniteUuid sesId,
@Nullable IgniteUuid jobId,
boolean sys) |
GridJobCancelRequest(@Nullable IgniteUuid sesId,
@Nullable IgniteUuid jobId,
boolean sys) |
GridJobContextImpl(@Nullable 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,
@Nullable Collection<UUID> top,
@Nullable IgnitePredicate<ClusterNode> topPred,
byte[] topPredBytes,
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,
@Nullable int[] cacheIds,
int part,
@Nullable AffinityTopologyVersion topVer,
@Nullable String execName) |
GridJobExecuteResponse(UUID nodeId,
IgniteUuid sesId,
IgniteUuid jobId,
byte[] gridExBytes,
IgniteException gridEx,
byte[] resBytes,
Object res,
byte[] jobAttrsBytes,
Map<Object,Object> jobAttrs,
boolean isCancelled,
AffinityTopologyVersion retry) |
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,
@Nullable GridDeployment dep,
String taskClsName,
IgniteUuid sesId,
@Nullable Collection<UUID> top,
@Nullable IgnitePredicate<ClusterNode> topPred,
long startTime,
long endTime,
Collection<ComputeJobSibling> siblings,
@Nullable Map<Object,Object> attrs,
GridKernalContext ctx,
boolean fullSup,
boolean internal,
UUID subjId,
@Nullable String execName) |
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,
@Nullable Collection<UUID> top,
@Nullable IgnitePredicate<ClusterNode> topPred,
byte[] topPredBytes,
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,
@Nullable int[] cacheIds,
int part,
@Nullable AffinityTopologyVersion topVer,
@Nullable String execName) |
| Modifier and Type | Method and Description |
|---|---|
static @Nullable IgniteUuid |
BinaryUtils.readIgniteUuid(BinaryRawReader in)
Read
IgniteUuid instance. |
| Modifier and Type | Method and Description |
|---|---|
static void |
BinaryUtils.writeIgniteUuid(BinaryRawWriter out,
@Nullable 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 |
|---|---|
@Nullable IgniteUuid |
GridIoUserMessage.classLoaderId() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridDeploymentInfo.classLoaderId() |
IgniteUuid |
GridDeployment.classLoaderId()
Gets property clsLdrId.
|
IgniteUuid |
GridDeploymentInfoBean.classLoaderId() |
@Nullable IgniteUuid |
GridDeploymentManager.getClassLoaderId(ClassLoader ldr) |
| Modifier and Type | Method and Description |
|---|---|
Map<UUID,IgniteUuid> |
GridDeploymentInfo.participants() |
Map<UUID,IgniteUuid> |
GridDeploymentMetadata.participants() |
Map<UUID,IgniteUuid> |
GridDeploymentInfoBean.participants() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDeploymentMetadata.classLoaderId(IgniteUuid clsLdrId)
Sets property clsLdrId.
|
@Nullable GridDeployment |
GridDeploymentStore.getDeployment(IgniteUuid ldrId)
Gets class loader based on ID.
|
@Nullable GridDeployment |
GridDeploymentManager.getDeployment(IgniteUuid ldrId)
Gets any deployment by loader ID.
|
GridDeployment |
GridDeploymentPerVersionStore.getDeployment(IgniteUuid ldrId)
Gets class loader based on ID.
|
GridDeployment |
GridDeploymentPerLoaderStore.getDeployment(IgniteUuid ldrId)
Gets class loader based on ID.
|
@Nullable GridDeployment |
GridDeploymentManager.getGlobalDeployment(DeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
IgniteUuid clsLdrId,
Map<UUID,IgniteUuid> participants,
@Nullable 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 |
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.
|
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.
|
@Nullable GridDeployment |
GridDeploymentManager.getGlobalDeployment(DeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
IgniteUuid clsLdrId,
Map<UUID,IgniteUuid> participants,
@Nullable IgnitePredicate<ClusterNode> nodeFilter) |
void |
GridDeploymentMetadata.participants(Map<UUID,IgniteUuid> participants) |
| Constructor and Description |
|---|
GridDeploymentInfoBean(IgniteUuid clsLdrId,
String userVer,
DeploymentMode depMode,
Map<UUID,IgniteUuid> participants) |
| Constructor and Description |
|---|
GridDeploymentInfoBean(IgniteUuid clsLdrId,
String userVer,
DeploymentMode depMode,
Map<UUID,IgniteUuid> participants) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
DiscoveryCustomMessage.id() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GenerateEncryptionKeyRequest.id() |
IgniteUuid |
GenerateEncryptionKeyResponse.requestId() |
| Constructor and Description |
|---|
GenerateEncryptionKeyResponse(IgniteUuid id,
Collection<byte[]> encKeys,
byte[] masterKeyDigest) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
UserAuthenticateResponseMessage.id() |
IgniteUuid |
UserManagementOperation.id() |
IgniteUuid |
UserProposedMessage.id() |
IgniteUuid |
UserAcceptedMessage.id() |
IgniteUuid |
UserAuthenticateRequestMessage.id() |
IgniteUuid |
UserManagementOperationFinishedMessage.operationId() |
| Constructor and Description |
|---|
UserAuthenticateResponseMessage(IgniteUuid id,
String errMsg) |
UserManagementOperationFinishedMessage(IgniteUuid opId,
String errorMsg) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
CacheJoinNodeDiscoveryData.cacheDeploymentId() |
IgniteUuid |
CacheGroupDescriptor.deploymentId() |
IgniteUuid |
DynamicCacheDescriptor.deploymentId() |
IgniteUuid |
CacheData.deploymentId() |
IgniteUuid |
DynamicCacheChangeRequest.deploymentId() |
IgniteUuid |
CacheGroupData.deploymentId() |
IgniteUuid |
GridCacheContext.dynamicDeploymentId() |
IgniteUuid |
GridCacheContextInfo.dynamicDeploymentId() |
IgniteUuid |
GridCacheFuture.futureId() |
@Nullable IgniteUuid |
GridCacheDeploymentManager.getClassLoaderId(@Nullable ClassLoader ldr) |
IgniteUuid |
WalStateAbstractMessage.groupDeploymentId() |
IgniteUuid |
CacheStatisticsClearMessage.id() |
IgniteUuid |
WalStateAbstractMessage.id() |
IgniteUuid |
DynamicCacheChangeFailureMessage.id() |
IgniteUuid |
DynamicCacheChangeBatch.id() |
IgniteUuid |
TxTimeoutOnPartitionMapExchangeChangeMessage.id() |
IgniteUuid |
CacheAffinityChangeMessage.id() |
IgniteUuid |
StateChangeRequest.id() |
IgniteUuid |
ClientCacheChangeDummyDiscoveryMessage.id() |
IgniteUuid |
ClientCacheChangeDiscoveryMessage.id() |
IgniteUuid |
CacheStatisticsModeChangeMessage.id() |
IgniteUuid |
GridCacheDeploymentManager.locLoaderId()
Gets a local class loader id.
|
IgniteUuid |
DynamicCacheChangeRequest.restartId() |
| Modifier and Type | Method and Description |
|---|---|
Map<Integer,IgniteUuid> |
CacheAffinityChangeMessage.cacheDeploymentIds() |
Map<String,IgniteUuid> |
WalStateProposeMessage.caches() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridCacheMvccManager.addFuture(GridCacheFuture<?> fut,
IgniteUuid futId) |
@NotNull DynamicCacheChangeRequest |
GridCacheProcessor.createStopRequest(String cacheName,
boolean restart,
IgniteUuid restartId,
boolean destroy)
Prepares cache stop request.
|
void |
DynamicCacheChangeRequest.deploymentId(IgniteUuid deploymentId) |
IgniteInternalFuture<Boolean> |
GridCacheProcessor.dynamicDestroyCache(String cacheName,
boolean sql,
boolean checkThreadTx,
boolean restart,
IgniteUuid restartId) |
IgniteInternalFuture<Boolean> |
GridCacheProcessor.dynamicStartCachesByStoredConf(Collection<StoredCacheData> storedCacheDataList,
boolean failIfExists,
boolean checkThreadTx,
boolean disabledAfterStart,
IgniteUuid restartId)
Dynamically starts multiple caches.
|
@Nullable GridCacheFuture |
GridCacheMvccManager.future(IgniteUuid futId) |
@Nullable ClassLoader |
GridCacheDeploymentManager.getClassLoader(IgniteUuid ldrId) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccUpdateRowsWithPreloadInfo(IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
List<GridCacheEntryInfo> entries,
GridCacheOperation op,
MvccSnapshot mvccVer,
IgniteUuid futId,
int batchNum) |
GridCacheUpdateTxResult |
GridCacheMapEntry.mvccUpdateRowsWithPreloadInfo(IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
List<GridCacheEntryInfo> entries,
GridCacheOperation op,
MvccSnapshot mvccVer,
IgniteUuid futId,
int batchNum) |
void |
GridCacheDeploymentManager.p2pContext(UUID sndId,
IgniteUuid ldrId,
String userVer,
DeploymentMode mode,
Map<UUID,IgniteUuid> participants) |
void |
GridCacheMvccManager.removeFuture(IgniteUuid futId) |
void |
DynamicCacheChangeRequest.restartId(IgniteUuid restartId) |
@Nullable GridCacheVersionedFuture<?> |
GridCacheMvccManager.versionedFuture(GridCacheVersion ver,
IgniteUuid futId)
Gets future for given future ID and lock ID.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDeploymentManager.p2pContext(UUID sndId,
IgniteUuid ldrId,
String userVer,
DeploymentMode mode,
Map<UUID,IgniteUuid> participants) |
| Constructor and Description |
|---|
CacheAffinityChangeMessage(AffinityTopologyVersion topVer,
Map<Integer,IgniteUuid> cacheDeploymentIds)
Constructor used when message is created after cache rebalance finished.
|
WalStateProposeMessage(UUID opId,
int grpId,
IgniteUuid grpDepId,
UUID nodeId,
Map<String,IgniteUuid> caches,
boolean enable)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
MetadataUpdateAcceptedMessage.id() |
IgniteUuid |
MetadataUpdateProposedMessage.id() |
IgniteUuid |
MetadataRemoveAcceptedMessage.id() |
IgniteUuid |
MetadataRemoveProposedMessage.id() |
| Modifier and Type | Method and Description |
|---|---|
ConcurrentMap<IgniteUuid,GridCacheQueueProxy> |
CacheDataStructuresManager.queues() |
ConcurrentMap<IgniteUuid,GridCacheSetProxy> |
CacheDataStructuresManager.sets() |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheDataStructuresManager.removeSetData(IgniteUuid id,
boolean separated) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridDistributedTxFinishRequest.futureId() |
IgniteUuid |
GridCacheTxRecoveryRequest.futureId() |
IgniteUuid |
GridDistributedLockResponse.futureId() |
IgniteUuid |
GridCacheTxRecoveryFuture.futureId() |
IgniteUuid |
GridCacheTxRecoveryResponse.futureId() |
IgniteUuid |
GridDistributedTxFinishResponse.futureId() |
IgniteUuid |
GridDistributedLockRequest.futureId() |
IgniteUuid |
GridCacheTxRecoveryRequest.miniId() |
IgniteUuid |
GridCacheTxRecoveryResponse.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,
@Nullable 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,
@NotNull AffinityTopologyVersion topVer,
@Nullable GridCacheVersion commitVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
@Nullable UUID subjId,
int taskNameHash,
int txSize,
boolean addDepInfo) |
GridDistributedTxFinishResponse(int part,
GridCacheVersion txId,
IgniteUuid futId) |
| Modifier and Type | Field and Description |
|---|---|
protected IgniteUuid |
GridDhtTxPrepareFuture.deploymentLdrId
Deployment class loader id which will be used for deserialization of entries on a distributed task.
|
protected IgniteUuid |
CacheDistributedGetFutureAdapter.deploymentLdrId
Deployment class loader id which will be used for deserialization of entries on a distributed task.
|
protected IgniteUuid |
GridPartitionedSingleGetFuture.deploymentLdrId
Deployment class loader id which will be used for deserialization of entries on a distributed task.
|
protected IgniteUuid |
GridDhtTxAbstractEnlistFuture.deploymentLdrId
Deployment class loader id which will be used for deserialization of entries on a distributed task.
|
protected IgniteUuid |
CacheDistributedGetFutureAdapter.futId
Future ID.
|
protected IgniteUuid |
GridDhtTxAbstractEnlistFuture.futId
Future ID.
|
protected IgniteUuid |
GridDhtTxAbstractEnlistFuture.nearFutId
Future ID.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridDhtTxQueryEnlistRequest.dhtFutureId() |
IgniteUuid |
GridDhtTxPrepareResponse.futureId() |
IgniteUuid |
GridDhtTxPrepareFuture.futureId() |
IgniteUuid |
CacheDistributedGetFutureAdapter.futureId() |
IgniteUuid |
CacheDistributedGetFutureAdapter.AbstractMiniFuture.futureId() |
IgniteUuid |
GridDhtGetFuture.futureId() |
IgniteUuid |
GridDhtTxPrepareRequest.futureId() |
IgniteUuid |
GridDhtGetSingleFuture.futureId() |
IgniteUuid |
GridDhtTxFinishFuture.futureId() |
IgniteUuid |
GridPartitionedSingleGetFuture.futureId() |
IgniteUuid |
GridDhtLockFuture.futureId() |
IgniteUuid |
GridDhtTxAbstractEnlistFuture.futureId() |
IgniteUuid |
GridDhtTxQueryEnlistResponse.futureId() |
IgniteUuid |
GridDhtLockResponse.miniId() |
IgniteUuid |
GridDhtLockRequest.miniId() |
IgniteUuid |
GridDhtTxLocal.nearFinishFutureId() |
protected abstract IgniteUuid |
GridDhtTxLocalAdapter.nearFutureId() |
protected IgniteUuid |
GridDhtTxLocal.nearFutureId() |
| Modifier and Type | Method and Description |
|---|---|
GridNearGetRequest |
CacheDistributedGetFutureAdapter.AbstractMiniFuture.createGetRequest(IgniteUuid rootFutId)
Factory methond for generate request associated with this miniFuture.
|
protected abstract GridNearGetRequest |
CacheDistributedGetFutureAdapter.AbstractMiniFuture.createGetRequest0(IgniteUuid rootFutId,
IgniteUuid futId) |
GridDhtTxLocal |
GridDhtTransactionalCacheAdapter.initTxTopologyVersion(UUID nodeId,
ClusterNode nearNode,
GridCacheVersion nearLockVer,
IgniteUuid nearFutId,
int nearMiniId,
boolean firstClientReq,
AffinityTopologyVersion topVer,
long nearThreadId,
long timeout,
UUID txSubjectId,
int txTaskNameHash,
MvccSnapshot snapshot) |
void |
GridDhtTxLocal.nearFinishFutureId(IgniteUuid nearFinFutId) |
void |
GridDhtTxLocal.nearFutureId(IgniteUuid nearFutId) |
| Constructor and Description |
|---|
GridDhtLockRequest(int cacheId,
UUID nodeId,
GridCacheVersion nearXidVer,
long threadId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion lockVer,
@NotNull AffinityTopologyVersion topVer,
boolean isInTx,
boolean isRead,
TransactionIsolation isolation,
boolean isInvalidate,
long timeout,
int dhtCnt,
int nearCnt,
int txSize,
@Nullable UUID subjId,
int taskNameHash,
long accessTtl,
boolean skipStore,
boolean storeUsed,
boolean keepBinary,
boolean addDepInfo,
String txLbl) |
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) |
GridDhtTxAbstractEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
@Nullable CacheEntryPredicate filter,
boolean keepBinary) |
GridDhtTxEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
Collection<Object> rows,
EnlistOperation op,
@Nullable CacheEntryPredicate filter,
boolean needRes,
boolean keepBinary)
Constructor.
|
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
@NotNull AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
@Nullable UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean retVal,
boolean waitRemoteTxs,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
@NotNull AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
@Nullable UUID subjId,
int taskNameHash,
boolean addDepInfo,
Collection<Long> updateIdxs,
boolean retVal,
boolean waitRemoteTxs,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
GridDhtTxFinishResponse(int part,
GridCacheVersion xid,
IgniteUuid futId,
int miniId) |
GridDhtTxLocal(GridCacheSharedContext cctx,
AffinityTopologyVersion topVer,
UUID nearNodeId,
GridCacheVersion nearXidVer,
IgniteUuid nearFutId,
int 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,
@Nullable String lb,
GridNearTxLocal parentTx) |
GridDhtTxPrepareRequest(IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridDhtTxLocalAdapter tx,
long timeout,
Collection<IgniteTxEntry> dhtWrites,
Collection<IgniteTxEntry> nearWrites,
Map<UUID,Collection<UUID>> txNodes,
GridCacheVersion nearXidVer,
boolean last,
boolean onePhaseCommit,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean storeWriteThrough,
boolean retVal,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
GridDhtTxPrepareResponse(int part,
GridCacheVersion xid,
IgniteUuid futId,
int miniId,
boolean addDepInfo) |
GridDhtTxPrepareResponse(int part,
GridCacheVersion xid,
IgniteUuid futId,
int miniId,
Throwable err,
boolean addDepInfo) |
GridDhtTxQueryAbstractEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx)
Constructor.
|
GridDhtTxQueryEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
int[] cacheIds,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
long timeout,
GridCacheContext<?,?> cctx) |
GridDhtTxQueryEnlistResponse(int cacheId,
IgniteUuid futId,
int batchId,
Throwable err) |
GridDhtTxQueryResultsEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
Collection<Object> rows,
EnlistOperation op) |
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,
@Nullable UUID subjId,
int taskNameHash,
boolean single,
boolean storeWriteThrough,
@Nullable String txLbl)
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,
@Nullable UUID subjId,
int taskNameHash,
boolean storeWriteThrough,
@Nullable String txLbl)
This constructor is meant for pessimistic transactions.
|
| Modifier and Type | Field and Description |
|---|---|
protected IgniteUuid |
GridNearAtomicAbstractUpdateFuture.deploymentLdrId
Deployment class loader id which will be used for deserialization of entries on a distributed task.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridNearAtomicAbstractUpdateFuture.futureId() |
IgniteUuid |
GridDhtAtomicAbstractUpdateFuture.futureId() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridDhtColocatedLockFuture.futureId() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridDhtForceKeysResponse.futureId() |
IgniteUuid |
GridDhtForceKeysRequest.futureId() |
IgniteUuid |
GridDhtForceKeysFuture.futureId() |
IgniteUuid |
GridDhtForceKeysResponse.miniId() |
IgniteUuid |
GridDhtForceKeysRequest.miniId() |
| Constructor and Description |
|---|
GridDhtForceKeysResponse(int cacheId,
IgniteUuid futId,
IgniteUuid miniId,
boolean addDepInfo) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
PartitionDefferedDeleteQueueCleanupTask.timeoutId() |
| Modifier and Type | Field and Description |
|---|---|
protected IgniteUuid |
GridNearTxPrepareFutureAdapter.futId
Future ID.
|
protected IgniteUuid |
GridNearTxAbstractEnlistFuture.futId
Mvcc future id.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridNearTxQueryResultsEnlistResponse.dhtFutureId() |
IgniteUuid |
GridNearTxEnlistResponse.dhtFutureId() |
IgniteUuid |
GridNearTxQueryEnlistRequest.futureId() |
IgniteUuid |
GridNearTxQueryEnlistResponse.futureId() |
IgniteUuid |
GridNearTxQueryResultsEnlistRequest.futureId() |
IgniteUuid |
GridNearLockFuture.futureId() |
IgniteUuid |
GridNearGetResponse.futureId() |
IgniteUuid |
GridNearTxPrepareFutureAdapter.futureId() |
IgniteUuid |
GridNearGetRequest.futureId() |
IgniteUuid |
GridNearTxPrepareResponse.futureId() |
IgniteUuid |
GridNearTxFinishFuture.futureId() |
IgniteUuid |
GridNearTxPrepareRequest.futureId() |
IgniteUuid |
GridNearTxEnlistResponse.futureId() |
IgniteUuid |
GridNearTxEnlistRequest.futureId() |
IgniteUuid |
GridNearTxAbstractEnlistFuture.futureId() |
IgniteUuid |
GridNearGetResponse.miniId() |
IgniteUuid |
GridNearGetRequest.miniId() |
protected IgniteUuid |
GridNearTxLocal.nearFutureId() |
IgniteUuid |
GridNearTxLocal.timeoutId() |
| Constructor and Description |
|---|
GridNearGetRequest(int cacheId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion ver,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
@NotNull AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean addReader,
boolean skipVals,
boolean addDepInfo,
boolean recovery,
@Nullable String txLbl,
@Nullable MvccSnapshot mvccSnapshot) |
GridNearGetResponse(int cacheId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion ver,
boolean addDepInfo) |
GridNearLockRequest(int cacheId,
@NotNull AffinityTopologyVersion topVer,
UUID nodeId,
long threadId,
IgniteUuid futId,
GridCacheVersion lockVer,
boolean isInTx,
boolean isRead,
boolean retVal,
TransactionIsolation isolation,
boolean isInvalidate,
long timeout,
int keyCnt,
int txSize,
boolean syncCommit,
@Nullable UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean skipStore,
boolean keepBinary,
boolean firstClientReq,
boolean nearCache,
boolean addDepInfo,
@Nullable String txLbl) |
GridNearLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
int miniId,
boolean filterRes,
int cnt,
Throwable err,
AffinityTopologyVersion clientRemapVer,
boolean addDepInfo,
boolean compatibleRemapVer) |
GridNearTxEnlistResponse(int cacheId,
IgniteUuid futId,
int miniId,
GridCacheVersion lockVer,
GridCacheReturn res,
GridCacheVersion dhtVer,
IgniteUuid dhtFutId,
Set<UUID> newDhtNodes)
Constructor for normal result.
|
GridNearTxEnlistResponse(int cacheId,
IgniteUuid futId,
int miniId,
GridCacheVersion lockVer,
Throwable err)
Constructor for error result.
|
GridNearTxFinishRequest(IgniteUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
boolean explicitLock,
boolean storeEnabled,
@NotNull AffinityTopologyVersion topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
@Nullable UUID subjId,
int taskNameHash,
MvccSnapshot mvccSnapshot,
boolean addDepInfo) |
GridNearTxFinishResponse(int part,
GridCacheVersion xid,
long nearThreadId,
IgniteUuid futId,
int miniId,
@Nullable Throwable err) |
GridNearTxPrepareRequest(IgniteUuid futId,
AffinityTopologyVersion topVer,
GridNearTxLocal tx,
long timeout,
Collection<IgniteTxEntry> reads,
Collection<IgniteTxEntry> writes,
boolean near,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
boolean onePhaseCommit,
boolean retVal,
boolean implicitSingle,
boolean explicitLock,
@Nullable UUID subjId,
int taskNameHash,
boolean firstClientReq,
boolean allowWaitTopFut,
boolean addDepInfo,
boolean recovery) |
GridNearTxPrepareResponse(int part,
GridCacheVersion xid,
IgniteUuid futId,
int miniId,
GridCacheVersion dhtVer,
GridCacheVersion writeVer,
GridCacheReturn retVal,
Throwable err,
AffinityTopologyVersion clientRemapVer,
boolean onePhaseCommit,
boolean addDepInfo) |
GridNearTxQueryEnlistRequest(int cacheId,
long threadId,
IgniteUuid futId,
int miniId,
UUID subjId,
AffinityTopologyVersion topVer,
GridCacheVersion lockVer,
MvccSnapshot mvccSnapshot,
int[] cacheIds,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
long timeout,
long txTimeout,
int taskNameHash,
boolean clientFirst) |
GridNearTxQueryEnlistResponse(int cacheId,
IgniteUuid futId,
int miniId,
GridCacheVersion lockVer,
long res,
boolean removeMapping,
Set<UUID> newDhtNodes) |
GridNearTxQueryEnlistResponse(int cacheId,
IgniteUuid futId,
int miniId,
GridCacheVersion lockVer,
Throwable err) |
GridNearTxQueryResultsEnlistResponse(int cacheId,
IgniteUuid futId,
int miniId,
GridCacheVersion lockVer,
long res,
GridCacheVersion dhtVer,
IgniteUuid dhtFutId,
Set<UUID> newDhtNodes) |
GridNearTxQueryResultsEnlistResponse(int cacheId,
IgniteUuid futId,
int miniId,
GridCacheVersion lockVer,
Throwable err) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridLocalLockFuture.futureId() |
| Modifier and Type | Method and Description |
|---|---|
void |
MvccCachingManager.addEnlisted(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
CacheObject oldVal,
boolean primary,
AffinityTopologyVersion topVer,
MvccVersion mvccVer,
int cacheId,
IgniteInternalTx tx,
IgniteUuid futId,
int batchNum)
Adds enlisted tx entry to cache.
|
| Modifier and Type | Method and Description |
|---|---|
Set<UUID> |
IgniteSnapshotManager.cacheStartRequiredAliveNodes(@Nullable IgniteUuid restoreId) |
Set<UUID> |
SnapshotRestoreProcess.cacheStartRequiredAliveNodes(IgniteUuid reqId) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridCacheQueryFutureAdapter.timeoutId() |
| Modifier and Type | Field and Description |
|---|---|
protected IgniteUuid |
IgniteTxAdapter.deploymentLdrId
Deployment class loader id which will be used for deserialization of entries on a distributed task.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
IgniteTxAdapter.xid()
Gets unique identifier for this transaction.
|
IgniteUuid |
TransactionEventProxyImpl.xid()
Gets unique identifier for this transaction.
|
IgniteUuid |
TransactionProxyImpl.xid()
Gets unique identifier for this transaction.
|
IgniteUuid |
IgniteInternalTx.xid()
Gets unique identifier for this transaction.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxHandler.mvccEnlistBatch(GridDhtTxRemote tx,
GridCacheContext ctx,
EnlistOperation op,
List<KeyCacheObject> keys,
List<Message> vals,
MvccSnapshot snapshot,
IgniteUuid futId,
int batchNum)
Writes updated values on the backup node.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridCacheVersion.asIgniteUuid() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
ChangeGlobalStateFinishMessage.id() |
IgniteUuid |
ChangeGlobalStateMessage.id() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridClusterStateProcessor.afterStateChangeFinished(IgniteUuid msgId,
boolean success) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable 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,
@Nullable 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,
@NotNull AffinityTopologyVersion topVer,
int partId) |
| Constructor and Description |
|---|
DataStreamerRequest(long reqId,
byte[] resTopicBytes,
@Nullable 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,
@NotNull AffinityTopologyVersion topVer,
int partId) |
| Modifier and Type | Field and Description |
|---|---|
protected IgniteUuid |
GridCacheQueueAdapter.id
Queue unique ID.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridCacheQueueHeader.id() |
IgniteUuid |
GridCacheSetImpl.id() |
IgniteUuid |
GridCacheSetHeader.id() |
IgniteUuid |
GridCacheQueueAdapter.id() |
IgniteUuid |
CollocatedSetItemKey.setId() |
IgniteUuid |
SetItemKey.setId() |
IgniteUuid |
GridSetQueryPredicate.setId() |
IgniteUuid |
GridCacheSetItemKey.setId() |
| Constructor and Description |
|---|
AddProcessor(IgniteUuid id,
int size) |
ClearProcessor(IgniteUuid id) |
CollocatedQueueItemKey(IgniteUuid queueId,
String queueName,
long idx) |
CollocatedSetItemKey(String setName,
IgniteUuid setId,
Object item) |
GridCacheQueueHeader(IgniteUuid id,
int cap,
boolean collocated,
long head,
long tail,
@Nullable Set<Long> rmvIdxs) |
GridCacheSetHeader(IgniteUuid id,
boolean collocated,
boolean separated) |
GridSetQueryPredicate(IgniteUuid setId,
boolean collocated) |
PollProcessor(IgniteUuid id) |
RemoveProcessor(IgniteUuid id,
Long idx) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridJobWorker.getJobId() |
IgniteUuid |
GridJobWorker.timeoutId() |
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridJobWorker |
GridJobProcessor.activeJob(IgniteUuid jobId)
Gets active job.
|
void |
GridJobProcessor.cancelJob(@Nullable IgniteUuid sesId,
@Nullable IgniteUuid jobId,
boolean sys) |
void |
GridJobProcessor.cancelJob(@Nullable IgniteUuid sesId,
@Nullable 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 |
|---|---|
IgniteUuid |
MappingProposedMessage.id() |
IgniteUuid |
MappingAcceptedMessage.id() |
| Modifier and Type | Method and Description |
|---|---|
void |
FilePerformanceStatisticsWriter.job(IgniteUuid sesId,
long queuedTime,
long startTime,
long duration,
boolean timedOut) |
void |
PerformanceStatisticsProcessor.job(IgniteUuid sesId,
long queuedTime,
long startTime,
long duration,
boolean timedOut) |
void |
PerformanceStatisticsHandler.job(UUID nodeId,
IgniteUuid sesId,
long queuedTime,
long startTime,
long duration,
boolean timedOut) |
void |
FilePerformanceStatisticsWriter.task(IgniteUuid sesId,
String taskName,
long startTime,
long duration,
int affPartId) |
void |
PerformanceStatisticsProcessor.task(IgniteUuid sesId,
String taskName,
long startTime,
long duration,
int affPartId) |
void |
PerformanceStatisticsHandler.task(UUID nodeId,
IgniteUuid sesId,
String taskName,
long startTime,
long duration,
int affPartId) |
| 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 |
|---|---|
void |
GridQueryProcessor.processSchemaOperationLocal(SchemaAbstractOperation op,
QueryTypeDescriptorImpl type,
IgniteUuid depId,
SchemaIndexOperationCancellationToken cancelTok)
Process schema operation.
|
| Constructor and Description |
|---|
SchemaOperationWorker(GridKernalContext ctx,
GridQueryProcessor qryProc,
IgniteUuid depId,
SchemaAbstractOperation op,
boolean nop,
@Nullable SchemaOperationException err,
boolean cacheRegistered,
@Nullable QueryTypeDescriptorImpl type)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteUuid |
SchemaProposeDiscoveryMessage.deploymentId() |
IgniteUuid |
SchemaAbstractDiscoveryMessage.id() |
| Modifier and Type | Method and Description |
|---|---|
void |
SchemaProposeDiscoveryMessage.deploymentId(IgniteUuid depId) |
| 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 |
|---|---|
IgniteUuid |
ServiceChangeBatchRequest.id() |
IgniteUuid |
ServiceClusterDeploymentResultBatch.id() |
IgniteUuid |
ServiceDeploymentProcessId.requestId() |
IgniteUuid |
ServiceClusterDeploymentResult.serviceId() |
IgniteUuid |
ServiceInfo.serviceId()
Rerurns services id.
|
| Modifier and Type | Method and Description |
|---|---|
Map<IgniteUuid,ServiceSingleNodeDeploymentResult> |
ServiceSingleNodeDeploymentResultBatch.results() |
| Constructor and Description |
|---|
ServiceClusterDeploymentResult(@NotNull IgniteUuid srvcId,
@NotNull Map<UUID,ServiceSingleNodeDeploymentResult> results) |
ServiceDeploymentRequest(@NotNull IgniteUuid srvcId,
@NotNull ServiceConfiguration cfg) |
ServiceInfo(@NotNull UUID originNodeId,
@NotNull IgniteUuid srvcId,
@NotNull ServiceConfiguration cfg) |
ServiceInfo(@NotNull UUID originNodeId,
@NotNull IgniteUuid srvcId,
@NotNull ServiceConfiguration cfg,
boolean staticCfg) |
ServiceUndeploymentRequest(@NotNull IgniteUuid srvcId) |
| Modifier and Type | Method and Description |
|---|---|
GridTaskSessionImpl |
GridTaskSessionProcessor.createTaskSession(IgniteUuid sesId,
UUID taskNodeId,
String taskName,
@Nullable GridDeployment dep,
String taskClsName,
@Nullable Collection<UUID> top,
@Nullable IgnitePredicate<ClusterNode> topPred,
long startTime,
long endTime,
Collection<ComputeJobSibling> siblings,
Map<Object,Object> attrs,
boolean fullSup,
boolean internal,
UUID subjId,
@Nullable String execName) |
@Nullable GridTaskSessionImpl |
GridTaskSessionProcessor.getSession(IgniteUuid sesId) |
boolean |
GridTaskSessionProcessor.removeSession(IgniteUuid sesId)
Removes session for a given session ID.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridTaskWorker.timeoutId() |
| 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> @Nullable ComputeTaskInternalFuture<R> |
GridTaskProcessor.taskFuture(IgniteUuid sesId) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
GridSpiTimeoutObject.timeoutId() |
IgniteUuid |
GridTimeoutObject.timeoutId() |
IgniteUuid |
GridTimeoutProcessor.CancelableTask.timeoutId() |
IgniteUuid |
GridTimeoutObjectAdapter.timeoutId() |
| Constructor and Description |
|---|
GridTimeoutObjectAdapter(IgniteUuid id,
long timeout) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
SqlKillComputeTaskCommand.getSessionId() |
| Modifier and Type | Method and Description |
|---|---|
static IgniteUuid |
IgniteUtils.bytesToIgniteUuid(byte[] in,
int off)
Converts bytes to
IgniteUuid. |
static IgniteUuid |
IgniteUtils.contextDeploymentClassLoaderId(GridKernalContext ctx)
Returns Deployment class loader id if method was invoked in the job context
(it may be the context of a cache's operation which was triggered by the distributed job)
or
null if no context was found or Deployment is switched off. |
static @Nullable IgniteUuid |
IgniteUtils.readIgniteUuid(DataInput in)
Reads
IgniteUuid from input stream. |
| Modifier and Type | Method and Description |
|---|---|
static ClassLoader |
IgniteUtils.deploymentClassLoader(GridKernalContext ctx,
IgniteUuid ldrId)
Gets that deployment class loader matching by the specific id, or
null
if the class loader was not found. |
static String |
IgniteUtils.id8(IgniteUuid id)
Gets 8-character substring of
IgniteUuid (for terse logging). |
static byte[] |
IgniteUtils.igniteUuidToBytes(IgniteUuid uuid)
Converts
IgniteUuid to bytes. |
static void |
IgniteUtils.igniteUuidToBytes(IgniteUuid uuid,
byte[] out,
int off)
Converts
IgniteUuid to bytes. |
static void |
IgniteUtils.restoreDeploymentContext(GridKernalContext ctx,
IgniteUuid ldrId)
Restores a deployment context for cache deployment.
|
static void |
IgniteUtils.writeIgniteUuid(DataOutput out,
IgniteUuid uid)
Writes
IgniteUuid to output stream. |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
InitMessage.id() |
IgniteUuid |
FullMessage.id() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
VisorCache.getDynamicDeploymentId() |
IgniteUuid |
VisorCacheConfiguration.getDynamicDeploymentId() |
| Modifier and Type | Method and Description |
|---|---|
Map<String,IgniteUuid> |
VisorCacheNamesCollectorTaskResult.getCaches() |
| Modifier and Type | Method and Description |
|---|---|
protected VisorCacheConfiguration |
VisorCacheConfigurationCollectorJob.config(CacheConfiguration ccfg,
IgniteUuid dynamicDeploymentId) |
| Constructor and Description |
|---|
VisorCacheConfiguration(IgniteEx ignite,
CacheConfiguration ccfg,
IgniteUuid dynamicDeploymentId)
Create data transfer object for cache configuration properties.
|
| Constructor and Description |
|---|
VisorCacheNamesCollectorTaskResult(Map<String,IgniteUuid> caches,
Set<String> groups) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
VisorComputeCancelSessionTaskArg.getSessionId() |
| Modifier and Type | Method and Description |
|---|---|
Set<IgniteUuid> |
VisorComputeCancelSessionsTaskArg.getSessionIds() |
| Constructor and Description |
|---|
VisorComputeCancelSessionTaskArg(IgniteUuid sesId) |
| Constructor and Description |
|---|
VisorComputeCancelSessionsTaskArg(Set<IgniteUuid> sesIds) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
VisorGridEvent.getId() |
IgniteUuid |
VisorGridJobEvent.getJobId() |
IgniteUuid |
VisorGridJobEvent.getTaskSessionId() |
IgniteUuid |
VisorGridTaskEvent.getTaskSessionId() |
| Constructor and Description |
|---|
VisorGridDeploymentEvent(int typeId,
IgniteUuid id,
String name,
UUID nid,
long ts,
@Nullable String msg,
String shortDisplay,
String alias)
Create event with given parameters.
|
VisorGridDiscoveryEvent(int typeId,
IgniteUuid id,
String name,
UUID nid,
long ts,
@Nullable String msg,
String shortDisplay,
UUID evtNodeId,
String addr,
boolean isDaemon,
long topVer)
Create event with given parameters.
|
VisorGridEvent(int typeId,
IgniteUuid id,
String name,
UUID nid,
long ts,
@Nullable String msg,
String shortDisplay)
Create event with given parameters.
|
VisorGridJobEvent(int typeId,
IgniteUuid id,
String name,
UUID nid,
long ts,
@Nullable 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,
@Nullable String msg,
String shortDisplay,
String taskName,
String taskClsName,
IgniteUuid taskSesId,
boolean internal)
Create event with given parameters.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
VisorNodeEventsCollectorTaskArg.getTaskSessionId() |
| Modifier and Type | Method and Description |
|---|---|
static VisorNodeEventsCollectorTaskArg |
VisorNodeEventsCollectorTaskArg.createTasksArg(@Nullable Long timeArg,
@Nullable String taskName,
@Nullable IgniteUuid taskSesId) |
| Constructor and Description |
|---|
VisorNodeEventsCollectorTaskArg(@Nullable String keyOrder,
@Nullable int[] typeArg,
@Nullable Long timeArg,
@Nullable String taskName,
@Nullable IgniteUuid taskSesId) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteUuid |
VisorTxInfo.getNearXid() |
IgniteUuid |
VisorTxInfo.getXid() |
IgniteUuid |
TxVerboseId.uuid() |
| Constructor and Description |
|---|
TxVerboseId(IgniteUuid uuid,
GridCacheVersion gridCacheVer) |
VisorTxInfo(IgniteUuid xid,
long startTime,
long duration,
TransactionIsolation isolation,
TransactionConcurrency concurrency,
long timeout,
String lb,
Collection<UUID> primaryNodes,
TransactionState state,
int size,
IgniteUuid nearXid,
Collection<UUID> masterNodeIds,
AffinityTopologyVersion topVer,
TxVerboseInfo info) |
VisorTxInfo(IgniteUuid xid,
TransactionState state)
Constructor for historical mode.
|
| Modifier and Type | Method and Description |
|---|---|
protected VisorGridEvent |
VisorEventMapper.deploymentEvent(DeploymentEvent de,
int type,
IgniteUuid id,
String name,
UUID nid,
long ts,
String msg,
String shortDisplay) |
protected VisorGridEvent |
VisorEventMapper.discoveryEvent(DiscoveryEvent de,
int type,
IgniteUuid id,
String name,
UUID nid,
long ts,
String msg,
String shortDisplay) |
protected VisorGridEvent |
VisorEventMapper.jobEvent(JobEvent je,
int type,
IgniteUuid id,
String name,
UUID nid,
long ts,
String msg,
String shortDisplay) |
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.
|
protected VisorGridEvent |
VisorEventMapper.taskEvent(TaskEvent te,
int type,
IgniteUuid id,
String name,
UUID nid,
long ts,
String msg,
String shortDisplay) |
| Modifier and Type | Method and Description |
|---|---|
static IgniteUuid |
IgniteUuid.fromString(String s)
Converts string into
IgniteUuid. |
static IgniteUuid |
IgniteUuid.fromUuid(UUID id)
Constructs new
IgniteUuid 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 |
TcpConnectionRequestDiscoveryMessage.id() |
IgniteUuid |
TcpCommunicationConnectionCheckFuture.id() |
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteUuid |
TcpDiscoveryNodeAddedMessage.discardedCustomMessageId()
Gets discarded custom message ID.
|
@Nullable 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(@Nullable Collection<TcpDiscoveryAbstractMessage> msgs,
@Nullable IgniteUuid discardMsgId,
@Nullable IgniteUuid discardCustomMsgId)
Sets pending messages to send to new node.
|
void |
TcpDiscoveryNodeAddedMessage.messages(@Nullable Collection<TcpDiscoveryAbstractMessage> msgs,
@Nullable IgniteUuid discardMsgId,
@Nullable 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 |
ComputeJobView.id() |
IgniteUuid |
ComputeTaskView.id() |
IgniteUuid |
ComputeTaskView.jobId()
Deprecated.
Use
ComputeTaskView.id() or ComputeTaskView.sessionId() instead. |
IgniteUuid |
ServiceView.serviceId() |
IgniteUuid |
ComputeJobView.sessionId()
ComputeJobView.sessionId() value equal to the value of ComputeTaskView.sessionId()
if both records represents parts of the same computation. |
IgniteUuid |
ComputeTaskView.sessionId()
ComputeTaskView.sessionId() value equal to the value of ComputeJobView.sessionId()
if both records represents parts of the same computation. |
IgniteUuid |
TransactionView.xid() |
| Constructor and Description |
|---|
ComputeJobView(IgniteUuid id,
GridJobWorker job,
ComputeJobView.ComputeJobState state) |
ComputeTaskView(IgniteUuid id,
GridTaskWorker worker) |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
QueueView.id() |
IgniteUuid |
SetView.id() |
| Modifier and Type | Method and Description |
|---|---|
IgniteUuid |
Transaction.xid()
Gets unique identifier for this transaction.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.0 Release Date : September 11 2021