org.apache.flink.graph.asm.translate

Class TranslateEdgeValues<K,VV,OLD,NEW>

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,OLD,K,VV,NEW>

org.apache.flink.graph.asm.translate.TranslateEdgeValues<K,VV,OLD,NEW>

Type Parameters:

K - vertex ID type

VV - vertex value type

OLD - old edge value type

NEW - new edge value type

All Implemented Interfaces:

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

public class TranslateEdgeValues<K,VV,OLD,NEW>
extends GraphAlgorithmWrappingGraph<K,VV,OLD,K,VV,NEW>

Translate Edge values using the given TranslateFunction.

Field Summary

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

parallelism

Constructor Summary

Constructors

Constructor and Description
TranslateEdgeValues(TranslateFunction<OLD,NEW> translator) Translate Edge values 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<K,VV,NEW>	runInternal(Graph<K,VV,OLD> 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

TranslateEdgeValues

public TranslateEdgeValues(TranslateFunction<OLD,NEW> translator)

Translate Edge values 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<K,VV,OLD,Graph<K,VV,NEW>>

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

Parameters:

input - the input graph

Returns:

the algorithm's output

Throws:

Exception