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

Class EdgeSourceDegrees<K,VV,EV>

java.lang.Object

org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase<K,VV,EV,org.apache.flink.api.java.DataSet<T>>

org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingDataSet<K,VV,EV,Edge<K,org.apache.flink.api.java.tuple.Tuple2<EV,VertexDegrees.Degrees>>>

org.apache.flink.graph.asm.degree.annotate.directed.EdgeSourceDegrees<K,VV,EV>

Type Parameters:

K - ID type

VV - vertex value type

EV - edge value type

All Implemented Interfaces:

GraphAlgorithm<K,VV,EV,org.apache.flink.api.java.DataSet<Edge<K,org.apache.flink.api.java.tuple.Tuple2<EV,VertexDegrees.Degrees>>>>

public class EdgeSourceDegrees<K,VV,EV>
extends GraphAlgorithmWrappingDataSet<K,VV,EV,Edge<K,org.apache.flink.api.java.tuple.Tuple2<EV,VertexDegrees.Degrees>>>

Annotates edges of a directed graph with the degree, out-degree, and in-degree of the source vertex.

Field Summary

Fields inherited from class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase

parallelism

Constructor Summary

Constructors

Constructor and Description
EdgeSourceDegrees()

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.java.DataSet<Edge<K,org.apache.flink.api.java.tuple.Tuple2<EV,VertexDegrees.Degrees>>>	runInternal(Graph<K,VV,EV> input) The implementation of the algorithm, renamed from GraphAlgorithm.run(Graph).

Methods inherited from class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingDataSet

equals, hashCode, run

Methods inherited from class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase

canMergeConfigurationWith, getAlgorithmName, mergeConfiguration, setParallelism

Methods inherited from class java.lang.Object

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

Constructor Detail

EdgeSourceDegrees

public EdgeSourceDegrees()

Method Detail

runInternal

public org.apache.flink.api.java.DataSet<Edge<K,org.apache.flink.api.java.tuple.Tuple2<EV,VertexDegrees.Degrees>>> runInternal(Graph<K,VV,EV> input)
                                                                                                                        throws Exception

Description copied from class: GraphAlgorithmWrappingDataSet

The implementation of the algorithm, renamed from GraphAlgorithm.run(Graph).

Specified by:

runInternal in class GraphAlgorithmWrappingDataSet<K,VV,EV,Edge<K,org.apache.flink.api.java.tuple.Tuple2<EV,VertexDegrees.Degrees>>>

Parameters:

input - the input graph

Returns:

the algorithm's output

Throws:

Exception