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.utils |
Package of all generic utility classes.
|
org.apache.giraph.worker |
Package of all the worker related things
|
Modifier and Type | Method and Description |
---|---|
WorkerObserver[] |
CentralizedServiceWorker.getWorkerObservers()
Get the observers for this Worker.
|
Modifier and Type | Field and Description |
---|---|
static ClassConfOption<WorkerObserver> |
GiraphConstants.WORKER_OBSERVER_CLASSES
Classes for Worker Observer - optional
|
Modifier and Type | Method and Description |
---|---|
WorkerObserver[] |
ImmutableClassesGiraphConfiguration.createWorkerObservers(org.apache.hadoop.mapreduce.Mapper.Context context)
Create array of WorkerObservers.
|
Modifier and Type | Method and Description |
---|---|
void |
GiraphConfiguration.addWorkerObserverClass(Class<? extends WorkerObserver> workerObserverClass)
Add a WorkerObserver class (optional)
|
Modifier and Type | Class and Description |
---|---|
class |
JMapHistoDumper
An observer for both worker and master that periodically dumps the memory
usage using jmap tool.
|
class |
LogVersions
Logs versions of Giraph dependencies on job start.
|
class |
ReactiveJMapHistoDumper
An observer for both worker and master that periodically checks if available
memory on heap is below certain threshold, and if found to be the case
dumps jmap -histo for the process
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultWorkerObserver
Default Observer for Worker that does nothing.
|
Modifier and Type | Method and Description |
---|---|
WorkerObserver[] |
BspServiceWorker.getWorkerObservers() |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.