See: Description
| Interface | Description |
|---|---|
| VertexPostprocessor |
Interface containing a single function - postprocess.
|
| 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.
|
| 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.