public abstract class StreamSource extends StreamBase
Operation.OperationType
identifier, incomingStreamTypes, isBufferingAccess, outGoingStreamTypes, streamDataset
defaultOutputStream, mapReduceDataset, MODULE
Constructor and Description |
---|
StreamSource() |
Modifier and Type | Method and Description |
---|---|
abstract void |
emit()
Emit the next tuple.
|
void |
execute()
Execute the operation.
|
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 emit() throws StreamingDatasetException
StreamingDatasetException
Copyright © 2015. All rights reserved.