public class ConnectedComponents<K extends Comparable<K>,VV,EV> extends DriverBase<K,VV,EV>
The gather-sum-apply implementation is used because scatter-gather does not handle object reuse (see FLINK-5891).
|Constructor and Description|
|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.
addParameter, configure, getName, getUsage
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
configure, getName, getUsage
public String getShortDescription()
public String getLongDescription()
public 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
not execute a
GraphAlgorithm but only executes a
graph- input graph
Exception- on error
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.