org.apache.flink.graph.utils.proxy

Class GraphAlgorithmWrappingDataSet<K,VV,EV,T>

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,T>

Type Parameters:

K - ID type

VV - vertex value type

EV - edge value type

T - output DataSet type

All Implemented Interfaces:

GraphAlgorithm<K,VV,EV,org.apache.flink.api.java.DataSet<T>>

Direct Known Subclasses:

AdamicAdar, EdgeDegreePair, EdgeDegreesPair, EdgeSourceDegree, EdgeSourceDegrees, EdgeTargetDegree, EdgeTargetDegrees, HITS, JaccardIndex, LocalClusteringCoefficient, LocalClusteringCoefficient, PageRank, TriangleListingBase, VertexDegree, VertexDegrees, VertexInDegree, VertexOutDegree

public abstract class GraphAlgorithmWrappingDataSet<K,VV,EV,T>
extends GraphAlgorithmWrappingBase<K,VV,EV,org.apache.flink.api.java.DataSet<T>>

Base class for a mergeable GraphAlgorithm which wraps and returns a result DataSet.

See Also:

GraphAlgorithmWrappingBase

Field Summary

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

parallelism

Constructor Summary

Constructors

Constructor and Description
GraphAlgorithmWrappingDataSet()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
int	hashCode()
org.apache.flink.api.java.DataSet<T>	run(Graph<K,VV,EV> input)
protected abstract org.apache.flink.api.java.DataSet<T>	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.GraphAlgorithmWrappingBase

canMergeConfigurationWith, getAlgorithmName, mergeConfiguration, setParallelism

Methods inherited from class java.lang.Object

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

Constructor Detail

GraphAlgorithmWrappingDataSet

public GraphAlgorithmWrappingDataSet()

Method Detail

runInternal

protected abstract org.apache.flink.api.java.DataSet<T> runInternal(Graph<K,VV,EV> input)
                                                             throws Exception

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

Parameters:

input - the input graph

Returns:

the algorithm's output

Throws:

Exception

hashCode

public final int hashCode()

Overrides:

hashCode in class Object

equals

public final boolean equals(Object obj)

Overrides:

equals in class Object

run

public final org.apache.flink.api.java.DataSet<T> run(Graph<K,VV,EV> input)
                                               throws Exception

Throws:

Exception