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

A

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

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

C

camelCaseToHyphenLower(String) - Static method in class org.springframework.cloud.dataflow.composedtaskrunner.RelaxedNames

CfServiceBindingPropertySourceInitializer - Class in org.springframework.cloud.dataflow.composedtaskrunner.support

If the composed task runner is running on Cloud Foundry and is bound to a service instance from SCDF for VMware Tanzu, use the values from the service binding credentials to configure the composed task runner.

CfServiceBindingPropertySourceInitializer() - Constructor for class org.springframework.cloud.dataflow.composedtaskrunner.support.CfServiceBindingPropertySourceInitializer

clientRegistrationRepository(ComposedTaskProperties) - Method in class org.springframework.cloud.dataflow.composedtaskrunner.DataFlowConfiguration

ComposedBatchConfigurer - Class in org.springframework.cloud.dataflow.composedtaskrunner

A BatchConfigurer for CTR that will establish the transaction isolation level to ISOLATION_REPEATABLE_READ by default.

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

Create a new BasicBatchConfigurer instance.

ComposedRunnerJobFactory - Class in org.springframework.cloud.dataflow.composedtaskrunner

Genererates a Composed Task Job Flow.

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

ComposedRunnerJobFactory.UuidIncrementer - Class in org.springframework.cloud.dataflow.composedtaskrunner

ComposedRunnerVisitor - Class in org.springframework.cloud.dataflow.composedtaskrunner

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

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

ComposedTaskException - Exception in org.springframework.cloud.dataflow.composedtaskrunner.support

ComposedTaskException(String) - Constructor for exception org.springframework.cloud.dataflow.composedtaskrunner.support.ComposedTaskException

composedTaskJob(ComposedTaskProperties) - Method in class org.springframework.cloud.dataflow.composedtaskrunner.ComposedTaskRunnerConfiguration

ComposedTaskProperties - Class in org.springframework.cloud.dataflow.composedtaskrunner.properties

Configuration properties used to setup the ComposedTaskRunner.

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

ComposedTaskRunner - Class in org.springframework.cloud.dataflow.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.dataflow.composedtaskrunner.ComposedTaskRunner

ComposedTaskRunnerConfiguration - Class in org.springframework.cloud.dataflow.composedtaskrunner

Configures the Job that will execute the Composed Task Execution.

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

ComposedTaskRunnerStepFactory - Class in org.springframework.cloud.dataflow.composedtaskrunner

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

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

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

ComposedTaskStepExecutionListener - Class in org.springframework.cloud.dataflow.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.dataflow.composedtaskrunner.ComposedTaskStepExecutionListener

createJobRepository() - Method in class org.springframework.cloud.dataflow.composedtaskrunner.ComposedBatchConfigurer

D

DataFlowConfiguration - Class in org.springframework.cloud.dataflow.composedtaskrunner

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

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

dataFlowOperations() - Method in class org.springframework.cloud.dataflow.composedtaskrunner.TaskLauncherTasklet

E

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

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

F

forCamelCase(String) - Static method in class org.springframework.cloud.dataflow.composedtaskrunner.RelaxedNames

Return a RelaxedNames for the given source camelCase source name.

G

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

getComposedTaskAppArguments() - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

getComposedTaskAppProperties() - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

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

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

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

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

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

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

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

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

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

getJobRepository() - Method in class org.springframework.cloud.dataflow.composedtaskrunner.ComposedBatchConfigurer

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

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

getNext(JobParameters) - Method in class org.springframework.cloud.dataflow.composedtaskrunner.ComposedRunnerJobFactory.UuidIncrementer

getOauth2ClientCredentialsClientAuthenticationMethod() - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

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

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

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

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

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

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

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

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

getParentTaskExecutionId(StepContribution) - Method in class org.springframework.cloud.dataflow.composedtaskrunner.TaskLauncherTasklet

getPlatformName() - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

getSequenceQuery() - Method in class org.springframework.cloud.dataflow.composedtaskrunner.support.SqlServerSequenceMaxValueIncrementer

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

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

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

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

getTransactionIsolationLevel() - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

I

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

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

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

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

isSkipTlsCertificateVerification() - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

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

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

isUuidInstanceEnabled() - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

iterator() - Method in class org.springframework.cloud.dataflow.composedtaskrunner.RelaxedNames

M

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

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

O

onApplicationEvent(ApplicationEnvironmentPreparedEvent) - Method in class org.springframework.cloud.dataflow.composedtaskrunner.support.CfServiceBindingPropertySourceInitializer

OnOAuth2ClientCredentialsEnabled - Class in org.springframework.cloud.dataflow.composedtaskrunner.support

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

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

org.springframework.cloud.dataflow.composedtaskrunner - package org.springframework.cloud.dataflow.composedtaskrunner

Root package for Spring Cloud Data Flow Composed Task Runner application.

org.springframework.cloud.dataflow.composedtaskrunner.properties - package org.springframework.cloud.dataflow.composedtaskrunner.properties

org.springframework.cloud.dataflow.composedtaskrunner.support - package org.springframework.cloud.dataflow.composedtaskrunner.support

P

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

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

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

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

PROPERTY_SOURCE_NAME - Static variable in class org.springframework.cloud.dataflow.composedtaskrunner.support.CfServiceBindingPropertySourceInitializer

R

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

RelaxedNames - Class in org.springframework.cloud.dataflow.composedtaskrunner

Generates relaxed name variations from a given source.

RelaxedNames(String) - Constructor for class org.springframework.cloud.dataflow.composedtaskrunner.RelaxedNames

Create a new RelaxedNames instance.

S

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

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

setComposedTaskAppArguments(Map<String, String>) - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

setComposedTaskAppProperties(Map<String, String>) - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

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

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

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

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

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

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

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

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

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

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

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

setOauth2ClientCredentialsClientAuthenticationMethod(ClientAuthenticationMethod) - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

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

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

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

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

setPlatformName(String) - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

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

setSkipTlsCertificateVerification(boolean) - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

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

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

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

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

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

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

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

setTransactionIsolationLevel(String) - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

setUuidInstanceEnabled(boolean) - Method in class org.springframework.cloud.dataflow.composedtaskrunner.properties.ComposedTaskProperties

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

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

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

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

SqlServerSequenceMaxValueIncrementer - Class in org.springframework.cloud.dataflow.composedtaskrunner.support

Incrementer using SQL Server's sequence.

SqlServerSequenceMaxValueIncrementer(DataSource, String) - Constructor for class org.springframework.cloud.dataflow.composedtaskrunner.support.SqlServerSequenceMaxValueIncrementer

StepBeanDefinitionRegistrar - Class in org.springframework.cloud.dataflow.composedtaskrunner

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

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

T

TaskExecutionTimeoutException - Exception in org.springframework.cloud.dataflow.composedtaskrunner.support

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

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

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

taskExecutor(ComposedTaskProperties) - Method in class org.springframework.cloud.dataflow.composedtaskrunner.ComposedTaskRunnerConfiguration

TaskLauncherTasklet - Class in org.springframework.cloud.dataflow.composedtaskrunner

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

TaskLauncherTasklet(ClientRegistrationRepository, OAuth2AccessTokenResponseClient<OAuth2ClientCredentialsGrantRequest>, TaskExplorer, ComposedTaskProperties, String, TaskProperties) - Constructor for class org.springframework.cloud.dataflow.composedtaskrunner.TaskLauncherTasklet

taskOperations() - Method in class org.springframework.cloud.dataflow.composedtaskrunner.TaskLauncherTasklet

U

UuidIncrementer() - Constructor for class org.springframework.cloud.dataflow.composedtaskrunner.ComposedRunnerJobFactory.UuidIncrementer

V

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

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

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

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

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