org.apache.flink.graph.asm.simple.directed

Class Simplify<K extends Comparable<K>,VV,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<K,VV,EV,K,VV,EV>

org.apache.flink.graph.asm.simple.directed.Simplify<K,VV,EV>

Type Parameters:

K - ID type

VV - vertex value type

EV - edge value type

All Implemented Interfaces:

GraphAlgorithm<K,VV,EV,Graph<K,VV,EV>>

public class Simplify<K extends Comparable<K>,VV,EV>
extends GraphAlgorithmWrappingGraph<K,VV,EV,K,VV,EV>

Remove self-loops and duplicate edges from a directed graph.

Field Summary

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

parallelism

Constructor Summary

Constructors

Constructor and Description
Simplify()

Method Summary

Modifier and Type	Method and Description
Graph<K,VV,EV>	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.GraphAlgorithmWrappingGraph

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

Simplify

public Simplify()

Method Detail

runInternal

public Graph<K,VV,EV> runInternal(Graph<K,VV,EV> input)
                           throws Exception

Description copied from class: GraphAlgorithmWrappingGraph

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

Specified by:

runInternal in class GraphAlgorithmWrappingGraph<K extends Comparable<K>,VV,EV,K extends Comparable<K>,VV,EV>

Parameters:

input - the input graph

Returns:

the algorithm's output

Throws:

Exception