|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object storm.trident.testing.FeederBatchSpout.FeederEmitter
public class FeederBatchSpout.FeederEmitter
Constructor Summary | |
---|---|
FeederBatchSpout.FeederEmitter(int index)
|
Method Summary | |
---|---|
void |
close()
Release any resources held by this emitter. |
void |
emitBatch(TransactionAttempt tx,
java.util.Map<java.lang.Integer,java.util.List<java.util.List<java.lang.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. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public FeederBatchSpout.FeederEmitter(int index)
Method Detail |
---|
public void emitBatch(TransactionAttempt tx, java.util.Map<java.lang.Integer,java.util.List<java.util.List<java.lang.Object>>> coordinatorMeta, TridentCollector collector)
ITridentSpout.Emitter
emitBatch
in interface ITridentSpout.Emitter<java.util.Map<java.lang.Integer,java.util.List<java.util.List<java.lang.Object>>>>
public void success(TransactionAttempt tx)
ITridentSpout.Emitter
success
in interface ITridentSpout.Emitter<java.util.Map<java.lang.Integer,java.util.List<java.util.List<java.lang.Object>>>>
public void close()
ITridentSpout.Emitter
close
in interface ITridentSpout.Emitter<java.util.Map<java.lang.Integer,java.util.List<java.util.List<java.lang.Object>>>>
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |