edu.iu.dsc.tws.master.barrier

Class ZKBarrierHandler

java.lang.Object

edu.iu.dsc.tws.master.barrier.ZKBarrierHandler

All Implemented Interfaces:

BarrierResponder

public class ZKBarrierHandler
extends java.lang.Object
implements BarrierResponder

Constructor Summary

Constructors

Constructor and Description
ZKBarrierHandler(BarrierMonitor barrierMonitor, Config config, java.lang.String jobID, int numberOfWorkers)

Method Summary

Modifier and Type	Method and Description
void	allArrived(JobMasterAPI.BarrierType barrierType) publish all arrived event
void	barrierFailed(JobMasterAPI.BarrierType barrierType, JobMasterAPI.BarrierResult result) this method is called when the barrier failed all waiting workers shall be released with a failure message
void	close() close all local entities.
void	initialize(JobMasterAPI.JobMasterState initialState) initialize ZKBarrierHandler, create znode children caches for job master to watch barrier events
void	publishBarrierDone(JobMasterAPI.BarrierType barrierType, JobMasterAPI.BarrierResult barrierResult) publish BarrierDone event

Methods inherited from class java.lang.Object

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

Constructor Detail

ZKBarrierHandler

public ZKBarrierHandler(BarrierMonitor barrierMonitor,
                        Config config,
                        java.lang.String jobID,
                        int numberOfWorkers)

Method Detail

initialize

public void initialize(JobMasterAPI.JobMasterState initialState)
                throws Twister2Exception

initialize ZKBarrierHandler, create znode children caches for job master to watch barrier events

Throws:

Twister2Exception

allArrived

public void allArrived(JobMasterAPI.BarrierType barrierType)

publish all arrived event

Specified by:

allArrived in interface BarrierResponder

barrierFailed

public void barrierFailed(JobMasterAPI.BarrierType barrierType,
                          JobMasterAPI.BarrierResult result)

Description copied from interface: BarrierResponder

this method is called when the barrier failed all waiting workers shall be released with a failure message

Specified by:

barrierFailed in interface BarrierResponder

publishBarrierDone

public void publishBarrierDone(JobMasterAPI.BarrierType barrierType,
                               JobMasterAPI.BarrierResult barrierResult)

publish BarrierDone event

close

public void close()

close all local entities.