public class StreamFactory
extends java.lang.Object
Stream instances.| Constructor and Description |
|---|
StreamFactory(StreamDefinitionRepository streamDefinitionRepository,
ModuleRegistry moduleRegistry,
ModuleOptionsMetadataResolver moduleOptionsMetadataResolver)
Construct a StreamFactory to create
Stream domain model instances. |
| Modifier and Type | Method and Description |
|---|---|
Stream |
createStream(java.lang.String name,
java.util.Map<java.lang.String,java.lang.String> properties)
Create a new instance of
Stream for the given name and
properties. |
public StreamFactory(StreamDefinitionRepository streamDefinitionRepository, ModuleRegistry moduleRegistry, ModuleOptionsMetadataResolver moduleOptionsMetadataResolver)
Stream domain model instances.streamDefinitionRepository - repository for stream definitionsmoduleRegistry - registry for module definitionsmoduleOptionsMetadataResolver - resolver for module options metadatapublic Stream createStream(java.lang.String name, java.util.Map<java.lang.String,java.lang.String> properties)
Stream for the given name and
properties. The properties should at minimum contain the following
entries:
| definition | DSL definition for stream |
|---|---|
| deploymentProperties | Deployment properties for stream |
name - stream nameproperties - properties for streamStream domain model instance