public class ConnectedComponents<K extends Comparable<K>,VV,EV> extends DriverBase<K,VV,EV>
GSAConnectedComponents
.
The gather-sum-apply implementation is used because scatter-gather does not handle object reuse (see FLINK-5891).
parallelism
Constructor and Description |
---|
ConnectedComponents() |
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.
|
printAnalytics
addParameter, configure, getName, getUsage
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
configure, getName, getUsage
public String getShortDescription()
Driver
public String getLongDescription()
Driver
public DataSet plan(Graph<K,VV,EV> graph) throws Exception
Driver
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 errorCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.