public class PyCollMap extends MapReduceBase implements JavaMessageHandler
Constructor and Description |
---|
PyCollMap() |
Modifier and Type | Method and Description |
---|---|
void |
execute()
Execute the operation.
|
void |
handleMessage(byte[] msg)
Function to handle messages recieved via a
StreamReader . |
void |
pyCollInit()
Simple function to actually initialize the c++ program
|
addMap, addMapper, addReduce, addReducer, createResults, getAwaitingOutputsFrom, getBytes, getDatasetCollection, getMapIdentifiers, getMapReduceDataset, getNumberOfMaps, getNumberOfReducers, getReduceIdentifiers, isAwaitingOutputs, removeMap, removeMapper, removeReduce, removeReducer, resetOutputTracker, setReceivedOutputFrom, unmarshall, writeResults, writeResults, writeResults
changeToExecuteFixedNumberOfTimes, changeToExecuteOnce, changeToExecutePeriodically, changeToExecuteWhenDataAvailable, changeToStayAlive, dispose, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, initialize, isInitialized, markInitializationAsComplete, needsInitialization, setAsExecuteFixedNumberOfTimes, setAsExecuteOnce, setAsExecutePeriodically, setAsExecuteWhenDataAvailable, setAsStayAlive, setDatasetCollection, setDomain, setInitializationComplete, setInitializationNeeded, setInstanceIdentifier, setOperationIdentifier, setProcessingDirectives, setTeminationConditionReached, setVersionInformation, terminationConditionReached, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
dispose, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, initialize, isInitialized, needsInitialization, terminationConditionReached, toString
public PyCollMap() throws java.io.IOException
java.io.IOException
public void pyCollInit()
public void execute() throws ProcessingException
Operation
execute
in interface Operation
execute
in class OperationBase
ProcessingException
- If there are problems executing the operation in question.public void handleMessage(byte[] msg)
JavaMessageHandler
StreamReader
.
Allows the user to define an asynchronous method of handling messageshandleMessage
in interface JavaMessageHandler
msg
- byte[]
to be decoded