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

Class DegreeAnnotationFunctions.JoinVertexWithVertexDegree<K,VV>

java.lang.Object

org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinVertexWithVertexDegree<K,VV>

Type Parameters:

K - ID type

VV - vertex value type

All Implemented Interfaces:

Serializable, Function, JoinFunction<Vertex<K,VV>,Vertex<K,LongValue>,Vertex<K,LongValue>>

Enclosing class:

DegreeAnnotationFunctions

public static class DegreeAnnotationFunctions.JoinVertexWithVertexDegree<K,VV>
extends Object
implements JoinFunction<Vertex<K,VV>,Vertex<K,LongValue>,Vertex<K,LongValue>>

Performs a left outer join to apply a zero count for vertices with out- or in-degree of zero.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JoinVertexWithVertexDegree()

Method Summary

Modifier and Type	Method and Description
Vertex<K,LongValue>	join(Vertex<K,VV> vertex, Vertex<K,LongValue> vertexDegree) The join method, called once per joined pair of elements.

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinVertexWithVertexDegree

public JoinVertexWithVertexDegree()

Method Detail

join

public Vertex<K,LongValue> join(Vertex<K,VV> vertex,
                                Vertex<K,LongValue> vertexDegree)
                         throws Exception

Description copied from interface: JoinFunction

The join method, called once per joined pair of elements.

Specified by:

join in interface JoinFunction<Vertex<K,VV>,Vertex<K,LongValue>,Vertex<K,LongValue>>

Parameters:

vertex - The element from first input.

vertexDegree - The element from second input.

Returns:

The resulting element.

Throws:

Exception - This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.