org.apache.flink.table.sinks

Class CsvTableSink.CsvFormatter

java.lang.Object

org.apache.flink.table.sinks.CsvTableSink.CsvFormatter

All Implemented Interfaces:

Serializable, Function, MapFunction<Row,String>

Enclosing class:

CsvTableSink

public static class CsvTableSink.CsvFormatter
extends Object
implements MapFunction<Row,String>

Formats a Row into a String with fields separated by the field delimiter.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
String	map(Row row) The mapping method.

Methods inherited from class java.lang.Object

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

Method Detail

map

public String map(Row row)

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<Row,String>

Parameters:

row - The input value.

Returns:

The transformed value