Uses of Interface
com.cloudera.crunch.type.PType

Packages that use PType

com.cloudera.crunch
com.cloudera.crunch.impl.mem
com.cloudera.crunch.impl.mem.collect
com.cloudera.crunch.impl.mr
com.cloudera.crunch.impl.mr.collect
com.cloudera.crunch.impl.mr.plan
com.cloudera.crunch.io
com.cloudera.crunch.io.avro
com.cloudera.crunch.io.hbase
com.cloudera.crunch.io.impl
com.cloudera.crunch.io.seq
com.cloudera.crunch.io.text
com.cloudera.crunch.type
com.cloudera.crunch.type.avro
com.cloudera.crunch.type.writable
com.cloudera.crunch.util

Uses of PType in com.cloudera.crunch

Methods in com.cloudera.crunch that return PType

PType<K>	PTable.getKeyType() Returns the PType of the key.
PType<S>	PCollection.getPType() Returns the PType of this PCollection.
PType<T>	Source.getType() Returns the PType for this source.
PType<V>	PTable.getValueType() Returns the PType of the value.

Methods in com.cloudera.crunch with parameters of type PType

boolean	Target.accept(OutputHandler handler, PType<?> ptype)
<T> SourceTarget<T>	Target.asSourceTarget(PType<T> ptype)
<T> PCollection<T>	PCollection.parallelDo(DoFn<S,T> doFn, PType<T> type) Applies the given doFn to the elements of this PCollection and returns a new PCollection that is the output of this processing.
<T> PCollection<T>	PCollection.parallelDo(String name, DoFn<S,T> doFn, PType<T> type) Applies the given doFn to the elements of this PCollection and returns a new PCollection that is the output of this processing.

Uses of PType in com.cloudera.crunch.impl.mem

Methods in com.cloudera.crunch.impl.mem with parameters of type PType

static <T> PCollection<T>	MemPipeline.typedCollectionOf(PType<T> ptype, Iterable<T> collect)
static <T> PCollection<T>	MemPipeline.typedCollectionOf(PType<T> ptype, T... ts)

Uses of PType in com.cloudera.crunch.impl.mem.collect

Methods in com.cloudera.crunch.impl.mem.collect that return PType

PType<K>	MemTable.getKeyType()
PType<S>	MemCollection.getPType()
PType<V>	MemTable.getValueType()

Methods in com.cloudera.crunch.impl.mem.collect with parameters of type PType

<T> PCollection<T>	MemCollection.parallelDo(DoFn<S,T> doFn, PType<T> type)
<T> PCollection<T>	MemCollection.parallelDo(String name, DoFn<S,T> doFn, PType<T> type)

Constructors in com.cloudera.crunch.impl.mem.collect with parameters of type PType

MemCollection(Iterable<S> collect, PType<S> ptype)

MemCollection(Iterable<S> collect, PType<S> ptype, String name)

Uses of PType in com.cloudera.crunch.impl.mr

Methods in com.cloudera.crunch.impl.mr with parameters of type PType

<T> SourceTarget<T>

MRPipeline.createIntermediateOutput(PType<T> ptype)

Uses of PType in com.cloudera.crunch.impl.mr.collect

Methods in com.cloudera.crunch.impl.mr.collect that return PType

PType<K>	PTableBase.getKeyType()
PType<Pair<K,V>>	UnionTable.getPType()
PType<S>	UnionCollection.getPType()
PType<Pair<K,Iterable<V>>>	PGroupedTableImpl.getPType()
PType<Pair<K,V>>	InputTable.getPType()
PType<S>	InputCollection.getPType()
PType<Pair<K,V>>	DoTableImpl.getPType()
PType<S>	DoCollectionImpl.getPType()
PType<V>	PTableBase.getValueType()

Methods in com.cloudera.crunch.impl.mr.collect with parameters of type PType

<T> PCollection<T>	PCollectionImpl.parallelDo(DoFn<S,T> fn, PType<T> type)
<T> PCollection<T>	PCollectionImpl.parallelDo(String name, DoFn<S,T> fn, PType<T> type)

Uses of PType in com.cloudera.crunch.impl.mr.plan

Methods in com.cloudera.crunch.impl.mr.plan that return PType

PType

DoNode.getPType()

Methods in com.cloudera.crunch.impl.mr.plan with parameters of type PType

boolean	MSCROutputHandler.configure(Target target, PType<?> ptype)
static DoNode	DoNode.createFnNode(String name, DoFn<?,?> function, PType<?> ptype)
static <S> DoNode	DoNode.createOutputNode(String name, PType<S> ptype)

Uses of PType in com.cloudera.crunch.io

Methods in com.cloudera.crunch.io with parameters of type PType

boolean	OutputHandler.configure(Target target, PType<?> ptype)
void	PathTargetImpl.configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)
void	MapReduceTarget.configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)
static <K,V> TableSource<K,V>	From.formattedFile(org.apache.hadoop.fs.Path path, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat> formatClass, PType<K> keyType, PType<V> valueType)
static <K,V> TableSource<K,V>	From.formattedFile(org.apache.hadoop.fs.Path path, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat> formatClass, PType<K> keyType, PType<V> valueType)
static <K,V> TableSource<K,V>	From.formattedFile(String path, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat> formatClass, PType<K> keyType, PType<V> valueType)
static <K,V> TableSource<K,V>	From.formattedFile(String path, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat> formatClass, PType<K> keyType, PType<V> valueType)
static <K,V> TableSource<K,V>	From.sequenceFile(org.apache.hadoop.fs.Path path, PType<K> keyType, PType<V> valueType)
static <K,V> TableSource<K,V>	From.sequenceFile(org.apache.hadoop.fs.Path path, PType<K> keyType, PType<V> valueType)
static <K,V> SeqFileTableSourceTarget<K,V>	At.sequenceFile(org.apache.hadoop.fs.Path path, PType<K> keyType, PType<V> valueType)
static <K,V> SeqFileTableSourceTarget<K,V>	At.sequenceFile(org.apache.hadoop.fs.Path path, PType<K> keyType, PType<V> valueType)
static <T> Source<T>	From.sequenceFile(org.apache.hadoop.fs.Path path, PType<T> ptype)
static <T> SeqFileSourceTarget<T>	At.sequenceFile(org.apache.hadoop.fs.Path path, PType<T> ptype)
static <K,V> TableSource<K,V>	From.sequenceFile(String pathName, PType<K> keyType, PType<V> valueType)
static <K,V> TableSource<K,V>	From.sequenceFile(String pathName, PType<K> keyType, PType<V> valueType)
static <K,V> SeqFileTableSourceTarget<K,V>	At.sequenceFile(String pathName, PType<K> keyType, PType<V> valueType)
static <K,V> SeqFileTableSourceTarget<K,V>	At.sequenceFile(String pathName, PType<K> keyType, PType<V> valueType)
static <T> Source<T>	From.sequenceFile(String pathName, PType<T> ptype)
static <T> SeqFileSourceTarget<T>	At.sequenceFile(String pathName, PType<T> ptype)
static <T> Source<T>	From.textFile(org.apache.hadoop.fs.Path path, PType<T> ptype)
static <T> TextFileSourceTarget<T>	At.textFile(org.apache.hadoop.fs.Path path, PType<T> ptype)
static <T> Source<T>	From.textFile(String pathName, PType<T> ptype)
static <T> TextFileSourceTarget<T>	At.textFile(String pathName, PType<T> ptype)

Uses of PType in com.cloudera.crunch.io.avro

Methods in com.cloudera.crunch.io.avro with parameters of type PType

boolean	AvroFileTarget.accept(OutputHandler handler, PType<?> ptype)
<T> SourceTarget<T>	AvroFileTarget.asSourceTarget(PType<T> ptype)
void	AvroFileTarget.configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)

Uses of PType in com.cloudera.crunch.io.hbase

Methods in com.cloudera.crunch.io.hbase that return PType

PType<Pair<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result>>

HBaseSourceTarget.getType()

Methods in com.cloudera.crunch.io.hbase with parameters of type PType

boolean	HBaseTarget.accept(OutputHandler handler, PType<?> ptype)
<T> SourceTarget<T>	HBaseTarget.asSourceTarget(PType<T> ptype)
void	HBaseTarget.configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)

Uses of PType in com.cloudera.crunch.io.impl

Fields in com.cloudera.crunch.io.impl declared as PType

protected PType<T>

FileSourceImpl.ptype

Methods in com.cloudera.crunch.io.impl that return PType

PType<T>	SourceTargetImpl.getType()
PType<T>	FileSourceImpl.getType()

Methods in com.cloudera.crunch.io.impl with parameters of type PType

boolean	SourceTargetImpl.accept(OutputHandler handler, PType<?> ptype)
boolean	FileTargetImpl.accept(OutputHandler handler, PType<?> ptype)
<S> SourceTarget<S>	SourceTargetImpl.asSourceTarget(PType<S> ptype)
<T> SourceTarget<T>	FileTargetImpl.asSourceTarget(PType<T> ptype)
void	SourcePathTargetImpl.configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)
void	FileTargetImpl.configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)

Constructors in com.cloudera.crunch.io.impl with parameters of type PType

FileSourceImpl(org.apache.hadoop.fs.Path path, PType<T> ptype, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat> inputFormatClass)

Uses of PType in com.cloudera.crunch.io.seq

Methods in com.cloudera.crunch.io.seq that return PType

PType<Pair<K,V>>

SeqFileTableSourceTarget.getType()

Methods in com.cloudera.crunch.io.seq with parameters of type PType

<T> SourceTarget<T>

SeqFileTarget.asSourceTarget(PType<T> ptype)

Constructors in com.cloudera.crunch.io.seq with parameters of type PType

SeqFileReaderFactory(PType<T> ptype, org.apache.hadoop.conf.Configuration conf)

SeqFileSource(org.apache.hadoop.fs.Path path, PType<T> ptype)

SeqFileSourceTarget(org.apache.hadoop.fs.Path path, PType<T> ptype)

SeqFileSourceTarget(String path, PType<T> ptype)

Uses of PType in com.cloudera.crunch.io.text

Methods in com.cloudera.crunch.io.text with parameters of type PType

<T> SourceTarget<T>

TextFileTarget.asSourceTarget(PType<T> ptype)

Constructors in com.cloudera.crunch.io.text with parameters of type PType

TextFileReaderFactory(PType<T> ptype)

TextFileSource(org.apache.hadoop.fs.Path path, PType<T> ptype)

TextFileSourceTarget(org.apache.hadoop.fs.Path path, PType<T> ptype)

TextFileSourceTarget(String path, PType<T> ptype)

Uses of PType in com.cloudera.crunch.type

Subinterfaces of PType in com.cloudera.crunch.type

interface

PTableType<K,V> An extension of PType specifically for PTable objects.

Classes in com.cloudera.crunch.type that implement PType

class

PGroupedTableType<K,V> The PType instance for PGroupedTable instances.

Methods in com.cloudera.crunch.type that return PType

<T> PType<T>	PTypeFamily.as(PType<T> ptype) Returns the equivalent of the given ptype for this family, if it exists.
PType<Boolean>	PTypeFamily.booleans()
PType<ByteBuffer>	PTypeFamily.bytes()
<T> PType<Collection<T>>	PTypeFamily.collections(PType<T> ptype)
static <T> PType<T>	PTypeUtils.convert(PType<T> ptype, PTypeFamily tf)
<S,T> PType<T>	PTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
PType<Double>	PTypeFamily.doubles()
PType<Float>	PTypeFamily.floats()
PType<K>	PTableType.getKeyType() Returns the key type for the table.
PType<V>	PTableType.getValueType() Returns the value type for the table.
PType<Integer>	PTypeFamily.ints()
PType<Long>	PTypeFamily.longs()
<T> PType<Map<String,T>>	PTypeFamily.maps(PType<T> ptype)
PType<Void>	PTypeFamily.nulls()
<V1,V2> PType<Pair<V1,V2>>	PTypeFamily.pairs(PType<V1> p1, PType<V2> p2)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	PTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<T> PType<T>	PTypeFamily.records(Class<T> clazz)
PType<String>	PTypeFamily.strings()
<V1,V2,V3> PType<Tuple3<V1,V2,V3>>	PTypeFamily.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
<T extends Tuple> PType<T>	PTypeFamily.tuples(Class<T> clazz, PType... ptypes)
PType<TupleN>	PTypeFamily.tuples(PType... ptypes)

Methods in com.cloudera.crunch.type that return types with arguments of type PType

List<PType>	PType.getSubTypes() Returns the sub-types that make up this PType if it is a composite instance, such as a tuple.
List<PType>	PGroupedTableType.getSubTypes()

Methods in com.cloudera.crunch.type with parameters of type PType

<T> PType<T>	PTypeFamily.as(PType<T> ptype) Returns the equivalent of the given ptype for this family, if it exists.
<T> PType<Collection<T>>	PTypeFamily.collections(PType<T> ptype)
static <T> PType<T>	PTypeUtils.convert(PType<T> ptype, PTypeFamily tf)
<S,T> PType<T>	PTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
<T> PType<Map<String,T>>	PTypeFamily.maps(PType<T> ptype)
<V1,V2> PType<Pair<V1,V2>>	PTypeFamily.pairs(PType<V1> p1, PType<V2> p2)
<V1,V2> PType<Pair<V1,V2>>	PTypeFamily.pairs(PType<V1> p1, PType<V2> p2)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	PTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	PTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	PTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	PTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<K,V> PTableType<K,V>	PTypeFamily.tableOf(PType<K> key, PType<V> value)
<K,V> PTableType<K,V>	PTypeFamily.tableOf(PType<K> key, PType<V> value)
<V1,V2,V3> PType<Tuple3<V1,V2,V3>>	PTypeFamily.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
<V1,V2,V3> PType<Tuple3<V1,V2,V3>>	PTypeFamily.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
<V1,V2,V3> PType<Tuple3<V1,V2,V3>>	PTypeFamily.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
<T extends Tuple> PType<T>	PTypeFamily.tuples(Class<T> clazz, PType... ptypes)
PType<TupleN>	PTypeFamily.tuples(PType... ptypes)

Uses of PType in com.cloudera.crunch.type.avro

Classes in com.cloudera.crunch.type.avro that implement PType

class	AvroGroupedTableType<K,V>
class	AvroTableType<K,V> The implementation of the PTableType interface for Avro-based serialization.
class	AvroType<T> The implementation of the PType interface for Avro-based serialization.

Methods in com.cloudera.crunch.type.avro that return PType

<T> PType<T>	AvroTypeFamily.as(PType<T> ptype)
PType<Boolean>	AvroTypeFamily.booleans()
PType<ByteBuffer>	AvroTypeFamily.bytes()
<T> PType<Collection<T>>	AvroTypeFamily.collections(PType<T> ptype)
<T> PType<T>	AvroTypeFamily.containers(Class<T> clazz)
<S,T> PType<T>	AvroTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
PType<Double>	AvroTypeFamily.doubles()
PType<Float>	AvroTypeFamily.floats()
PType<org.apache.avro.generic.GenericData.Record>	AvroTypeFamily.generics(org.apache.avro.Schema schema)
PType<K>	AvroTableType.getKeyType()
static <T> PType<T>	Avros.getPrimitiveType(Class<T> clazz)
PType<V>	AvroTableType.getValueType()
PType<Integer>	AvroTypeFamily.ints()
static <T> PType<T>	Avros.jsons(Class<T> clazz)
PType<Long>	AvroTypeFamily.longs()
<T> PType<Map<String,T>>	AvroTypeFamily.maps(PType<T> ptype)
PType<Void>	AvroTypeFamily.nulls()
<V1,V2> PType<Pair<V1,V2>>	AvroTypeFamily.pairs(PType<V1> p1, PType<V2> p2)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	AvroTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<T> PType<T>	AvroTypeFamily.records(Class<T> clazz)
PType<String>	AvroTypeFamily.strings()
<V1,V2,V3> PType<Tuple3<V1,V2,V3>>	AvroTypeFamily.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
<T extends Tuple> PType<T>	AvroTypeFamily.tuples(Class<T> clazz, PType... ptypes)
PType<TupleN>	AvroTypeFamily.tuples(PType... ptypes)

Methods in com.cloudera.crunch.type.avro that return types with arguments of type PType

List<PType>

AvroType.getSubTypes()

Methods in com.cloudera.crunch.type.avro with parameters of type PType

<T> PType<T>	AvroTypeFamily.as(PType<T> ptype)
<T> PType<Collection<T>>	AvroTypeFamily.collections(PType<T> ptype)
static <T> AvroType<Collection<T>>	Avros.collections(PType<T> ptype)
<S,T> PType<T>	AvroTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
static <S,T> AvroType<T>	Avros.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
<T> PType<Map<String,T>>	AvroTypeFamily.maps(PType<T> ptype)
static <T> AvroType<Map<String,T>>	Avros.maps(PType<T> ptype)
<V1,V2> PType<Pair<V1,V2>>	AvroTypeFamily.pairs(PType<V1> p1, PType<V2> p2)
<V1,V2> PType<Pair<V1,V2>>	AvroTypeFamily.pairs(PType<V1> p1, PType<V2> p2)
static <V1,V2> AvroType<Pair<V1,V2>>	Avros.pairs(PType<V1> p1, PType<V2> p2)
static <V1,V2> AvroType<Pair<V1,V2>>	Avros.pairs(PType<V1> p1, PType<V2> p2)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	AvroTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	AvroTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	AvroTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	AvroTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
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 <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 <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 <V1,V2,V3,V4> AvroType<Tuple4<V1,V2,V3,V4>>	Avros.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<K,V> PTableType<K,V>	AvroTypeFamily.tableOf(PType<K> key, PType<V> value)
<K,V> PTableType<K,V>	AvroTypeFamily.tableOf(PType<K> key, PType<V> value)
static <K,V> AvroTableType<K,V>	Avros.tableOf(PType<K> key, PType<V> value)
static <K,V> AvroTableType<K,V>	Avros.tableOf(PType<K> key, PType<V> value)
<V1,V2,V3> PType<Tuple3<V1,V2,V3>>	AvroTypeFamily.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
<V1,V2,V3> PType<Tuple3<V1,V2,V3>>	AvroTypeFamily.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
<V1,V2,V3> PType<Tuple3<V1,V2,V3>>	AvroTypeFamily.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
static <V1,V2,V3> AvroType<Tuple3<V1,V2,V3>>	Avros.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
static <V1,V2,V3> AvroType<Tuple3<V1,V2,V3>>	Avros.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
static <V1,V2,V3> AvroType<Tuple3<V1,V2,V3>>	Avros.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
<T extends Tuple> PType<T>	AvroTypeFamily.tuples(Class<T> clazz, PType... ptypes)
static <T extends Tuple> AvroType<T>	Avros.tuples(Class<T> clazz, PType... ptypes)
PType<TupleN>	AvroTypeFamily.tuples(PType... ptypes)
static AvroType<TupleN>	Avros.tuples(PType... ptypes)

Constructors in com.cloudera.crunch.type.avro with parameters of type PType

AvroType(Class<T> typeClass, org.apache.avro.Schema schema, MapFn inputMapFn, MapFn outputMapFn, PType... ptypes)

AvroType(Class<T> typeClass, org.apache.avro.Schema schema, PType... ptypes)

Uses of PType in com.cloudera.crunch.type.writable

Classes in com.cloudera.crunch.type.writable that implement PType

class	WritableGroupedTableType<K,V>
class	WritableType<T,W>

Methods in com.cloudera.crunch.type.writable that return PType

<T> PType<T>	WritableTypeFamily.as(PType<T> ptype)
PType<Boolean>	WritableTypeFamily.booleans()
PType<ByteBuffer>	WritableTypeFamily.bytes()
<T> PType<Collection<T>>	WritableTypeFamily.collections(PType<T> ptype)
<S,T> PType<T>	WritableTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
static <S,T> PType<T>	Writables.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
PType<Double>	WritableTypeFamily.doubles()
PType<Float>	WritableTypeFamily.floats()
static <T> PType<T>	Writables.getPrimitiveType(Class<T> clazz)
PType<Integer>	WritableTypeFamily.ints()
static <T> PType<T>	Writables.jsons(Class<T> clazz)
PType<Long>	WritableTypeFamily.longs()
<T> PType<Map<String,T>>	WritableTypeFamily.maps(PType<T> ptype)
PType<Void>	WritableTypeFamily.nulls()
<V1,V2> PType<Pair<V1,V2>>	WritableTypeFamily.pairs(PType<V1> p1, PType<V2> p2)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	WritableTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<T> PType<T>	WritableTypeFamily.records(Class<T> clazz)
PType<String>	WritableTypeFamily.strings()
<V1,V2,V3> PType<Tuple3<V1,V2,V3>>	WritableTypeFamily.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
<T extends Tuple> PType<T>	WritableTypeFamily.tuples(Class<T> clazz, PType... ptypes)
static <T extends Tuple> PType<T>	Writables.tuples(Class<T> clazz, PType... ptypes)
PType<TupleN>	WritableTypeFamily.tuples(PType... ptypes)
<W extends org.apache.hadoop.io.Writable> PType<W>	WritableTypeFamily.writables(Class<W> clazz)

Methods in com.cloudera.crunch.type.writable that return types with arguments of type PType

List<PType>

WritableType.getSubTypes()

Methods in com.cloudera.crunch.type.writable with parameters of type PType

<T> PType<T>	WritableTypeFamily.as(PType<T> ptype)
<T> PType<Collection<T>>	WritableTypeFamily.collections(PType<T> ptype)
static <T> WritableType<Collection<T>,GenericArrayWritable<T>>	Writables.collections(PType<T> ptype)
<S,T> PType<T>	WritableTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
static <S,T> PType<T>	Writables.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
<T> PType<Map<String,T>>	WritableTypeFamily.maps(PType<T> ptype)
static <T> WritableType<Map<String,T>,org.apache.hadoop.io.MapWritable>	Writables.maps(PType<T> ptype)
<V1,V2> PType<Pair<V1,V2>>	WritableTypeFamily.pairs(PType<V1> p1, PType<V2> p2)
<V1,V2> PType<Pair<V1,V2>>	WritableTypeFamily.pairs(PType<V1> p1, PType<V2> p2)
static <V1,V2> WritableType<Pair<V1,V2>,TupleWritable>	Writables.pairs(PType<V1> p1, PType<V2> p2)
static <V1,V2> WritableType<Pair<V1,V2>,TupleWritable>	Writables.pairs(PType<V1> p1, PType<V2> p2)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	WritableTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	WritableTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	WritableTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<V1,V2,V3,V4> PType<Tuple4<V1,V2,V3,V4>>	WritableTypeFamily.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
static <V1,V2,V3,V4> WritableType<Tuple4<V1,V2,V3,V4>,TupleWritable>	Writables.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
static <V1,V2,V3,V4> WritableType<Tuple4<V1,V2,V3,V4>,TupleWritable>	Writables.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
static <V1,V2,V3,V4> WritableType<Tuple4<V1,V2,V3,V4>,TupleWritable>	Writables.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
static <V1,V2,V3,V4> WritableType<Tuple4<V1,V2,V3,V4>,TupleWritable>	Writables.quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
<K,V> PTableType<K,V>	WritableTypeFamily.tableOf(PType<K> key, PType<V> value)
<K,V> PTableType<K,V>	WritableTypeFamily.tableOf(PType<K> key, PType<V> value)
static <K,V> com.cloudera.crunch.type.writable.WritableTableType<K,V>	Writables.tableOf(PType<K> key, PType<V> value)
static <K,V> com.cloudera.crunch.type.writable.WritableTableType<K,V>	Writables.tableOf(PType<K> key, PType<V> value)
<V1,V2,V3> PType<Tuple3<V1,V2,V3>>	WritableTypeFamily.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
<V1,V2,V3> PType<Tuple3<V1,V2,V3>>	WritableTypeFamily.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
<V1,V2,V3> PType<Tuple3<V1,V2,V3>>	WritableTypeFamily.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
static <V1,V2,V3> WritableType<Tuple3<V1,V2,V3>,TupleWritable>	Writables.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
static <V1,V2,V3> WritableType<Tuple3<V1,V2,V3>,TupleWritable>	Writables.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
static <V1,V2,V3> WritableType<Tuple3<V1,V2,V3>,TupleWritable>	Writables.triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
<T extends Tuple> PType<T>	WritableTypeFamily.tuples(Class<T> clazz, PType... ptypes)
static <T extends Tuple> PType<T>	Writables.tuples(Class<T> clazz, PType... ptypes)
PType<TupleN>	WritableTypeFamily.tuples(PType... ptypes)
static WritableType<TupleN,TupleWritable>	Writables.tuples(PType... ptypes)

Uses of PType in com.cloudera.crunch.util

Methods in com.cloudera.crunch.util that return PType

static PType<BigInteger>	PTypes.bigInt(PTypeFamily typeFamily)
static <T> PType<T>	PTypes.jsonString(Class<T> clazz, PTypeFamily typeFamily)
static <T extends com.google.protobuf.Message> PType<T>	PTypes.protos(Class<T> clazz, PTypeFamily typeFamily)
static <T> PType<T>	PTypes.smile(Class<T> clazz, PTypeFamily typeFamily)
static <T extends org.apache.thrift.TBase> PType<T>	PTypes.thrifts(Class<T> clazz, PTypeFamily typeFamily)