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

Class DefaultTaskService

java.lang.Object

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

All Implemented Interfaces:

TaskService

@Transactional
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, Thomas Risberg, Ilayaperumal Gopinathan

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, AppRegistryCommon registry, org.springframework.core.io.ResourceLoader resourceLoader, org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher, ApplicationConfigurationMetadataResolver metaDataResolver, TaskConfigurationProperties taskConfigurationProperties, DeploymentIdRepository deploymentIdRepository, String dataflowServerUri, CommonApplicationProperties commonApplicationProperties) 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.
void	deleteTaskDefinition(String name) Destroy the task definition.
long	executeTask(String taskName, Map<String,String> taskDeploymentProperties, List<String> commandLineArgs) Execute a task with the provided task name and optional runtime properties.
boolean	isComposedDefinition(String dsl) Determines if the DSL is a composed DSL definition.
void	saveTaskDefinition(String name, String dsl) Saves the task definition.

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,
                          AppRegistryCommon registry,
                          org.springframework.core.io.ResourceLoader resourceLoader,
                          org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher,
                          ApplicationConfigurationMetadataResolver metaDataResolver,
                          TaskConfigurationProperties taskConfigurationProperties,
                          DeploymentIdRepository deploymentIdRepository,
                          String dataflowServerUri,
                          CommonApplicationProperties commonApplicationProperties)

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.

metaDataResolver - the metadata resolver

taskConfigurationProperties - the properties used to define the behavior of tasks

deploymentIdRepository - the repository that maps deployment keys to IDs

dataflowServerUri - the data flow server URI

commonApplicationProperties - the common application properties

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.

isComposedDefinition

public boolean isComposedDefinition(String dsl)

Description copied from interface: TaskService

Determines if the DSL is a composed DSL definition.

Specified by:

isComposedDefinition in interface TaskService

Parameters:

dsl - the Task DSL to evaluate

Returns:

true if it is composed task definition else false.

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

Parameters:

id - the execution id

saveTaskDefinition

@Transactional
public void saveTaskDefinition(String name,
                                              String dsl)

Description copied from interface: TaskService

Saves the task definition. If it is a Composed Task then the task definitions required for a ComposedTaskRunner task are also created.

Specified by:

saveTaskDefinition in interface TaskService

Parameters:

name - The name of the task.

dsl - The dsl that comprises the task.

deleteTaskDefinition

public void deleteTaskDefinition(String name)

Description copied from interface: TaskService

Destroy the task definition. If it is a Composed Task then the task definitions required for a ComposedTaskRunner task are also destroyed.

Specified by:

deleteTaskDefinition in interface TaskService

Parameters:

name - The name of the task.