Package | Description |
---|---|
org.apache.flink.connector.datagen.table.types | |
org.apache.flink.connector.jdbc.internal | |
org.apache.flink.formats.csv |
Constructor and Description |
---|
DataGeneratorMapper(DataGenerator<A> generator,
SerializableFunction<A,B> mapper) |
Modifier and Type | Interface and Description |
---|---|
static interface |
JdbcOutputFormat.StatementExecutorFactory<T extends JdbcBatchStatementExecutor<?>>
A factory for creating
JdbcBatchStatementExecutor instance. |
Modifier and Type | Method and Description |
---|---|
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. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.