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
org.apache.crunch.impl.mem
org.apache.crunch.impl.mem.collect
org.apache.crunch.impl.mr.collect
org.apache.crunch.io.hbase
org.apache.crunch.io.impl
org.apache.crunch.io.seq
org.apache.crunch.lib
org.apache.crunch.types
org.apache.crunch.types.avro
org.apache.crunch.types.writable

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.

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)

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 that return PTableType

PTableType<K,V>	UnionTable.getPTableType()
PTableType<K,V>	InputTable.getPTableType()
PTableType<K,V>	DoTableImpl.getPTableType()

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

<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)

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(org.apache.hadoop.fs.Path path, PTableType<K,V> tableType, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat> formatClass)

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

SeqFileTableReaderFactory(PTableType<K,V> tableType, org.apache.hadoop.conf.Configuration conf)

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

Uses of PTableType in org.apache.crunch.types

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

Classes in org.apache.crunch.types.avro that implement PTableType

class

AvroTableType<K,V> The implementation of the PTableType interface for Avro-based serialization.

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)