org.apache.giraph.graph

Interface JobProgressTrackerClient

All Superinterfaces:

JobProgressTracker

All Known Implementing Classes:

JobProgressTrackerClientNoOp, RetryableJobProgressTrackerClient

public interface JobProgressTrackerClient
extends JobProgressTracker

Wrapper around JobProgressTracker which retries to connect and swallows exceptions so app wouldn't crash if something goes wrong with progress reports.

Method Summary

Modifier and Type	Method and Description
void	cleanup() Close the connections if any
void	init(GiraphConfiguration conf) Initialize the client.

Methods inherited from interface org.apache.giraph.job.JobProgressTracker

logError, logFailure, logInfo, mapperStarted, sendMasterCounters, updateMasterProgress, updateProgress

Method Detail

cleanup

void cleanup()
      throws IOException

Close the connections if any

Throws:

IOException

init

void init(GiraphConfiguration conf)
   throws Exception

Initialize the client.

Parameters:

conf - Job configuration

Throws:

Exception