public class ConnectedComponents<K extends Comparable<K>,VV,EV> extends ParameterizedBase implements Driver<K,VV,EV>, CSV, Hash, Print
GSAConnectedComponents
.
The gather-sum-apply implementation is used because scatter-gather does not
handle object reuse (see FLINK-5891).Constructor and Description |
---|
ConnectedComponents() |
Modifier and Type | Method and Description |
---|---|
String |
getLongDescription()
A multi-line description, presented in the algorithm usage.
|
String |
getName()
A unique, human-readable identifier.
|
String |
getShortDescription()
A one-line description, presented in the algorithm listing.
|
void |
hash(String executionName)
Print hash of execution results.
|
void |
plan(Graph<K,VV,EV> graph)
"Run" algorithms and analytics on the input graph.
|
void |
print(String executionName)
Print execution results.
|
void |
writeCSV(String filename,
String lineDelimiter,
String fieldDelimiter)
Write execution results to file using CSV format.
|
addParameter, configure, getUsage
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
configure, getUsage
public String getName()
Parameterized
getName
in interface Parameterized
public String getShortDescription()
Driver
getShortDescription
in interface Driver<K extends Comparable<K>,VV,EV>
public String getLongDescription()
Driver
getLongDescription
in interface Driver<K extends Comparable<K>,VV,EV>
public void plan(Graph<K,VV,EV> graph) throws Exception
Driver
public void hash(String executionName) throws Exception
Hash
public void print(String executionName) throws Exception
Print
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.