org.apache.flink.graph.utils.proxy

Class GraphAlgorithmWrappingGraph<IN_K,IN_VV,IN_EV,OUT_K,OUT_VV,OUT_EV>

java.lang.Object

org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase<IN_K,IN_VV,IN_EV,Graph<OUT_K,OUT_VV,OUT_EV>>

org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingGraph<IN_K,IN_VV,IN_EV,OUT_K,OUT_VV,OUT_EV>

Type Parameters:

IN_K - input ID type

IN_VV - input vertex value type

IN_EV - input edge value type

OUT_K - output ID type

OUT_VV - output vertex value type

OUT_EV - output edge value type

All Implemented Interfaces:

GraphAlgorithm<IN_K,IN_VV,IN_EV,Graph<OUT_K,OUT_VV,OUT_EV>>

Direct Known Subclasses:

MaximumDegree, Simplify, Simplify, TranslateEdgeValues, TranslateGraphIds, TranslateVertexValues

public abstract class GraphAlgorithmWrappingGraph<IN_K,IN_VV,IN_EV,OUT_K,OUT_VV,OUT_EV>
extends GraphAlgorithmWrappingBase<IN_K,IN_VV,IN_EV,Graph<OUT_K,OUT_VV,OUT_EV>>

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

See Also:

GraphAlgorithmWrappingBase

Field Summary

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

parallelism

Constructor Summary

Constructors

Constructor and Description
GraphAlgorithmWrappingGraph()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
int	hashCode()
Graph<OUT_K,OUT_VV,OUT_EV>	run(Graph<IN_K,IN_VV,IN_EV> input)
protected abstract Graph<OUT_K,OUT_VV,OUT_EV>	runInternal(Graph<IN_K,IN_VV,IN_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

GraphAlgorithmWrappingGraph

public GraphAlgorithmWrappingGraph()

Method Detail

runInternal

protected abstract Graph<OUT_K,OUT_VV,OUT_EV> runInternal(Graph<IN_K,IN_VV,IN_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 Graph<OUT_K,OUT_VV,OUT_EV> run(Graph<IN_K,IN_VV,IN_EV> input)
                                     throws Exception

Throws:

Exception