org.apache.flink.formats.csv

Class PythonCsvUtils

java.lang.Object

org.apache.flink.formats.csv.PythonCsvUtils

public class PythonCsvUtils
extends Object

Utilities for using CSV format in PyFlink.

Constructor Summary

Constructors

Constructor and Description
PythonCsvUtils()

Method Summary

Modifier and Type	Method and Description
static BulkWriter.Factory<RowData>	createCsvBulkWriterFactory(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema schema, DataType physicalDataType) Util for creating a BulkWriter.Factory that wraps CsvBulkWriter.forSchema(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvMapper, org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema, org.apache.flink.formats.common.Converter<T, R, C>, C, org.apache.flink.core.fs.FSDataOutputStream).
static CsvReaderFormat<Object>	createCsvReaderFormat(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema schema, DataType dataType) Util for creating a CsvReaderFormat.
static RowDataToCsvConverters.RowDataToCsvConverter.RowDataToCsvFormatConverterContext	createRowDataToCsvFormatConverterContext(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvMapper mapper, org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ContainerNode<?> container) Util for creating a RowDataToCsvConverters.RowDataToCsvConverter.RowDataToCsvFormatConverterContext.

Methods inherited from class java.lang.Object

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

Constructor Detail

PythonCsvUtils

public PythonCsvUtils()

Method Detail

createCsvReaderFormat

public static CsvReaderFormat<Object> createCsvReaderFormat(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema schema,
                                                            DataType dataType)

Util for creating a CsvReaderFormat.

createRowDataToCsvFormatConverterContext

public static RowDataToCsvConverters.RowDataToCsvConverter.RowDataToCsvFormatConverterContext createRowDataToCsvFormatConverterContext(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvMapper mapper,
                                                                                                                                       org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ContainerNode<?> container)

Util for creating a RowDataToCsvConverters.RowDataToCsvConverter.RowDataToCsvFormatConverterContext.

createCsvBulkWriterFactory

public static BulkWriter.Factory<RowData> createCsvBulkWriterFactory(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema schema,
                                                                     DataType physicalDataType)

Util for creating a BulkWriter.Factory that wraps CsvBulkWriter.forSchema(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvMapper, org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema, org.apache.flink.formats.common.Converter<T, R, C>, C, org.apache.flink.core.fs.FSDataOutputStream).