Package | Description |
---|---|
ds.granules.operation |
This package encapsulates functionality related to application instances that will be deployed on the cloud.
|
Modifier and Type | Method and Description |
---|---|
int |
Reduce.addMap(Map map)
Adds a Map that will be reduced.
|
int |
MapReduceBase.addMap(Map map) |
protected void |
MapReduceBase.addMapper(Map map)
This method is called on a Reduce, once it has been added to a
Map using the Map.addReduce() method. |
int |
MapReduceBase.addReduce(Reduce reduce) |
int |
Map.addReduce(Reduce reduce)
Adds a Reduce for this particular Map.
|
protected void |
MapReduceBase.addReducer(Reduce reduce)
This method is called on a Map, once it has been added to a
Reduce using the Reduce.addMap() method. |
int |
Reduce.removeMap(String mapIdentifier)
Removes a Map from the list of Maps that are registered to this reducer.
|
int |
MapReduceBase.removeMap(String mapIdentifier) |
protected void |
MapReduceBase.removeMapper(Map map)
This method is called on a Reduce, once it has been removed from a
Map using the Map.removeReduce() method. |
int |
MapReduceBase.removeReduce(String reduceIdentifier) |
int |
Map.removeReduce(String reduceIdentifier)
Removes a given reducer from the list of Reducers for a given Map
function.
|
protected void |
MapReduceBase.removeReducer(Reduce reduce)
This method is called on a Map, once it has been removed from a
Reduce using the Reduce.removeMap() method. |
void |
MapReduceBase.writeResults(int synopsisType,
String streamSynopsis,
Results results)
Deprecated.
|
void |
MapReduce.writeResults(int synopsisType,
String streamSynopsis,
Results results)
Deprecated.
|
void |
MapReduceBase.writeResults(Results results) |
void |
MapReduce.writeResults(Results results)
Writes the specified results to the default output stream.
|
void |
MapReduceBase.writeResults(String streamSynopsis,
Results results)
Deprecated.
|
void |
MapReduce.writeResults(String streamSynopsis,
Results results)
Deprecated.
|
void |
MapReduceBase.writeResults(ds.funnel.topic.Topic topic,
Results results) |
void |
MapReduce.writeResults(ds.funnel.topic.Topic topic,
Results results)
Writes the specified results to a specific output stream.
|
Copyright © 2015. All rights reserved.