org.apache.giraph.job

Interface JobProgressTracker

All Known Subinterfaces:

JobProgressTrackerClient, JobProgressTrackerService

All Known Implementing Classes:

DefaultJobProgressTrackerService, JobProgressTrackerClientNoOp, RetryableJobProgressTrackerClient

@ThriftService
public interface JobProgressTracker

Interface for job progress tracker on job client

Method Summary

Modifier and Type	Method and Description
void	logError(String logLine, byte[] exByteArray) Call this when you want to log an error line and exception object from any mapper to command line KryoWritableWrapper.convertFromByteArray can be used to get exception object back
void	logFailure(String reason) Notify that job is failing
void	logInfo(String logLine) Call this when you want to log an info line from any mapper to command line
void	mapperStarted() Notify JobProgressTracker that mapper started
void	sendMasterCounters(GiraphCountersThriftStruct giraphCounters) Master should call this method after all supersteps are finished, and send the aggregated counters to the job client
void	updateMasterProgress(MasterProgress masterProgress) Master should call this method to update its progress
void	updateProgress(WorkerProgress workerProgress) Workers should call this method to update their progress

Method Detail

mapperStarted

@ThriftMethod
void mapperStarted()

Notify JobProgressTracker that mapper started

logInfo

@ThriftMethod
void logInfo(String logLine)

Call this when you want to log an info line from any mapper to command line

Parameters:

logLine - Line to log

logError

@ThriftMethod
void logError(String logLine,
                            byte[] exByteArray)

Call this when you want to log an error line and exception object from any mapper to command line KryoWritableWrapper.convertFromByteArray can be used to get exception object back

Parameters:

logLine - Line to log

exByteArray - Exception byte array

logFailure

@ThriftMethod
void logFailure(String reason)

Notify that job is failing

Parameters:

reason - Reason for failure

updateProgress

@ThriftMethod
void updateProgress(WorkerProgress workerProgress)

Workers should call this method to update their progress

Parameters:

workerProgress - Progress of the worker

updateMasterProgress

@ThriftMethod
void updateMasterProgress(MasterProgress masterProgress)

Master should call this method to update its progress

Parameters:

masterProgress - Progress of the master

sendMasterCounters

@ThriftMethod
void sendMasterCounters(GiraphCountersThriftStruct giraphCounters)

Master should call this method after all supersteps are finished, and send the aggregated counters to the job client

Parameters:

giraphCounters - Giraph-based counters