org.apache.flink.formats.csv

Class CsvRowDataDeserializationSchema.Builder

java.lang.Object

org.apache.flink.formats.csv.CsvRowDataDeserializationSchema.Builder

Enclosing class:

CsvRowDataDeserializationSchema

@Internal
public static class CsvRowDataDeserializationSchema.Builder
extends Object

A builder for creating a CsvRowDataDeserializationSchema.

Constructor Summary

Constructors

Constructor and Description
Builder(RowType rowType, TypeInformation<RowData> resultTypeInfo) Creates a CSV deserialization schema for the given TypeInformation with optional parameters.

Method Summary

Modifier and Type	Method and Description
CsvRowDataDeserializationSchema	build()
CsvRowDataDeserializationSchema.Builder	setAllowComments(boolean allowComments)
CsvRowDataDeserializationSchema.Builder	setArrayElementDelimiter(String delimiter)
CsvRowDataDeserializationSchema.Builder	setEscapeCharacter(char c)
CsvRowDataDeserializationSchema.Builder	setFieldDelimiter(char delimiter)
CsvRowDataDeserializationSchema.Builder	setIgnoreParseErrors(boolean ignoreParseErrors)
CsvRowDataDeserializationSchema.Builder	setNullLiteral(String nullLiteral)
CsvRowDataDeserializationSchema.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(RowType rowType,
               TypeInformation<RowData> resultTypeInfo)

Creates a CSV deserialization schema for the given TypeInformation with optional parameters.

Method Detail

setFieldDelimiter

public CsvRowDataDeserializationSchema.Builder setFieldDelimiter(char delimiter)

setAllowComments

public CsvRowDataDeserializationSchema.Builder setAllowComments(boolean allowComments)

setArrayElementDelimiter

public CsvRowDataDeserializationSchema.Builder setArrayElementDelimiter(String delimiter)

setQuoteCharacter

public CsvRowDataDeserializationSchema.Builder setQuoteCharacter(char c)

setEscapeCharacter

public CsvRowDataDeserializationSchema.Builder setEscapeCharacter(char c)

setNullLiteral

public CsvRowDataDeserializationSchema.Builder setNullLiteral(String nullLiteral)

setIgnoreParseErrors

public CsvRowDataDeserializationSchema.Builder setIgnoreParseErrors(boolean ignoreParseErrors)

build

public CsvRowDataDeserializationSchema build()