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

Class DegreeAnnotationFunctions.JoinEdgeWithVertexDegree<K,EV,D>

java.lang.Object

org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinEdgeWithVertexDegree<K,EV,D>

Type Parameters:

K - ID type

EV - edge value type

D - degree type

All Implemented Interfaces:

Serializable, Function, JoinFunction<Edge<K,EV>,Vertex<K,D>,Edge<K,Tuple2<EV,D>>>

Enclosing class:

DegreeAnnotationFunctions

public static class DegreeAnnotationFunctions.JoinEdgeWithVertexDegree<K,EV,D>
extends Object
implements JoinFunction<Edge<K,EV>,Vertex<K,D>,Edge<K,Tuple2<EV,D>>>

Assigns the vertex degree to this edge value.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JoinEdgeWithVertexDegree()

Method Summary

Modifier and Type	Method and Description
Edge<K,Tuple2<EV,D>>	join(Edge<K,EV> edge, Vertex<K,D> vertex) 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

JoinEdgeWithVertexDegree

public JoinEdgeWithVertexDegree()

Method Detail

join

public Edge<K,Tuple2<EV,D>> join(Edge<K,EV> edge,
                                 Vertex<K,D> vertex)
                          throws Exception

Description copied from interface: JoinFunction

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

Specified by:

join in interface JoinFunction<Edge<K,EV>,Vertex<K,D>,Edge<K,Tuple2<EV,D>>>

Parameters:

edge - The element from first input.

vertex - 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.