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 repository, DeploymentIdRepository deploymentIdRepository, org.springframework.cloud.deployer.resource.registry.UriRegistry 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	executeTask(String taskName, Map<String,String> runtimeProperties, List<String> runtimeParams) 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 repository,
                          DeploymentIdRepository deploymentIdRepository,
                          org.springframework.cloud.deployer.resource.registry.UriRegistry registry,
                          ResourceLoader resourceLoader,
                          org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher,
                          ApplicationConfigurationMetadataResolver metaDataResolver)

Initializes the DefaultTaskService.

Parameters:

dataSourceProperties - the data source properties.

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

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

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 void executeTask(String taskName,
                        Map<String,String> runtimeProperties,
                        List<String> runtimeParams)

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.

runtimeProperties - Optional runtime properties. Must not be null.

runtimeParams - Optional runtime commandline arguments