org.apache.iceberg.parquet

Class Parquet.ReadBuilder

java.lang.Object

org.apache.iceberg.parquet.Parquet.ReadBuilder

Enclosing class:

Parquet

public static class Parquet.ReadBuilder
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
<D> CloseableIterable<D>	build()
Parquet.ReadBuilder	callInit()
Parquet.ReadBuilder	caseInsensitive()
Parquet.ReadBuilder	caseSensitive(boolean newCaseSensitive)
Parquet.ReadBuilder	createBatchedReaderFunc(java.util.function.Function<org.apache.parquet.schema.MessageType,VectorizedReader<?>> func)
Parquet.ReadBuilder	createReaderFunc(java.util.function.Function<org.apache.parquet.schema.MessageType,ParquetValueReader<?>> newReaderFunction)
Parquet.ReadBuilder	filter(Expression newFilter)
Parquet.ReadBuilder	filterRecords(boolean newFilterRecords)
Parquet.ReadBuilder	project(Schema newSchema)
Parquet.ReadBuilder	readSupport(org.apache.parquet.hadoop.api.ReadSupport<?> newFilterSupport)
Parquet.ReadBuilder	recordsPerBatch(int numRowsPerBatch)
Parquet.ReadBuilder	reuseContainers()
Parquet.ReadBuilder	set(java.lang.String key, java.lang.String value)
Parquet.ReadBuilder	split(long newStart, long newLength) Restricts the read to the given range: [start, start + length).
Parquet.ReadBuilder	withNameMapping(NameMapping newNameMapping)

Methods inherited from class java.lang.Object

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

Method Detail

split

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

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

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)

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

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

createReaderFunc

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

createBatchedReaderFunc

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

set

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

callInit

public Parquet.ReadBuilder callInit()

reuseContainers

public Parquet.ReadBuilder reuseContainers()

recordsPerBatch

public Parquet.ReadBuilder recordsPerBatch(int numRowsPerBatch)

withNameMapping

public Parquet.ReadBuilder withNameMapping(NameMapping newNameMapping)

build

public <D> CloseableIterable<D> build()