public class FeederBatchSpout.FeederEmitter extends Object implements ITridentSpout.Emitter<Map<Integer,List<List<Object>>>>
Constructor and Description |
---|
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.Emitter
public void success(TransactionAttempt tx)
ITridentSpout.Emitter
public void close()
ITridentSpout.Emitter
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.