org.apache.giraph.bsp

Interface CentralizedService<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Type Parameters:

I - Vertex id

V - Vertex value

E - Edge value

All Known Subinterfaces:

CentralizedServiceMaster<I,V,E>, CentralizedServiceWorker<I,V,E>

All Known Implementing Classes:

BspService, BspServiceMaster, BspServiceWorker

public interface CentralizedService<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Basic service interface shared by both CentralizedServiceMaster and CentralizedServiceWorker.

Method Summary

Modifier and Type	Method and Description
ImmutableClassesGiraphConfiguration<I,V,E>	getConfiguration() Get configuration
JobProgressTracker	getJobProgressTracker() Get JobProgressTracker to report progress to
MasterInfo	getMasterInfo() Get master info
long	getRestartedSuperstep() Get the restarted superstep
long	getSuperstep() Get the current global superstep of the application to work on.
List<WorkerInfo>	getWorkerInfoList() Get list of workers

Method Detail

getSuperstep

long getSuperstep()

Get the current global superstep of the application to work on.

Returns:

global superstep (begins at INPUT_SUPERSTEP)

getRestartedSuperstep

long getRestartedSuperstep()

Get the restarted superstep

Returns:

-1 if not manually restarted, otherwise the superstep id

getWorkerInfoList

List<WorkerInfo> getWorkerInfoList()

Get list of workers

Returns:

List of workers

getMasterInfo

MasterInfo getMasterInfo()

Get master info

Returns:

Master info

getJobProgressTracker

JobProgressTracker getJobProgressTracker()

Get JobProgressTracker to report progress to

Returns:

JobProgressTrackerClient

getConfiguration

ImmutableClassesGiraphConfiguration<I,V,E> getConfiguration()

Get configuration

Returns:

configuration