public class ConnectedComponents extends Object implements ProgramDescription
org.apache.flink.graph.library
.
In particular, this example uses the GSAConnectedComponents
library method to compute the connected components of the input graph.
The input file is a plain text file and must be formatted as follows:
Edges are represented by tuples of srcVertexId, trgVertexId which are
separated by tabs. Edges themselves are separated by newlines.
For example: 1\t2\n1\t3\n
defines two edges,
1-2 with and 1-3.
Usage ConnectedComponents <edge path> <result path>
<number of iterations>
ConnectedComponentsDefaultData
Constructor and Description |
---|
ConnectedComponents() |
Modifier and Type | Method and Description |
---|---|
String |
getDescription()
Returns a description of the plan that is generated by the assembler and
also of the arguments if they are available.
|
static void |
main(String[] args) |
public String getDescription()
ProgramDescription
getDescription
in interface ProgramDescription
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.