org.apache.storm.kafka.spout.trident

Class KafkaTridentSpoutOpaqueCoordinator<K,V>

java.lang.Object

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

All Implemented Interfaces:

Serializable, IOpaquePartitionedTridentSpout.Coordinator<List<Map<String,Object>>>

public class KafkaTridentSpoutOpaqueCoordinator<K,V>
extends Object
implements IOpaquePartitionedTridentSpout.Coordinator<List<Map<String,Object>>>, Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KafkaTridentSpoutOpaqueCoordinator(KafkaTridentSpoutManager<K,V> kafkaManager)

Method Summary

Modifier and Type	Method and Description
void	close()
List<Map<String,Object>>	getPartitionsForBatch() Gets the partitions for the following batches.
boolean	isReady(long txid) Indicates whether this coordinator is ready to commit the given transaction.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaTridentSpoutOpaqueCoordinator

public KafkaTridentSpoutOpaqueCoordinator(KafkaTridentSpoutManager<K,V> kafkaManager)

Method Detail

isReady

public boolean isReady(long txid)

Description copied from interface: IOpaquePartitionedTridentSpout.Coordinator

Indicates whether this coordinator is ready to commit the given transaction. The master batch coordinator will only begin committing if at least one coordinator indicates it is ready to commit.

Specified by:

isReady in interface IOpaquePartitionedTridentSpout.Coordinator<List<Map<String,Object>>>

Parameters:

txid - The transaction id

Returns:

true if this coordinator is ready to commit, false otherwise.

getPartitionsForBatch

public List<Map<String,Object>> getPartitionsForBatch()

Description copied from interface: IOpaquePartitionedTridentSpout.Coordinator

Gets the partitions for the following batches. The emitter will be asked to refresh partitions when this value changes.

Specified by:

getPartitionsForBatch in interface IOpaquePartitionedTridentSpout.Coordinator<List<Map<String,Object>>>

Returns:

The partitions for the following batches.

close

public void close()

Specified by:

close in interface IOpaquePartitionedTridentSpout.Coordinator<List<Map<String,Object>>>

toString

public final String toString()

Overrides:

toString in class Object