org.apache.flink.graph.asm.translate

Class Translate

java.lang.Object

org.apache.flink.graph.asm.translate.Translate

public class Translate
extends Object

Methods for translation of the type or modification of the data of graph IDs, vertex values, and edge values.

Constructor Summary

Constructors

Constructor and Description
Translate()

Method Summary

Modifier and Type	Method and Description
static <OLD,NEW,EV> org.apache.flink.api.java.DataSet<Edge<NEW,EV>>	translateEdgeIds(org.apache.flink.api.java.DataSet<Edge<OLD,EV>> edges, TranslateFunction<OLD,NEW> translator) Translate Edge IDs using the given TranslateFunction.
static <OLD,NEW,EV> org.apache.flink.api.java.DataSet<Edge<NEW,EV>>	translateEdgeIds(org.apache.flink.api.java.DataSet<Edge<OLD,EV>> edges, TranslateFunction<OLD,NEW> translator, int parallelism) Translate Edge IDs using the given TranslateFunction.
static <K,OLD,NEW> org.apache.flink.api.java.DataSet<Edge<K,NEW>>	translateEdgeValues(org.apache.flink.api.java.DataSet<Edge<K,OLD>> edges, TranslateFunction<OLD,NEW> translator) Translate Edge values using the given TranslateFunction.
static <K,OLD,NEW> org.apache.flink.api.java.DataSet<Edge<K,NEW>>	translateEdgeValues(org.apache.flink.api.java.DataSet<Edge<K,OLD>> edges, TranslateFunction<OLD,NEW> translator, int parallelism) Translate Edge values using the given TranslateFunction.
static <OLD,NEW,VV> org.apache.flink.api.java.DataSet<Vertex<NEW,VV>>	translateVertexIds(org.apache.flink.api.java.DataSet<Vertex<OLD,VV>> vertices, TranslateFunction<OLD,NEW> translator) Translate Vertex IDs using the given TranslateFunction.
static <OLD,NEW,VV> org.apache.flink.api.java.DataSet<Vertex<NEW,VV>>	translateVertexIds(org.apache.flink.api.java.DataSet<Vertex<OLD,VV>> vertices, TranslateFunction<OLD,NEW> translator, int parallelism) Translate Vertex IDs using the given TranslateFunction.
static <K,OLD,NEW> org.apache.flink.api.java.DataSet<Vertex<K,NEW>>	translateVertexValues(org.apache.flink.api.java.DataSet<Vertex<K,OLD>> vertices, TranslateFunction<OLD,NEW> translator) Translate Vertex values using the given TranslateFunction.
static <K,OLD,NEW> org.apache.flink.api.java.DataSet<Vertex<K,NEW>>	translateVertexValues(org.apache.flink.api.java.DataSet<Vertex<K,OLD>> vertices, TranslateFunction<OLD,NEW> translator, int parallelism) Translate Vertex values using the given TranslateFunction.

Methods inherited from class java.lang.Object

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

Constructor Detail

Translate

public Translate()

Method Detail

translateVertexIds

public static <OLD,NEW,VV> org.apache.flink.api.java.DataSet<Vertex<NEW,VV>> translateVertexIds(org.apache.flink.api.java.DataSet<Vertex<OLD,VV>> vertices,
                                                                                                TranslateFunction<OLD,NEW> translator)

Translate Vertex IDs using the given TranslateFunction.

Type Parameters:

OLD - old vertex ID type

NEW - new vertex ID type

VV - vertex value type

Parameters:

vertices - input vertices

translator - implements conversion from OLD to NEW

Returns:

translated vertices

translateVertexIds

public static <OLD,NEW,VV> org.apache.flink.api.java.DataSet<Vertex<NEW,VV>> translateVertexIds(org.apache.flink.api.java.DataSet<Vertex<OLD,VV>> vertices,
                                                                                                TranslateFunction<OLD,NEW> translator,
                                                                                                int parallelism)

Translate Vertex IDs using the given TranslateFunction.

Type Parameters:

OLD - old vertex ID type

NEW - new vertex ID type

VV - vertex value type

Parameters:

vertices - input vertices

translator - implements conversion from OLD to NEW

parallelism - operator parallelism

Returns:

translated vertices

translateEdgeIds

public static <OLD,NEW,EV> org.apache.flink.api.java.DataSet<Edge<NEW,EV>> translateEdgeIds(org.apache.flink.api.java.DataSet<Edge<OLD,EV>> edges,
                                                                                            TranslateFunction<OLD,NEW> translator)

Translate Edge IDs using the given TranslateFunction.

Type Parameters:

OLD - old edge ID type

NEW - new edge ID type

EV - edge value type

Parameters:

edges - input edges

translator - implements conversion from OLD to NEW

Returns:

translated edges

translateEdgeIds

public static <OLD,NEW,EV> org.apache.flink.api.java.DataSet<Edge<NEW,EV>> translateEdgeIds(org.apache.flink.api.java.DataSet<Edge<OLD,EV>> edges,
                                                                                            TranslateFunction<OLD,NEW> translator,
                                                                                            int parallelism)

Translate Edge IDs using the given TranslateFunction.

Type Parameters:

OLD - old edge ID type

NEW - new edge ID type

EV - edge value type

Parameters:

edges - input edges

translator - implements conversion from OLD to NEW

parallelism - operator parallelism

Returns:

translated edges

translateVertexValues

public static <K,OLD,NEW> org.apache.flink.api.java.DataSet<Vertex<K,NEW>> translateVertexValues(org.apache.flink.api.java.DataSet<Vertex<K,OLD>> vertices,
                                                                                                 TranslateFunction<OLD,NEW> translator)

Translate Vertex values using the given TranslateFunction.

Type Parameters:

K - vertex ID type

OLD - old vertex value type

NEW - new vertex value type

Parameters:

vertices - input vertices

translator - implements conversion from OLD to NEW

Returns:

translated vertices

translateVertexValues

public static <K,OLD,NEW> org.apache.flink.api.java.DataSet<Vertex<K,NEW>> translateVertexValues(org.apache.flink.api.java.DataSet<Vertex<K,OLD>> vertices,
                                                                                                 TranslateFunction<OLD,NEW> translator,
                                                                                                 int parallelism)

Translate Vertex values using the given TranslateFunction.

Type Parameters:

K - vertex ID type

OLD - old vertex value type

NEW - new vertex value type

Parameters:

vertices - input vertices

translator - implements conversion from OLD to NEW

parallelism - operator parallelism

Returns:

translated vertices

translateEdgeValues

public static <K,OLD,NEW> org.apache.flink.api.java.DataSet<Edge<K,NEW>> translateEdgeValues(org.apache.flink.api.java.DataSet<Edge<K,OLD>> edges,
                                                                                             TranslateFunction<OLD,NEW> translator)

Translate Edge values using the given TranslateFunction.

Type Parameters:

K - edge ID type

OLD - old edge value type

NEW - new edge value type

Parameters:

edges - input edges

translator - implements conversion from OLD to NEW

Returns:

translated edges

translateEdgeValues

public static <K,OLD,NEW> org.apache.flink.api.java.DataSet<Edge<K,NEW>> translateEdgeValues(org.apache.flink.api.java.DataSet<Edge<K,OLD>> edges,
                                                                                             TranslateFunction<OLD,NEW> translator,
                                                                                             int parallelism)

Translate Edge values using the given TranslateFunction.

Type Parameters:

K - vertex ID type

OLD - old edge value type

NEW - new edge value type

Parameters:

edges - input edges

translator - implements conversion from OLD to NEW

parallelism - operator parallelism

Returns:

translated edges