org.apache.flink.api.java.functions

Class FormattingMapper<T>

java.lang.Object

org.apache.flink.api.java.functions.FormattingMapper<T>

Type Parameters:

T -

All Implemented Interfaces:

Serializable, Function, MapFunction<T,String>

@Internal
public class FormattingMapper<T>
extends Object
implements MapFunction<T,String>

Mapper that converts values to strings using a TextOutputFormat.TextFormatter.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FormattingMapper(TextOutputFormat.TextFormatter<T> formatter)

Method Summary

Modifier and Type	Method and Description
String	map(T value) The mapping method.

Methods inherited from class java.lang.Object

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

Constructor Detail

FormattingMapper

public FormattingMapper(TextOutputFormat.TextFormatter<T> formatter)

Method Detail

map

public String map(T value)
           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<T,String>

Parameters:

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