org.springframework.cloud.dataflow.aggregate.task.impl

Class DefaultAggregateExecutionSupport

java.lang.Object

org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateExecutionSupport

All Implemented Interfaces:

AggregateExecutionSupport

public class DefaultAggregateExecutionSupport
extends Object
implements AggregateExecutionSupport

Provides support for access to SchemaVersionTarget information and conversion of execution data to composite executions.

Author:

Corneil du Plessis

Constructor Summary

Constructors

Constructor and Description
DefaultAggregateExecutionSupport(AppRegistryService registryService, SchemaService schemaService)

Method Summary

Modifier and Type	Method and Description
org.springframework.cloud.dataflow.schema.SchemaVersionTarget	findSchemaVersionTarget(String taskName, String version, TaskDefinition taskDefinition)
org.springframework.cloud.dataflow.schema.SchemaVersionTarget	findSchemaVersionTarget(String taskName, String version, TaskDefinitionReader taskDefinitionReader)
org.springframework.cloud.dataflow.schema.SchemaVersionTarget	findSchemaVersionTarget(String taskName, TaskDefinition taskDefinition)
org.springframework.cloud.dataflow.schema.SchemaVersionTarget	findSchemaVersionTarget(String taskName, TaskDefinitionReader taskDefinitionReader) Retrieves the SchemaVersionTarget for the task name.
AppRegistration	findTaskAppRegistration(String registeredName) Retrieve the AppRegistration for the registeredName.
AppRegistration	findTaskAppRegistration(String registeredAppName, String version)
org.springframework.cloud.dataflow.schema.AggregateTaskExecution	from(org.springframework.cloud.task.repository.TaskExecution execution, String schemaTarget, String platformName) Return the AggregateTaskExecution for the TaskExecution and Schema Target name specified.
org.springframework.cloud.dataflow.schema.AggregateTaskExecution	from(org.springframework.cloud.task.repository.TaskExecution execution, TaskDefinitionReader taskDefinitionReader, TaskDeploymentReader taskDeploymentReader) Retrieves the AggregateTaskExecution for the task execution and TaskDefinitionReader provided.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultAggregateExecutionSupport

public DefaultAggregateExecutionSupport(AppRegistryService registryService,
                                        SchemaService schemaService)

Method Detail

from

public org.springframework.cloud.dataflow.schema.AggregateTaskExecution from(org.springframework.cloud.task.repository.TaskExecution execution,
                                                                             TaskDefinitionReader taskDefinitionReader,
                                                                             TaskDeploymentReader taskDeploymentReader)

Description copied from interface: AggregateExecutionSupport

Retrieves the AggregateTaskExecution for the task execution and TaskDefinitionReader provided.

Specified by:

from in interface AggregateExecutionSupport

Parameters:

execution - A TaskExecution that contains the TaskName that will be used to find the AggregateTaskExecution.

taskDefinitionReader - TaskDefinitionReader that will be used to find the SchemaVersionTarget for the task execution.

taskDeploymentReader - TaskDeploymentReader will be used to read the deployment.

Returns:

The AggregateTaskExecution containing the SchemaVersionTarget for the TaskExecution.

findSchemaVersionTarget

public org.springframework.cloud.dataflow.schema.SchemaVersionTarget findSchemaVersionTarget(String taskName,
                                                                                             TaskDefinitionReader taskDefinitionReader)

Description copied from interface: AggregateExecutionSupport

Retrieves the SchemaVersionTarget for the task name.

Specified by:

findSchemaVersionTarget in interface AggregateExecutionSupport

Parameters:

taskName - The name of the TaskDefinition from which the SchemaVersionTarget will be retreived.

taskDefinitionReader - TaskDefinitionReader that will be used to find the SchemaVersionTarget

Returns:

The SchemaVersionTarget for the taskName specified.

findSchemaVersionTarget

public org.springframework.cloud.dataflow.schema.SchemaVersionTarget findSchemaVersionTarget(String taskName,
                                                                                             String version,
                                                                                             TaskDefinitionReader taskDefinitionReader)

Specified by:

findSchemaVersionTarget in interface AggregateExecutionSupport

findSchemaVersionTarget

public org.springframework.cloud.dataflow.schema.SchemaVersionTarget findSchemaVersionTarget(String taskName,
                                                                                             TaskDefinition taskDefinition)

Specified by:

findSchemaVersionTarget in interface AggregateExecutionSupport

findSchemaVersionTarget

public org.springframework.cloud.dataflow.schema.SchemaVersionTarget findSchemaVersionTarget(String taskName,
                                                                                             String version,
                                                                                             TaskDefinition taskDefinition)

Specified by:

findSchemaVersionTarget in interface AggregateExecutionSupport

findTaskAppRegistration

public AppRegistration findTaskAppRegistration(String registeredName)

Description copied from interface: AggregateExecutionSupport

Retrieve the AppRegistration for the registeredName.

Specified by:

findTaskAppRegistration in interface AggregateExecutionSupport

Parameters:

registeredName - Registered name for registration to find.

Returns:

The application registration

findTaskAppRegistration

public AppRegistration findTaskAppRegistration(String registeredAppName,
                                               String version)

Specified by:

findTaskAppRegistration in interface AggregateExecutionSupport

from

public org.springframework.cloud.dataflow.schema.AggregateTaskExecution from(org.springframework.cloud.task.repository.TaskExecution execution,
                                                                             String schemaTarget,
                                                                             String platformName)

Description copied from interface: AggregateExecutionSupport

Return the AggregateTaskExecution for the TaskExecution and Schema Target name specified.

Specified by:

from in interface AggregateExecutionSupport

Parameters:

execution - The task execution

schemaTarget - The schemaTarget of the task execution

platformName - The platform name of the task execution

Returns:

The task execution