|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AvroType | |
---|---|
com.cloudera.crunch.io | |
com.cloudera.crunch.io.avro | |
com.cloudera.crunch.type.avro |
Uses of AvroType in com.cloudera.crunch.io |
---|
Methods in com.cloudera.crunch.io with parameters of type AvroType | ||
---|---|---|
static
|
From.avroFile(org.apache.hadoop.fs.Path path,
AvroType<T> avroType)
|
|
static
|
At.avroFile(org.apache.hadoop.fs.Path path,
AvroType<T> avroType)
|
|
static
|
From.avroFile(String pathName,
AvroType<T> avroType)
|
|
static
|
At.avroFile(String pathName,
AvroType<T> avroType)
|
Uses of AvroType in com.cloudera.crunch.io.avro |
---|
Constructors in com.cloudera.crunch.io.avro with parameters of type AvroType | |
---|---|
AvroFileReaderFactory(AvroType<T> atype)
|
|
AvroFileSource(org.apache.hadoop.fs.Path path,
AvroType<T> ptype)
|
|
AvroFileSourceTarget(org.apache.hadoop.fs.Path path,
AvroType<T> atype)
|
Uses of AvroType in com.cloudera.crunch.type.avro |
---|
Subclasses of AvroType in com.cloudera.crunch.type.avro | |
---|---|
class |
AvroTableType<K,V>
The implementation of the PTableType interface for Avro-based serialization. |
Methods in com.cloudera.crunch.type.avro that return AvroType | ||
---|---|---|
static AvroType<Boolean> |
Avros.booleans()
|
|
static AvroType<ByteBuffer> |
Avros.bytes()
|
|
static
|
Avros.collections(PType<T> ptype)
|
|
static
|
Avros.containers(Class<T> clazz)
|
|
static
|
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
|
Avros.maps(PType<T> ptype)
|
|
static AvroType<Void> |
Avros.nulls()
|
|
static
|
Avros.pairs(PType<V1> p1,
PType<V2> p2)
|
|
static
|
Avros.quads(PType<V1> p1,
PType<V2> p2,
PType<V3> p3,
PType<V4> p4)
|
|
static
|
Avros.records(Class<T> clazz)
|
|
static
|
Avros.reflects(Class<T> clazz)
|
|
static AvroType<String> |
Avros.strings()
|
|
static
|
Avros.triples(PType<V1> p1,
PType<V2> p2,
PType<V3> p3)
|
|
static
|
Avros.tuples(Class<T> clazz,
PType... ptypes)
|
|
static AvroType<TupleN> |
Avros.tuples(PType... ptypes)
|
Methods in com.cloudera.crunch.type.avro with parameters of type AvroType | ||
---|---|---|
static
|
Avros.register(Class<T> clazz,
AvroType<T> ptype)
|
Constructors in com.cloudera.crunch.type.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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |