org.apache.flink.examples.scala.graph

Class EnumTriangles.TriadBuilder

java.lang.Object

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

All Implemented Interfaces:

Serializable, Function, GroupReduceFunction<EnumTriangles.Edge,EnumTriangles.Triad>

Enclosing class:

EnumTriangles

public static class EnumTriangles.TriadBuilder
extends Object
implements GroupReduceFunction<EnumTriangles.Edge,EnumTriangles.Triad>

Builds triads (triples of vertices) from pairs of edges that share a vertex. The first vertex of a triad is the shared vertex, the second and third vertex are ordered by vertexId. Assumes that input edges share the first vertex and are in ascending order of the second vertex.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TriadBuilder()

Method Summary

Modifier and Type	Method and Description
void	reduce(Iterable<EnumTriangles.Edge> edges, Collector<EnumTriangles.Triad> out) The reduce method.
scala.collection.mutable.MutableList<Integer>	vertices()

Methods inherited from class java.lang.Object

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

Constructor Detail

TriadBuilder

public TriadBuilder()

Method Detail

vertices

public scala.collection.mutable.MutableList<Integer> vertices()

reduce

public void reduce(Iterable<EnumTriangles.Edge> edges,
                   Collector<EnumTriangles.Triad> out)

Description copied from interface: GroupReduceFunction

The reduce method. The function receives one call per group of elements.

Specified by:

reduce in interface GroupReduceFunction<EnumTriangles.Edge,EnumTriangles.Triad>

Parameters:

edges - All records that belong to the given input key.

out - The collector to hand results to.