storm.trident.spout
Interface IPartitionedTridentSpout.Coordinator

Enclosing interface:

IPartitionedTridentSpout<T>

public static interface IPartitionedTridentSpout.Coordinator

Method Summary

void	close()
boolean	isReady(long txid)
long	numPartitions() Return the number of partitions currently in the source of data.

Method Detail

numPartitions

long numPartitions()

Return the number of 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 how many partitions were in that transaction.

isReady

boolean isReady(long txid)

close

void close()