org.apache.giraph.worker

Class WorkerProgressWriter

java.lang.Object

org.apache.giraph.worker.WorkerProgressWriter

public class WorkerProgressWriter
extends Object

Class which periodically writes worker's progress to zookeeper

Constructor Summary

Constructors

Constructor and Description
WorkerProgressWriter(JobProgressTracker jobProgressTracker) Constructor, starts separate thread to periodically update worker's progress

Method Summary

Modifier and Type	Method and Description
void	stop() Stop the thread which writes worker's progress

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerProgressWriter

public WorkerProgressWriter(JobProgressTracker jobProgressTracker)

Constructor, starts separate thread to periodically update worker's progress

Parameters:

jobProgressTracker - JobProgressTracker to report job progress to

Method Detail

stop

public void stop()
          throws InterruptedException

Stop the thread which writes worker's progress

Throws:

InterruptedException