This project has retired. For details please refer to its Attic page.
Mapreduce (Apache Crunch 0.8.0 API)

org.apache.crunch.lib
Class Mapreduce

java.lang.Object
  extended by 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)


Copyright © 2013 The Apache Software Foundation. All Rights Reserved.