public class StreamConfigParser extends java.lang.Object implements StreamLookupEnvironment
| Constructor and Description |
|---|
StreamConfigParser(org.springframework.data.repository.CrudRepository<? extends BaseDefinition,java.lang.String> repository) |
| Modifier and Type | Method and Description |
|---|---|
ModuleReferenceNode |
eatPossiblyQualifiedLabelOrModuleReference() |
java.lang.String |
lookupChannelForLabelOrModule(java.lang.String streamName,
java.lang.String streamOrLabelOrModuleName)
Look up an existing label or module name.
|
StreamNode |
lookupStream(java.lang.String name)
Look up a previously defined stream by name, returns the parsed AST for it.
|
java.lang.String |
maybeEatStreamName() |
StreamsNode |
parse(java.lang.String stream)
Parse a stream definition without supplying the stream name up front.
|
StreamsNode |
parse(java.lang.String name,
java.lang.String stream)
Parse a stream definition.
|
java.lang.String |
toString() |
java.lang.String |
toString(org.springframework.xd.dirt.stream.dsl.Token t) |
public StreamConfigParser(org.springframework.data.repository.CrudRepository<? extends BaseDefinition,java.lang.String> repository)
public StreamsNode parse(java.lang.String stream)
mystream = http | filepublic StreamsNode parse(java.lang.String name, java.lang.String stream)
public java.lang.String maybeEatStreamName()
public ModuleReferenceNode eatPossiblyQualifiedLabelOrModuleReference()
public java.lang.String toString(org.springframework.xd.dirt.stream.dsl.Token t)
public java.lang.String toString()
toString in class java.lang.Objectpublic StreamNode lookupStream(java.lang.String name)
StreamLookupEnvironmentlookupStream in interface StreamLookupEnvironmentname - name of the streampublic java.lang.String lookupChannelForLabelOrModule(java.lang.String streamName,
java.lang.String streamOrLabelOrModuleName)
StreamLookupEnvironment
mystream = http | foo | file
tap mystream.foo > count
will cause a lookup for stream 'mystream' module 'foo' when the tap is being resolved. The return value would be
'mystream.1' (The output channel for a module is based on the index of the module within the stream, starting at
0).lookupChannelForLabelOrModule in interface StreamLookupEnvironmentstreamName - the name of the streamstreamOrLabelOrModuleName - a label or name of a module