public class ParquetReader<T> extends Object implements Closeable
Constructor and Description |
---|
ParquetReader(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path file,
ReadSupport<T> readSupport) |
ParquetReader(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path file,
ReadSupport<T> readSupport,
UnboundRecordFilter filter) |
ParquetReader(org.apache.hadoop.fs.Path file,
ReadSupport<T> readSupport) |
ParquetReader(org.apache.hadoop.fs.Path file,
ReadSupport<T> readSupport,
UnboundRecordFilter filter) |
public ParquetReader(org.apache.hadoop.fs.Path file, ReadSupport<T> readSupport) throws IOException
file
- the file to readreadSupport
- to materialize recordsIOException
public ParquetReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path file, ReadSupport<T> readSupport) throws IOException
conf
- the configurationfile
- the file to readreadSupport
- to materialize recordsIOException
public ParquetReader(org.apache.hadoop.fs.Path file, ReadSupport<T> readSupport, UnboundRecordFilter filter) throws IOException
file
- the file to readreadSupport
- to materialize recordsfilter
- the filter to use to filter recordsIOException
public ParquetReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path file, ReadSupport<T> readSupport, UnboundRecordFilter filter) throws IOException
conf
- the configurationfile
- the file to readreadSupport
- to materialize recordsfilter
- the filter to use to filter recordsIOException
public T read() throws IOException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2015. All rights reserved.