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.