org.apache.flink.graph.asm.translate

Class TranslateVertexValues<K,OLD,NEW,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,OLD,EV,K,NEW,EV>

org.apache.flink.graph.asm.translate.TranslateVertexValues<K,OLD,NEW,EV>

Type Parameters:

K - vertex ID type

OLD - old vertex value type

NEW - new vertex value type

EV - edge value type

All Implemented Interfaces:

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

public class TranslateVertexValues<K,OLD,NEW,EV>
extends GraphAlgorithmWrappingGraph<K,OLD,EV,K,NEW,EV>

Translate Vertex 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
TranslateVertexValues(TranslateFunction<OLD,NEW> translator) Translate Vertex 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,NEW,EV>	runInternal(Graph<K,OLD,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

TranslateVertexValues

public TranslateVertexValues(TranslateFunction<OLD,NEW> translator)

Translate Vertex 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,OLD,EV,Graph<K,NEW,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,NEW,EV> runInternal(Graph<K,OLD,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,OLD,EV,K,NEW,EV>

Parameters:

input - the input graph

Returns:

the algorithm's output

Throws:

Exception