A C D E G I J M O P R S T V

A

afterStep(StepExecution) - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskStepExecutionListener

If endTime for task is null then the ExitStatus will be set to UNKNOWN.

C

ComposedBatchConfigurer - Class in org.springframework.cloud.task.app.composedtaskrunner

A BatchConfigurer for CTR that will establish the transaction isolation lavel to READ_COMMITTED.

ComposedBatchConfigurer(BatchProperties, DataSource, TransactionManagerCustomizers) - Constructor for class org.springframework.cloud.task.app.composedtaskrunner.ComposedBatchConfigurer

Create a new BasicBatchConfigurer instance.

ComposedRunnerJobFactory - Class in org.springframework.cloud.task.app.composedtaskrunner

Genererates a Composed Task Job Flow.

ComposedRunnerJobFactory(ComposedTaskProperties) - Constructor for class org.springframework.cloud.task.app.composedtaskrunner.ComposedRunnerJobFactory

ComposedRunnerVisitor - Class in org.springframework.cloud.task.app.composedtaskrunner

Creates a stack of task executions from a composed task DSL.

ComposedRunnerVisitor() - Constructor for class org.springframework.cloud.task.app.composedtaskrunner.ComposedRunnerVisitor

composedTaskJob() - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskRunnerConfiguration

ComposedTaskProperties - Class in org.springframework.cloud.task.app.composedtaskrunner.properties

Configuration properties used to setup the ComposedTaskRunner.

ComposedTaskProperties() - Constructor for class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

ComposedTaskRunner - Class in org.springframework.cloud.task.app.composedtaskrunner

Accepts a composed task DSL via the command line args and executes the tasks based on the DSL.

ComposedTaskRunner() - Constructor for class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskRunner

ComposedTaskRunnerConfiguration - Class in org.springframework.cloud.task.app.composedtaskrunner

Configures the Job that will execute the Composed Task Execution.

ComposedTaskRunnerConfiguration() - Constructor for class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskRunnerConfiguration

ComposedTaskRunnerStepFactory - Class in org.springframework.cloud.task.app.composedtaskrunner

FactoryBean that creates a Spring Batch Step that executes a configured TaskLaunchTasklet.

ComposedTaskRunnerStepFactory(ComposedTaskProperties, String) - Constructor for class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskRunnerStepFactory

composedTaskStepExecutionListener(TaskExplorer) - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskRunnerConfiguration

ComposedTaskStepExecutionListener - Class in org.springframework.cloud.task.app.composedtaskrunner

Listener for the TaskLauncherTasklet that waits for the task to complete and sets the appropriate result for this step based on the launched task exit code.

ComposedTaskStepExecutionListener(TaskExplorer) - Constructor for class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskStepExecutionListener

D

DataFlowConfiguration - Class in org.springframework.cloud.task.app.composedtaskrunner

Configures the beans required for Connectivity to the Data Flow Server.

DataFlowConfiguration() - Constructor for class org.springframework.cloud.task.app.composedtaskrunner.DataFlowConfiguration

dataFlowOperations(ClientRegistrationRepository, OAuth2AccessTokenResponseClient<OAuth2ClientCredentialsGrantRequest>) - Method in class org.springframework.cloud.task.app.composedtaskrunner.DataFlowConfiguration

determineIsolationLevel() - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedBatchConfigurer

E

execute(StepContribution, ChunkContext) - Method in class org.springframework.cloud.task.app.composedtaskrunner.TaskLauncherTasklet

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

G

getComposedBatchConfigurer(BatchProperties, DataSource, TransactionManagerCustomizers) - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskRunnerConfiguration

getComposedTaskArguments() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getComposedTaskProperties() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getDataflowServerAccessToken() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getDataflowServerPassword() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getDataflowServerUri() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getDataflowServerUsername() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getFlow() - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedRunnerVisitor

getFormat() - Method in class org.springframework.cloud.task.app.timestamp.batch.TimestampBatchTaskProperties

getFormat() - Method in class org.springframework.cloud.task.app.timestamp.TimestampTaskProperties

getGraph() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getIntervalTimeBetweenChecks() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getMatchOutcome(ConditionContext, AnnotatedTypeMetadata) - Method in class org.springframework.cloud.task.app.composedtaskrunner.support.OnOAuth2ClientCredentialsEnabled

getMaxWaitTime() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getOauth2ClientCredentialsClientId() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getOauth2ClientCredentialsClientSecret() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getOauth2ClientCredentialsScopes() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getOauth2ClientCredentialsTokenUri() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getObject() - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedRunnerJobFactory

getObject() - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskRunnerStepFactory

getObjectType() - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedRunnerJobFactory

getObjectType() - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskRunnerStepFactory

getSplitThreadCorePoolSize() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getSplitThreadKeepAliveSeconds() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getSplitThreadMaxPoolSize() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

getSplitThreadQueueCapacity() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

I

INTERVAL_TIME_BETWEEN_CHECKS_DEFAULT - Static variable in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

isIncrementInstanceEnabled() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

isSingleton() - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedRunnerJobFactory

isSingleton() - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskRunnerStepFactory

isSplitThreadAllowCoreThreadTimeout() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

isSplitThreadWaitForTasksToCompleteOnShutdown() - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

J

job1() - Method in class org.springframework.cloud.task.app.timestamp.batch.TimestampBatchTaskConfiguration

job2() - Method in class org.springframework.cloud.task.app.timestamp.batch.TimestampBatchTaskConfiguration

jobBuilderFactory - Variable in class org.springframework.cloud.task.app.timestamp.batch.TimestampBatchTaskConfiguration

M

main(String[]) - Static method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskRunner

MAX_WAIT_TIME_DEFAULT - Static variable in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

O

OnOAuth2ClientCredentialsEnabled - Class in org.springframework.cloud.task.app.composedtaskrunner.support

Condition that is only valid if the property oauth2-client-credentials exists.

OnOAuth2ClientCredentialsEnabled() - Constructor for class org.springframework.cloud.task.app.composedtaskrunner.support.OnOAuth2ClientCredentialsEnabled

org.springframework.cloud.task.app.composedtaskrunner - package org.springframework.cloud.task.app.composedtaskrunner

org.springframework.cloud.task.app.composedtaskrunner.properties - package org.springframework.cloud.task.app.composedtaskrunner.properties

org.springframework.cloud.task.app.composedtaskrunner.support - package org.springframework.cloud.task.app.composedtaskrunner.support

org.springframework.cloud.task.app.timestamp - package org.springframework.cloud.task.app.timestamp

org.springframework.cloud.task.app.timestamp.batch - package org.springframework.cloud.task.app.timestamp.batch

P

postVisit(SplitNode) - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedRunnerVisitor

Push the split node on the stack to record the Ending of the split.

preVisit(FlowNode) - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedRunnerVisitor

Push the flow node on the stack to record the beginning of the flow.

R

registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class org.springframework.cloud.task.app.composedtaskrunner.StepBeanDefinitionRegistrar

run(String...) - Method in class org.springframework.cloud.task.app.timestamp.TimestampTaskConfiguration.TimestampTask

S

setArguments(List<String>) - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskRunnerStepFactory

setArguments(List<String>) - Method in class org.springframework.cloud.task.app.composedtaskrunner.TaskLauncherTasklet

setComposedTaskArguments(String) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setComposedTaskProperties(String) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setDataflowServerAccessToken(String) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setDataflowServerPassword(String) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setDataflowServerUri(URI) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setDataflowServerUsername(String) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setEnvironment(Environment) - Method in class org.springframework.cloud.task.app.composedtaskrunner.StepBeanDefinitionRegistrar

setFormat(String) - Method in class org.springframework.cloud.task.app.timestamp.batch.TimestampBatchTaskProperties

setFormat(String) - Method in class org.springframework.cloud.task.app.timestamp.TimestampTaskProperties

setGraph(String) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setIncrementInstanceEnabled(boolean) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setIntervalTimeBetweenChecks(int) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setMaxWaitTime(int) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setOauth2ClientCredentialsClientId(String) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setOauth2ClientCredentialsClientSecret(String) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setOauth2ClientCredentialsScopes(Set<String>) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setOauth2ClientCredentialsTokenUri(String) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setProperties(Map<String, String>) - Method in class org.springframework.cloud.task.app.composedtaskrunner.TaskLauncherTasklet

setSplitThreadAllowCoreThreadTimeout(boolean) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setSplitThreadCorePoolSize(int) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setSplitThreadKeepAliveSeconds(int) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setSplitThreadMaxPoolSize(int) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setSplitThreadQueueCapacity(int) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setSplitThreadWaitForTasksToCompleteOnShutdown(boolean) - Method in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

setTaskSpecificProps(Map<String, String>) - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskRunnerStepFactory

SPLIT_THREAD_CORE_POOL_SIZE_DEFAULT - Static variable in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

SPLIT_THREAD_KEEP_ALIVE_SECONDS_DEFAULT - Static variable in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

SPLIT_THREAD_MAX_POOL_SIZE_DEFAULT - Static variable in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

SPLIT_THREAD_QUEUE_CAPACITY_DEFAULT - Static variable in class org.springframework.cloud.task.app.composedtaskrunner.properties.ComposedTaskProperties

StepBeanDefinitionRegistrar - Class in org.springframework.cloud.task.app.composedtaskrunner

Creates the Steps necessary to execute the directed graph of a Composed Task.

StepBeanDefinitionRegistrar() - Constructor for class org.springframework.cloud.task.app.composedtaskrunner.StepBeanDefinitionRegistrar

stepBuilderFactory - Variable in class org.springframework.cloud.task.app.timestamp.batch.TimestampBatchTaskConfiguration

T

TaskExecutionTimeoutException - Exception in org.springframework.cloud.task.app.composedtaskrunner.support

Exception thrown when a task execution exceeds the configured ComposedTaskProperties.getMaxWaitTime().

TaskExecutionTimeoutException(String) - Constructor for exception org.springframework.cloud.task.app.composedtaskrunner.support.TaskExecutionTimeoutException

TaskExecutionTimeoutException(String, Throwable) - Constructor for exception org.springframework.cloud.task.app.composedtaskrunner.support.TaskExecutionTimeoutException

taskExecutor() - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedTaskRunnerConfiguration

TaskLauncherTasklet - Class in org.springframework.cloud.task.app.composedtaskrunner

Executes task launch request using Spring Cloud Data Flow's Restful API then returns the execution id once the task launched.

TaskLauncherTasklet(TaskOperations, TaskExplorer, ComposedTaskProperties, String, TaskProperties) - Constructor for class org.springframework.cloud.task.app.composedtaskrunner.TaskLauncherTasklet

taskOperations(DataFlowOperations) - Method in class org.springframework.cloud.task.app.composedtaskrunner.DataFlowConfiguration

TimestampBatchTaskConfiguration - Class in org.springframework.cloud.task.app.timestamp.batch

A batch application that runs 2 jobs and for each job prints a Job name and timestamp.

TimestampBatchTaskConfiguration() - Constructor for class org.springframework.cloud.task.app.timestamp.batch.TimestampBatchTaskConfiguration

TimestampBatchTaskProperties - Class in org.springframework.cloud.task.app.timestamp.batch

TimestampBatchTaskProperties() - Constructor for class org.springframework.cloud.task.app.timestamp.batch.TimestampBatchTaskProperties

timeStampTask() - Method in class org.springframework.cloud.task.app.timestamp.TimestampTaskConfiguration

TimestampTask() - Constructor for class org.springframework.cloud.task.app.timestamp.TimestampTaskConfiguration.TimestampTask

TimestampTaskConfiguration - Class in org.springframework.cloud.task.app.timestamp

A commandline runner that prints a timestamp.

TimestampTaskConfiguration() - Constructor for class org.springframework.cloud.task.app.timestamp.TimestampTaskConfiguration

TimestampTaskConfiguration.TimestampTask - Class in org.springframework.cloud.task.app.timestamp

A commandline runner that prints a timestamp.

TimestampTaskProperties - Class in org.springframework.cloud.task.app.timestamp

TimestampTaskProperties() - Constructor for class org.springframework.cloud.task.app.timestamp.TimestampTaskProperties

V

visit(SplitNode) - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedRunnerVisitor

Push the split node on the stack to record the beginning of the split.

visit(TaskAppNode) - Method in class org.springframework.cloud.task.app.composedtaskrunner.ComposedRunnerVisitor

Push the task app node on the stack to record the task app.

A C D E G I J M O P R S T V