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

Uses of Class
org.apache.crunch.CombineFn

Packages that use CombineFn

org.apache.crunch	Client-facing API and core abstractions.
org.apache.crunch.fn	Commonly used functions for manipulating collections.
org.apache.crunch.impl.dist.collect
org.apache.crunch.impl.mr.collect
org.apache.crunch.impl.spark
org.apache.crunch.impl.spark.collect
org.apache.crunch.impl.spark.fn
org.apache.crunch.lib	Joining, sorting, aggregating, and other commonly used functionality.

Uses of CombineFn in org.apache.crunch

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

PTable<K,V>	PGroupedTable.combineValues(CombineFn<K,V> combineFn) Combines the values of this grouping using the given CombineFn.
PTable<K,V>	PGroupedTable.combineValues(CombineFn<K,V> combineFn, CombineFn<K,V> reduceFn) Combines and reduces the values of this grouping using the given CombineFn instances.
PTable<K,V>	PGroupedTable.combineValues(CombineFn<K,V> combineFn, CombineFn<K,V> reduceFn) Combines and reduces the values of this grouping using the given CombineFn instances.

Uses of CombineFn in org.apache.crunch.fn

Methods in org.apache.crunch.fn that return CombineFn

static <K,V> CombineFn<K,V>

Aggregators.toCombineFn(Aggregator<V> aggregator) Wrap a CombineFn adapter around the given aggregator.

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

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

PTable<K,V>	BaseGroupedTable.combineValues(CombineFn<K,V> combineFn)
PTable<K,V>	BaseGroupedTable.combineValues(CombineFn<K,V> combineFn, CombineFn<K,V> reduceFn)
PTable<K,V>	BaseGroupedTable.combineValues(CombineFn<K,V> combineFn, CombineFn<K,V> reduceFn)
<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)

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

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)

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

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

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

Uses of CombineFn in org.apache.crunch.impl.spark

Methods in org.apache.crunch.impl.spark that return CombineFn

CombineFn

SparkRuntime.getCombineFn()

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

void	SparkRuntime.setCombineFn(CombineFn combineFn)

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

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

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

Uses of CombineFn in org.apache.crunch.impl.spark.fn

Constructors in org.apache.crunch.impl.spark.fn with parameters of type CombineFn

CombineMapsideFunction(CombineFn<K,V> combineFn, SparkRuntimeContext ctxt)

Uses of CombineFn in org.apache.crunch.lib

Subclasses of CombineFn in org.apache.crunch.lib

static class

Aggregate.TopKCombineFn<K,V>