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