K
- graph ID typeVV
- vertex value typeEV
- edge value typepublic interface Driver<K,VV,EV> extends Parameterized
GraphAlgorithm
and/or GraphAnalytic
.
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 |
---|---|
String |
getLongDescription()
A multi-line description, presented in the algorithm usage.
|
String |
getShortDescription()
A one-line description, presented in the algorithm listing.
|
DataSet |
plan(Graph<K,VV,EV> graph)
"Run" algorithms and analytics on the input graph.
|
void |
printAnalytics(PrintStream out)
Analytic results are summaries so are always printed to the console irrespective of the
chosen
Output . |
configure, getName, getUsage
String getShortDescription()
String getLongDescription()
DataSet plan(Graph<K,VV,EV> graph) throws Exception
Drivers are first configured, next planned, and finally the chosen output method is called.
A null
value should be returned when the Driver
does not execute a GraphAlgorithm
but only executes a GraphAnalytic
.
graph
- input graphException
- on errorvoid printAnalytics(PrintStream out)
Output
.out
- output stream for printing resultsCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.