Interface | Description |
---|---|
BoltDeclarer | |
ComponentConfigurationDeclarer<T extends ComponentConfigurationDeclarer> | |
IBasicBolt | |
IBasicOutputCollector | |
IComponent |
Common methods for all possible components in a topology.
|
InputDeclarer<T extends InputDeclarer> | |
IRichBolt |
When writing topologies using Java,
IRichBolt and IRichSpout are the main interfaces
to use to implement components of the topology. |
IRichSpout |
When writing topologies using Java,
IRichBolt and IRichSpout are the main interfaces
to use to implement components of the topology. |
IStatefulBolt<T extends State> |
A bolt abstraction for supporting stateful computation.
|
IStatefulComponent<T extends State> |
Common methods for stateful components in the topology.
|
IStatefulWindowedBolt<T extends State> |
A windowed bolt abstraction for supporting windowing operation with state.
|
IWindowedBolt |
A bolt abstraction for supporting time and count based sliding & tumbling windows.
|
OutputFieldsDeclarer | |
SpoutDeclarer |
Class | Description |
---|---|
BasicOutputCollector | |
TopologyBuilder | |
TupleFieldTimestampExtractor |
A
TimestampExtractor that extracts timestamp from a specific field in the tuple. |
WindowedBoltExecutor |
An
IWindowedBolt wrapper that does the windowing of tuples. |
Exception | Description |
---|---|
FailedException |