org.apache.storm.trident.spout

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

All Known Implementing Classes:

KafkaTridentSpoutEmitter, 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)
List<Partition>	getPartitionsForTask(int taskId, int numTasks, List<Partition> allPartitionInfoSorted)
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)

Returns:

The oredered list of partitions being processed by all the tasks

getPartitionsForTask

List<Partition> getPartitionsForTask(int taskId,
                                     int numTasks,
                                     List<Partition> allPartitionInfoSorted)

Returns:

The list of partitions that are to be processed by the task with id taskId

close

void close()