org.springframework.cloud.dataflow.composedtaskrunner

Class TaskLauncherTasklet

java.lang.Object

org.springframework.cloud.dataflow.composedtaskrunner.TaskLauncherTasklet

All Implemented Interfaces:

org.springframework.batch.core.step.tasklet.Tasklet

public class TaskLauncherTasklet
extends Object
implements org.springframework.batch.core.step.tasklet.Tasklet

Executes task launch request using Spring Cloud Data Flow's Restful API then returns the execution id once the task launched. Note: This class is not thread-safe and as such should not be used as a singleton.

Author:

Glenn Renfro

Constructor Summary

Constructors

Constructor and Description

TaskLauncherTasklet(org.springframework.security.oauth2.client.registration.ClientRegistrationRepository clientRegistrations, org.springframework.security.oauth2.client.endpoint.OAuth2AccessTokenResponseClient<org.springframework.security.oauth2.client.endpoint.OAuth2ClientCredentialsGrantRequest> clientCredentialsTokenResponseClient, org.springframework.cloud.task.repository.TaskExplorer taskExplorer, ComposedTaskProperties composedTaskProperties, String taskName, org.springframework.cloud.task.configuration.TaskProperties taskProperties)

Method Summary

Modifier and Type	Method and Description
protected DataFlowOperations	dataFlowOperations()
org.springframework.batch.repeat.RepeatStatus	execute(org.springframework.batch.core.StepContribution contribution, org.springframework.batch.core.scope.context.ChunkContext chunkContext) Executes the task as specified by the taskName with the associated properties and arguments.
String	getParentTaskExecutionId(org.springframework.batch.core.StepContribution stepContribution)
void	setArguments(List<String> arguments)
void	setProperties(Map<String,String> properties)
TaskOperations	taskOperations()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskLauncherTasklet

public TaskLauncherTasklet(org.springframework.security.oauth2.client.registration.ClientRegistrationRepository clientRegistrations,
                           org.springframework.security.oauth2.client.endpoint.OAuth2AccessTokenResponseClient<org.springframework.security.oauth2.client.endpoint.OAuth2ClientCredentialsGrantRequest> clientCredentialsTokenResponseClient,
                           org.springframework.cloud.task.repository.TaskExplorer taskExplorer,
                           ComposedTaskProperties composedTaskProperties,
                           String taskName,
                           org.springframework.cloud.task.configuration.TaskProperties taskProperties)

Method Detail

setProperties

public void setProperties(Map<String,String> properties)

setArguments

public void setArguments(List<String> arguments)

execute

public org.springframework.batch.repeat.RepeatStatus execute(org.springframework.batch.core.StepContribution contribution,
                                                             org.springframework.batch.core.scope.context.ChunkContext chunkContext)

Executes the task as specified by the taskName with the associated properties and arguments.

Specified by:

execute in interface org.springframework.batch.core.step.tasklet.Tasklet

Parameters:

contribution - mutable state to be passed back to update the current step execution

chunkContext - contains the task-execution-id used by the listener.

Returns:

Repeat status of FINISHED.

getParentTaskExecutionId

public String getParentTaskExecutionId(org.springframework.batch.core.StepContribution stepContribution)

taskOperations

public TaskOperations taskOperations()

dataFlowOperations

protected DataFlowOperations dataFlowOperations()

Returns:

new instance of DataFlowOperations