org.apache.giraph.job

Interface JobProgressTrackerService

All Superinterfaces:

JobProgressTracker

All Known Implementing Classes:

DefaultJobProgressTrackerService

public interface JobProgressTrackerService
extends JobProgressTracker

Implementation of job progress tracker service on job client

Method Summary

Modifier and Type	Method and Description
void	init(GiraphConfiguration conf, GiraphJobObserver jobObserver) Initialize the service
void	setJob(org.apache.hadoop.mapreduce.Job job) Set job
void	stop(boolean succeeded) Stop the thread which logs application progress and server

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

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

Method Detail

init

void init(GiraphConfiguration conf,
          GiraphJobObserver jobObserver)

Initialize the service

Parameters:

conf - Configuration

jobObserver - Giraph job callbacks

setJob

void setJob(org.apache.hadoop.mapreduce.Job job)

Set job

Parameters:

job - Job

stop

void stop(boolean succeeded)

Stop the thread which logs application progress and server

Parameters:

succeeded - Whether job succeeded or not