| Package | Description |
|---|---|
| ds.granules.interfere.computation | |
| ds.granules.interfere.computation.eeg | |
| ds.granules.operation |
This package encapsulates functionality related to application instances that will be deployed on the cloud.
|
| ds.granules.samples.wordcount |
This package contains classes that demonstrate using Granules with a simple information retrieval capability: Histogramming Word Counts in a set of files on a distributed set of machines.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ComputationManager.deployJob(int inStreamGrp,
java.lang.String inDeployStream,
boolean inActive) |
void |
GIComputation.startMigration(double inScore) |
| Modifier and Type | Method and Description |
|---|---|
EEGMap |
EEGDeployer.initializeEEGMap(EEGReduce reduce,
int computationID) |
void |
EEGDeployer.prepareInstancesAndDeploy(int numOfMaps) |
| Modifier and Type | Method and Description |
|---|---|
int |
Reduce.addMap(Map map)
Adds a Map that will be reduced.
|
int |
MapReduceBase.addMap(Map map) |
int |
Map.addReduce(Reduce reduce)
Adds a Reduce for this particular Map.
|
int |
MapReduceBase.addReduce(Reduce reduce) |
int |
Reduce.removeMap(java.lang.String mapIdentifier)
Removes a Map from the list of Maps that are registered to this reducer.
|
int |
MapReduceBase.removeMap(java.lang.String mapIdentifier) |
int |
Map.removeReduce(java.lang.String reduceIdentifier)
Removes a given reducer from the list of Reducers for a given Map
function.
|
int |
MapReduceBase.removeReduce(java.lang.String reduceIdentifier) |
void |
MapReduceBase.writeResults(int synopsisType,
java.lang.String streamSynopsis,
Results results)
Deprecated.
|
void |
MapReduce.writeResults(int synopsisType,
java.lang.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(java.lang.String streamSynopsis,
Results results)
Deprecated.
|
void |
MapReduce.writeResults(java.lang.String streamSynopsis,
Results results)
Deprecated.
|
void |
MapReduceBase.writeResults(Topic topic,
Results results) |
void |
MapReduce.writeResults(Topic topic,
Results results)
Writes the specified results to a specific output stream.
|
| Modifier and Type | Method and Description |
|---|---|
void |
WordCountDeployer.prepareInstancesAndDeploy(int numOfMaps,
java.lang.String filenameBase)
Prepares a set of Map/Reduce instances for the WordCount example and
deploys it on the set of available resources.
|