|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
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
|
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
|
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
|
From.avroFile(String pathName,
AvroType<T> avroType)
Creates a Source<T> instance from the Avro file(s) at the given path name. |
|
static
|
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
|
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
|
Avros.specifics(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)
|
|
static
|
Avros.writables(Class<T> clazz)
|
Methods in org.apache.crunch.types.avro with parameters of type AvroType | ||
---|---|---|
static AvroMode |
AvroMode.fromType(AvroType<?> type)
|
|
static
|
Avros.newReader(AvroType<T> type)
|
|
static
|
Avros.newWriter(AvroType<T> type)
|
|
static
|
Avros.register(Class<T> clazz,
AvroType<T> ptype)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |