Package | Description |
---|---|
org.apache.crunch.io |
Data input and output for Pipelines.
|
org.apache.crunch.types.avro |
Business object serialization using Apache Avro.
|
Modifier and Type | Method and Description |
---|---|
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. |
Modifier and Type | Method and Description |
---|---|
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> |
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> |
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> |
Avros.tuples(Class<T> clazz,
PType... ptypes) |
static AvroType<TupleN> |
Avros.tuples(PType... ptypes) |
static <T extends org.apache.hadoop.io.Writable> |
Avros.writables(Class<T> clazz) |
Modifier and Type | Method and Description |
---|---|
static <T> void |
Avros.register(Class<T> clazz,
AvroType<T> ptype) |
Copyright © 2013 The Apache Software Foundation. All Rights Reserved.