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.impl.spark.serde
org.apache.crunch.types.avro	Business object serialization using Apache Avro.

Uses of AvroType in org.apache.crunch.impl.spark.serde

Constructors in org.apache.crunch.impl.spark.serde with parameters of type AvroType

AvroSerDe(AvroType<T> avroType)

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 <S,T> AvroType<T>	Avros.derivedImmutable(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> AvroType<T>	Avros.reflects(Class<T> clazz, org.apache.avro.Schema schema)
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 AvroMode	AvroMode.fromType(AvroType<?> type) Creates an AvroMode based upon the specified type.
static <T> org.apache.avro.io.DatumReader<T>	Avros.newReader(AvroType<T> type)
static <T> org.apache.avro.io.DatumWriter<T>	Avros.newWriter(AvroType<T> type)
static <T> void	Avros.register(Class<T> clazz, AvroType<T> ptype)

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

AvroDerivedValueDeepCopier(MapFn<T,S> derivedToAvroFn, MapFn<S,T> avroToDerivedFn, AvroType<S> avroBaseType)