Package | Description |
---|---|
org.apache.flink.formats.csv |
Modifier and Type | Method and Description |
---|---|
static CsvReaderFormat<Object> |
PythonCsvUtils.createCsvReaderFormat(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema schema,
DataType dataType)
Util for creating a
CsvReaderFormat . |
static <T> CsvReaderFormat<T> |
CsvReaderFormat.forPojo(Class<T> pojoType)
Builds a new
CsvReaderFormat for reading CSV files mapped to the provided POJO class
definition. |
static <T> CsvReaderFormat<T> |
CsvReaderFormat.forSchema(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvMapper mapper,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema schema,
TypeInformation<T> typeInformation)
Deprecated.
This method is limited to serializable
CsvMappers , preventing
the usage of certain Jackson modules (like the Java 8 Date/Time Serializers ). Use #forSchema(Supplier, Function,
TypeInformation) instead. |
static <T> CsvReaderFormat<T> |
CsvReaderFormat.forSchema(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema schema,
TypeInformation<T> typeInformation)
Builds a new
CsvReaderFormat using a CsvSchema . |
static <T> CsvReaderFormat<T> |
CsvReaderFormat.forSchema(SerializableSupplier<org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvMapper> mapperFactory,
SerializableFunction<org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvMapper,org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema> schemaGenerator,
TypeInformation<T> typeInformation)
Builds a new
CsvReaderFormat using a CsvSchema generator and CsvMapper factory. |
CsvReaderFormat<T> |
CsvReaderFormat.withIgnoreParseErrors()
Returns a new
CsvReaderFormat configured to ignore all parsing errors. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.