storm.kafka.trident
Class DefaultCoordinator

java.lang.Object
  extended by storm.kafka.trident.DefaultCoordinator
All Implemented Interfaces:
Serializable, IBatchCoordinator

public class DefaultCoordinator
extends Object
implements IBatchCoordinator

See Also:
Serialized Form

Constructor Summary
DefaultCoordinator()
           
 
Method Summary
 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


Copyright © 2015 The Apache Software Foundation. All Rights Reserved.