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 | Method and Description |
---|---|
void |
StaticFlowControl.newSuperstep(SuperstepMetricsRegistry metrics) |
Modifier and Type | Method and Description |
---|---|
void |
NettyWorkerClient.newSuperstep(SuperstepMetricsRegistry metrics) |
void |
ByteCounterDelegate.newSuperstep(SuperstepMetricsRegistry superstepMetrics)
Called by Inbound/ Outbound counters to refresh meters on a new superstep
|
void |
OutboundByteCounter.newSuperstep(SuperstepMetricsRegistry superstepMetrics) |
void |
InboundByteCounter.newSuperstep(SuperstepMetricsRegistry superstepMetrics) |
Modifier and Type | Method and Description |
---|---|
void |
GraphTaskManager.newSuperstep(SuperstepMetricsRegistry superstepMetrics) |
Modifier and Type | Method and Description |
---|---|
void |
BspServiceMaster.newSuperstep(SuperstepMetricsRegistry superstepMetrics) |
Modifier and Type | Method and Description |
---|---|
static SuperstepMetricsRegistry |
SuperstepMetricsRegistry.create(GiraphConfiguration conf,
long superstep)
Create with Hadoop Configuration and superstep number.
|
static SuperstepMetricsRegistry |
SuperstepMetricsRegistry.createFake()
Create an empty registry
|
SuperstepMetricsRegistry |
GiraphMetrics.perSuperstep()
Get per-superstep metrics.
|
Modifier and Type | Method and Description |
---|---|
void |
ResetSuperstepMetricsObserver.newSuperstep(SuperstepMetricsRegistry superstepMetrics)
Starting a new superstep.
|
Modifier and Type | Method and Description |
---|---|
void |
OutOfCoreIOCallable.newSuperstep(SuperstepMetricsRegistry superstepMetrics) |
void |
OutOfCoreEngine.newSuperstep(SuperstepMetricsRegistry superstepMetrics) |
Modifier and Type | Method and Description |
---|---|
void |
BspServiceWorker.newSuperstep(SuperstepMetricsRegistry superstepMetrics) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.