Package | Description |
---|---|
org.apache.flink.orc |
Modifier and Type | Method and Description |
---|---|
static OrcTableSource.Builder |
OrcTableSource.builder() |
OrcTableSource.Builder |
OrcTableSource.Builder.forOrcSchema(String orcSchema)
Sets the ORC schema of the files to read as a String.
|
OrcTableSource.Builder |
OrcTableSource.Builder.forOrcSchema(org.apache.orc.TypeDescription orcSchema)
Sets the ORC schema of the files to read as a
TypeDescription . |
OrcTableSource.Builder |
OrcTableSource.Builder.path(String path)
Sets the path of the ORC file(s).
|
OrcTableSource.Builder |
OrcTableSource.Builder.path(String path,
boolean recursive)
Sets the path of the ORC file(s).
|
OrcTableSource.Builder |
OrcTableSource.Builder.withBatchSize(int batchSize)
Sets the number of rows that are read in a batch.
|
OrcTableSource.Builder |
OrcTableSource.Builder.withConfiguration(Configuration config)
Sets a Hadoop
Configuration for the ORC reader. |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.