An Aster Graph Function must implement the GraphFunction interface, which defines these methods:
Method | Description |
---|---|
Constructor | Generates the contract. |
initializeVertex() | Connects edges to vertices. |
operateOnVertex() | Performs a local computation for a given graph vertex and graph processing iteration. You can use this method to:
|
emitFinalRows() | Allows a vertex to emit final graph function output after graph processing iterations have completed. This method is called per vertex and may emit 0, 1, or more rows per vertex. The number of rows emitted may be different for different vertices. |
undeliverableMessageHandler() | Allows the application to receive and respond to undeliverable vertex messages. |