org.springframework.cloud.dataflow.aggregate.task

Interface AggregateExecutionSupport

All Known Implementing Classes:

DefaultAggregateExecutionSupport

public interface AggregateExecutionSupport

Allows users to retrieve Task execution and SchemaVersion information from either TaskExecution as well as Task Name.

Author:

Corneil du Plessis

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 registeredName, 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.

Method Detail

from

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.

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

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

Retrieves the SchemaVersionTarget for the task name.

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

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

findSchemaVersionTarget

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

findSchemaVersionTarget

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

findTaskAppRegistration

AppRegistration findTaskAppRegistration(String registeredName)

Retrieve the AppRegistration for the registeredName.

Parameters:

registeredName - Registered name for registration to find.

Returns:

The application registration

findTaskAppRegistration

AppRegistration findTaskAppRegistration(String registeredName,
                                        String version)

from

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.

Parameters:

execution - The task execution

schemaTarget - The schemaTarget of the task execution

platformName - The platform name of the task execution

Returns:

The task execution