org.apache.flink.orc

Class OrcTableSource.Builder

java.lang.Object

org.apache.flink.orc.OrcTableSource.Builder

Enclosing class:

OrcTableSource

public static class OrcTableSource.Builder
extends Object

Constructs an OrcTableSource.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
OrcTableSource	build() Builds the OrcTableSource for this builder.
OrcTableSource.Builder	forOrcSchema(String orcSchema) Sets the ORC schema of the files to read as a String.
OrcTableSource.Builder	forOrcSchema(org.apache.orc.TypeDescription orcSchema) Sets the ORC schema of the files to read as a TypeDescription.
OrcTableSource.Builder	path(String path) Sets the path of the ORC file(s).
OrcTableSource.Builder	path(String path, boolean recursive) Sets the path of the ORC file(s).
OrcTableSource.Builder	withBatchSize(int batchSize) Sets the number of rows that are read in a batch.
OrcTableSource.Builder	withConfiguration(Configuration config) Sets a Hadoop Configuration for the ORC reader.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Method Detail

path

public OrcTableSource.Builder path(String path)

Sets the path of the ORC file(s). If the path specifies a directory, it will be recursively enumerated.

Parameters:

path - The path of the ORC file(s).

Returns:

The builder.

path

public OrcTableSource.Builder path(String path,
                                   boolean recursive)

Sets the path of the ORC file(s).

Parameters:

path - The path of the ORC file(s).

recursive - Flag whether the to enumerate

Returns:

The builder.

forOrcSchema

public OrcTableSource.Builder forOrcSchema(String orcSchema)

Sets the ORC schema of the files to read as a String.

Parameters:

orcSchema - The ORC schema of the files to read as a String.

Returns:

The builder.

forOrcSchema

public OrcTableSource.Builder forOrcSchema(org.apache.orc.TypeDescription orcSchema)

Sets the ORC schema of the files to read as a TypeDescription.

Parameters:

orcSchema - The ORC schema of the files to read as a String.

Returns:

The builder.

withConfiguration

public OrcTableSource.Builder withConfiguration(Configuration config)

Sets a Hadoop Configuration for the ORC reader. If no configuration is configured, an empty configuration is used.

Parameters:

config - The Hadoop Configuration for the ORC reader.

Returns:

The builder.

withBatchSize

public OrcTableSource.Builder withBatchSize(int batchSize)

Sets the number of rows that are read in a batch. If not configured, the ORC files are read with a batch size of 1000.

Parameters:

batchSize - The number of rows that are read in a batch.

Returns:

The builder.

build

public OrcTableSource build()

Builds the OrcTableSource for this builder.

Returns:

The OrcTableSource for this builder.