org.apache.flink.formats.csv

Class CsvRowSerializationSchema.Builder

java.lang.Object

org.apache.flink.formats.csv.CsvRowSerializationSchema.Builder

Enclosing class:

CsvRowSerializationSchema

@PublicEvolving
public static class CsvRowSerializationSchema.Builder
extends Object

A builder for creating a CsvRowSerializationSchema.

Constructor Summary

Constructors

Constructor and Description
Builder(TypeInformation<Row> typeInfo) Creates a CsvRowSerializationSchema expecting the given TypeInformation.

Method Summary

Modifier and Type	Method and Description
CsvRowSerializationSchema	build()
CsvRowSerializationSchema.Builder	setArrayElementDelimiter(String delimiter)
CsvRowSerializationSchema.Builder	setEscapeCharacter(char c)
CsvRowSerializationSchema.Builder	setFieldDelimiter(char c)
CsvRowSerializationSchema.Builder	setLineDelimiter(String delimiter)
CsvRowSerializationSchema.Builder	setNullLiteral(String s)
CsvRowSerializationSchema.Builder	setQuoteCharacter(char c)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder(TypeInformation<Row> typeInfo)

Creates a CsvRowSerializationSchema expecting the given TypeInformation.

Parameters:

typeInfo - type information used to create schema.

Method Detail

setFieldDelimiter

public CsvRowSerializationSchema.Builder setFieldDelimiter(char c)

setLineDelimiter

public CsvRowSerializationSchema.Builder setLineDelimiter(String delimiter)

setArrayElementDelimiter

public CsvRowSerializationSchema.Builder setArrayElementDelimiter(String delimiter)

setQuoteCharacter

public CsvRowSerializationSchema.Builder setQuoteCharacter(char c)

setEscapeCharacter

public CsvRowSerializationSchema.Builder setEscapeCharacter(char c)

setNullLiteral

public CsvRowSerializationSchema.Builder setNullLiteral(String s)

build

public CsvRowSerializationSchema build()