org.apache.storm.kafka.trident

Class DefaultCoordinator

java.lang.Object

org.apache.storm.kafka.trident.DefaultCoordinator

All Implemented Interfaces:

Serializable, IBatchCoordinator

public class DefaultCoordinator
extends Object
implements IBatchCoordinator

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DefaultCoordinator()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultCoordinator

public DefaultCoordinator()

Method Detail

isReady

public boolean isReady(long txid)

Specified by:

isReady in interface IBatchCoordinator

close

public void close()

Specified by:

close in interface IBatchCoordinator