Constructor and Description |
---|
KeyValueDataFileWriter(org.apache.flink.api.common.serialization.BulkWriter.Factory<org.apache.flink.table.data.RowData> factory,
org.apache.flink.core.fs.Path path,
java.util.function.Function<KeyValue,org.apache.flink.table.data.RowData> converter,
org.apache.flink.table.types.logical.RowType keyType,
org.apache.flink.table.types.logical.RowType valueType,
FileStatsExtractor fileStatsExtractor,
long schemaId,
int level) |
RowDataFileWriter(org.apache.flink.api.common.serialization.BulkWriter.Factory<org.apache.flink.table.data.RowData> factory,
org.apache.flink.core.fs.Path path,
org.apache.flink.table.types.logical.RowType writeSchema,
FileStatsExtractor fileStatsExtractor,
long schemaId,
org.apache.flink.api.common.accumulators.LongCounter seqNumCounter) |
StatsCollectingSingleFileWriter(org.apache.flink.api.common.serialization.BulkWriter.Factory<org.apache.flink.table.data.RowData> factory,
org.apache.flink.core.fs.Path path,
java.util.function.Function<T,org.apache.flink.table.data.RowData> converter,
org.apache.flink.table.types.logical.RowType writeSchema,
FileStatsExtractor fileStatsExtractor) |
Modifier and Type | Method and Description |
---|---|
Optional<FileStatsExtractor> |
FileFormat.createStatsExtractor(org.apache.flink.table.types.logical.RowType type) |
Modifier and Type | Class and Description |
---|---|
class |
OrcFileStatsExtractor
FileStatsExtractor for orc files. |
Modifier and Type | Method and Description |
---|---|
Optional<FileStatsExtractor> |
OrcFileFormat.createStatsExtractor(org.apache.flink.table.types.logical.RowType type) |
Modifier and Type | Class and Description |
---|---|
class |
ParquetFileStatsExtractor
FileStatsExtractor for parquet files. |
Modifier and Type | Method and Description |
---|---|
Optional<FileStatsExtractor> |
ParquetFileFormat.createStatsExtractor(org.apache.flink.table.types.logical.RowType type) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.