org.apache.flink.formats.csv

Class CsvRowDeserializationSchema.Builder

java.lang.Object

org.apache.flink.formats.csv.CsvRowDeserializationSchema.Builder

Enclosing class:

CsvRowDeserializationSchema

@PublicEvolving
public static class CsvRowDeserializationSchema.Builder
extends Object

A builder for creating a CsvRowDeserializationSchema.

Constructor Summary

Constructors

Constructor and Description
Builder(TypeInformation<Row> typeInfo) Creates a CSV deserialization schema for the given TypeInformation with optional parameters.

Method Summary

Modifier and Type	Method and Description
CsvRowDeserializationSchema	build()
CsvRowDeserializationSchema.Builder	setAllowComments(boolean allowComments)
CsvRowDeserializationSchema.Builder	setArrayElementDelimiter(String delimiter)
CsvRowDeserializationSchema.Builder	setEscapeCharacter(char c)
CsvRowDeserializationSchema.Builder	setFieldDelimiter(char delimiter)
CsvRowDeserializationSchema.Builder	setIgnoreParseErrors(boolean ignoreParseErrors)
CsvRowDeserializationSchema.Builder	setNullLiteral(String nullLiteral)
CsvRowDeserializationSchema.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 CSV deserialization schema for the given TypeInformation with optional parameters.

Method Detail

setFieldDelimiter

public CsvRowDeserializationSchema.Builder setFieldDelimiter(char delimiter)

setAllowComments

public CsvRowDeserializationSchema.Builder setAllowComments(boolean allowComments)

setArrayElementDelimiter

public CsvRowDeserializationSchema.Builder setArrayElementDelimiter(String delimiter)

setQuoteCharacter

public CsvRowDeserializationSchema.Builder setQuoteCharacter(char c)

setEscapeCharacter

public CsvRowDeserializationSchema.Builder setEscapeCharacter(char c)

setNullLiteral

public CsvRowDeserializationSchema.Builder setNullLiteral(String nullLiteral)

setIgnoreParseErrors

public CsvRowDeserializationSchema.Builder setIgnoreParseErrors(boolean ignoreParseErrors)

build

public CsvRowDeserializationSchema build()