Uses of Class
ds.granules.streaming.core.exception.StreamingGraphConfigurationException

Packages that use StreamingGraphConfigurationException

Package	Description
ds.granules.streaming.core

Uses of StreamingGraphConfigurationException in ds.granules.streaming.core

Methods in ds.granules.streaming.core that throw StreamingGraphConfigurationException

Modifier and Type	Method and Description
void	Job.addLink(String sourceElem, String destElem, String streamId, int partitioningScheme) Adds a link connecting two stream processors/sources.
protected void	StreamBase.addStreamConsumer(ds.funnel.topic.Topic topic, StreamBase destination)
void	Job.addStreamProcessor(String name, Class processorClass, int parallelism) Adds a new stream processing element to the job.
void	Job.addStreamSource(String name, Class sourceClass, int parallelism) Adds a new stream source to the job.
protected abstract void	StreamBase.declareOutputStreams() The classes that extend StreamProcessor and StreamSource should implement this method in order to declare output streams.
protected void	StreamBase.declareStream(String streamId, String streamType) Declare an output stream from the Stream operator.
void	Job.deploy() Deploy the current job in the Granules runtime.