Package 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 Object

Method Summary

Modifier and Type	Method	Description
<D> CloseableIterable<D>	build()
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(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)	Deprecated. will be removed in 2.0.0; use createReaderFunc(Function) instead
Parquet.ReadBuilder	recordsPerBatch(int numRowsPerBatch)
Parquet.ReadBuilder	reuseContainers()
Parquet.ReadBuilder	set(String key, String value)
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).

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

@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)

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()

recordsPerBatch

public Parquet.ReadBuilder recordsPerBatch(int numRowsPerBatch)

withNameMapping

public Parquet.ReadBuilder withNameMapping(NameMapping newNameMapping)

withFileEncryptionKey

public Parquet.ReadBuilder withFileEncryptionKey(ByteBuffer encryptionKey)

withAADPrefix

public Parquet.ReadBuilder withAADPrefix(ByteBuffer aadPrefix)

build

public <D> CloseableIterable<D> build()