|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public static interface ITridentSpout.Emitter<X>
Method Summary | |
---|---|
void |
close()
Release any resources held by this emitter. |
void |
emitBatch(TransactionAttempt tx,
X 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. |
Method Detail |
---|
void emitBatch(TransactionAttempt tx, X coordinatorMeta, TridentCollector collector)
void success(TransactionAttempt tx)
void close()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |