org.apache.flink.graph.asm.translate

Class TranslateGraphIds<OLD,NEW,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<OLD,VV,EV,NEW,VV,EV>

org.apache.flink.graph.asm.translate.TranslateGraphIds<OLD,NEW,VV,EV>

Type Parameters:

OLD - old graph ID type

NEW - new graph ID type

VV - vertex value type

EV - edge value type

All Implemented Interfaces:

GraphAlgorithm<OLD,VV,EV,Graph<NEW,VV,EV>>

public class TranslateGraphIds<OLD,NEW,VV,EV>
extends GraphAlgorithmWrappingGraph<OLD,VV,EV,NEW,VV,EV>

Translate Vertex and Edge IDs of a Graph using the given TranslateFunction.

Field Summary

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

parallelism

Constructor Summary

Constructors

Constructor and Description
TranslateGraphIds(TranslateFunction<OLD,NEW> translator) Translate Vertex and Edge IDs of a Graph using the given TranslateFunction.

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<NEW,VV,EV>	runInternal(Graph<OLD,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

TranslateGraphIds

public TranslateGraphIds(TranslateFunction<OLD,NEW> translator)

Translate Vertex and Edge IDs of a Graph using the given TranslateFunction.

Parameters:

translator - implements conversion from OLD to NEW

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<OLD,VV,EV,Graph<NEW,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<NEW,VV,EV> runInternal(Graph<OLD,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<OLD,VV,EV,NEW,VV,EV>

Parameters:

input - the input graph

Returns:

the algorithm's output

Throws:

Exception