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

Uses of Class
org.apache.crunch.types.avro.AvroType

Packages that use AvroType

org.apache.crunch.io	Data input and output for Pipelines.
org.apache.crunch.types.avro	Business object serialization using Apache Avro.

Uses of AvroType in org.apache.crunch.io

Methods in org.apache.crunch.io with parameters of type AvroType

static <T> Source<T>	From.avroFile(org.apache.hadoop.fs.Path path, AvroType<T> avroType) Creates a Source<T> instance from the Avro file(s) at the given Path.
static <T> SourceTarget<T>	At.avroFile(org.apache.hadoop.fs.Path path, AvroType<T> avroType) Creates a SourceTarget<T> instance from the Avro file(s) at the given Path.
static <T> Source<T>	From.avroFile(String pathName, AvroType<T> avroType) Creates a Source<T> instance from the Avro file(s) at the given path name.
static <T> SourceTarget<T>	At.avroFile(String pathName, AvroType<T> avroType) Creates a SourceTarget<T> instance from the Avro file(s) at the given path name.

Uses of AvroType in org.apache.crunch.types.avro

Methods in org.apache.crunch.types.avro that return AvroType

static AvroType<Boolean>	Avros.booleans()
static AvroType<ByteBuffer>	Avros.bytes()
static <T> AvroType<Collection<T>>	Avros.collections(PType<T> ptype)
static <T> AvroType<T>	Avros.containers(Class<T> clazz)
static <S,T> AvroType<T>	Avros.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
static AvroType<Double>	Avros.doubles()
static AvroType<Float>	Avros.floats()
static AvroType<org.apache.avro.generic.GenericData.Record>	Avros.generics(org.apache.avro.Schema schema)
static AvroType<Integer>	Avros.ints()
static AvroType<Long>	Avros.longs()
static <T> AvroType<Map<String,T>>	Avros.maps(PType<T> ptype)
static AvroType<Void>	Avros.nulls()
static <V1,V2> AvroType<Pair<V1,V2>>	Avros.pairs(PType<V1> p1, PType<V2> p2)
static <V1,V2,V3,V4> AvroType<Tuple4<V1,V2,V3,V4>>	Avros.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
static <T> AvroType<T>	Avros.records(Class<T> clazz)
static <T> AvroType<T>	Avros.reflects(Class<T> clazz)
static <T extends org.apache.avro.specific.SpecificRecord> AvroType<T>	Avros.specifics(Class<T> clazz)
static AvroType<String>	Avros.strings()
static <V1,V2,V3> AvroType<Tuple3<V1,V2,V3>>	Avros.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
static <T extends Tuple> AvroType<T>	Avros.tuples(Class<T> clazz, PType... ptypes)
static AvroType<TupleN>	Avros.tuples(PType... ptypes)
static <T extends org.apache.hadoop.io.Writable> AvroType<T>	Avros.writables(Class<T> clazz)

Methods in org.apache.crunch.types.avro with parameters of type AvroType

static <T> void

Avros.register(Class<T> clazz, AvroType<T> ptype)