Package | Description |
---|---|
com.google.appengine.tools.mapreduce | |
com.google.appengine.tools.mapreduce.impl | |
com.google.appengine.tools.mapreduce.reducers |
Modifier and Type | Method and Description |
---|---|
MapReduceSpecification.Builder<I,K,V,O,R> |
MapReduceSpecification.Builder.setReducer(Reducer<K,V,? extends O> reducer) |
Constructor and Description |
---|
MapReduceSpecification.Builder(Input<I> input,
Mapper<I,K,V> mapper,
Reducer<K,V,O> reducer,
Output<O,R> output) |
Modifier and Type | Method and Description |
---|---|
static Reducer |
InProcessUtil.getReducer(MapReduceSpecification spec) |
Constructor and Description |
---|
ReduceShardTask(String mrJobId,
int shardNumber,
int shardCount,
InputReader<KeyValue<K,Iterator<V>>> in,
Reducer<K,V,O> reducer,
OutputWriter<O> out,
long millisPerSlice) |
Modifier and Type | Class and Description |
---|---|
class |
IdentityReducer<K,V>
A passthrough reducer that passes it's input to it's output.
|
class |
KeyProjectionReducer<K,V>
Reducer that emits the keys that occur in its input, discarding the values.
|
class |
NoReducer<K,V,O>
Deprecated.
Consider using
MapJob instead. |
class |
ValueProjectionReducer<K,V>
Reducer that emits the values that occur in its input, discarding the keys.
|
Copyright © 2015 Google. All rights reserved.