ds.granules.streaming.core

Class StreamProcessor

java.lang.Object

ds.granules.operation.OperationBase

ds.granules.operation.MapReduceBase

ds.granules.streaming.core.StreamBase

ds.granules.streaming.core.StreamProcessor

All Implemented Interfaces:

ds.funnel.data.format.FormatMarshaller, Map, MapReduce, Operation, OperationConfiguration, Reduce

public abstract class StreamProcessor
extends StreamBase

Any stream processing element should extend this abstract class. Once a tuple is available through a incoming stream, it is made available through the process method.

Author:

: Thilina Buddhika

Nested Class Summary

Nested classes/interfaces inherited from interface ds.granules.operation.Operation

Operation.OperationType

Field Summary

Fields inherited from class ds.granules.streaming.core.StreamBase

identifier, incomingStreamTypes, isBufferingAccess, outGoingStreamTypes, streamDataset

Fields inherited from class ds.granules.operation.MapReduceBase

defaultOutputStream, mapReduceDataset, MODULE

Constructor Summary

Constructors

Constructor and Description
StreamProcessor()

Method Summary

Methods

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.

Methods inherited from class ds.granules.streaming.core.StreamBase

addStreamConsumer, declareOutputStreams, declareStream, getDatasetIdentifier, getDefaultStreamDataset, getStreamIdentifier, initialize, marshall, unmarshall, writeToStream

Methods inherited from class ds.granules.operation.MapReduceBase

addMap, addMapper, addReduce, addReducer, createResults, getAwaitingOutputsFrom, getDatasetCollection, getMapIdentifiers, getMapReduceDataset, getNumberOfMaps, getNumberOfReducers, getReduceIdentifiers, isAwaitingOutputs, removeMap, removeMapper, removeReduce, removeReducer, resetOutputTracker, setReceivedOutputFrom, writeResults, writeResults, writeResults, writeResults

Methods inherited from class ds.granules.operation.OperationBase

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface ds.granules.operation.Operation

dispose, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, isInitialized, needsInitialization, terminationConditionReached, toString

Constructor Detail

StreamProcessor

public StreamProcessor()

Method Detail

execute

public void execute()
             throws ProcessingException

Description copied from interface: Operation

Execute the operation.

Specified by:

execute in interface Operation

Specified by:

execute in class OperationBase

Throws:

ProcessingException - If there are problems executing the operation in question.

onEvent

public abstract void onEvent(StreamEvent event)
                      throws StreamingDatasetException

This method will be invoked by the framework when data is available in one of the input streams.

Parameters:

event - A StreamTuple object.

Throws:

StreamingDatasetException - Error when accessing the streaming dataset.