storm.trident.spout

Interface IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition extends ISpoutPartition,M>

All Known Implementing Classes:

OpaqueTridentEventHubEmitter

Enclosing interface:

IOpaquePartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,M>

public static interface IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition extends ISpoutPartition,M>

Method Summary

Modifier and Type	Method and Description
void	close()
M	emitPartitionBatch(TransactionAttempt tx, TridentCollector collector, Partition partition, M lastPartitionMeta) Emit a batch of tuples for a partition/transaction.
List<Partition>	getOrderedPartitions(Partitions allPartitionInfo)
void	refreshPartitions(List<Partition> partitionResponsibilities) This method is called when this task is responsible for a new set of partitions.

Method Detail

emitPartitionBatch

M emitPartitionBatch(TransactionAttempt tx,
                     TridentCollector collector,
                     Partition partition,
                     M lastPartitionMeta)

Emit a batch of tuples for a partition/transaction. Return the metadata describing this batch that will be used as lastPartitionMeta for defining the parameters of the next batch.

refreshPartitions

void refreshPartitions(List<Partition> partitionResponsibilities)

This method is called when this task is responsible for a new set of partitions. Should be used to manage things like connections to brokers.

getOrderedPartitions

List<Partition> getOrderedPartitions(Partitions allPartitionInfo)

close

void close()