org.apache.flink.graph.asm.simple.undirected

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.undirected.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>

Add symmetric edges and remove self-loops and duplicate edges from an undirected graph.

Field Summary

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

parallelism

Constructor Summary

Constructors

Constructor and Description
Simplify(boolean clipAndFlip) Simplifies an undirected graph by adding reverse edges and removing self-loops and duplicate edges.

Method Summary

Modifier and Type	Method and Description
protected boolean	canMergeConfigurationWith(GraphAlgorithmWrappingBase other) First test whether the algorithm configurations can be merged before the call to GraphAlgorithmWrappingBase.mergeConfiguration(org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase).
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

getAlgorithmName, mergeConfiguration, setParallelism

Methods inherited from class java.lang.Object

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

Constructor Detail

Simplify

public Simplify(boolean clipAndFlip)

Simplifies an undirected graph by adding reverse edges and removing self-loops and duplicate edges.

When clip-and-flip is set, edges where source < target are removed before symmetrizing the graph.

Parameters:

clipAndFlip - method for generating simple graph

Method Detail

canMergeConfigurationWith

protected boolean canMergeConfigurationWith(GraphAlgorithmWrappingBase other)

Description copied from class: GraphAlgorithmWrappingBase

First test whether the algorithm configurations can be merged before the call to GraphAlgorithmWrappingBase.mergeConfiguration(org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase).

Overrides:

canMergeConfigurationWith in class GraphAlgorithmWrappingBase<K extends Comparable<K>,VV,EV,Graph<K extends Comparable<K>,VV,EV>>

Parameters:

other - the algorithm with which to compare configuration

Returns:

true if and only if configuration can be merged and the algorithm's output can be reused

See Also:

GraphAlgorithmWrappingBase.mergeConfiguration(GraphAlgorithmWrappingBase)

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