Uses of Interface org.apache.crunch.PGroupedTable (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.PGroupedTable

Packages that use PGroupedTable
org.apache.crunch	Client-facing API and core abstractions.
org.apache.crunch.lib	Joining, sorting, aggregating, and other commonly used functionality.

Uses of PGroupedTable in org.apache.crunch

Methods in org.apache.crunch that return PGroupedTable

PGroupedTable<K,V> PTable.groupByKey()
          Performs a grouping operation on the keys of this table.

PGroupedTable<K,V> PTable.groupByKey(GroupingOptions options)
          Performs a grouping operation on the keys of this table, using the additional GroupingOptions to control how the grouping is executed.

PGroupedTable<K,V> PTable.groupByKey(int numPartitions)
          Performs a grouping operation on the keys of this table, using the given number of partitions.

Methods in org.apache.crunch that return PGroupedTable
`PGroupedTable<K,V>`	`PTable.groupByKey()` Performs a grouping operation on the keys of this table.
`PGroupedTable<K,V>`	`PTable.groupByKey(GroupingOptions options)` Performs a grouping operation on the keys of this table, using the additional `GroupingOptions` to control how the grouping is executed.
`PGroupedTable<K,V>`	`PTable.groupByKey(int numPartitions)` Performs a grouping operation on the keys of this table, using the given number of partitions.

Uses of PGroupedTable in org.apache.crunch.lib

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

static <K,U,V> PTable<K,V> PTables.mapValues(PGroupedTable<K,U> ptable, MapFn<Iterable<U>,V> mapFn, PType<V> ptype)
          An analogue of the mapValues function for PGroupedTable<K, U> collections.

static <K,U,V> PTable<K,V> PTables.mapValues(String name, PGroupedTable<K,U> ptable, MapFn<Iterable<U>,V> mapFn, PType<V> ptype)
          An analogue of the mapValues function for PGroupedTable<K, U> collections.

static <K1,V1,K2 extends org.apache.hadoop.io.Writable,V2 extends org.apache.hadoop.io.Writable> PTable<K2,V2> Mapreduce.reduce(PGroupedTable<K1,V1> input, Class<? extends org.apache.hadoop.mapreduce.Reducer<K1,V1,K2,V2>> reducerClass, Class<K2> keyClass, Class<V2> valueClass)


static <K1,V1,K2 extends org.apache.hadoop.io.Writable,V2 extends org.apache.hadoop.io.Writable> PTable<K2,V2> Mapred.reduce(PGroupedTable<K1,V1> input, Class<? extends org.apache.hadoop.mapred.Reducer<K1,V1,K2,V2>> reducerClass, Class<K2> keyClass, Class<V2> valueClass)