public class DefaultStreamDefinitionService extends Object implements StreamDefinitionService
StreamDefinitionService.dataFlowAddedProperties| Constructor and Description |
|---|
DefaultStreamDefinitionService() |
| Modifier and Type | Method and Description |
|---|---|
String |
constructDsl(String originalDslText,
LinkedList<StreamAppDefinition> streamAppDefinitions)
Return the updated stream DSL for the given stream definition with the associated properties.
|
LinkedList<StreamAppDefinition> |
getAppDefinitions(StreamDefinition streamDefinition)
Return the ordered list of application definitions for this stream as a
List. |
org.springframework.cloud.dataflow.core.dsl.StreamNode |
parse(StreamDefinition streamDefinition)
Use the
StreamParser to retrieve the StreamNode representation of the stream. |
String |
redactDsl(StreamDefinition streamDefinition) |
public org.springframework.cloud.dataflow.core.dsl.StreamNode parse(StreamDefinition streamDefinition)
StreamParser to retrieve the StreamNode representation of the stream.parse in interface StreamDefinitionServicestreamDefinition - the stream definitionpublic LinkedList<StreamAppDefinition> getAppDefinitions(StreamDefinition streamDefinition)
List. This allows for retrieval of application definitions in the stream by
index. Application definitions are maintained in stream flow order (source is
first, sink is last).getAppDefinitions in interface StreamDefinitionServicestreamDefinition - the stream definitionpublic String constructDsl(String originalDslText, LinkedList<StreamAppDefinition> streamAppDefinitions)
StreamDefinitionServiceconstructDsl in interface StreamDefinitionServicestreamAppDefinitions - the linked list of StreamAppDefinitions associated with the stream with some of app properties modifiedpublic String redactDsl(StreamDefinition streamDefinition)
redactDsl in interface StreamDefinitionServiceCopyright © 2021 Pivotal Software, Inc.. All rights reserved.