public class FeederBatchSpout.FeederEmitter extends Object implements ITridentSpout.Emitter<Map<Integer,List<List<Object>>>>
| Constructor and Description |
|---|
FeederBatchSpout.FeederEmitter(int index) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Release any resources held by this emitter.
|
void |
emitBatch(TransactionAttempt tx,
Map<Integer,List<List<Object>>> coordinatorMeta,
TridentCollector collector)
Emit a batch for the specified transaction attempt and metadata for the transaction.
|
void |
success(TransactionAttempt tx)
This attempt committed successfully, so all state for this commit and before can be safely cleaned up.
|
public void emitBatch(TransactionAttempt tx, Map<Integer,List<List<Object>>> coordinatorMeta, TridentCollector collector)
ITridentSpout.Emitterpublic void success(TransactionAttempt tx)
ITridentSpout.Emitterpublic void close()
ITridentSpout.EmitterCopyright © 2015. All rights reserved.