K- graph ID type
VV- vertex value type
EV- edge value type
public interface Driver<K,VV,EV> extends Parameterized
It is preferable to include multiple, overlapping algorithms/analytics in the same driver both for simplicity and since this examples module demonstrates Flink capabilities rather than absolute performance.
|Modifier and Type||Method and Description|
A multi-line description, presented in the algorithm usage.
A one-line description, presented in the algorithm listing.
"Run" algorithms and analytics on the input graph.
Analytic results are summaries so are always printed to the console irrespective of the chosen
configure, getName, getUsage
DataSet plan(Graph<K,VV,EV> graph) throws Exception
Drivers are first configured, next planned, and finally the chosen output method is called.
null value should be returned when the
Driver does not execute a
GraphAlgorithm but only executes a
graph- input graph
Exception- on error
void printAnalytics(PrintStream out)
out- output stream for printing results
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.