Class EnumTriangles.TupleEdgeConverter
- java.lang.Object
-
- org.apache.flink.examples.java.graph.EnumTriangles.TupleEdgeConverter
-
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.functions.Function,org.apache.flink.api.common.functions.MapFunction<org.apache.flink.api.java.tuple.Tuple2<Integer,Integer>,EnumTrianglesDataTypes.Edge>
- Enclosing class:
- EnumTriangles
public static class EnumTriangles.TupleEdgeConverter extends Object implements org.apache.flink.api.common.functions.MapFunction<org.apache.flink.api.java.tuple.Tuple2<Integer,Integer>,EnumTrianglesDataTypes.Edge>
Converts a Tuple2 into an Edge.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description TupleEdgeConverter()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description EnumTrianglesDataTypes.Edgemap(org.apache.flink.api.java.tuple.Tuple2<Integer,Integer> t)
-
-
-
Method Detail
-
map
public EnumTrianglesDataTypes.Edge map(org.apache.flink.api.java.tuple.Tuple2<Integer,Integer> t) throws Exception
- Specified by:
mapin interfaceorg.apache.flink.api.common.functions.MapFunction<org.apache.flink.api.java.tuple.Tuple2<Integer,Integer>,EnumTrianglesDataTypes.Edge>- Throws:
Exception
-
-