Package | Description |
---|---|
org.apache.giraph.bsp |
Package of generic bulk synchronous processing objects.
|
org.apache.giraph.conf |
Package of Giraph configuration related things.
|
org.apache.giraph.io.superstep_output |
Classes related to output during computation
|
org.apache.giraph.worker |
Package of all the worker related things
|
Modifier and Type | Method and Description |
---|---|
SuperstepOutput<I,V,E> |
CentralizedServiceWorker.getSuperstepOutput()
Get the superstep output class
|
Modifier and Type | Method and Description |
---|---|
SuperstepOutput<I,V,E> |
ImmutableClassesGiraphConfiguration.createSuperstepOutput(org.apache.hadoop.mapreduce.Mapper.Context context)
Create the proper superstep output, based on the configuration settings.
|
Modifier and Type | Class and Description |
---|---|
class |
MultiThreadedSuperstepOutput<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Class to use as
SuperstepOutput when chosen VertexOutputFormat is
thread-safe. |
class |
NoOpSuperstepOutput<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Class to use as
SuperstepOutput when we don't have output during
computation. |
class |
SynchronizedSuperstepOutput<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Class to use as
SuperstepOutput when chosen VertexOutputFormat is
not thread-safe. |
Modifier and Type | Method and Description |
---|---|
SuperstepOutput<I,V,E> |
BspServiceWorker.getSuperstepOutput() |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.