Package | Description |
---|---|
org.apache.giraph.block_app.framework.piece |
Single execution object - Piece, and related classes.
|
org.apache.giraph.block_app.framework.piece.delegate |
Pieces that delegate their work to a set of one or multiple other Pieces.
|
org.apache.giraph.block_app.framework.piece.interfaces |
Vertex processing functions for Pieces
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractPiece.InnerVertexReceiver
Inner class to provide clean use without specifying types
|
class |
AbstractPiece.InnerVertexSender
Inner class to provide clean use without specifying types
|
Modifier and Type | Class and Description |
---|---|
protected class |
DelegatePiece.DelegateWorkerReceiveFunctions
Delegating WorkerReceivePiece
|
protected class |
DelegatePiece.DelegateWorkerSendFunctions
Delegating WorkerSendPiece
|
Modifier and Type | Interface and Description |
---|---|
interface |
VertexPostprocessor
Interface containing a single function - postprocess.
|
interface |
VertexReceiver<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable>
Interface representing actions that happen on worker, for each vertex,
during receive phase:
to receive messages from vertices
to receive data from master through aggregators
Marked to not allow seriazliation, as it should be created on the worker,
so should never be serialiized, disallow only for catching problems early.
|
interface |
VertexSender<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Interface representing actions that happen on worker, for each vertex,
during send phase:
to send messages to vertices
to send data for aggregation on master
Marked to not allow seriazliation, as it should be created on the worker,
so should never be serialiized, disallow only for catching problems early.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.