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 caseSensitive)
Parquet.ReadBuilder	createReaderFunc(java.util.function.Function<org.apache.parquet.schema.MessageType,ParquetValueReader<?>> readerFunc)
Parquet.ReadBuilder	filter(Expression filter)
Parquet.ReadBuilder	filterRecords(boolean filterRecords)
Parquet.ReadBuilder	project(Schema schema)
Parquet.ReadBuilder	readSupport(org.apache.parquet.hadoop.api.ReadSupport<?> readSupport)
Parquet.ReadBuilder	reuseContainers()
Parquet.ReadBuilder	set(java.lang.String key, java.lang.String value)
Parquet.ReadBuilder	split(long start, long length) Restricts the read to the given range: [start, start + length).

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 start,
                                 long length)

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

Parameters:

start - the start position for this read

length - the length of the range this read should scan

Returns:

this builder for method chaining

project

public Parquet.ReadBuilder project(Schema schema)

caseInsensitive

public Parquet.ReadBuilder caseInsensitive()

caseSensitive

public Parquet.ReadBuilder caseSensitive(boolean caseSensitive)

filterRecords

public Parquet.ReadBuilder filterRecords(boolean filterRecords)

filter

public Parquet.ReadBuilder filter(Expression filter)

readSupport

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

createReaderFunc

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

set

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

callInit

public Parquet.ReadBuilder callInit()

reuseContainers

public Parquet.ReadBuilder reuseContainers()

build

public <D> CloseableIterable<D> build()