org.springframework.cloud.dataflow.server.service.impl

Class DefaultTaskService

java.lang.Object

org.springframework.cloud.dataflow.server.service.impl.DefaultTaskService

All Implemented Interfaces:

TaskService

public class DefaultTaskService
extends Object
implements TaskService

Default implementation of the TaskService interface. Provide service methods for Tasks.

Author:

Michael Minella, Marius Bogoevici, Glenn Renfro, Mark Fisher, Janne Valkealahti, Gunnar Hillert

Constructor Summary

Constructors

Constructor and Description

DefaultTaskService(org.springframework.boot.autoconfigure.jdbc.DataSourceProperties dataSourceProperties, TaskDefinitionRepository taskDefinitionRepository, org.springframework.cloud.task.repository.TaskExplorer taskExplorer, org.springframework.cloud.task.repository.TaskRepository taskExecutionRepository, AppRegistry registry, ResourceLoader resourceLoader, org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher, ApplicationConfigurationMetadataResolver metaDataResolver) Initializes the DefaultTaskService.

Method Summary

Modifier and Type	Method and Description
void	cleanupExecution(long id) Cleanup the resources that resulted from running the task with the given execution id.
long	executeTask(String taskName, Map<String,String> taskDeploymentProperties, List<String> commandLineArgs) Execute a task with the provided task name and optional runtime properties.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTaskService

public DefaultTaskService(org.springframework.boot.autoconfigure.jdbc.DataSourceProperties dataSourceProperties,
                          TaskDefinitionRepository taskDefinitionRepository,
                          org.springframework.cloud.task.repository.TaskExplorer taskExplorer,
                          org.springframework.cloud.task.repository.TaskRepository taskExecutionRepository,
                          AppRegistry registry,
                          ResourceLoader resourceLoader,
                          org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher,
                          ApplicationConfigurationMetadataResolver metaDataResolver)

Initializes the DefaultTaskService.

Parameters:

dataSourceProperties - the data source properties.

taskDefinitionRepository - the TaskDefinitionRepository this service will use for task CRUD operations.

taskExecutionRepository - the repository this service will use for deployment IDs.

taskExplorer - the explorer this service will use to lookup task executions

registry - URI registry this service will use to look up app URIs.

resourceLoader - the ResourceLoader that will resolve URIs to Resources.

taskLauncher - the launcher this service will use to launch task apps.

Method Detail

executeTask

public long executeTask(String taskName,
                        Map<String,String> taskDeploymentProperties,
                        List<String> commandLineArgs)

Description copied from interface: TaskService

Execute a task with the provided task name and optional runtime properties.

Specified by:

executeTask in interface TaskService

Parameters:

taskName - Name of the task. Must not be null or empty.

taskDeploymentProperties - Optional deployment properties. Must not be null.

commandLineArgs - Optional runtime commandline arguments

Returns:

the taskExecutionId for the executed task.

cleanupExecution

public void cleanupExecution(long id)

Description copied from interface: TaskService

Cleanup the resources that resulted from running the task with the given execution id.

Specified by:

cleanupExecution in interface TaskService