Uses of Interface org.apache.crunch.Emitter (Apache Crunch 0.7.0 API)

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

Overview

Package

Class

Use

Tree

Deprecated

Index

PREV NEXT

FRAMES NO FRAMES

Uses of Interface
org.apache.crunch.Emitter

Packages that use Emitter
org.apache.crunch	Client-facing API and core abstractions.
org.apache.crunch.contrib.bloomfilter	Support for creating Bloom Filters.
org.apache.crunch.fn	Commonly used functions for manipulating collections.
org.apache.crunch.lib	Joining, sorting, aggregating, and other commonly used functionality.
org.apache.crunch.lib.join	Inner and outer joins on collections.

Uses of Emitter in org.apache.crunch

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

void FilterFn.cleanup(Emitter<T> emitter)


void DoFn.cleanup(Emitter<T> emitter)
          Called during the cleanup of the MapReduce job this DoFn is associated with.

void CombineFn.AggregatorCombineFn.process(Pair<K,Iterable<V>> input, Emitter<Pair<K,V>> emitter)
          Deprecated.

void MapFn.process(S input, Emitter<T> emitter)


abstract void DoFn.process(S input, Emitter<T> emitter)
          Processes the records from a PCollection.

void FilterFn.process(T input, Emitter<T> emitter)

Methods in org.apache.crunch with parameters of type Emitter
`void`	`FilterFn.cleanup(Emitter<T> emitter)`
`void`	`DoFn.cleanup(Emitter<T> emitter)` Called during the cleanup of the MapReduce job this `DoFn` is associated with.
`void`	`CombineFn.AggregatorCombineFn.process(Pair<K,Iterable<V>> input, Emitter<Pair<K,V>> emitter)` Deprecated.
`void`	`MapFn.process(S input, Emitter<T> emitter)`
`abstract void`	`DoFn.process(S input, Emitter<T> emitter)` Processes the records from a `PCollection`.
`void`	`FilterFn.process(T input, Emitter<T> emitter)`

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

Methods in org.apache.crunch.contrib.bloomfilter with parameters of type Emitter

void BloomFilterFn.cleanup(Emitter<Pair<String,org.apache.hadoop.util.bloom.BloomFilter>> emitter)

void BloomFilterFn.process(S input, Emitter<Pair<String,org.apache.hadoop.util.bloom.BloomFilter>> emitter)

Methods in org.apache.crunch.contrib.bloomfilter with parameters of type Emitter
`void`	`BloomFilterFn.cleanup(Emitter<Pair<String,org.apache.hadoop.util.bloom.BloomFilter>> emitter)`
`void`	`BloomFilterFn.process(S input, Emitter<Pair<String,org.apache.hadoop.util.bloom.BloomFilter>> emitter)`

Uses of Emitter in org.apache.crunch.fn

Methods in org.apache.crunch.fn with parameters of type Emitter

void PairMapFn.cleanup(Emitter<Pair<S,T>> emitter)


void CompositeMapFn.cleanup(Emitter<T> emitter)


void MapKeysFn.process(Pair<K1,V> input, Emitter<Pair<K2,V>> emitter)
          Deprecated.

void MapValuesFn.process(Pair<K,V1> input, Emitter<Pair<K,V2>> emitter)
          Deprecated.

Methods in org.apache.crunch.fn with parameters of type Emitter
`void`	`PairMapFn.cleanup(Emitter<Pair<S,T>> emitter)`
`void`	`CompositeMapFn.cleanup(Emitter<T> emitter)`
`void`	`MapKeysFn.process(Pair<K1,V> input, Emitter<Pair<K2,V>> emitter)` Deprecated.
`void`	`MapValuesFn.process(Pair<K,V1> input, Emitter<Pair<K,V2>> emitter)` Deprecated.

Uses of Emitter in org.apache.crunch.lib

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

void Aggregate.TopKFn.cleanup(Emitter<Pair<Integer,Pair<K,V>>> emitter)


void Aggregate.TopKCombineFn.process(Pair<Integer,Iterable<Pair<K,V>>> input, Emitter<Pair<Integer,Pair<K,V>>> emitter)


void Aggregate.TopKFn.process(Pair<K,V> input, Emitter<Pair<Integer,Pair<K,V>>> emitter)

Methods in org.apache.crunch.lib with parameters of type Emitter
`void`	`Aggregate.TopKFn.cleanup(Emitter<Pair<Integer,Pair<K,V>>> emitter)`
`void`	`Aggregate.TopKCombineFn.process(Pair<Integer,Iterable<Pair<K,V>>> input, Emitter<Pair<Integer,Pair<K,V>>> emitter)`
`void`	`Aggregate.TopKFn.process(Pair<K,V> input, Emitter<Pair<Integer,Pair<K,V>>> emitter)`

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

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

void LeftOuterJoinFn.cleanup(Emitter<Pair<K,Pair<U,V>>> emitter)
          Called during the cleanup of the MapReduce job this DoFn is associated with.

void FullOuterJoinFn.cleanup(Emitter<Pair<K,Pair<U,V>>> emitter)
          Called during the cleanup of the MapReduce job this DoFn is associated with.

void RightOuterJoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter)
          Performs the actual joining.

void LeftOuterJoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter)
          Performs the actual joining.

abstract void JoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter)
          Performs the actual joining.

void InnerJoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter)
          Performs the actual joining.

void FullOuterJoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter)
          Performs the actual joining.

void JoinFn.process(Pair<Pair<K,Integer>,Iterable<Pair<U,V>>> input, Emitter<Pair<K,Pair<U,V>>> emitter)
          Split up the input record to make coding a bit more manageable.

Methods in org.apache.crunch.lib.join with parameters of type Emitter
`void`	`LeftOuterJoinFn.cleanup(Emitter<Pair<K,Pair<U,V>>> emitter)` Called during the cleanup of the MapReduce job this `DoFn` is associated with.
`void`	`FullOuterJoinFn.cleanup(Emitter<Pair<K,Pair<U,V>>> emitter)` Called during the cleanup of the MapReduce job this `DoFn` is associated with.
`void`	`RightOuterJoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter)` Performs the actual joining.
`void`	`LeftOuterJoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter)` Performs the actual joining.
`abstract void`	`JoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter)` Performs the actual joining.
`void`	`InnerJoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter)` Performs the actual joining.
`void`	`FullOuterJoinFn.join(K key, int id, Iterable<Pair<U,V>> pairs, Emitter<Pair<K,Pair<U,V>>> emitter)` Performs the actual joining.
`void`	`JoinFn.process(Pair<Pair<K,Integer>,Iterable<Pair<U,V>>> input, Emitter<Pair<K,Pair<U,V>>> emitter)` Split up the input record to make coding a bit more manageable.