This project has retired. For details please refer to its
Attic page.
Mapreduce (Apache Crunch 0.7.0 API)
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.
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)
|
Mapreduce
public Mapreduce()
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.