org.apache.flink.examples.java.graph

Class EnumTriangles

java.lang.Object

org.apache.flink.examples.java.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 --edges <path> --output <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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EnumTriangles.TupleEdgeConverter Converts a Tuple2 into an Edge

Constructor Summary

Constructors

Constructor and Description
EnumTriangles()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

EnumTriangles

public EnumTriangles()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception