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

Class DegreeAnnotationFunctions.JoinEdgeDegreeWithVertexDegree<K,EV,D>

java.lang.Object

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

Type Parameters:

K - ID type

EV - edge value type

D - degree type

All Implemented Interfaces:

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

Enclosing class:

DegreeAnnotationFunctions

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

Composes the vertex degree with this edge value.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JoinEdgeDegreeWithVertexDegree()

Method Summary

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

JoinEdgeDegreeWithVertexDegree

public JoinEdgeDegreeWithVertexDegree()

Method Detail

join

public Edge<K,Tuple3<EV,D,D>> join(Edge<K,Tuple2<EV,D>> 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,Tuple2<EV,D>>,Vertex<K,D>,Edge<K,Tuple3<EV,D,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.