Package | Description |
---|---|
com.google.appengine.tools.mapreduce | |
com.google.appengine.tools.mapreduce.impl | |
com.google.appengine.tools.mapreduce.mappers |
Modifier and Type | Method and Description |
---|---|
static <I,Void,V> MapOnlyMapper<I,V> |
MapOnlyMapper.forMapper(Mapper<I,Void,V> mapper)
Returns a MapOnlyMapper for a given Mapper passing only the values to the output.
|
MapReduceSpecification.Builder<I,K,V,O,R> |
MapReduceSpecification.Builder.setMapper(Mapper<? extends I,K,V> mapper) |
MapSpecification.Builder<I,O,R> |
MapSpecification.Builder.setMapper(Mapper<? extends I,Void,O> mapper)
A convenience method that wraps the given
mapper using
MapOnlyMapper.forMapper(Mapper) . |
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 Mapper |
InProcessUtil.getMapper(MapReduceSpecification spec) |
Constructor and Description |
---|
MapShardTask(String mrJobId,
int shardNumber,
int shardCount,
InputReader<I> in,
Mapper<I,K,V> mapper,
OutputWriter<KeyValue<K,V>> out,
long millisPerSlice) |
Modifier and Type | Class and Description |
---|---|
class |
IdentityMapper<K,V>
A mapper that passes an incoming KeyValue to it's output.
|
class |
KeyProjectionMapper<T>
A pass through mapper that passes the input to the output key.
|
Copyright © 2015 Google. All rights reserved.