com.google.appengine.tools.mapreduce.impl

Class InProcessMapReduce<I,K,V,O,R>

java.lang.Object

com.google.appengine.tools.mapreduce.impl.InProcessMapReduce<I,K,V,O,R>

Type Parameters:

I - type of input values

K - type of intermediate keys

V - type of intermediate values

O - type of output values

R - type of result returned by the Output

public class InProcessMapReduce<I,K,V,O,R>
extends Object

Runs a MapReduce in the current process. Only for very small datasets. Easier to debug than a parallel MapReduce.

Author:

ohler@google.com (Christian Ohler)

Constructor Summary

Constructors

Constructor and Description
InProcessMapReduce(String id, MapReduceSpecification<I,K,V,O,R> mrSpec)

Method Summary

Methods

Modifier and Type	Method and Description
static <I,K,V,O,R> MapReduceResult<R>	runMapReduce(MapReduceSpecification<I,K,V,O,R> mrSpec)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

InProcessMapReduce

public InProcessMapReduce(String id,
                  MapReduceSpecification<I,K,V,O,R> mrSpec)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

runMapReduce

public static <I,K,V,O,R> MapReduceResult<R> runMapReduce(MapReduceSpecification<I,K,V,O,R> mrSpec)
                                       throws IOException

Throws:

IOException