Uses of Interface
org.apache.giraph.zk.BspEvent

Packages that use BspEvent

Package	Description
org.apache.giraph.bsp	Package of generic bulk synchronous processing objects.
org.apache.giraph.master	Package of all the master related things.
org.apache.giraph.worker	Package of all the worker related things
org.apache.giraph.zk	Package of ZooKeeper related objects.

Uses of BspEvent in org.apache.giraph.bsp

Methods in org.apache.giraph.bsp that return BspEvent

Modifier and Type	Method and Description
BspEvent	BspService.getApplicationAttemptChangedEvent()
BspEvent	BspService.getCleanedUpChildrenChangedEvent()
BspEvent	BspService.getInputSplitsAllDoneEvent()
BspEvent	BspService.getInputSplitsWorkerDoneEvent()
BspEvent	BspService.getMasterElectionChildrenChangedEvent()
BspEvent	BspService.getSuperstepFinishedEvent()
BspEvent	BspService.getWorkerHealthRegistrationChangedEvent()
BspEvent	BspService.getWrittenCountersToZKEvent()

Methods in org.apache.giraph.bsp with parameters of type BspEvent

Modifier and Type	Method and Description
void	BspService.registerBspEvent(BspEvent event) Register a BspEvent.

Uses of BspEvent in org.apache.giraph.master

Methods in org.apache.giraph.master that return BspEvent

Modifier and Type	Method and Description
BspEvent	BspServiceMaster.getSuperstepStateChangedEvent() Event that the master watches that denotes if a worker has done something that changes the state of a superstep (either a worker completed or died)
BspEvent	BspServiceMaster.getWorkerWroteCheckpointEvent() Event that the master watches that denotes when a worker wrote checkpoint

Uses of BspEvent in org.apache.giraph.worker

Methods in org.apache.giraph.worker that return BspEvent

Modifier and Type	Method and Description
BspEvent	BspServiceWorker.getPartitionExchangeChildrenChangedEvent() Get event when the state of a partition exchange has changed.

Uses of BspEvent in org.apache.giraph.zk

Classes in org.apache.giraph.zk that implement BspEvent

Modifier and Type	Class and Description
class	PredicateLock A lock with a predicate that was be used to synchronize events and keep the job context updated while waiting.