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> |
class |
WorkerShardTask<I,O,C extends WorkerContext<O>>
Base class for the specific MR stage 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.