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

Uses of Interface
org.apache.crunch.PObject

Packages that use PObject

org.apache.crunch	Client-facing API and core abstractions.
org.apache.crunch.contrib.bloomfilter	Support for creating Bloom Filters.
org.apache.crunch.impl.dist.collect
org.apache.crunch.impl.mem.collect
org.apache.crunch.lib	Joining, sorting, aggregating, and other commonly used functionality.
org.apache.crunch.materialize.pobject

Uses of PObject in org.apache.crunch

Methods in org.apache.crunch that return PObject

PObject<Collection<S>>	PCollection.asCollection()
PObject<Map<K,V>>	PTable.asMap() Returns a PObject encapsulating a Map made up of the keys and values in this PTable.
PObject<Long>	PCollection.length() Returns the number of elements represented by this PCollection.
PObject<S>	PCollection.max() Returns a PObject of the maximum element of this instance.
PObject<S>	PCollection.min() Returns a PObject of the minimum element of this instance.

Uses of PObject in org.apache.crunch.contrib.bloomfilter

Methods in org.apache.crunch.contrib.bloomfilter that return PObject

static PObject<Map<String,org.apache.hadoop.util.bloom.BloomFilter>>	BloomFilterFactory.createFilter(org.apache.hadoop.fs.Path inputPath, BloomFilterFn<String> filterFn) The method will take an input path and generates BloomFilters for all text files in that path.
static <T> PObject<org.apache.hadoop.util.bloom.BloomFilter>	BloomFilterFactory.createFilter(PCollection<T> collection, BloomFilterFn<T> filterFn)

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

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

PObject<Collection<S>>	PCollectionImpl.asCollection()
PObject<Map<K,V>>	PTableBase.asMap() Returns a PObject encapsulating a Map made up of the keys and values in this PTable.
PObject<Long>	PCollectionImpl.length()
PObject<S>	PCollectionImpl.max()
PObject<S>	PCollectionImpl.min()

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

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

PObject<Collection<S>>	MemCollection.asCollection()
PObject<Map<K,V>>	MemTable.asMap()
PObject<Long>	MemCollection.length()
PObject<S>	MemCollection.max()
PObject<S>	MemCollection.min()

Uses of PObject in org.apache.crunch.lib

Methods in org.apache.crunch.lib that return PObject

static <S> PObject<Long>	Aggregate.length(PCollection<S> collect) Returns the number of elements in the provided PCollection.
static <S> PObject<S>	Aggregate.max(PCollection<S> collect) Returns the largest numerical element from the input collection.
static <S> PObject<S>	Aggregate.min(PCollection<S> collect) Returns the smallest numerical element from the input collection.

Uses of PObject in org.apache.crunch.materialize.pobject

Classes in org.apache.crunch.materialize.pobject that implement PObject

class	CollectionPObject<S> A concrete implementation of PObjectImpl whose value is a Java Collection containing the elements of the underlying PCollection for this PObject.
class	FirstElementPObject<T> A concrete implementation of PObjectImpl that uses the first element in the backing PCollection as the PObject value.
class	MapPObject<K,V> A concrete implementation of PObjectImpl whose value is a Java Map.
class	PObjectImpl<S,T> An abstract implementation of PObject that is backed by a PCollection.