storm.trident.spout

Interface IOpaquePartitionedTridentSpout.Coordinator<Partitions>

Enclosing interface:

IOpaquePartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,M>

public static interface IOpaquePartitionedTridentSpout.Coordinator<Partitions>

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
Partitions	getPartitionsForBatch()
boolean	isReady(long txid)

Method Detail

isReady

boolean isReady(long txid)

getPartitionsForBatch

Partitions getPartitionsForBatch()

close

void close()