@ThriftService
public interface JobProgressTracker
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
|
@ThriftMethod void mapperStarted()
@ThriftMethod void logInfo(String logLine)
logLine
- Line to log@ThriftMethod void logError(String logLine, byte[] exByteArray)
logLine
- Line to logexByteArray
- Exception byte array@ThriftMethod void logFailure(String reason)
reason
- Reason for failure@ThriftMethod void updateProgress(WorkerProgress workerProgress)
workerProgress
- Progress of the worker@ThriftMethod void updateMasterProgress(MasterProgress masterProgress)
masterProgress
- Progress of the master@ThriftMethod void sendMasterCounters(GiraphCountersThriftStruct giraphCounters)
giraphCounters
- Giraph-based countersCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.