org.apache.storm.kafka.spout.trident

Class KafkaTridentSpoutEmitter<K,V>

java.lang.Object

org.apache.storm.kafka.spout.trident.KafkaTridentSpoutEmitter<K,V>

All Implemented Interfaces:

Serializable

public class KafkaTridentSpoutEmitter<K,V>
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KafkaTridentSpoutEmitter(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig, TopologyContext topologyContext) Create a new Kafka spout emitter.

Method Summary

Modifier and Type	Method and Description
void	close()
Map<String,Object>	emitPartitionBatchNew(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String,Object> lastBatch) Emit a new batch.
List<KafkaTridentSpoutTopicPartition>	getOrderedPartitions(List<Map<String,Object>> allPartitionInfo) Get the input partitions in sorted order.
List<KafkaTridentSpoutTopicPartition>	getPartitionsForTask(int taskId, int numTasks, List<KafkaTridentSpoutTopicPartition> allPartitionInfoSorted) Get the partitions that should be handled by this task.
void	reEmitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String,Object> currBatch) Emit a batch that has already been emitted.
void	refreshPartitions(List<KafkaTridentSpoutTopicPartition> partitionResponsibilities) Prepare the emitter to handle the input partitions.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaTridentSpoutEmitter

public KafkaTridentSpoutEmitter(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig,
                                TopologyContext topologyContext)

Create a new Kafka spout emitter.

Parameters:

kafkaSpoutConfig - The kafka spout config

topologyContext - The topology context

Method Detail

reEmitPartitionBatch

public void reEmitPartitionBatch(TransactionAttempt tx,
                                 TridentCollector collector,
                                 KafkaTridentSpoutTopicPartition currBatchPartition,
                                 Map<String,Object> currBatch)

Emit a batch that has already been emitted.

emitPartitionBatchNew

public Map<String,Object> emitPartitionBatchNew(TransactionAttempt tx,
                                                TridentCollector collector,
                                                KafkaTridentSpoutTopicPartition currBatchPartition,
                                                Map<String,Object> lastBatch)

Emit a new batch.

getOrderedPartitions

public List<KafkaTridentSpoutTopicPartition> getOrderedPartitions(List<Map<String,Object>> allPartitionInfo)

Get the input partitions in sorted order.

getPartitionsForTask

public List<KafkaTridentSpoutTopicPartition> getPartitionsForTask(int taskId,
                                                                  int numTasks,
                                                                  List<KafkaTridentSpoutTopicPartition> allPartitionInfoSorted)

Get the partitions that should be handled by this task.

refreshPartitions

public void refreshPartitions(List<KafkaTridentSpoutTopicPartition> partitionResponsibilities)

Prepare the emitter to handle the input partitions.

close

public void close()

toString

public final String toString()

Overrides:

toString in class Object