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

org.apache.crunch.lib
Class Mapred

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


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