|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ITransactionalSpout<T>
Nested Class Summary | |
---|---|
static interface |
ITransactionalSpout.Coordinator<X>
|
static interface |
ITransactionalSpout.Emitter<X>
|
Method Summary | |
---|---|
ITransactionalSpout.Coordinator<T> |
getCoordinator(java.util.Map conf,
TopologyContext context)
The coordinator for a TransactionalSpout runs in a single thread and indicates when batches of tuples should be emitted and when transactions should commit. |
ITransactionalSpout.Emitter<T> |
getEmitter(java.util.Map conf,
TopologyContext context)
The emitter for a TransactionalSpout runs as many tasks across the cluster. |
Methods inherited from interface backtype.storm.topology.IComponent |
---|
declareOutputFields, getComponentConfiguration |
Method Detail |
---|
ITransactionalSpout.Coordinator<T> getCoordinator(java.util.Map conf, TopologyContext context)
ITransactionalSpout.Emitter<T> getEmitter(java.util.Map conf, TopologyContext context)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |