Uses of Interface
com.cloudera.crunch.PTable

Packages that use PTable

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.lib
com.cloudera.crunch.tool

Uses of PTable in com.cloudera.crunch

Methods in com.cloudera.crunch that return PTable

PTable<K,V>	PTable.bottom(int count) Returns a PTable made up of the pairs in this PTable with the smallest value field.
<U> PTable<K,Pair<Collection<V>,Collection<U>>>	PTable.cogroup(PTable<K,U> other) Co-group operation with the given table on common keys.
PTable<K,Collection<V>>	PTable.collectValues() Aggregate all of the values with the same key into a single key-value pair in the returned PTable.
PTable<K,V>	PGroupedTable.combineValues(CombineFn<K,V> combineFn) Combines the values of this grouping using the given CombineFn.
PTable<S,Long>	PCollection.count() Returns a PTable instance that contains the counts of each unique element of this PCollection.
<U> PTable<K,Pair<V,U>>	PTable.join(PTable<K,U> other) Perform an inner join on this table and the one passed in as an argument on their common keys.
<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>	Pipeline.read(TableSource<K,V> tableSource) A version of the read method for TableSource instances that map to PTables.
PTable<K,V>	PTable.top(int count) Returns a PTable made up of the pairs in this PTable with the largest value field.
PTable<K,V>	PGroupedTable.ungroup() Convert this grouping back into a multimap.
PTable<K,V>	PTable.union(PTable<K,V>... others) Returns a PTable instance that acts as the union of this PTable and the input PTables.
PTable<K,V>	PTable.write(Target target) Writes this PTable to the given Target.

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

<U> PTable<K,Pair<Collection<V>,Collection<U>>>	PTable.cogroup(PTable<K,U> other) Co-group operation with the given table on common keys.
<U> PTable<K,Pair<V,U>>	PTable.join(PTable<K,U> other) Perform an inner join on this table and the one passed in as an argument on their common keys.
PTable<K,V>	PTable.union(PTable<K,V>... others) Returns a PTable instance that acts as the union of this PTable and the input PTables.

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

Methods in com.cloudera.crunch.impl.mem that return PTable

<K,V> PTable<K,V>	MemPipeline.read(TableSource<K,V> source)
static <S,T> PTable<S,T>	MemPipeline.tableOf(Iterable<Pair<S,T>> pairs)
static <S,T> PTable<S,T>	MemPipeline.tableOf(S s, T t, Object... more)
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 PTable in com.cloudera.crunch.impl.mem.collect

Classes in com.cloudera.crunch.impl.mem.collect that implement PTable

class

MemTable<K,V>

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

PTable<K,V>	MemTable.bottom(int count)
<U> PTable<K,Pair<Collection<V>,Collection<U>>>	MemTable.cogroup(PTable<K,U> other)
PTable<K,Collection<V>>	MemTable.collectValues()
PTable<S,Long>	MemCollection.count()
<U> PTable<K,Pair<V,U>>	MemTable.join(PTable<K,U> other)
<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)
PTable<K,V>	MemTable.top(int count)
PTable<K,V>	MemTable.union(PTable<K,V>... others)
PTable<K,V>	MemTable.write(Target target)

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

<U> PTable<K,Pair<Collection<V>,Collection<U>>>	MemTable.cogroup(PTable<K,U> other)
<U> PTable<K,Pair<V,U>>	MemTable.join(PTable<K,U> other)
PTable<K,V>	MemTable.union(PTable<K,V>... others)

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

Methods in com.cloudera.crunch.impl.mr that return PTable

<K,V> PTable<K,V>

MRPipeline.read(TableSource<K,V> source)

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

Classes in com.cloudera.crunch.impl.mr.collect that implement PTable

class	DoTableImpl<K,V>
class	InputTable<K,V>
class	PTableBase<K,V>
class	UnionTable<K,V>

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

PTable<K,V>	PTableBase.bottom(int count)
<U> PTable<K,Pair<Collection<V>,Collection<U>>>	PTableBase.cogroup(PTable<K,U> other)
PTable<K,Collection<V>>	PTableBase.collectValues()
PTable<K,V>	PGroupedTableImpl.combineValues(CombineFn<K,V> combineFn)
PTable<S,Long>	PCollectionImpl.count()
<U> PTable<K,Pair<V,U>>	PTableBase.join(PTable<K,U> other)
<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)
PTable<K,V>	PTableBase.top(int count)
PTable<K,V>	PGroupedTableImpl.ungroup()
PTable<K,V>	PTableBase.union(PTable<K,V>... others)
PTable<K,V>	PTableBase.write(Target target)

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

<U> PTable<K,Pair<Collection<V>,Collection<U>>>	PTableBase.cogroup(PTable<K,U> other)
<U> PTable<K,Pair<V,U>>	PTableBase.join(PTable<K,U> other)
PTable<K,V>	PTableBase.union(PTable<K,V>... others)

Uses of PTable in com.cloudera.crunch.lib

Methods in com.cloudera.crunch.lib that return PTable

static <K,U,V> PTable<K,Pair<Collection<U>,Collection<V>>>	Cogroup.cogroup(PTable<K,U> left, PTable<K,V> right) Co-groups the two PTable arguments.
static <K,V> PTable<K,Collection<V>>	Aggregate.collectValues(PTable<K,V> collect)
static <S> PTable<S,Long>	Aggregate.count(PCollection<S> collect) Returns a PTable that contains the unique elements of this collection mapped to a count of their occurrences.
static <K,U,V> PTable<K,Pair<U,V>>	Join.innerJoin(PTable<K,U> left, PTable<K,V> right)
static <K,U,V> PTable<K,Pair<U,V>>	Join.join(PTable<K,U> left, PTable<K,V> right)
static <K,U,V> PTable<K,Pair<U,V>>	Join.leftJoin(PTable<K,U> left, PTable<K,V> right)
static <K,V> PTable<K,V>	Sort.sort(PTable<K,V> table) Sorts the PTable using the natural ordering of its keys.
static <K,V> PTable<K,V>	Sort.sort(PTable<K,V> table, Sort.Order key) Sorts the PTable using the natural ordering of its keys in the order specified.
static <K,V> PTable<K,V>	Aggregate.top(PTable<K,V> ptable, int limit, boolean maximize)

Methods in com.cloudera.crunch.lib with parameters of type PTable

static <K,U,V> PTable<K,Pair<Collection<U>,Collection<V>>>	Cogroup.cogroup(PTable<K,U> left, PTable<K,V> right) Co-groups the two PTable arguments.
static <K,U,V> PTable<K,Pair<Collection<U>,Collection<V>>>	Cogroup.cogroup(PTable<K,U> left, PTable<K,V> right) Co-groups the two PTable arguments.
static <K,V> PTable<K,Collection<V>>	Aggregate.collectValues(PTable<K,V> collect)
static <K,U,V> PTable<K,Pair<U,V>>	Join.innerJoin(PTable<K,U> left, PTable<K,V> right)
static <K,U,V> PTable<K,Pair<U,V>>	Join.innerJoin(PTable<K,U> left, PTable<K,V> right)
static <K,U,V> PTable<K,Pair<U,V>>	Join.join(PTable<K,U> left, PTable<K,V> right)
static <K,U,V> PTable<K,Pair<U,V>>	Join.join(PTable<K,U> left, PTable<K,V> right)
static <K,V> PCollection<K>	PTables.keys(PTable<K,V> ptable)
static <K,U,V> PTable<K,Pair<U,V>>	Join.leftJoin(PTable<K,U> left, PTable<K,V> right)
static <K,U,V> PTable<K,Pair<U,V>>	Join.leftJoin(PTable<K,U> left, PTable<K,V> right)
static <K,V> PTable<K,V>	Sort.sort(PTable<K,V> table) Sorts the PTable using the natural ordering of its keys.
static <K,V> PTable<K,V>	Sort.sort(PTable<K,V> table, Sort.Order key) Sorts the PTable using the natural ordering of its keys in the order specified.
static <K,V> PTable<K,V>	Aggregate.top(PTable<K,V> ptable, int limit, boolean maximize)
static <K,V> PCollection<V>	PTables.values(PTable<K,V> ptable)

Uses of PTable in com.cloudera.crunch.tool

Methods in com.cloudera.crunch.tool that return PTable

<K,V> PTable<K,V>

CrunchTool.read(TableSource<K,V> tableSource)