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

org.apache.crunch.lib
Class Mapreduce

java.lang.Object
  org.apache.crunch.lib.Mapreduce

public class Mapreduce
extends Object

Static functions for working with legacy Mappers and Reducers that live under the org.apache.hadoop.mapreduce.* package as part of Crunch pipelines.

Constructor Summary

Mapreduce()

Method Summary

static <K1,V1,K2 extends org.apache.hadoop.io.Writable,V2 extends org.apache.hadoop.io.Writable> PTable<K2,V2>	map(PTable<K1,V1> input, Class<? extends org.apache.hadoop.mapreduce.Mapper<K1,V1,K2,V2>> mapperClass, 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>	reduce(PGroupedTable<K1,V1> input, Class<? extends org.apache.hadoop.mapreduce.Reducer<K1,V1,K2,V2>> reducerClass, Class<K2> keyClass, Class<V2> valueClass)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Mapreduce

public Mapreduce()

Method Detail

map

public static <K1,V1,K2 extends org.apache.hadoop.io.Writable,V2 extends org.apache.hadoop.io.Writable> PTable<K2,V2> map(PTable<K1,V1> input,
                                                                                                                          Class<? extends org.apache.hadoop.mapreduce.Mapper<K1,V1,K2,V2>> mapperClass,
                                                                                                                          Class<K2> keyClass,
                                                                                                                          Class<V2> valueClass)

reduce

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