org.apache.storm.trident.spout

Interface IOpaquePartitionedTridentSpout.Coordinator<Partitions>

All Known Implementing Classes:

Coordinator, KafkaTridentSpoutOpaqueCoordinator

Enclosing interface:

IOpaquePartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,M>

public static interface IOpaquePartitionedTridentSpout.Coordinator<Partitions>

Coordinator for batches. Trident will only begin committing once at least one coordinator is ready.

Method Summary

Modifier and Type	Method and Description
void	close()
Partitions	getPartitionsForBatch() Gets the partitions for the following batches.
boolean	isReady(long txid) Indicates whether this coordinator is ready to commit the given transaction.

Method Detail

isReady

boolean isReady(long txid)

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.

Parameters:

txid - The transaction id

Returns:

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

getPartitionsForBatch

Partitions getPartitionsForBatch()

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

Returns:

The partitions for the following batches.

close

void close()