org.apache.storm.trident.spout

Interface IPartitionedTridentSpout.Coordinator<PartitionsT>

All Known Implementing Classes:

Coordinator, KafkaTridentSpoutCoordinator

Enclosing interface:

IPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,T>

public static interface IPartitionedTridentSpout.Coordinator<PartitionsT>

Method Summary

Modifier and Type	Method and Description
void	close()
PartitionsT	getPartitionsForBatch() Return the partitions currently in the source of data.
boolean	isReady(long txid)

Method Detail

getPartitionsForBatch

PartitionsT getPartitionsForBatch()

Return the partitions currently in the source of data. The idea is is that if a new partition is added and a prior transaction is replayed, it doesn't emit tuples for the new partition because it knows what partitions were in that transaction.

isReady

boolean isReady(long txid)

close

void close()