org.apache.flink.graph.asm.degree.annotate

Class DegreeAnnotationFunctions

java.lang.Object

org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions

public class DegreeAnnotationFunctions
extends Object

Common user-defined-functions.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DegreeAnnotationFunctions.DegreeCount<K> Combines the vertex degree count.
static class	DegreeAnnotationFunctions.JoinEdgeDegreeWithVertexDegree<K,EV,D> Composes the vertex degree with this edge value.
static class	DegreeAnnotationFunctions.JoinEdgeWithVertexDegree<K,EV,D> Assigns the vertex degree to this edge value.
static class	DegreeAnnotationFunctions.JoinVertexWithVertexDegree<K,VV> Performs a left outer join to apply a zero count for vertices with out- or in-degree of zero.
static class	DegreeAnnotationFunctions.MapEdgeToSourceId<K,EV> Emits the source vertex ID along with an initial count.
static class	DegreeAnnotationFunctions.MapEdgeToTargetId<K,EV> Emits the target vertex ID along with an initial count.

Method Summary

Methods inherited from class java.lang.Object

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