Package org.springframework.cloud.task.batch.partition

Class TaskLauncherHandler

java.lang.Object

org.springframework.cloud.task.batch.partition.TaskLauncherHandler

All Implemented Interfaces:

Runnable

public class TaskLauncherHandler
extends Object
implements Runnable

Supports the launching of partitions.

Author:

Glenn Renfro

Constructor Summary

Constructors

Constructor	Description
TaskLauncherHandler(CommandLineArgsProvider commandLineArgsProvider, TaskRepository taskRepository, boolean defaultArgsAsEnvironmentVars, String stepName, TaskExecution taskExecution, EnvironmentVariablesProvider environmentVariablesProvider, org.springframework.core.io.Resource resource, Map<String,String> deploymentProperties, org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher, String applicationName)
TaskLauncherHandler(CommandLineArgsProvider commandLineArgsProvider, TaskRepository taskRepository, boolean defaultArgsAsEnvironmentVars, String stepName, TaskExecution taskExecution, EnvironmentVariablesProvider environmentVariablesProvider, org.springframework.core.io.Resource resource, Map<String,String> deploymentProperties, org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher, String applicationName, org.springframework.batch.core.StepExecution workerStepExecution)

Method Summary

Modifier and Type	Method	Description
void	launchWorker(org.springframework.batch.core.StepExecution workerStepExecution)	Launches the partition for the StepExecution.
void	run()

Methods inherited from class java.lang.Object

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

Constructor Details

TaskLauncherHandler

public TaskLauncherHandler(CommandLineArgsProvider commandLineArgsProvider,
 TaskRepository taskRepository,
 boolean defaultArgsAsEnvironmentVars,
 String stepName,
 TaskExecution taskExecution,
 EnvironmentVariablesProvider environmentVariablesProvider,
 org.springframework.core.io.Resource resource,
 Map<String,String> deploymentProperties,
 org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher,
 String applicationName,
 org.springframework.batch.core.StepExecution workerStepExecution)

Parameters:

commandLineArgsProvider - The CommandLineArgsProvider that provides command line arguments passed to each partition's execution.

taskRepository - The TaskRepository task repository for launching the partition.

defaultArgsAsEnvironmentVars - - If set to true, the default args that are used internally by Spring Cloud Task and Spring Batch are passed as environment variables instead of command line arguments.

stepName - The name of the step.

taskExecution - The TaskExecution to be associated with the partition.

environmentVariablesProvider - EnvironmentVariablesProvider that provides the environmennt variables.

resource - The Resource to be launched.

deploymentProperties - The Map containing the deployment properties for the partition.

taskLauncher - TaskLauncher that is used to launch the partition.

applicationName - The name to be associated with task.

workerStepExecution - The StepExecution for the paritition.

TaskLauncherHandler

public TaskLauncherHandler(CommandLineArgsProvider commandLineArgsProvider,
 TaskRepository taskRepository,
 boolean defaultArgsAsEnvironmentVars,
 String stepName,
 TaskExecution taskExecution,
 EnvironmentVariablesProvider environmentVariablesProvider,
 org.springframework.core.io.Resource resource,
 Map<String,String> deploymentProperties,
 org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher,
 String applicationName)

Parameters:

commandLineArgsProvider - The CommandLineArgsProvider that provides command line arguments passed to each partition's execution.

taskRepository - The TaskRepository task repository for launching the partition.

defaultArgsAsEnvironmentVars - - If set to true, the default args that are used internally by Spring Cloud Task and Spring Batch are passed as environment variables instead of command line arguments.

stepName - The name of the step.

taskExecution - The TaskExecution to be associated with the partition.

environmentVariablesProvider - EnvironmentVariablesProvider that provides the environmennt variables.

resource - The Resource to be launched.

deploymentProperties - The Map containing the deployment properties for the partition.

taskLauncher - TaskLauncher that is used to launch the partition.

applicationName - The name to be associated with task.

Method Details

run

public void run()

Specified by:

run in interface Runnable

launchWorker

public void launchWorker(org.springframework.batch.core.StepExecution workerStepExecution)

Launches the partition for the StepExecution.

Parameters:

workerStepExecution - The StepExecution