org.apache.crunch.io.avro
Class AvroFileSource<T>
java.lang.Object
org.apache.crunch.io.impl.FileSourceImpl<T>
org.apache.crunch.io.avro.AvroFileSource<T>
- All Implemented Interfaces:
- ReadableSource<T>, Source<T>
public class AvroFileSource<T>
- extends FileSourceImpl<T>
- implements ReadableSource<T>
AvroFileSource
public AvroFileSource(org.apache.hadoop.fs.Path path,
AvroType<T> ptype)
toString
public String toString()
- Overrides:
toString
in class FileSourceImpl<T>
read
public Iterable<T> read(org.apache.hadoop.conf.Configuration conf)
throws IOException
- Specified by:
read
in interface ReadableSource<T>
- Throws:
IOException
Copyright © 2012 The Apache Software Foundation. All Rights Reserved.