org.apache.iceberg.orc

Class ORC.ReadBuilder

java.lang.Object

org.apache.iceberg.orc.ORC.ReadBuilder

Enclosing class:

ORC

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

Method Summary

Modifier and Type	Method and Description
<D> CloseableIterable<D>	build()
ORC.ReadBuilder	caseSensitive(boolean newCaseSensitive)
ORC.ReadBuilder	config(java.lang.String property, java.lang.String value)
ORC.ReadBuilder	createBatchedReaderFunc(java.util.function.Function<org.apache.orc.TypeDescription,OrcBatchReader<?>> batchReaderFunction)
ORC.ReadBuilder	createReaderFunc(java.util.function.Function<org.apache.orc.TypeDescription,OrcRowReader<?>> readerFunction)
ORC.ReadBuilder	filter(Expression newFilter)
ORC.ReadBuilder	project(Schema newSchema)
ORC.ReadBuilder	recordsPerBatch(int numRecordsPerBatch)
ORC.ReadBuilder	split(long newStart, long newLength) Restricts the read to the given range: [start, start + length).
ORC.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 ORC.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 ORC.ReadBuilder project(Schema newSchema)

caseSensitive

public ORC.ReadBuilder caseSensitive(boolean newCaseSensitive)

config

public ORC.ReadBuilder config(java.lang.String property,
                              java.lang.String value)

createReaderFunc

public ORC.ReadBuilder createReaderFunc(java.util.function.Function<org.apache.orc.TypeDescription,OrcRowReader<?>> readerFunction)

filter

public ORC.ReadBuilder filter(Expression newFilter)

createBatchedReaderFunc

public ORC.ReadBuilder createBatchedReaderFunc(java.util.function.Function<org.apache.orc.TypeDescription,OrcBatchReader<?>> batchReaderFunction)

recordsPerBatch

public ORC.ReadBuilder recordsPerBatch(int numRecordsPerBatch)

withNameMapping

public ORC.ReadBuilder withNameMapping(NameMapping newNameMapping)

build

public <D> CloseableIterable<D> build()