public interface ITransactionalSpout<T> extends IComponent
Modifier and Type | Interface and Description |
---|---|
static interface |
ITransactionalSpout.Coordinator<X> |
static interface |
ITransactionalSpout.Emitter<X> |
Modifier and Type | Method and Description |
---|---|
ITransactionalSpout.Coordinator<T> |
getCoordinator(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(Map conf,
TopologyContext context)
The emitter for a TransactionalSpout runs as many tasks across the cluster.
|
declareOutputFields, getComponentConfiguration
ITransactionalSpout.Coordinator<T> getCoordinator(Map conf, TopologyContext context)
ITransactionalSpout.Emitter<T> getEmitter(Map conf, TopologyContext context)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.