Package | Description |
---|---|
com.google.appengine.tools.mapreduce.impl | |
com.google.appengine.tools.mapreduce.impl.sort |
Modifier and Type | Class and Description |
---|---|
class |
MapOnlyShardTask<I,O> |
class |
MapShardTask<I,K,V> |
class |
ReduceShardTask<K,V,O> |
Modifier and Type | Method and Description |
---|---|
void |
WorkerController.completed(Iterator<WorkerShardTask<I,O,C>> workers) |
Modifier and Type | Class and Description |
---|---|
class |
MergeShardTask
Passes input to the output.
|
class |
SortShardTask
Keeps accepting inputs and passing them to a SortWorker until the worker's buffer is full.
|
Copyright © 2015 Google. All rights reserved.