public class TaskServiceUtils extends Object
Constructor and Description |
---|
TaskServiceUtils() |
Modifier and Type | Method and Description |
---|---|
static String |
createComposedTaskDefinition(String alternateComposedTaskRunnerName,
String graph,
TaskConfigurationProperties taskConfigurationProperties)
Creates a properly formatted CTR definition based on the graph provided.
|
static String |
createComposedTaskDefinition(String graph,
TaskConfigurationProperties taskConfigurationProperties)
Creates a properly formatted CTR definition based on the graph provided.
|
static Map<String,String> |
establishComposedTaskProperties(Map<String,String> taskDeploymentProperties,
org.springframework.cloud.dataflow.core.dsl.TaskNode taskNode)
Establish the app and deployment properties to be used for a CTR.
|
static Map<String,String> |
extractAppProperties(String name,
Map<String,String> taskDeploymentProperties)
Extract app properties from the deployment properties by task name.
|
static boolean |
isComposedTaskDefinition(String dsl)
Parses the task DSL to see if it is a composed task definition
|
static org.springframework.cloud.deployer.spi.core.AppDefinition |
mergeAndExpandAppProperties(TaskDefinition original,
org.springframework.core.io.Resource resource,
Map<String,String> appDeploymentProperties,
WhitelistProperties whitelistProperties)
Return a copy of a given task definition where short form parameters have been expanded
to their long form (amongst the whitelisted supported properties of the app) if
applicable.
|
static void |
updateDataFlowUriIfNeeded(String dataflowServerUri,
Map<String,String> appDeploymentProperties,
List<String> commandLineArgs) |
static void |
updateDataFlowUriIfNeeded(String dataFlowServerUriKey,
String dataflowServerUri,
Map<String,String> appDeploymentProperties,
List<String> commandLineArgs) |
static TaskDefinition |
updateTaskProperties(TaskDefinition taskDefinition,
org.springframework.boot.autoconfigure.jdbc.DataSourceProperties dataSourceProperties)
Updates the task definition with the datasource properties.
|
public static boolean isComposedTaskDefinition(String dsl)
dsl
- task DSLpublic static String createComposedTaskDefinition(String graph, TaskConfigurationProperties taskConfigurationProperties)
graph
- the graph for the CTR to execute.taskConfigurationProperties
- the properties that contain the name
of the CTR app to be launched.public static String createComposedTaskDefinition(String alternateComposedTaskRunnerName, String graph, TaskConfigurationProperties taskConfigurationProperties)
alternateComposedTaskRunnerName
- a ctr name to be used instead of the default.graph
- the graph for the CTR to execute.taskConfigurationProperties
- the properties that contain the name
of the CTR app to be launched.public static Map<String,String> establishComposedTaskProperties(Map<String,String> taskDeploymentProperties, org.springframework.cloud.dataflow.core.dsl.TaskNode taskNode)
taskDeploymentProperties
- properties to be parsed for the CTR.taskNode
- containing the tasks apps to be executed by the CTRpublic static TaskDefinition updateTaskProperties(TaskDefinition taskDefinition, org.springframework.boot.autoconfigure.jdbc.DataSourceProperties dataSourceProperties)
taskDefinition
- the TaskDefinition
to be updated.dataSourceProperties
- the dataSource properties used by SCDF.TaskDefinition
public static Map<String,String> extractAppProperties(String name, Map<String,String> taskDeploymentProperties)
name
- the task app name to search for in the deployment properties.taskDeploymentProperties
- the properties for the task deployment.public static org.springframework.cloud.deployer.spi.core.AppDefinition mergeAndExpandAppProperties(TaskDefinition original, org.springframework.core.io.Resource resource, Map<String,String> appDeploymentProperties, WhitelistProperties whitelistProperties)
original
- the task definition with the original set of properties.resource
- the resource to be used for identifying white listed properties.appDeploymentProperties
- the app deployment properties to be added to the AppDefinition
.whitelistProperties
- util for formatting white listed properties properly.AppDefinition
.public static void updateDataFlowUriIfNeeded(String dataflowServerUri, Map<String,String> appDeploymentProperties, List<String> commandLineArgs)
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.