Package | Description |
---|---|
org.apache.giraph.comm.flow_control |
Package for flow-control policies.
|
org.apache.giraph.comm.netty |
Package for netty implementations.
|
org.apache.giraph.graph |
Package of all the graph related objects, built on the
org.apache.bsp package.
|
org.apache.giraph.master |
Package of all the master related things.
|
org.apache.giraph.metrics |
Package of all the Giraph metrics related data.
|
org.apache.giraph.ooc |
Package of out-of-core related classes.
|
org.apache.giraph.worker |
Package of all the worker related things
|
Modifier and Type | Class and Description |
---|---|
class |
StaticFlowControl
Representation of a flow control that limits the aggregate number of open
requests to all other workers to a constant user-defined value
|
Modifier and Type | Class and Description |
---|---|
class |
InboundByteCounter
Keep track of the bytes received and provide some metrics when
desired as part of the Netty Channel stack.
|
class |
NettyWorkerClient<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Takes users facing APIs in
WorkerClient and implements them
using the available WritableRequest objects. |
class |
OutboundByteCounter
Keep track of the bytes sent and provide some metrics when
desired as part of the Netty Channel stack.
|
Modifier and Type | Class and Description |
---|---|
class |
GraphTaskManager<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
The Giraph-specific business logic for a single BSP
compute node in whatever underlying type of cluster
our Giraph job will run on.
|
Modifier and Type | Class and Description |
---|---|
class |
BspServiceMaster<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
CentralizedServiceMaster . |
Modifier and Type | Method and Description |
---|---|
void |
GiraphMetrics.addSuperstepResetObserver(ResetSuperstepMetricsObserver observer)
Anyone using per-superstep counters needs to re-initialize their Metrics
object on each new superstep.
|
Modifier and Type | Class and Description |
---|---|
class |
OutOfCoreEngine
Class to represent an out-of-core engine.
|
class |
OutOfCoreIOCallable
IO threads for out-of-core mechanism.
|
Modifier and Type | Class and Description |
---|---|
class |
BspServiceWorker<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
CentralizedServiceWorker . |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.