public abstract class StreamProcessor extends StreamBase
process
method.Operation.OperationType
identifier, incomingStreamTypes, isBufferingAccess, outGoingStreamTypes, streamDataset
defaultOutputStream, mapReduceDataset, MODULE
Constructor and Description |
---|
StreamProcessor() |
Modifier and Type | Method and Description |
---|---|
void |
execute()
Execute the operation.
|
abstract void |
onEvent(StreamEvent event)
This method will be invoked by the framework when data is available in one of the input streams.
|
addStreamConsumer, declareOutputStreams, declareStream, getDatasetIdentifier, getDefaultStreamDataset, getStreamIdentifier, initialize, marshall, unmarshall, writeToStream
addMap, addMapper, addReduce, addReducer, createResults, getAwaitingOutputsFrom, getDatasetCollection, getMapIdentifiers, getMapReduceDataset, getNumberOfMaps, getNumberOfReducers, getReduceIdentifiers, isAwaitingOutputs, removeMap, removeMapper, removeReduce, removeReducer, resetOutputTracker, setReceivedOutputFrom, writeResults, writeResults, writeResults, writeResults
changeToExecuteFixedNumberOfTimes, changeToExecuteOnce, changeToExecutePeriodically, changeToExecuteWhenDataAvailable, changeToStayAlive, dispose, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, isInitialized, markInitializationAsComplete, needsInitialization, setAsExecuteContinuously, 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, isInitialized, needsInitialization, terminationConditionReached, toString
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 abstract void onEvent(StreamEvent event) throws StreamingDatasetException
event
- A StreamTuple
object.StreamingDatasetException
- Error when accessing the streaming dataset.Copyright © 2015. All rights reserved.