Package | Description |
---|---|
org.apache.flink.formats.parquet |
Modifier and Type | Method and Description |
---|---|
static ParquetTableSource.Builder |
ParquetTableSource.builder() |
ParquetTableSource.Builder |
ParquetTableSource.Builder.forParquetSchema(org.apache.parquet.schema.MessageType parquetSchema)
Sets the Parquet schema of the files to read as a String.
|
ParquetTableSource.Builder |
ParquetTableSource.Builder.path(String path)
Sets the path of Parquet files.
|
ParquetTableSource.Builder |
ParquetTableSource.Builder.path(String path,
boolean recursive)
Sets the path of the Parquet files.
|
ParquetTableSource.Builder |
ParquetTableSource.Builder.withConfiguration(Configuration config)
Sets a Hadoop
Configuration for the Parquet Reader. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.