org.apache.storm.kafka.trident

Interface IBatchCoordinator

All Superinterfaces:

Serializable

All Known Implementing Classes:

DefaultCoordinator

public interface IBatchCoordinator
extends Serializable

Method Summary

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

Method Detail

isReady

boolean isReady(long txid)

close

void close()