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 StreamDefinitionService
streamDefinition
- 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 StreamDefinitionService
streamDefinition
- the stream definitionpublic String constructDsl(String originalDslText, LinkedList<StreamAppDefinition> streamAppDefinitions)
StreamDefinitionService
constructDsl
in interface StreamDefinitionService
streamAppDefinitions
- the linked list of StreamAppDefinition
s associated with the stream with some of app properties modifiedpublic String redactDsl(StreamDefinition streamDefinition)
redactDsl
in interface StreamDefinitionService
Copyright © 2021 Pivotal Software, Inc.. All rights reserved.