Package org.apache.giraph.bsp

Package of generic bulk synchronous processing objects.

See:
          Description

Interface Summary
CentralizedService<I extends WritableComparable,V extends Writable,E extends Writable> Basic service interface shared by both CentralizedServiceMaster and CentralizedServiceWorker.
CentralizedServiceMaster<I extends WritableComparable,V extends Writable,E extends 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 WritableComparable,V extends Writable,E extends Writable> All workers should have access to this centralized service to execute the following methods.
 

Class Summary
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 WritableComparable,V extends Writable,E extends Writable> Zookeeper-based implementation of CentralizedService.
 

Enum Summary
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.



Copyright © 2011-2013 The Apache Software Foundation. All Rights Reserved.