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

org.apache.crunch.lib
Class Mapred

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

public class Mapred
extends Object

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

Constructor Summary

Mapred()

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.mapred.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.mapred.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

Mapred

public Mapred()

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.mapred.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.mapred.Reducer<K1,V1,K2,V2>> reducerClass,
                                                                                                                             Class<K2> keyClass,
                                                                                                                             Class<V2> valueClass)