Package | Description |
---|---|
ds.granules.streaming.core |
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.
|
Copyright © 2015. All rights reserved.