public class ParquetReader<T> extends CloseableGroup implements CloseableIterable<T>
CloseableIterable.ConcatCloseableIterable<E>
Constructor and Description |
---|
ParquetReader(InputFile input,
Schema expectedSchema,
org.apache.parquet.ParquetReadOptions options,
java.util.function.Function<org.apache.parquet.schema.MessageType,ParquetValueReader<?>> readerFunc,
Expression filter,
boolean reuseContainers,
boolean caseSensitive) |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<T> |
iterator() |
addCloseable, close
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
combine, concat, empty, filter, transform, withNoopClose, withNoopClose
public ParquetReader(InputFile input, Schema expectedSchema, org.apache.parquet.ParquetReadOptions options, java.util.function.Function<org.apache.parquet.schema.MessageType,ParquetValueReader<?>> readerFunc, Expression filter, boolean reuseContainers, boolean caseSensitive)