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

Packages that use StreamingDatasetException

Package	Description
ds.granules.streaming.core

Uses of StreamingDatasetException in ds.granules.streaming.core

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

Modifier and Type	Method and Description
protected void	StreamBase.addStreamConsumer(ds.funnel.topic.Topic topic, StreamBase destination)
abstract void	StreamSource.emit() Emit the next tuple.
abstract void	StreamProcessor.onEvent(StreamEvent event) This method will be invoked by the framework when data is available in one of the input streams.
protected void	StreamBase.writeToStream(String streamId, StreamEvent event) Write a stream data element to a Stream.