| 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() |
| Constructor and Description |
|---|
GridTaskSessionImpl(UUID taskNodeId,
String taskName,
GridDeployment dep,
String taskClsName,
IgniteUuid sesId,
Collection<UUID> top,
IgnitePredicate<ClusterNode> topPred,
long startTime,
long endTime,
Collection<ComputeJobSibling> siblings,
Map<Object,Object> attrs,
GridKernalContext ctx,
boolean fullSup,
boolean internal,
UUID subjId,
String execName) |
| Modifier and Type | Method and Description |
|---|---|
GridDeployment |
GridIoUserMessage.deployment() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoUserMessage.deployment(GridDeployment dep) |
| Modifier and Type | Method and Description |
|---|---|
GridDeployment |
GridDeploymentManager.deploy(Class<?> cls,
ClassLoader clsLdr) |
GridDeployment |
GridDeploymentStore.explicitDeploy(Class<?> cls,
ClassLoader clsLdr)
Explicitly deploys class.
|
GridDeployment |
GridDeploymentPerLoaderStore.getDeployment(org.apache.ignite.internal.managers.deployment.GridDeploymentMetadata meta) |
GridDeployment |
GridDeploymentStore.getDeployment(org.apache.ignite.internal.managers.deployment.GridDeploymentMetadata meta) |
GridDeployment |
GridDeploymentPerVersionStore.getDeployment(org.apache.ignite.internal.managers.deployment.GridDeploymentMetadata meta) |
GridDeployment |
GridDeploymentPerLoaderStore.getDeployment(IgniteUuid ldrId)
Gets class loader based on ID.
|
GridDeployment |
GridDeploymentStore.getDeployment(IgniteUuid ldrId)
Gets class loader based on ID.
|
GridDeployment |
GridDeploymentPerVersionStore.getDeployment(IgniteUuid ldrId)
Gets class loader based on ID.
|
GridDeployment |
GridDeploymentManager.getDeployment(IgniteUuid ldrId)
Gets any deployment by loader ID.
|
GridDeployment |
GridDeploymentManager.getDeployment(String rsrcName) |
GridDeployment |
GridDeploymentManager.getGlobalDeployment(DeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
IgniteUuid clsLdrId,
Map<UUID,IgniteUuid> participants,
IgnitePredicate<ClusterNode> nodeFilter) |
GridDeployment |
GridDeploymentManager.getLocalDeployment(String rsrcName) |
| 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 |
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 |
GridResourceJobContextInjector.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.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 |
GridResourceJobContextInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceMethod mtd,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource with a setter method.
|
void |
GridResourceLoggerInjector.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.
|
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,
GridDeployment dep,
String taskClsName,
Collection<UUID> top,
IgnitePredicate<ClusterNode> topPred,
long startTime,
long endTime,
Collection<ComputeJobSibling> siblings,
Map<Object,Object> attrs,
boolean fullSup,
boolean internal,
UUID subjId,
String execName) |
| 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 Fabric : ver. 2.6.0 Release Date : July 10 2018