Package | Description |
---|---|
storm.trident.spout | |
storm.trident.testing |
Modifier and Type | Method and Description |
---|---|
void |
OpaquePartitionedTridentSpoutExecutor.Emitter.commit(TransactionAttempt attempt) |
void |
ICommitterTridentSpout.Emitter.commit(TransactionAttempt attempt) |
void |
OpaquePartitionedTridentSpoutExecutor.Emitter.emitBatch(TransactionAttempt tx,
Object coordinatorMeta,
TridentCollector collector) |
void |
BatchSpoutExecutor.BatchSpoutEmitter.emitBatch(TransactionAttempt tx,
Object coordinatorMeta,
TridentCollector collector) |
void |
ITridentSpout.Emitter.emitBatch(TransactionAttempt tx,
X coordinatorMeta,
TridentCollector collector)
Emit a batch for the specified transaction attempt and metadata for the transaction.
|
M |
IOpaquePartitionedTridentSpout.Emitter.emitPartitionBatch(TransactionAttempt tx,
TridentCollector collector,
Partition partition,
M lastPartitionMeta)
Emit a batch of tuples for a partition/transaction.
|
void |
IPartitionedTridentSpout.Emitter.emitPartitionBatch(TransactionAttempt tx,
TridentCollector collector,
Partition partition,
X partitionMeta)
Emit a batch of tuples for a partition/transaction that has been emitted before, using
the metadata created when it was first emitted.
|
X |
IPartitionedTridentSpout.Emitter.emitPartitionBatchNew(TransactionAttempt tx,
TridentCollector collector,
Partition partition,
X lastPartitionMeta)
Emit a batch of tuples for a partition/transaction that's never been emitted before.
|
void |
OpaquePartitionedTridentSpoutExecutor.Emitter.success(TransactionAttempt tx) |
void |
ITridentSpout.Emitter.success(TransactionAttempt tx)
This attempt committed successfully, so all state for this commit and before can be safely cleaned up.
|
void |
BatchSpoutExecutor.BatchSpoutEmitter.success(TransactionAttempt tx) |
Modifier and Type | Method and Description |
---|---|
void |
FeederBatchSpout.FeederEmitter.emitBatch(TransactionAttempt tx,
Map<Integer,List<List<Object>>> coordinatorMeta,
TridentCollector collector) |
void |
FeederBatchSpout.FeederEmitter.success(TransactionAttempt tx) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.