This project has retired. For details please refer to its Attic page.

Uses of Interface
org.apache.crunch.types.PType

Packages that use PType

org.apache.crunch
org.apache.crunch.impl.mem
org.apache.crunch.impl.mem.collect
org.apache.crunch.impl.mr
org.apache.crunch.impl.mr.collect
org.apache.crunch.impl.mr.plan
org.apache.crunch.io
org.apache.crunch.io.avro
org.apache.crunch.io.hbase
org.apache.crunch.io.impl
org.apache.crunch.io.seq
org.apache.crunch.io.text
org.apache.crunch.lib.join
org.apache.crunch.types
org.apache.crunch.types.avro
org.apache.crunch.types.writable
org.apache.crunch.util

Uses of PType in org.apache.crunch

Methods in org.apache.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 org.apache.crunch with parameters of type PType

boolean	Target.accept(OutputHandler handler, PType<?> ptype)
<T> SourceTarget<T>	Target.asSourceTarget(PType<T> ptype)
<K> PTable<K,S>	PCollection.by(MapFn<S,K> extractKeyFn, PType<K> keyType) Apply the given map function to each element of this instance in order to create a PTable.
<K> PTable<K,S>	PCollection.by(String name, MapFn<S,K> extractKeyFn, PType<K> keyType) Apply the given map function to each element of this instance in order to create a PTable.
<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 org.apache.crunch.impl.mem

Methods in org.apache.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 org.apache.crunch.impl.mem.collect

Methods in org.apache.crunch.impl.mem.collect that return PType

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

Methods in org.apache.crunch.impl.mem.collect with parameters of type PType

<K> PTable<K,S>	MemCollection.by(MapFn<S,K> mapFn, PType<K> keyType)
<K> PTable<K,S>	MemCollection.by(String name, MapFn<S,K> mapFn, PType<K> keyType)
<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 org.apache.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 org.apache.crunch.impl.mr

Methods in org.apache.crunch.impl.mr with parameters of type PType

<T> SourceTarget<T>

MRPipeline.createIntermediateOutput(PType<T> ptype)

Uses of PType in org.apache.crunch.impl.mr.collect

Methods in org.apache.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 org.apache.crunch.impl.mr.collect with parameters of type PType

<K> PTable<K,S>	PCollectionImpl.by(MapFn<S,K> mapFn, PType<K> keyType)
<K> PTable<K,S>	PCollectionImpl.by(String name, MapFn<S,K> mapFn, PType<K> keyType)
<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 org.apache.crunch.impl.mr.plan

Methods in org.apache.crunch.impl.mr.plan that return PType

PType<?>

DoNode.getPType()

Methods in org.apache.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 org.apache.crunch.io

Methods in org.apache.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 org.apache.crunch.io.avro

Methods in org.apache.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 org.apache.crunch.io.hbase

Methods in org.apache.crunch.io.hbase that return PType

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

HBaseSourceTarget.getType()

Methods in org.apache.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 org.apache.crunch.io.impl

Methods in org.apache.crunch.io.impl that return PType

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

Methods in org.apache.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 org.apache.crunch.io.impl with parameters of type PType

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

FileSourceImpl(org.apache.hadoop.fs.Path path, PType<T> ptype, InputBundle inputBundle)

Uses of PType in org.apache.crunch.io.seq

Methods in org.apache.crunch.io.seq with parameters of type PType

<T> SourceTarget<T>

SeqFileTarget.asSourceTarget(PType<T> ptype)

Constructors in org.apache.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 org.apache.crunch.io.text

Methods in org.apache.crunch.io.text with parameters of type PType

<T> SourceTarget<T>

TextFileTarget.asSourceTarget(PType<T> ptype)

Constructors in org.apache.crunch.io.text with parameters of type PType

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

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 org.apache.crunch.lib.join

Constructors in org.apache.crunch.lib.join with parameters of type PType

FullOuterJoinFn(PType<K> keyType, PType<U> leftValueType)

FullOuterJoinFn(PType<K> keyType, PType<U> leftValueType)

InnerJoinFn(PType<K> keyType, PType<U> leftValueType)

InnerJoinFn(PType<K> keyType, PType<U> leftValueType)

JoinFn(PType<K> keyType, PType<U> leftValueType)
Instantiate with the PType of the value of the left side of the join (used for creating deep copies of values).

JoinFn(PType<K> keyType, PType<U> leftValueType)
Instantiate with the PType of the value of the left side of the join (used for creating deep copies of values).

LeftOuterJoinFn(PType<K> keyType, PType<U> leftValueType)

LeftOuterJoinFn(PType<K> keyType, PType<U> leftValueType)

RightOuterJoinFn(PType<K> keyType, PType<U> leftValueType)

RightOuterJoinFn(PType<K> keyType, PType<U> leftValueType)

Uses of PType in org.apache.crunch.types

Subinterfaces of PType in org.apache.crunch.types

interface

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

Classes in org.apache.crunch.types that implement PType

class

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

Methods in org.apache.crunch.types 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 org.apache.crunch.types 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 org.apache.crunch.types 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)

Constructors in org.apache.crunch.types with parameters of type PType

CollectionDeepCopier(PType<T> elementType)

MapDeepCopier(PType<T> ptype)

TupleDeepCopier(Class<T> tupleClass, PType... elementTypes)

Uses of PType in org.apache.crunch.types.avro

Classes in org.apache.crunch.types.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 org.apache.crunch.types.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 org.apache.crunch.types.avro that return types with arguments of type PType

List<PType>

AvroType.getSubTypes()

Methods in org.apache.crunch.types.avro with parameters of type PType

<T> PType<T>	AvroTypeFamily.as(PType<T> ptype)
static <T> AvroType<Collection<T>>	Avros.collections(PType<T> ptype)
<T> PType<Collection<T>>	AvroTypeFamily.collections(PType<T> ptype)
static <S,T> AvroType<T>	Avros.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
<S,T> PType<T>	AvroTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
static <T> AvroType<Map<String,T>>	Avros.maps(PType<T> ptype)
<T> PType<Map<String,T>>	AvroTypeFamily.maps(PType<T> ptype)
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> 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,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)
<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 <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)
<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 <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)
<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 <T extends Tuple> AvroType<T>	Avros.tuples(Class<T> clazz, PType... ptypes)
<T extends Tuple> PType<T>	AvroTypeFamily.tuples(Class<T> clazz, PType<?>... ptypes)
static AvroType<TupleN>	Avros.tuples(PType... ptypes)
PType<TupleN>	AvroTypeFamily.tuples(PType<?>... ptypes)

Constructors in org.apache.crunch.types.avro with parameters of type PType

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

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

Uses of PType in org.apache.crunch.types.writable

Classes in org.apache.crunch.types.writable that implement PType

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

Methods in org.apache.crunch.types.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)
static <S,T> PType<T>	Writables.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
<S,T> PType<T>	WritableTypeFamily.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)
static <T extends Tuple> PType<T>	Writables.tuples(Class<T> clazz, PType... ptypes)
<T extends Tuple> PType<T>	WritableTypeFamily.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 org.apache.crunch.types.writable that return types with arguments of type PType

List<PType>

WritableType.getSubTypes()

Methods in org.apache.crunch.types.writable with parameters of type PType

<T> PType<T>	WritableTypeFamily.as(PType<T> ptype)
static <T> WritableType<Collection<T>,GenericArrayWritable<T>>	Writables.collections(PType<T> ptype)
<T> PType<Collection<T>>	WritableTypeFamily.collections(PType<T> ptype)
static <S,T> PType<T>	Writables.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
<S,T> PType<T>	WritableTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
static <T> WritableType<Map<String,T>,org.apache.hadoop.io.MapWritable>	Writables.maps(PType<T> ptype)
<T> PType<Map<String,T>>	WritableTypeFamily.maps(PType<T> ptype)
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> 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,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)
<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 <K,V> org.apache.crunch.types.writable.WritableTableType<K,V>	Writables.tableOf(PType<K> key, PType<V> value)
static <K,V> org.apache.crunch.types.writable.WritableTableType<K,V>	Writables.tableOf(PType<K> key, PType<V> value)
<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 <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)
<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 <T extends Tuple> PType<T>	Writables.tuples(Class<T> clazz, PType... ptypes)
<T extends Tuple> PType<T>	WritableTypeFamily.tuples(Class<T> clazz, PType<?>... ptypes)
static WritableType<TupleN,TupleWritable>	Writables.tuples(PType... ptypes)
PType<TupleN>	WritableTypeFamily.tuples(PType<?>... ptypes)

Uses of PType in org.apache.crunch.util

Methods in org.apache.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 extends org.apache.thrift.TBase> PType<T>	PTypes.thrifts(Class<T> clazz, PTypeFamily typeFamily)