This project has retired. For details please refer to its Attic page.

org.apache.crunch.io.parquet
Class AvroParquetFileSource.Builder<T extends org.apache.avro.generic.IndexedRecord>

java.lang.Object
  org.apache.crunch.io.parquet.AvroParquetFileSource.Builder<T>

Enclosing class:

AvroParquetFileSource<T extends org.apache.avro.generic.IndexedRecord>

public static class AvroParquetFileSource.Builder<T extends org.apache.avro.generic.IndexedRecord>
extends Object

Helper class for constructing an AvroParquetFileSource that only reads a subset of the fields defined in an Avro schema.

Method Summary

AvroParquetFileSource<T>	build(List<org.apache.hadoop.fs.Path> paths)
AvroParquetFileSource<T>	build(org.apache.hadoop.fs.Path path)
AvroParquetFileSource.Builder	filterClass(Class<? extends parquet.filter.UnboundRecordFilter> filterClass)
AvroParquetFileSource.Builder	includeField(String fieldName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

includeField

public AvroParquetFileSource.Builder includeField(String fieldName)

filterClass

public AvroParquetFileSource.Builder filterClass(Class<? extends parquet.filter.UnboundRecordFilter> filterClass)

build

public AvroParquetFileSource<T> build(org.apache.hadoop.fs.Path path)

build

public AvroParquetFileSource<T> build(List<org.apache.hadoop.fs.Path> paths)