| Interface | Description |
|---|---|
| WorkerAggregatorUsage |
Vertex classes can access and change aggregators through this interface
|
| WorkerBroadcastUsage |
Methods on worker can access broadcasted values through this interface
|
| WorkerGlobalCommUsage |
Methods on worker can access broadcasted values and provide
values to reduce through this interface
|
| WorkerIndexUsage<I> |
Interface providing utilities for using worker index.
|
| WorkerObserver |
Observer for worker.
|
| WorkerReduceUsage |
Methods on worker can provide values to reduce through this interface
|
| WorkerThreadGlobalCommUsage |
WorkerAggregatorUsage which can be used in each of the
computation threads. |
| Class | Description |
|---|---|
| AllWorkersInfo |
Information about all workers, their WorkerInfo values, and indices.
|
| 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. |
| DefaultWorkerContext |
A dummy implementation of
WorkerContext. |
| DefaultWorkerObserver |
Default Observer for Worker that does nothing.
|
| EdgeInputSplitsCallable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Load as many edge input splits as possible.
|
| EdgeInputSplitsCallableFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Factory for
EdgeInputSplitsCallables. |
| InputSplitsCallable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Abstract base class for loading vertex/edge input splits.
|
| LocalData<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,B extends org.apache.hadoop.io.Writable> |
Stores LocalData for each worker
|
| MappingInputSplitsCallable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,B extends org.apache.hadoop.io.Writable> |
Load as many mapping input splits as possible.
|
| MappingInputSplitsCallableFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,B extends org.apache.hadoop.io.Writable> |
Factory for
MappingInputSplitsCallables. |
| MemoryObserver |
Memory observer to help synchronize when full gcs are happening across all
the workers
|
| VertexInputSplitsCallable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Load as many vertex input splits as possible.
|
| VertexInputSplitsCallableFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Factory for
VertexInputSplitsCallables. |
| WorkerAggregatorDelegator<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Class for delegating WorkerAggregatorUsage and
WorkerGlobalCommUsage methods to corresponding interface.
|
| WorkerAggregatorHandler |
Handler for reduce/broadcast on the workers
|
| WorkerContext |
WorkerContext allows for the execution of user code
on a per-worker basis.
|
| WorkerInfo |
Information about a worker that is sent to the master and other workers.
|
| WorkerInputSplitsHandler |
Requests splits from master and keeps track of them
|
| WorkerProgress |
Stores information about a worker's progress that is periodically written to
ZooKeeper with
WorkerProgressWriter. |
| WorkerProgressStats |
Stats about a worker's progress
|
| WorkerProgressWriter |
Class which periodically writes worker's progress to zookeeper
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.