Package | Description |
---|---|
com.google.appengine.tools.mapreduce | |
com.google.appengine.tools.mapreduce.impl |
Modifier and Type | Method and Description |
---|---|
MapReduceSpecification<I,K,V,O,R> |
MapReduceSpecification.Builder.build() |
Modifier and Type | Method and Description |
---|---|
static <I,K,V,O,R> |
MapReduceJob.start(MapReduceSpecification<I,K,V,O,R> specification,
MapReduceSettings settings)
Starts a
MapReduceJob with the given parameters in a new Pipeline. |
Constructor and Description |
---|
MapReduceJob(MapReduceSpecification<I,K,V,O,R> specification,
MapReduceSettings settings) |
Modifier and Type | Method and Description |
---|---|
static Input |
InProcessUtil.getInput(MapReduceSpecification spec) |
static Marshaller |
InProcessUtil.getKeyMarshaller(MapReduceSpecification spec) |
static Mapper |
InProcessUtil.getMapper(MapReduceSpecification spec) |
static Integer |
InProcessUtil.getNumReducers(MapReduceSpecification spec) |
static Output |
InProcessUtil.getOutput(MapReduceSpecification spec) |
static Reducer |
InProcessUtil.getReducer(MapReduceSpecification spec) |
static <I,K,V,O,R> |
InProcessMapReduce.runMapReduce(MapReduceSpecification<I,K,V,O,R> mrSpec) |
Constructor and Description |
---|
InProcessMapReduce(String id,
MapReduceSpecification<I,K,V,O,R> mrSpec) |
Copyright © 2015 Google. All rights reserved.