| Package | Description |
|---|---|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.managers.communication |
TODO.
|
| org.apache.ignite.internal.managers.deployment |
TODO.
|
| org.apache.ignite.internal.processors.job |
TODO.
|
| org.apache.ignite.internal.processors.resource |
TODO.
|
| org.apache.ignite.internal.processors.session |
Session processing package to guarantee reuse of same session
object on the same node.
|
| org.apache.ignite.internal.processors.task |
TODO.
|
| Modifier and Type | Method and Description |
|---|---|
GridDeployment |
GridTaskSessionImpl.deployment() |
GridDeployment |
GridJobSessionImpl.deployment()
Grid job deployment.
|
| Constructor and Description |
|---|
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,
@Nullable String execName,
@Nullable SecurityContext secCtx)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridDeployment |
GridIoUserMessage.deployment() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoUserMessage.deployment(GridDeployment dep) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridDeployment |
GridDeploymentManager.deploy(Class<?> cls,
ClassLoader clsLdr) |
GridDeployment |
GridDeploymentStore.explicitDeploy(Class<?> cls,
ClassLoader clsLdr)
Explicitly deploys class.
|
GridDeployment |
GridDeploymentPerLoaderStore.getDeployment(GridDeploymentMetadata meta) |
@Nullable GridDeployment |
GridDeploymentStore.getDeployment(GridDeploymentMetadata meta) |
@Nullable GridDeployment |
GridDeploymentPerVersionStore.getDeployment(GridDeploymentMetadata meta) |
@Nullable GridDeployment |
GridDeploymentManager.getDeployment(IgniteUuid ldrId)
Gets any deployment by loader ID.
|
GridDeployment |
GridDeploymentPerLoaderStore.getDeployment(IgniteUuid ldrId)
Gets class loader based on ID.
|
@Nullable GridDeployment |
GridDeploymentStore.getDeployment(IgniteUuid ldrId)
Gets class loader based on ID.
|
GridDeployment |
GridDeploymentPerVersionStore.getDeployment(IgniteUuid ldrId)
Gets class loader based on ID.
|
@Nullable GridDeployment |
GridDeploymentManager.getDeployment(String rsrcName) |
@Nullable GridDeployment |
GridDeploymentManager.getGlobalDeployment(DeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
IgniteUuid clsLdrId,
Map<UUID,IgniteUuid> participants,
@Nullable IgnitePredicate<ClusterNode> nodeFilter) |
@Nullable GridDeployment |
GridDeploymentManager.getLocalDeployment(String rsrcName) |
GridDeployment |
GridDeploymentPerLoaderStore.searchDeploymentCache(GridDeploymentMetadata meta) |
@Nullable GridDeployment |
GridDeploymentStore.searchDeploymentCache(GridDeploymentMetadata meta) |
GridDeployment |
GridDeploymentPerVersionStore.searchDeploymentCache(GridDeploymentMetadata meta) |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridDeployment> |
GridDeploymentPerLoaderStore.getDeployments() |
Collection<GridDeployment> |
GridDeploymentStore.getDeployments() |
Collection<GridDeployment> |
GridDeploymentPerVersionStore.getDeployments() |
| Modifier and Type | Method and Description |
|---|---|
GridDeployment |
GridJobProcessor.currentDeployment()
Returns current deployment.
|
GridDeployment |
GridJobWorker.getDeployment() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridResourceProcessor.inject(GridDeployment dep,
Class<?> taskCls,
ComputeJob job,
ComputeTaskSession ses,
GridJobContextImpl jobCtx)
Injects held resources into given
job. |
void |
GridResourceProcessor.inject(GridDeployment dep,
Class<?> depCls,
Object target)
Injects resources into generic class.
|
void |
GridResourceProcessor.inject(GridDeployment dep,
ComputeTask<?,?> task,
GridTaskSessionImpl ses,
ComputeLoadBalancer balancer,
ComputeTaskContinuousMapper mapper)
Injects held resources into given grid task.
|
void |
GridResourceLoggerInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceField field,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource into field.
|
void |
GridResourceJobContextInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceField field,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource into field.
|
void |
GridResourceProxiedIgniteInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceField field,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource into field.
|
void |
GridResourceServiceInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceField field,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource into field.
|
void |
GridResourceLoggerInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceMethod mtd,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource with a setter method.
|
void |
GridResourceJobContextInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceMethod mtd,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource with a setter method.
|
void |
GridResourceProxiedIgniteInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceMethod mtd,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource with a setter method.
|
void |
GridResourceServiceInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceMethod mtd,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource with a setter method.
|
boolean |
GridResourceIoc.inject(Object target,
Class<? extends Annotation> annCls,
org.apache.ignite.internal.processors.resource.GridResourceInjector injector,
@Nullable GridDeployment dep,
@Nullable Class<?> depCls)
Injects given resource via field or setter with specified annotations on provided target object.
|
void |
GridResourceProcessor.invokeAnnotated(GridDeployment dep,
Object target,
Class<? extends Annotation> annCls) |
boolean |
GridResourceProcessor.isAnnotationPresent(GridDeployment dep,
Object target,
Class<? extends Annotation> annCls)
Checks if annotation presents in specified object.
|
boolean |
GridResourceProcessor.isAnnotationsPresent(GridDeployment dep,
Object target,
GridResourceIoc.AnnotationSet annSet)
Checks if annotations presents in specified object.
|
void |
GridResourceProcessor.onUndeployed(GridDeployment dep)
Callback to be called when class loader is undeployed.
|
| 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,
@Nullable String execName,
@Nullable SecurityContext secCtx)
Creates task session.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,GridDeployment> |
GridTaskProcessor.getUsedDeploymentMap()
Gets currently used deployments mapped by task name or aliases.
|
Collection<GridDeployment> |
GridTaskProcessor.getUsedDeployments()
Gets currently used deployments.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.15.0 Release Date : April 25 2023