org.apache.flink.graph.utils

Class GraphUtils.MapTo<I,O>

java.lang.Object

org.apache.flink.graph.utils.GraphUtils.MapTo<I,O>

Type Parameters:

I - input type

O - output type

All Implemented Interfaces:

Serializable, Function, MapFunction<I,O>, ResultTypeQueryable<O>, TranslateFunction<I,O>

Enclosing class:

GraphUtils

public static class GraphUtils.MapTo<I,O>
extends Object
implements MapFunction<I,O>, ResultTypeQueryable<O>, TranslateFunction<I,O>

Map each element to a value.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MapTo(O value) Map each element to the given object.

Method Summary

Modifier and Type	Method and Description
TypeInformation<O>	getProducedType() Gets the data type (as a TypeInformation) produced by this function or input format.
O	map(I input) The mapping method.
O	translate(I input, O reuse) The translating method.

Methods inherited from class java.lang.Object

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

Constructor Detail

MapTo

public MapTo(O value)

Map each element to the given object.

Parameters:

value - the object to emit for each element

Method Detail

map

public O map(I input)
      throws Exception

Description copied from interface: MapFunction

The mapping method. Takes an element from the input data set and transforms it into exactly one element.

Specified by:

map in interface MapFunction<I,O>

Parameters:

input - The input value.

Returns:

The transformed value

Throws:

Exception - This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.

translate

public O translate(I input,
                   O reuse)
            throws Exception

Description copied from interface: TranslateFunction

The translating method. Takes an element from the input data set and transforms it into exactly one element.

Specified by:

translate in interface TranslateFunction<I,O>

Parameters:

input - input value.

reuse - value which may be reused for output; if reuse is null then a new output object must be instantiated and returned

Returns:

the transformed value

Throws:

Exception - This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.

getProducedType

public TypeInformation<O> getProducedType()

Description copied from interface: ResultTypeQueryable

Gets the data type (as a TypeInformation) produced by this function or input format.

Specified by:

getProducedType in interface ResultTypeQueryable<O>

Returns:

The data type produced by this function or input format.