backtype.storm.transactional.partitioned
Interface IPartitionedTransactionalSpout.Coordinator

Enclosing interface:

IPartitionedTransactionalSpout<T>

public static interface IPartitionedTransactionalSpout.Coordinator

Method Summary

void	close()
int	numPartitions() Return the number of partitions currently in the source of data.

Method Detail

numPartitions

int 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.

close

void close()