Package | Description |
---|---|
org.apache.giraph.bsp |
Package of generic bulk synchronous processing objects.
|
org.apache.giraph.worker |
Package of all the worker related things
|
Modifier and Type | Method and Description |
---|---|
FinishedSuperstepStats |
CentralizedServiceWorker.finishSuperstep(List<PartitionStats> partitionStatsList,
GiraphTimerContext superstepTimerContext)
Worker is done with its portion of the superstep.
|
FinishedSuperstepStats |
CentralizedServiceWorker.setup()
Setup (must be called prior to any other function)
|
Modifier and Type | Method and Description |
---|---|
void |
CentralizedServiceWorker.cleanup(FinishedSuperstepStats finishedSuperstepStats)
Clean up the service (no calls may be issued after this)
|
Modifier and Type | Method and Description |
---|---|
FinishedSuperstepStats |
BspServiceWorker.finishSuperstep(List<PartitionStats> partitionStatsList,
GiraphTimerContext superstepTimerContext) |
FinishedSuperstepStats |
BspServiceWorker.setup() |
Modifier and Type | Method and Description |
---|---|
void |
BspServiceWorker.cleanup(FinishedSuperstepStats finishedSuperstepStats) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.