Package org.apache.giraph.bsp

Package of generic bulk synchronous processing objects.

See: Description

Interface Summary

Interface	Description
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.
CentralizedServiceMaster<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	At most, there will be one active master at a time, but many threads can be trying to be the active master.
CentralizedServiceWorker<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	All workers should have access to this centralized service to execute the following methods.

Class Summary

Class	Description
BspInputFormat	This InputFormat supports the BSP model by ensuring that the user specifies how many splits (number of mappers) should be started simultaneously.
BspInputSplit	This InputSplit will not give any ordering or location data.
BspOutputFormat	This is for internal use only.
BspRecordWriter	Used by BspOutputFormat since some versions of Hadoop require that a RecordWriter is returned from getRecordWriter.
BspService<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Zookeeper-based implementation of CentralizedService.
ImmutableOutputCommitter	This output committer doesn't do anything, meant for the case where output isn't desired, or as a base for not using FileOutputCommitter.

Enum Summary

Enum	Description
ApplicationState	State of the BSP application
SuperstepState	State of a coordinated superstep

Package org.apache.giraph.bsp Description

Package of generic bulk synchronous processing objects.