| Interface | Description |
|---|---|
| IMultiSchemableSpout | |
| ISchemableSpout | |
| ISpout |
ISpout is the core interface for implementing spouts.
|
| ISpoutOutputCollector | |
| ISpoutWaitStrategy |
The strategy a spout needs to use when its waiting.
|
| MultiScheme | |
| Scheme |
| Class | Description |
|---|---|
| CheckpointSpout |
Emits checkpoint tuples which is used to save the state of the
IStatefulComponent across the topology. |
| CheckPointState |
Captures the current state of the transaction in
CheckpointSpout. |
| NothingEmptyEmitStrategy | |
| RawMultiScheme | |
| RawScheme | |
| SchemeAsMultiScheme | |
| ShellSpout | |
| SleepSpoutWaitStrategy | |
| SpoutOutputCollector |
This output collector exposes the API for emitting tuples from an
IRichSpout. |
| Enum | Description |
|---|---|
| CheckPointState.Action | |
| CheckPointState.State |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.