public interface BarrierTransceiver
| Modifier and Type | Method and Description |
|---|---|
void |
broadcastBarrierFromSource(long barrierID)
A callback for notifying an operator of a new checkpoint barrier.
|
void |
confirmBarrier(long barrierID)
A callback for confirming that a barrier checkpoint is complete
|
void broadcastBarrierFromSource(long barrierID)
barrierID - void confirmBarrier(long barrierID)
throws IOException
barrierID - IOExceptionCopyright © 2014–2015 The Apache Software Foundation. All rights reserved.