org.apache.flink.runtime.iterative.concurrent

Class SuperstepBarrier

java.lang.Object

org.apache.flink.runtime.iterative.concurrent.SuperstepBarrier

All Implemented Interfaces:

EventListener<TaskEvent>

public class SuperstepBarrier
extends Object
implements EventListener<TaskEvent>

A resettable one-shot latch.

Constructor Summary

Constructors

Constructor and Description
SuperstepBarrier(ClassLoader userCodeClassLoader)

Method Summary

Modifier and Type	Method and Description
Value[]	getAggregates()
String[]	getAggregatorNames()
void	onEvent(TaskEvent event) Barrier will release the waiting thread if an event occurs.
void	setup() Setup the barrier, has to be called at the beginning of each superstep.
boolean	terminationSignaled()
void	waitForOtherWorkers() Wait on the barrier.

Methods inherited from class java.lang.Object

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

Constructor Detail

SuperstepBarrier

public SuperstepBarrier(ClassLoader userCodeClassLoader)

Method Detail

setup

public void setup()

Setup the barrier, has to be called at the beginning of each superstep.

waitForOtherWorkers

public void waitForOtherWorkers()
                         throws InterruptedException

Wait on the barrier.

Throws:

InterruptedException

getAggregatorNames

public String[] getAggregatorNames()

getAggregates

public Value[] getAggregates()

onEvent

public void onEvent(TaskEvent event)

Barrier will release the waiting thread if an event occurs.

Specified by:

onEvent in interface EventListener<TaskEvent>

terminationSignaled

public boolean terminationSignaled()