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, setContext
public static <K,V> KeyProjectionReducer<K,V> create()
public void reduce(K key, ReducerInput<V> values)
Reducer
Worker.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.