| Package | Description |
|---|---|
| org.gridgain.grid.kernal |
Contains main implementation.
|
| org.gridgain.grid.kernal.managers.communication |
TODO.
|
| org.gridgain.grid.kernal.managers.deployment |
TODO.
|
| org.gridgain.grid.kernal.processors.job |
TODO.
|
| org.gridgain.grid.kernal.processors.resource |
TODO.
|
| org.gridgain.grid.kernal.processors.session |
Session processing package to guarantee reuse of same session
object on the same node.
|
| org.gridgain.grid.kernal.processors.streamer |
TODO. |
| org.gridgain.grid.kernal.processors.task |
TODO.
|
| Modifier and Type | Method and Description |
|---|---|
GridDeployment |
GridTaskSessionImpl.deployment() |
| Constructor and Description |
|---|
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) |
| 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 |
GridDeploymentPerVersionStore.getDeployment(org.gridgain.grid.kernal.managers.deployment.GridDeploymentMetadata meta) |
GridDeployment |
GridDeploymentPerLoaderStore.getDeployment(org.gridgain.grid.kernal.managers.deployment.GridDeploymentMetadata meta) |
GridDeployment |
GridDeploymentStore.getDeployment(org.gridgain.grid.kernal.managers.deployment.GridDeploymentMetadata meta) |
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.getDeployment(String rsrcName) |
GridDeployment |
GridDeploymentManager.getGlobalDeployment(GridDeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
GridUuid clsLdrId,
Map<UUID,GridUuid> participants,
GridPredicate<GridNode> nodeFilter) |
GridDeployment |
GridDeploymentManager.getLocalDeployment(String rsrcName) |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridDeployment> |
GridDeploymentPerVersionStore.getDeployments() |
Collection<GridDeployment> |
GridDeploymentPerLoaderStore.getDeployments() |
Collection<GridDeployment> |
GridDeploymentStore.getDeployments() |
| Modifier and Type | Method and Description |
|---|---|
GridDeployment |
GridJobWorker.getDeployment() |
| Modifier and Type | Method and Description |
|---|---|
Collection<Method> |
GridResourceProcessor.getMethodsWithAnnotation(GridDeployment dep,
Class<?> rsrcCls,
Class<? extends Annotation> annCls)
Gets list of methods in specified class annotated with specified annotation.
|
void |
GridResourceProcessor.inject(GridDeployment dep,
Class<?> taskCls,
GridComputeJob job,
GridComputeTaskSession 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,
GridComputeTask<?,?> task,
GridTaskSessionImpl ses,
GridComputeLoadBalancer balancer,
GridComputeTaskContinuousMapper mapper)
Injects held resources into given grid task.
|
void |
GridResourceJobContextInjector.inject(org.gridgain.grid.kernal.processors.resource.GridResourceField field,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource into field.
|
void |
GridResourceLoggerInjector.inject(org.gridgain.grid.kernal.processors.resource.GridResourceField field,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource into field.
|
void |
GridResourceJobContextInjector.inject(org.gridgain.grid.kernal.processors.resource.GridResourceMethod mtd,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource with a setter method.
|
void |
GridResourceLoggerInjector.inject(org.gridgain.grid.kernal.processors.resource.GridResourceMethod mtd,
Object target,
Class<?> depCls,
GridDeployment dep)
Injects resource with a setter method.
|
void |
GridResourceProcessor.injectBasicResource(Object target,
Class<? extends Annotation> annCls,
Object rsrc,
GridDeployment dep,
Class<?> depCls)
This method is declared public as it is used from tests as well.
|
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.
|
void |
GridResourceProcessor.onUndeployed(GridDeployment dep)
Callback to be called when class loader is undeployed.
|
| 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) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridStreamerExecutionBatch.deployment(GridDeployment dep)
Sets deployment.
|
| 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.
|
Copyright © 2014. All rights reserved.