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
org.apache.crunch.io.avro
org.apache.crunch.types.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)
static <T> AvroFileSourceTarget<T>	At.avroFile(org.apache.hadoop.fs.Path path, AvroType<T> avroType)
static <T> Source<T>	From.avroFile(String pathName, AvroType<T> avroType)
static <T> AvroFileSourceTarget<T>	At.avroFile(String pathName, AvroType<T> avroType)

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

Constructors in org.apache.crunch.io.avro with parameters of type AvroType

AvroFileReaderFactory(AvroType<T> atype, org.apache.hadoop.conf.Configuration conf)

AvroFileSource(org.apache.hadoop.fs.Path path, AvroType<T> ptype)

AvroFileSourceTarget(org.apache.hadoop.fs.Path path, AvroType<T> atype)

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

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

class

AvroTableType<K,V> The implementation of the PTableType interface for Avro-based serialization.

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)

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

AvroTableType(AvroType<K> keyType, AvroType<V> valueType, Class<Pair<K,V>> pairClass)

AvroTableType(AvroType<K> keyType, AvroType<V> valueType, Class<Pair<K,V>> pairClass)