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

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

Packages that use PTableType

org.apache.crunch	Client-facing API and core abstractions.
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.spark.collect
org.apache.crunch.io.hbase
org.apache.crunch.io.impl
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.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 PTableType in org.apache.crunch

Methods in org.apache.crunch that return PTableType

PTableType<K,V>	PTable.getPTableType() Returns the PTableType of this PTable.
PTableType<K,V>	TableSource.getTableType()

Methods in org.apache.crunch with parameters of type PTableType

<K,V> PTable<K,V>	PCollection.parallelDo(DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type) Similar to the other parallelDo instance, but returns a PTable instance instead of a PCollection.
<K,V> PTable<K,V>	PCollection.parallelDo(String name, DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type) Similar to the other parallelDo instance, but returns a PTable instance instead of a PCollection.
<K,V> PTable<K,V>	PCollection.parallelDo(String name, DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type, ParallelDoOptions options) Similar to the other parallelDo instance, but returns a PTable instance instead of a PCollection.

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

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

protected PTableType<K,V>

BaseDoTable.type

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

PTableType<K,V>	BaseUnionTable.getPTableType()
PTableType<K,V>	BaseInputTable.getPTableType()
PTableType<K,V>	BaseDoTable.getPTableType()

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

<S,K,V> BaseDoTable<K,V>	PCollectionFactory.createDoTable(String name, PCollectionImpl<S> chainingCollection, CombineFn<K,V> combineFn, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type)
<S,K,V> BaseDoTable<K,V>	PCollectionFactory.createDoTable(String name, PCollectionImpl<S> chainingCollection, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type, ParallelDoOptions options)
<K,V> PTable<K,V>	PCollectionImpl.parallelDo(DoFn<S,Pair<K,V>> fn, PTableType<K,V> type)
<K,V> PTable<K,V>	PCollectionImpl.parallelDo(String name, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type)
<K,V> PTable<K,V>	PCollectionImpl.parallelDo(String name, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type, ParallelDoOptions options)

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

BaseDoTable(String name, PCollectionImpl<S> parent, CombineFn<K,V> combineFn, DoFn<S,Pair<K,V>> fn, PTableType<K,V> ntype)

BaseDoTable(String name, PCollectionImpl<S> parent, CombineFn<K,V> combineFn, DoFn<S,Pair<K,V>> fn, PTableType<K,V> ntype, ParallelDoOptions options)

BaseDoTable(String name, PCollectionImpl<S> parent, DoFn<S,Pair<K,V>> fn, PTableType<K,V> ntype, ParallelDoOptions options)

Uses of PTableType in org.apache.crunch.impl.mem

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

static <S,T> PTable<S,T>	MemPipeline.typedTableOf(PTableType<S,T> ptype, Iterable<Pair<S,T>> pairs)
static <S,T> PTable<S,T>	MemPipeline.typedTableOf(PTableType<S,T> ptype, S s, T t, Object... more)

Uses of PTableType in org.apache.crunch.impl.mem.collect

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

PTableType<K,V>

MemTable.getPTableType()

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

<K,V> PTable<K,V>	MemCollection.parallelDo(DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type)
<K,V> PTable<K,V>	MemCollection.parallelDo(String name, DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type)
<K,V> PTable<K,V>	MemCollection.parallelDo(String name, DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type, ParallelDoOptions options)

Constructors in org.apache.crunch.impl.mem.collect with parameters of type PTableType

MemTable(Iterable<Pair<K,V>> collect, PTableType<K,V> ptype, String name)

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

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

<S,K,V> BaseDoTable<K,V>	MRCollectionFactory.createDoTable(String name, PCollectionImpl<S> parent, CombineFn<K,V> combineFn, DoFn<S,Pair<K,V>> reduceFn, PTableType<K,V> type)
<S,K,V> BaseDoTable<K,V>	MRCollectionFactory.createDoTable(String name, PCollectionImpl<S> parent, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type, ParallelDoOptions options)

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

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

<S,K,V> BaseDoTable<K,V>	SparkCollectFactory.createDoTable(String name, PCollectionImpl<S> parent, CombineFn<K,V> combineFn, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type)
<S,K,V> BaseDoTable<K,V>	SparkCollectFactory.createDoTable(String name, PCollectionImpl<S> parent, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type, ParallelDoOptions options)

Uses of PTableType in org.apache.crunch.io.hbase

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

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

HBaseSourceTarget.getTableType()

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

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

PTableType<K,V>	TableSourceTargetImpl.getTableType()
PTableType<K,V>	TableSourcePathTargetImpl.getTableType()
PTableType<K,V>	FileTableSourceImpl.getTableType()

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

FileTableSourceImpl(List<org.apache.hadoop.fs.Path> paths, PTableType<K,V> tableType, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat> formatClass)

FileTableSourceImpl(List<org.apache.hadoop.fs.Path> paths, PTableType<K,V> tableType, FormatBundle bundle)

FileTableSourceImpl(org.apache.hadoop.fs.Path path, PTableType<K,V> tableType, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat> formatClass)

FileTableSourceImpl(org.apache.hadoop.fs.Path path, PTableType<K,V> tableType, FormatBundle bundle)

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

Methods in org.apache.crunch.io.seq that return PTableType

PTableType<K,V>

SeqFileTableSourceTarget.getTableType()

Constructors in org.apache.crunch.io.seq with parameters of type PTableType

SeqFileTableSource(List<org.apache.hadoop.fs.Path> paths, PTableType<K,V> ptype)

SeqFileTableSource(org.apache.hadoop.fs.Path path, PTableType<K,V> ptype)

SeqFileTableSource(String path, PTableType<K,V> ptype)

SeqFileTableSourceTarget(org.apache.hadoop.fs.Path path, PTableType<K,V> tableType)

SeqFileTableSourceTarget(org.apache.hadoop.fs.Path path, PTableType<K,V> tableType, FileNamingScheme fileNamingScheme)

SeqFileTableSourceTarget(String path, PTableType<K,V> tableType)

Uses of PTableType in org.apache.crunch.io.text

Methods in org.apache.crunch.io.text that return PTableType

PTableType<K,V>

TextFileTableSourceTarget.getTableType()

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

TextFileTableSource(List<org.apache.hadoop.fs.Path> paths, PTableType<K,V> tableType)

TextFileTableSource(List<org.apache.hadoop.fs.Path> paths, PTableType<K,V> tableType, String separator)

TextFileTableSource(org.apache.hadoop.fs.Path path, PTableType<K,V> tableType)

TextFileTableSource(org.apache.hadoop.fs.Path path, PTableType<K,V> tableType, String separator)

TextFileTableSource(String path, PTableType<K,V> tableType)

TextFileTableSource(String path, PTableType<K,V> tableType, String separator)

TextFileTableSourceTarget(org.apache.hadoop.fs.Path path, PTableType<K,V> tableType)

TextFileTableSourceTarget(org.apache.hadoop.fs.Path path, PTableType<K,V> tableType, FileNamingScheme fileNamingScheme)

TextFileTableSourceTarget(String path, PTableType<K,V> tableType)

Uses of PTableType in org.apache.crunch.lib

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

static <K,V> Pair<K,V>	PTables.getDetachedValue(PTableType<K,V> tableType, Pair<K,V> value) Create a detached value for a table Pair.
static <K,V1,V2,U,V> PTable<U,V>	SecondarySort.sortAndApply(PTable<K,Pair<V1,V2>> input, DoFn<Pair<K,Iterable<Pair<V1,V2>>>,Pair<U,V>> doFn, PTableType<U,V> ptype) Perform a secondary sort on the given PTable instance and then apply a DoFn to the resulting sorted data to yield an output PTable<U, V>.
static <K,V1,V2,U,V> PTable<U,V>	SecondarySort.sortAndApply(PTable<K,Pair<V1,V2>> input, DoFn<Pair<K,Iterable<Pair<V1,V2>>>,Pair<U,V>> doFn, PTableType<U,V> 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 PTable<U, V>, using the given number of reducers.

Uses of PTableType in org.apache.crunch.types

Fields in org.apache.crunch.types declared as PTableType

protected PTableType<K,V>

PGroupedTableType.tableType

Methods in org.apache.crunch.types that return PTableType

PTableType<K,V>	PGroupedTableType.getTableType()
<K,V> PTableType<K,V>	PTypeFamily.tableOf(PType<K> key, PType<V> value)

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

PGroupedTableType(PTableType<K,V> tableType)

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

Methods in org.apache.crunch.types.avro that return PTableType

<K,V> PTableType<K,V>

AvroTypeFamily.tableOf(PType<K> key, PType<V> value)

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

Methods in org.apache.crunch.types.writable that return PTableType

<K,V> PTableType<K,V>

WritableTypeFamily.tableOf(PType<K> key, PType<V> value)