org.apache.flink.graph.asm.translate

Class RichTranslateFunction<IN,OUT>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.graph.asm.translate.RichTranslateFunction<IN,OUT>

Type Parameters:

IN - Type of the input elements.

OUT - Type of the returned elements.

All Implemented Interfaces:

Serializable, Function, RichFunction, TranslateFunction<IN,OUT>

public abstract class RichTranslateFunction<IN,OUT>
extends AbstractRichFunction
implements TranslateFunction<IN,OUT>

Rich variant of the TranslateFunction. As a RichFunction, it gives access to the RuntimeContext and provides setup and teardown methods: RichFunction.open(org.apache.flink.configuration.Configuration) and RichFunction.close().

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RichTranslateFunction()

Method Summary

Modifier and Type	Method and Description
abstract OUT	translate(IN value, OUT reuse) The translating method.

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Detail

RichTranslateFunction

public RichTranslateFunction()

Method Detail

translate

public abstract OUT translate(IN value,
                              OUT 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<IN,OUT>

Parameters:

value - 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.