| Package | Description |
|---|---|
| parquet.avro |
Provides classes to store Avro data in Parquet files.
|
| parquet.filter | |
| parquet.hadoop |
Provides classes to store use Parquet files in Hadoop
In a map reduce job:
|
| parquet.io |
| Constructor and Description |
|---|
AvroParquetReader(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path file,
UnboundRecordFilter recordFilter) |
AvroParquetReader(org.apache.hadoop.fs.Path file,
UnboundRecordFilter recordFilter) |
| Modifier and Type | Method and Description |
|---|---|
static UnboundRecordFilter |
AndRecordFilter.and(UnboundRecordFilter filter1,
UnboundRecordFilter filter2)
Returns builder for creating an and filter.
|
static UnboundRecordFilter |
ColumnRecordFilter.column(String columnPath,
ColumnPredicates.Predicate predicate)
Factory method for record filter which applies the supplied predicate to the specified column.
|
static UnboundRecordFilter |
NotRecordFilter.not(UnboundRecordFilter filter)
Returns builder for creating an and filter.
|
static UnboundRecordFilter |
OrRecordFilter.or(UnboundRecordFilter filter1,
UnboundRecordFilter filter2)
Returns builder for creating an and filter.
|
static UnboundRecordFilter |
PagedRecordFilter.page(long startPos,
long pageSize)
Returns builder for creating a paged query.
|
| Modifier and Type | Method and Description |
|---|---|
static UnboundRecordFilter |
AndRecordFilter.and(UnboundRecordFilter filter1,
UnboundRecordFilter filter2)
Returns builder for creating an and filter.
|
static UnboundRecordFilter |
NotRecordFilter.not(UnboundRecordFilter filter)
Returns builder for creating an and filter.
|
static UnboundRecordFilter |
OrRecordFilter.or(UnboundRecordFilter filter1,
UnboundRecordFilter filter2)
Returns builder for creating an and filter.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
ParquetInputFormat.setUnboundRecordFilter(org.apache.hadoop.mapreduce.Job job,
Class<? extends UnboundRecordFilter> filterClass) |
| Constructor and Description |
|---|
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,
UnboundRecordFilter filter) |
ParquetRecordReader(ReadSupport<T> readSupport,
UnboundRecordFilter filter) |
| Modifier and Type | Method and Description |
|---|---|
<T> RecordReader<T> |
MessageColumnIO.getRecordReader(PageReadStore columns,
RecordMaterializer<T> recordMaterializer,
UnboundRecordFilter unboundFilter) |
Copyright © 2015. All rights reserved.