backtype.storm.transactional.partitioned
Interface IOpaquePartitionedTransactionalSpout.Coordinator

Enclosing interface:

IOpaquePartitionedTransactionalSpout<T>

public static interface IOpaquePartitionedTransactionalSpout.Coordinator

Method Summary

void	close()
boolean	isReady() Returns true if its ok to emit start a new transaction, false otherwise (will skip this transaction).

Method Detail

isReady

boolean isReady()

Returns true if its ok to emit start a new transaction, false otherwise (will skip this transaction). You should sleep here if you want a delay between asking for the next transaction (this will be called repeatedly in a loop).

close

void close()