This project has retired. For details please refer to its Attic page.
Uses of Class org.apache.crunch.types.avro.AvroType (Apache Crunch 0.9.0 API)

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

Packages that use AvroType
org.apache.crunch.impl.spark.serde   
org.apache.crunch.io Data input and output for Pipelines. 
org.apache.crunch.io.avro   
org.apache.crunch.io.avro.trevni   
org.apache.crunch.io.parquet   
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.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.io.avro
 

Methods in org.apache.crunch.io.avro with parameters of type AvroType
protected  AvroFileReaderFactory<T> AvroFileSource.getFileReaderFactory(AvroType<T> ptype)
           
 

Constructors in org.apache.crunch.io.avro with parameters of type AvroType
AvroFileReaderFactory(AvroType<T> atype)
           
AvroFileReaderFactory(org.apache.avro.io.DatumReader<T> reader, AvroType<T> atype)
           
AvroFileSource(List<org.apache.hadoop.fs.Path> paths, AvroType<T> ptype)
           
AvroFileSource(List<org.apache.hadoop.fs.Path> paths, AvroType<T> ptype, org.apache.avro.io.DatumReader<T> reader)
           
AvroFileSource(org.apache.hadoop.fs.Path path, AvroType<T> ptype)
           
AvroFileSource(org.apache.hadoop.fs.Path path, AvroType<T> ptype, org.apache.avro.io.DatumReader<T> reader)
           
AvroFileSourceTarget(org.apache.hadoop.fs.Path path, AvroType<T> atype)
           
AvroFileSourceTarget(org.apache.hadoop.fs.Path path, AvroType<T> atype, org.apache.avro.io.DatumReader<T> reader)
           
AvroFileSourceTarget(org.apache.hadoop.fs.Path path, AvroType<T> atype, org.apache.avro.io.DatumReader<T> reader, FileNamingScheme fileNamingScheme)
           
AvroFileSourceTarget(org.apache.hadoop.fs.Path path, AvroType<T> atype, FileNamingScheme fileNamingScheme)
           
AvroReadableData(List<org.apache.hadoop.fs.Path> paths, AvroType<T> avroType)
           
 

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

Constructors in org.apache.crunch.io.avro.trevni with parameters of type AvroType
TrevniFileReaderFactory(AvroType<T> atype)
           
TrevniKeySource(List<org.apache.hadoop.fs.Path> paths, AvroType<T> ptype)
           
TrevniKeySource(org.apache.hadoop.fs.Path path, AvroType<T> ptype)
           
TrevniKeySourceTarget(org.apache.hadoop.fs.Path path, AvroType<T> atype)
           
TrevniKeySourceTarget(org.apache.hadoop.fs.Path path, AvroType<T> atype, FileNamingScheme fileNamingScheme)
           
TrevniReadableData(List<org.apache.hadoop.fs.Path> paths, AvroType<T> avroType)
           
 

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

Methods in org.apache.crunch.io.parquet with parameters of type AvroType
protected  org.apache.crunch.io.parquet.AvroParquetFileReaderFactory<T> AvroParquetFileSource.getFileReaderFactory(AvroType<T> ptype)
           
 

Constructors in org.apache.crunch.io.parquet with parameters of type AvroType
AvroParquetFileSource(List<org.apache.hadoop.fs.Path> paths, AvroType<T> ptype)
           
AvroParquetFileSource(List<org.apache.hadoop.fs.Path> paths, AvroType<T> ptype, Class<? extends parquet.filter.UnboundRecordFilter> filterClass)
           
AvroParquetFileSource(List<org.apache.hadoop.fs.Path> paths, AvroType<T> ptype, org.apache.avro.Schema schema)
           
AvroParquetFileSource(List<org.apache.hadoop.fs.Path> paths, AvroType<T> ptype, org.apache.avro.Schema schema, Class<? extends parquet.filter.UnboundRecordFilter> filterClass)
           
AvroParquetFileSource(org.apache.hadoop.fs.Path path, AvroType<T> ptype)
           
AvroParquetFileSource(org.apache.hadoop.fs.Path path, AvroType<T> ptype, org.apache.avro.Schema schema)
           
AvroParquetFileSourceTarget(org.apache.hadoop.fs.Path path, AvroType<T> atype)
           
AvroParquetFileSourceTarget(org.apache.hadoop.fs.Path path, AvroType<T> atype, FileNamingScheme fileNamingScheme)
           
AvroParquetReadableData(List<org.apache.hadoop.fs.Path> paths, 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 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 AvroMode AvroMode.fromType(AvroType<?> 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)
           
 



Copyright © 2014 The Apache Software Foundation. All Rights Reserved.