org.apache.flink.examples.scala.graph

Class EnumTriangles$

java.lang.Object

org.apache.flink.examples.scala.graph.EnumTriangles$

public class EnumTriangles$
extends Object

Triangle enumeration is a pre-processing step to find closely connected parts in graphs. A triangle consists of three edges that connect three vertices with each other.

The algorithm works as follows: It groups all edges that share a common vertex and builds triads, i.e., triples of vertices that are connected by two edges. Finally, all triads are filtered for which no third edge exists that closes the triangle.

Input files are plain text files and must be formatted as follows:

- Edges are represented as pairs for vertex IDs which are separated by space characters. Edges are separated by new-line characters. For example "1 2\n2 12\n1 12\n42 63" gives four (undirected) edges (1)-(2), (2)-(12), (1)-(12), and (42)-(63) that include a triangle

     (1)
     /  \
   (2)-(12)
 

Usage:

 EnumTriangleBasic <edge path> <result path>
 

If no parameters are provided, the program is run with default data from EnumTrianglesData

This example shows how to use:

- Custom Java objects which extend Tuple - Group Sorting

Field Summary

Fields

Modifier and Type	Field and Description
static EnumTriangles$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
EnumTriangles$()

Method Summary

Modifier and Type	Method and Description
void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE$

public static final EnumTriangles$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

EnumTriangles$

public EnumTriangles$()

Method Detail

main

public void main(String[] args)