Package | Description |
---|---|
ds.granules.streaming.core |
Modifier and Type | Class and Description |
---|---|
class |
StreamProcessor
Any stream processing element should extend this abstract class.
|
class |
StreamSource
This class should be extended to implement a stream source.
|
Modifier and Type | Method and Description |
---|---|
protected void |
StreamBase.addStreamConsumer(ds.funnel.topic.Topic topic,
StreamBase destination) |
Copyright © 2015. All rights reserved.