K - type of keysV - type of values (discarded)public class KeyProjectionReducer<K,V> extends Reducer<K,V,K>
| Constructor and Description |
|---|
KeyProjectionReducer() |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> KeyProjectionReducer<K,V> |
create() |
void |
reduce(K key,
ReducerInput<V> values)
Processes the values for a given key, using the context returned by
Worker.getContext() to emit output to the Output of the MapReduce. |
allowSliceRetry, beginShard, beginSlice, endShard, endSlice, estimateMemoryRequirement, getContext, setContextpublic static <K,V> KeyProjectionReducer<K,V> create()
public void reduce(K key, ReducerInput<V> values)
ReducerWorker.getContext() to emit output to the Output of the MapReduce.
values enumerates all values that the map phase produced for the
key key. It will always contain at least one value.Copyright © 2015 Google. All rights reserved.