com.google.appengine.tools.mapreduce

Class MapReduceSpecification.Builder<I,K,V,O,R>

java.lang.Object

com.google.appengine.tools.mapreduce.MapReduceSpecification.Builder<I,K,V,O,R>

Enclosing class:

MapReduceSpecification<I,K,V,O,R>

public static class MapReduceSpecification.Builder<I,K,V,O,R>
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Input<? extends I>	input
protected String	jobName
protected Output<? super O,? extends R>	output

Constructor Summary

Constructors

Constructor and Description
MapReduceSpecification.Builder()
MapReduceSpecification.Builder(Input<I> input, Mapper<I,K,V> mapper, Reducer<K,V,O> reducer, Output<O,R> output)

Method Summary

Methods

Modifier and Type	Method and Description
MapReduceSpecification<I,K,V,O,R>	build()
protected MapReduceSpecification.Builder<I,K,V,O,R>	self()
B	setInput(Input<? extends I> input)
B	setJobName(String jobName)
MapReduceSpecification.Builder<I,K,V,O,R>	setKeyMarshaller(Marshaller<K> marshaller)
MapReduceSpecification.Builder<I,K,V,O,R>	setMapper(Mapper<? extends I,K,V> mapper)
MapReduceSpecification.Builder<I,K,V,O,R>	setNumReducers(int numReducers)
B	setOutput(Output<? super O,? extends R> output)
MapReduceSpecification.Builder<I,K,V,O,R>	setReducer(Reducer<K,V,? extends O> reducer)
MapReduceSpecification.Builder<I,K,V,O,R>	setValueMarshaller(Marshaller<V> marshaller)

Methods inherited from class java.lang.Object

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

Field Detail

jobName

protected String jobName

input

protected Input<? extends I> input

output

protected Output<? super O,? extends R> output

Constructor Detail

MapReduceSpecification.Builder

public MapReduceSpecification.Builder()

MapReduceSpecification.Builder

public MapReduceSpecification.Builder(Input<I> input,
                              Mapper<I,K,V> mapper,
                              Reducer<K,V,O> reducer,
                              Output<O,R> output)

Method Detail

self

protected MapReduceSpecification.Builder<I,K,V,O,R> self()

setMapper

public MapReduceSpecification.Builder<I,K,V,O,R> setMapper(Mapper<? extends I,K,V> mapper)

Parameters:

mapper - processes the input and optionally generates intermediate key-value pairs to be processed by reducer

setKeyMarshaller

public MapReduceSpecification.Builder<I,K,V,O,R> setKeyMarshaller(Marshaller<K> marshaller)

Parameters:

marshaller - turns intermediate keys into bytes and back. see Marshallers for default implementations.

setValueMarshaller

public MapReduceSpecification.Builder<I,K,V,O,R> setValueMarshaller(Marshaller<V> marshaller)

Parameters:

marshaller - turns intermediate values into bytes and back. see Marshallers for default implementations. defaults to Marshallers.getSerializationMarshaller().

setReducer

public MapReduceSpecification.Builder<I,K,V,O,R> setReducer(Reducer<K,V,? extends O> reducer)

Parameters:

reducer - processes the intermediate key-value pairs generated by the mapper and optionally writes to output.

setNumReducers

public MapReduceSpecification.Builder<I,K,V,O,R> setNumReducers(int numReducers)

Parameters:

numReducers - specify the number of reducers

build

public MapReduceSpecification<I,K,V,O,R> build()

setJobName

public B setJobName(String jobName)

Parameters:

jobName - descriptive name for the job (human readable, does not have to be unique).

setInput

public B setInput(Input<? extends I> input)

Parameters:

input - specifies what input the mapper should process

setOutput

public B setOutput(Output<? super O,? extends R> output)

Parameters:

output - specifies what to do with output values.