Package org.apache.iceberg.parquet

Class Parquet.ReadBuilder

java.lang.Object

org.apache.iceberg.parquet.Parquet.ReadBuilder

All Implemented Interfaces:

InternalData.ReadBuilder

Enclosing class:

Parquet

public static class Parquet.ReadBuilder
extends Object
implements InternalData.ReadBuilder

Method Summary

Modifier and Type	Method	Description
<D> CloseableIterable<D>	build()	Build the configured reader.
Parquet.ReadBuilder	callInit()	Deprecated. will be removed in 2.0.0; use createReaderFunc(Function) instead
Parquet.ReadBuilder	caseInsensitive()
Parquet.ReadBuilder	caseSensitive(boolean newCaseSensitive)
Parquet.ReadBuilder	createBatchedReaderFunc(Function<org.apache.parquet.schema.MessageType,VectorizedReader<?>> func)
Parquet.ReadBuilder	createReaderFunc(BiFunction<Schema,org.apache.parquet.schema.MessageType,ParquetValueReader<?>> newReaderFunction)
Parquet.ReadBuilder	createReaderFunc(Function<org.apache.parquet.schema.MessageType,ParquetValueReader<?>> newReaderFunction)
Parquet.ReadBuilder	filter(Expression newFilter)
Parquet.ReadBuilder	filterRecords(boolean newFilterRecords)
Parquet.ReadBuilder	project(Schema newSchema)	Set the projection schema.
Parquet.ReadBuilder	readSupport(org.apache.parquet.hadoop.api.ReadSupport<?> newFilterSupport)	Deprecated. will be removed in 2.0.0; use createReaderFunc(Function) instead
Parquet.ReadBuilder	recordsPerBatch(int numRowsPerBatch)
Parquet.ReadBuilder	reuseContainers()	Reuse container classes, like structs, lists, and maps.
Parquet.ReadBuilder	set(String key, String value)
Parquet.ReadBuilder	setCustomType(int fieldId, Class<? extends StructLike> structClass)	Set a custom class for in-memory objects at the given field ID.
Parquet.ReadBuilder	setRootType(Class<? extends StructLike> rootClass)	Set a custom class for in-memory objects at the schema root.
Parquet.ReadBuilder	split(long newStart, long newLength)	Restricts the read to the given range: [start, start + length).
Parquet.ReadBuilder	withAADPrefix(ByteBuffer aadPrefix)
Parquet.ReadBuilder	withFileEncryptionKey(ByteBuffer encryptionKey)
Parquet.ReadBuilder	withNameMapping(NameMapping newNameMapping)

Methods inherited from class java.lang.Object

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

Method Details

split

public Parquet.ReadBuilder split(long newStart,
 long newLength)

Restricts the read to the given range: [start, start + length).

Specified by:

split in interface InternalData.ReadBuilder

Parameters:

newStart - the start position for this read

newLength - the length of the range this read should scan

Returns:

this builder for method chaining

project

public Parquet.ReadBuilder project(Schema newSchema)

Description copied from interface: InternalData.ReadBuilder

Set the projection schema.

Specified by:

project in interface InternalData.ReadBuilder

caseInsensitive

public Parquet.ReadBuilder caseInsensitive()

caseSensitive

public Parquet.ReadBuilder caseSensitive(boolean newCaseSensitive)

filterRecords

public Parquet.ReadBuilder filterRecords(boolean newFilterRecords)

filter

public Parquet.ReadBuilder filter(Expression newFilter)

readSupport

@Deprecated
public Parquet.ReadBuilder readSupport(org.apache.parquet.hadoop.api.ReadSupport<?> newFilterSupport)

Deprecated.

will be removed in 2.0.0; use createReaderFunc(Function) instead

createReaderFunc

public Parquet.ReadBuilder createReaderFunc(Function<org.apache.parquet.schema.MessageType,ParquetValueReader<?>> newReaderFunction)

createReaderFunc

public Parquet.ReadBuilder createReaderFunc(BiFunction<Schema,org.apache.parquet.schema.MessageType,ParquetValueReader<?>> newReaderFunction)

createBatchedReaderFunc

public Parquet.ReadBuilder createBatchedReaderFunc(Function<org.apache.parquet.schema.MessageType,VectorizedReader<?>> func)

set

public Parquet.ReadBuilder set(String key,
 String value)

callInit

@Deprecated
public Parquet.ReadBuilder callInit()

Deprecated.

will be removed in 2.0.0; use createReaderFunc(Function) instead

reuseContainers

public Parquet.ReadBuilder reuseContainers()

Description copied from interface: InternalData.ReadBuilder

Reuse container classes, like structs, lists, and maps.

Specified by:

reuseContainers in interface InternalData.ReadBuilder

recordsPerBatch

public Parquet.ReadBuilder recordsPerBatch(int numRowsPerBatch)

withNameMapping

public Parquet.ReadBuilder withNameMapping(NameMapping newNameMapping)

setRootType

public Parquet.ReadBuilder setRootType(Class<? extends StructLike> rootClass)

Description copied from interface: InternalData.ReadBuilder

Set a custom class for in-memory objects at the schema root.

Specified by:

setRootType in interface InternalData.ReadBuilder

setCustomType

public Parquet.ReadBuilder setCustomType(int fieldId,
 Class<? extends StructLike> structClass)

Description copied from interface: InternalData.ReadBuilder

Set a custom class for in-memory objects at the given field ID.

Specified by:

setCustomType in interface InternalData.ReadBuilder

withFileEncryptionKey

public Parquet.ReadBuilder withFileEncryptionKey(ByteBuffer encryptionKey)

withAADPrefix

public Parquet.ReadBuilder withAADPrefix(ByteBuffer aadPrefix)

build

public <D> CloseableIterable<D> build()

Description copied from interface: InternalData.ReadBuilder

Build the configured reader.

Specified by:

build in interface InternalData.ReadBuilder