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	Client-facing API and core abstractions.
org.apache.crunch.contrib.text
org.apache.crunch.impl.dist
org.apache.crunch.impl.dist.collect
org.apache.crunch.impl.mem	In-memory Pipeline implementation for rapid prototyping and testing.
org.apache.crunch.impl.mem.collect
org.apache.crunch.impl.mr.collect
org.apache.crunch.impl.mr.emit
org.apache.crunch.impl.mr.plan
org.apache.crunch.impl.mr.run
org.apache.crunch.impl.spark.collect
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.hbase
org.apache.crunch.io.impl
org.apache.crunch.io.parquet
org.apache.crunch.io.seq
org.apache.crunch.io.text
org.apache.crunch.lib	Joining, sorting, aggregating, and other commonly used functionality.
org.apache.crunch.lib.join	Inner and outer joins on collections.
org.apache.crunch.lib.sort
org.apache.crunch.types	Common functionality for business object serialization.
org.apache.crunch.types.avro	Business object serialization using Apache Avro.
org.apache.crunch.types.writable	Business object serialization using Hadoop's Writables framework.

Uses of PType in org.apache.crunch

Methods in org.apache.crunch that return PType

static <V1,V2,V3> PType<Tuple3.Collect<V1,V2,V3>>	Tuple3.Collect.derived(PType<V1> first, PType<V2> second, PType<V3> third)
static <V1,V2,V3,V4> PType<Tuple4.Collect<V1,V2,V3,V4>>	Tuple4.Collect.derived(PType<V1> first, PType<V2> second, PType<V3> third, PType<V4> fourth)
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) Checks to see if this Target instance is compatible with the given PType.
<T> SourceTarget<T>	Target.asSourceTarget(PType<T> ptype) Attempt to create the SourceTarget type that corresponds to this Target for the given PType, if possible.
<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.
static <V1,V2,V3> PType<Tuple3.Collect<V1,V2,V3>>	Tuple3.Collect.derived(PType<V1> first, PType<V2> second, PType<V3> third)
static <V1,V2,V3> PType<Tuple3.Collect<V1,V2,V3>>	Tuple3.Collect.derived(PType<V1> first, PType<V2> second, PType<V3> third)
static <V1,V2,V3> PType<Tuple3.Collect<V1,V2,V3>>	Tuple3.Collect.derived(PType<V1> first, PType<V2> second, PType<V3> third)
static <V1,V2,V3,V4> PType<Tuple4.Collect<V1,V2,V3,V4>>	Tuple4.Collect.derived(PType<V1> first, PType<V2> second, PType<V3> third, PType<V4> fourth)
static <V1,V2,V3,V4> PType<Tuple4.Collect<V1,V2,V3,V4>>	Tuple4.Collect.derived(PType<V1> first, PType<V2> second, PType<V3> third, PType<V4> fourth)
static <V1,V2,V3,V4> PType<Tuple4.Collect<V1,V2,V3,V4>>	Tuple4.Collect.derived(PType<V1> first, PType<V2> second, PType<V3> third, PType<V4> fourth)
static <V1,V2,V3,V4> PType<Tuple4.Collect<V1,V2,V3,V4>>	Tuple4.Collect.derived(PType<V1> first, PType<V2> second, PType<V3> third, PType<V4> fourth)
Converter<?,?,?,?>	Target.getConverter(PType<?> ptype) Returns the Converter to use for mapping from the output PCollection into the output values expected by this instance.
<K2> PTable<K2,V>	PTable.mapKeys(MapFn<K,K2> mapFn, PType<K2> ptype) Returns a PTable that has the same values as this instance, but uses the given function to map the keys.
<K2> PTable<K2,V>	PTable.mapKeys(String name, MapFn<K,K2> mapFn, PType<K2> ptype) Returns a PTable that has the same values as this instance, but uses the given function to map the keys.
<U> PTable<K,U>	PGroupedTable.mapValues(MapFn<Iterable<V>,U> mapFn, PType<U> ptype) Maps the Iterable<V> elements of each record to a new type.
<U> PTable<K,U>	PTable.mapValues(MapFn<V,U> mapFn, PType<U> ptype) Returns a PTable that has the same keys as this instance, but uses the given function to map the values.
<U> PTable<K,U>	PGroupedTable.mapValues(String name, MapFn<Iterable<V>,U> mapFn, PType<U> ptype) Maps the Iterable<V> elements of each record to a new type.
<U> PTable<K,U>	PTable.mapValues(String name, MapFn<V,U> mapFn, PType<U> ptype) Returns a PTable that has the same keys as this instance, but uses the given function to map the values.
<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.
<T> PCollection<T>	PCollection.parallelDo(String name, DoFn<S,T> doFn, PType<T> type, ParallelDoOptions options) 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.contrib.text

Methods in org.apache.crunch.contrib.text that return PType

PType<T>

Extractor.getPType(PTypeFamily ptf) Returns the PType associated with this data type for the given PTypeFamily.

Uses of PType in org.apache.crunch.impl.dist

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

<T> SourceTarget<T>

DistributedPipeline.createIntermediateOutput(PType<T> ptype)

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

Fields in org.apache.crunch.impl.dist.collect declared as PType

protected PType<S>

BaseDoCollection.ptype

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

PType<K>	PTableBase.getKeyType()
PType<Pair<K,V>>	BaseUnionTable.getPType()
PType<S>	BaseUnionCollection.getPType()
PType<Pair<K,V>>	BaseInputTable.getPType()
PType<S>	BaseInputCollection.getPType()
PType<Pair<K,Iterable<V>>>	BaseGroupedTable.getPType()
PType<Pair<K,V>>	BaseDoTable.getPType()
PType<S>	BaseDoCollection.getPType()
PType<V>	PTableBase.getValueType()

Methods in org.apache.crunch.impl.dist.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)
<S,T> BaseDoCollection<T>	PCollectionFactory.createDoCollection(String name, PCollectionImpl<S> chainingCollection, DoFn<S,T> fn, PType<T> type, ParallelDoOptions options)
<K2> PTable<K2,V>	PTableBase.mapKeys(MapFn<K,K2> mapFn, PType<K2> ptype)
<K2> PTable<K2,V>	PTableBase.mapKeys(String name, MapFn<K,K2> mapFn, PType<K2> ptype)
<U> PTable<K,U>	BaseGroupedTable.mapValues(MapFn<Iterable<V>,U> mapFn, PType<U> ptype)
<U> PTable<K,U>	PTableBase.mapValues(MapFn<V,U> mapFn, PType<U> ptype)
<U> PTable<K,U>	BaseGroupedTable.mapValues(String name, MapFn<Iterable<V>,U> mapFn, PType<U> ptype)
<U> PTable<K,U>	PTableBase.mapValues(String name, MapFn<V,U> mapFn, PType<U> 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)
<T> PCollection<T>	PCollectionImpl.parallelDo(String name, DoFn<S,T> fn, PType<T> type, ParallelDoOptions options)

Constructors in org.apache.crunch.impl.dist.collect with parameters of type PType

BaseDoCollection(String name, PCollectionImpl<T> parent, DoFn<T,S> fn, PType<S> ptype, ParallelDoOptions options)

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)
<K2> PTable<K2,V>	MemTable.mapKeys(MapFn<K,K2> mapFn, PType<K2> ptype)
<K2> PTable<K2,V>	MemTable.mapKeys(String name, MapFn<K,K2> mapFn, PType<K2> ptype)
<U> PTable<K,U>	MemTable.mapValues(MapFn<V,U> mapFn, PType<U> ptype)
<U> PTable<K,U>	MemTable.mapValues(String name, MapFn<V,U> mapFn, PType<U> 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)
<T> PCollection<T>	MemCollection.parallelDo(String name, DoFn<S,T> doFn, PType<T> type, ParallelDoOptions options)

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.collect

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

<S,T> BaseDoCollection<T>

MRCollectionFactory.createDoCollection(String name, PCollectionImpl<S> parent, DoFn<S,T> fn, PType<T> type, ParallelDoOptions options)

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

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

IntermediateEmitter(PType<Object> outputPType, List<RTNode> children, org.apache.hadoop.conf.Configuration conf, boolean disableDeepCopy)

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, ParallelDoOptions options)
static DoNode	DoNode.createOutputNode(String name, Converter outputConverter, PType<?> ptype)

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

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

RTNode(DoFn<Object,Object> fn, PType<Object> outputPType, String name, List<RTNode> children, Converter inputConverter, Converter outputConverter, String outputName)

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

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

<S,T> BaseDoCollection<T>

SparkCollectFactory.createDoCollection(String name, PCollectionImpl<S> parent, DoFn<S,T> fn, PType<T> type, ParallelDoOptions options)

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	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) Creates a TableSource<K, V> for reading data from files that have custom FileInputFormat implementations not covered by the provided TableSource and Source factory methods.
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) Creates a TableSource<K, V> for reading data from files that have custom FileInputFormat implementations not covered by the provided TableSource and Source factory methods.
static <K,V> TableSource<K,V>	From.formattedFile(String pathName, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<?,?>> formatClass, PType<K> keyType, PType<V> valueType) Creates a TableSource<K, V> for reading data from files that have custom FileInputFormat implementations not covered by the provided TableSource and Source factory methods.
static <K,V> TableSource<K,V>	From.formattedFile(String pathName, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<?,?>> formatClass, PType<K> keyType, PType<V> valueType) Creates a TableSource<K, V> for reading data from files that have custom FileInputFormat implementations not covered by the provided TableSource and Source factory methods.
static <K,V> TableSource<K,V>	From.sequenceFile(org.apache.hadoop.fs.Path path, PType<K> keyType, PType<V> valueType) Creates a TableSource<K, V> instance for the SequenceFile(s) at the given Path.
static <K,V> TableSource<K,V>	From.sequenceFile(org.apache.hadoop.fs.Path path, PType<K> keyType, PType<V> valueType) Creates a TableSource<K, V> instance for the SequenceFile(s) at the given Path.
static <K,V> TableSourceTarget<K,V>	At.sequenceFile(org.apache.hadoop.fs.Path path, PType<K> keyType, PType<V> valueType) Creates a TableSourceTarget<K, V> instance from the SequenceFile(s) at the given Path from the key-value pairs in the SequenceFile(s).
static <K,V> TableSourceTarget<K,V>	At.sequenceFile(org.apache.hadoop.fs.Path path, PType<K> keyType, PType<V> valueType) Creates a TableSourceTarget<K, V> instance from the SequenceFile(s) at the given Path from the key-value pairs in the SequenceFile(s).
static <T> Source<T>	From.sequenceFile(org.apache.hadoop.fs.Path path, PType<T> ptype) Creates a Source<T> instance from the SequenceFile(s) at the given Path from the value field of each key-value pair in the SequenceFile(s).
static <T> SourceTarget<T>	At.sequenceFile(org.apache.hadoop.fs.Path path, PType<T> ptype) Creates a SourceTarget<T> instance from the SequenceFile(s) at the given Path from the value field of each key-value pair in the SequenceFile(s).
static <K,V> TableSource<K,V>	From.sequenceFile(String pathName, PType<K> keyType, PType<V> valueType) Creates a TableSource<K, V> instance for the SequenceFile(s) at the given path name.
static <K,V> TableSource<K,V>	From.sequenceFile(String pathName, PType<K> keyType, PType<V> valueType) Creates a TableSource<K, V> instance for the SequenceFile(s) at the given path name.
static <K,V> TableSourceTarget<K,V>	At.sequenceFile(String pathName, PType<K> keyType, PType<V> valueType) Creates a TableSourceTarget<K, V> instance from the SequenceFile(s) at the given path name from the key-value pairs in the SequenceFile(s).
static <K,V> TableSourceTarget<K,V>	At.sequenceFile(String pathName, PType<K> keyType, PType<V> valueType) Creates a TableSourceTarget<K, V> instance from the SequenceFile(s) at the given path name from the key-value pairs in the SequenceFile(s).
static <T> Source<T>	From.sequenceFile(String pathName, PType<T> ptype) Creates a Source<T> instance from the SequenceFile(s) at the given path name from the value field of each key-value pair in the SequenceFile(s).
static <T> SourceTarget<T>	At.sequenceFile(String pathName, PType<T> ptype) Creates a SourceTarget<T> instance from the SequenceFile(s) at the given path name from the value field of each key-value pair in the SequenceFile(s).
static <T> Source<T>	From.textFile(org.apache.hadoop.fs.Path path, PType<T> ptype) Creates a Source<T> instance for the text file(s) at the given Path using the provided PType<T> to convert the input text.
static <T> SourceTarget<T>	At.textFile(org.apache.hadoop.fs.Path path, PType<T> ptype) Creates a SourceTarget<T> instance for the text file(s) at the given Path using the provided PType<T> to convert the input text.
static <T> Source<T>	From.textFile(String pathName, PType<T> ptype) Creates a Source<T> instance for the text file(s) at the given path name using the provided PType<T> to convert the input text.
static <T> SourceTarget<T>	At.textFile(String pathName, PType<T> ptype) Creates a SourceTarget<T> instance for the text file(s) at the given path name using the provided PType<T> to convert the input text.

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

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

boolean	AvroPathPerKeyTarget.accept(OutputHandler handler, PType<?> ptype)
boolean	AvroFileTarget.accept(OutputHandler handler, PType<?> ptype)
<T> SourceTarget<T>	AvroFileTarget.asSourceTarget(PType<T> ptype)
void	AvroPathPerKeyTarget.configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)
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.avro.trevni

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

boolean	TrevniKeyTarget.accept(OutputHandler handler, PType<?> ptype)
<T> SourceTarget<T>	TrevniKeyTarget.asSourceTarget(PType<T> ptype)
void	TrevniKeyTarget.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

static PType<org.apache.hadoop.hbase.client.Delete>	HBaseTypes.deletes()
PType<Pair<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result>>	HBaseSourceTarget.getType()
static PType<org.apache.hadoop.hbase.KeyValue>	HBaseTypes.keyValues()
static PType<org.apache.hadoop.hbase.client.Put>	HBaseTypes.puts()
static PType<org.apache.hadoop.hbase.client.Result>	HBaseTypes.results()

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	HFileTarget.configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)
void	HBaseTarget.configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)
Converter<?,?,?,?>	HFileTarget.getConverter(PType<?> ptype)
Converter<?,?,?,?>	HBaseTarget.getConverter(PType<?> ptype)

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

Fields in org.apache.crunch.io.impl declared as PType

protected PType<T>

FileSourceImpl.ptype

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

PType<T>

FileSourceImpl.getType()

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

boolean	FileTargetImpl.accept(OutputHandler handler, PType<?> 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)
Converter<?,?,?,?>	FileTargetImpl.getConverter(PType<?> ptype)

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

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

FileSourceImpl(List<org.apache.hadoop.fs.Path> paths, PType<T> ptype, FormatBundle<? extends org.apache.hadoop.mapreduce.InputFormat> inputBundle)

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, FormatBundle<? extends org.apache.hadoop.mapreduce.InputFormat> inputBundle)

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

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

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

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

SeqFileReadableData(List<org.apache.hadoop.fs.Path> paths, PType<T> ptype)

SeqFileReaderFactory(PType<T> ptype)

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

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

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

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

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)
void	TextFileTarget.configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)

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

NLineFileSource(List<org.apache.hadoop.fs.Path> paths, PType<T> ptype, int linesPerTask)
Create a new NLineFileSource instance.

NLineFileSource(org.apache.hadoop.fs.Path path, PType<T> ptype, int linesPerTask)
Create a new NLineFileSource instance.

NLineFileSource(String path, PType<T> ptype, int linesPerTask)
Create a new NLineFileSource instance.

TextFileReaderFactory(PType<T> ptype)

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

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

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

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

TextFileSourceTarget(String path, PType<T> ptype)

TextReadableData(List<org.apache.hadoop.fs.Path> paths, PType<T> ptype)

TextReadableData(List<org.apache.hadoop.fs.Path> paths, PType<T> ptype, String sep)

Uses of PType in org.apache.crunch.lib

Methods in org.apache.crunch.lib with parameters of type PType

static <K1,K2,V> PTable<K2,V>	PTables.mapKeys(PTable<K1,V> ptable, MapFn<K1,K2> mapFn, PType<K2> ptype) Maps a PTable<K1, V> to a PTable<K2, V> using the given MapFn<K1, K2> on the keys of the PTable.
static <K1,K2,V> PTable<K2,V>	PTables.mapKeys(String name, PTable<K1,V> ptable, MapFn<K1,K2> mapFn, PType<K2> ptype) Maps a PTable<K1, V> to a PTable<K2, V> using the given MapFn<K1, K2> on the keys of the PTable.
static <K,U,V> PTable<K,V>	PTables.mapValues(PGroupedTable<K,U> ptable, MapFn<Iterable<U>,V> mapFn, PType<V> ptype) An analogue of the mapValues function for PGroupedTable<K, U> collections.
static <K,U,V> PTable<K,V>	PTables.mapValues(PTable<K,U> ptable, MapFn<U,V> mapFn, PType<V> ptype) Maps a PTable<K, U> to a PTable<K, V> using the given MapFn<U, V> on the values of the PTable.
static <K,U,V> PTable<K,V>	PTables.mapValues(String name, PGroupedTable<K,U> ptable, MapFn<Iterable<U>,V> mapFn, PType<V> ptype) An analogue of the mapValues function for PGroupedTable<K, U> collections.
static <K,U,V> PTable<K,V>	PTables.mapValues(String name, PTable<K,U> ptable, MapFn<U,V> mapFn, PType<V> ptype) Maps a PTable<K, U> to a PTable<K, V> using the given MapFn<U, V> on the values of the PTable.
static <K,V1,V2,T> PCollection<T>	SecondarySort.sortAndApply(PTable<K,Pair<V1,V2>> input, DoFn<Pair<K,Iterable<Pair<V1,V2>>>,T> doFn, PType<T> ptype) Perform a secondary sort on the given PTable instance and then apply a DoFn to the resulting sorted data to yield an output PCollection<T>.
static <K,V1,V2,T> PCollection<T>	SecondarySort.sortAndApply(PTable<K,Pair<V1,V2>> input, DoFn<Pair<K,Iterable<Pair<V1,V2>>>,T> doFn, PType<T> ptype, int numReducers) Perform a secondary sort on the given PTable instance and then apply a DoFn to the resulting sorted data to yield an output PCollection<T>, using the given number of reducers.
static <T,U> Pair<PCollection<T>,PCollection<U>>	Channels.split(PCollection<Pair<T,U>> pCollection, PType<T> firstPType, PType<U> secondPType) Splits a PCollection of any Pair of objects into a Pair of PCollection}, to allow for the output of a DoFn to be handled using separate channels.
static <T,U> Pair<PCollection<T>,PCollection<U>>	Channels.split(PCollection<Pair<T,U>> pCollection, PType<T> firstPType, PType<U> secondPType) Splits a PCollection of any Pair of objects into a Pair of PCollection}, to allow for the output of a DoFn to be handled using separate channels.

Uses of PType in org.apache.crunch.lib.join

Fields in org.apache.crunch.lib.join declared as PType

protected PType<K>	JoinFn.keyType
protected PType<U>	JoinFn.leftValueType

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

static <K,U,V,T> PCollection<T>	OneToManyJoin.oneToManyJoin(PTable<K,U> left, PTable<K,V> right, DoFn<Pair<U,Iterable<V>>,T> postProcessFn, PType<T> ptype) Performs a join on two tables, where the left table only contains a single value per key.
static <K,U,V,T> PCollection<T>	OneToManyJoin.oneToManyJoin(PTable<K,U> left, PTable<K,V> right, DoFn<Pair<U,Iterable<V>>,T> postProcessFn, PType<T> ptype, int numReducers) Supports a user-specified number of reducers for the one-to-many 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.lib.sort

Methods in org.apache.crunch.lib.sort that return PType

PType<Object>

SortFns.KeyExtraction.getKeyType()

Methods in org.apache.crunch.lib.sort with parameters of type PType

static <S> org.apache.avro.Schema

SortFns.createOrderedTupleSchema(PType<S> ptype, Sort.ColumnOrder[] orders) Constructs an Avro schema for the given PType<S> that respects the given column orderings.

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

SortFns.KeyExtraction(PType<V> ptype, Sort.ColumnOrder[] columnOrder)

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.
static PType<BigInteger>	PTypes.bigInt(PTypeFamily typeFamily)
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()
static <T extends Enum> PType<T>	PTypes.enums(Class<T> type, PTypeFamily typeFamily)
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()
static <T> PType<T>	PTypes.jsonString(Class<T> clazz, PTypeFamily typeFamily)
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)
static <T extends com.google.protobuf.Message> PType<T>	PTypes.protos(Class<T> clazz, PTypeFamily typeFamily)
<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()
static <T extends org.apache.thrift.TBase> PType<T>	PTypes.thrifts(Class<T> clazz, PTypeFamily typeFamily)
<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)
static PType<UUID>	PTypes.uuid(PTypeFamily ptf)

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

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)
static <T> PType<T>	Avros.getPrimitiveType(Class<T> clazz)
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> org.apache.crunch.types.avro.AvroTableType<K,V>	Avros.tableOf(PType<K> key, PType<V> value)
static <K,V> org.apache.crunch.types.avro.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

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>,org.apache.crunch.types.writable.GenericArrayWritable>	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)

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

WritableType(Class<T> typeClass, Class<W> writableClass, MapFn<W,T> inputDoFn, MapFn<T,W> outputDoFn, PType... subTypes)