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 java.lang.Object
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
-
-
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 readnewLength
- 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()
-
-