org.apache.streams.local.tasks

Class StreamsProcessorTask

java.lang.Object

org.apache.streams.local.tasks.BaseStreamsTask

org.apache.streams.local.tasks.StreamsProcessorTask

All Implemented Interfaces:

Runnable, DatumStatusCountable, StreamsTask

public class StreamsProcessorTask
extends BaseStreamsTask
implements DatumStatusCountable

Constructor Summary

Constructors

Constructor and Description
StreamsProcessorTask(StreamsProcessor processor) Default constructor, uses default sleep time of 500ms when inbound queue is empty
StreamsProcessorTask(StreamsProcessor processor, org.apache.streams.config.StreamsConfiguration streamConfig)

Method Summary

Modifier and Type	Method and Description
void	addInputQueue(BlockingQueue<StreamsDatum> inputQueue) Add an input Queue for this task.
DatumStatusCounter	getDatumStatusCounter()
List<BlockingQueue<StreamsDatum>>	getInputQueues() Returns the input queues that have been set for this task.
boolean	isRunning() Returns true when the task has not completed.
boolean	isWaiting() Returns true if the task is waiting on more data to process
void	run()
void	setStreamConfig(org.apache.streams.config.StreamsConfiguration config) Set the configuration object that will shared and passed to all instances of StreamsTask.
void	setStreamsTaskCounter(StreamsTaskCounter counter)
void	stopTask() Informs the task to stop.

Methods inherited from class org.apache.streams.local.tasks.BaseStreamsTask

addOutputQueue, addToOutgoingQueue, cloneStreamsDatum, getNextDatum, getOutputQueues, getStartedAt, getStreamIdentifier, setStartedAt

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamsProcessorTask

public StreamsProcessorTask(StreamsProcessor processor)

Default constructor, uses default sleep time of 500ms when inbound queue is empty

Parameters:

processor - process to run in task

StreamsProcessorTask

public StreamsProcessorTask(StreamsProcessor processor,
                            org.apache.streams.config.StreamsConfiguration streamConfig)

Parameters:

processor -

streamConfig -

Method Detail

getDatumStatusCounter

public DatumStatusCounter getDatumStatusCounter()

Specified by:

getDatumStatusCounter in interface DatumStatusCountable

isWaiting

public boolean isWaiting()

Description copied from interface: StreamsTask

Returns true if the task is waiting on more data to process

Specified by:

isWaiting in interface StreamsTask

Overrides:

isWaiting in class BaseStreamsTask

Returns:

true, if waiting on more data to process

stopTask

public void stopTask()

Description copied from interface: StreamsTask

Informs the task to stop. Tasks may or may not try to empty its inbound queue before halting.

Specified by:

stopTask in interface StreamsTask

setStreamConfig

public void setStreamConfig(org.apache.streams.config.StreamsConfiguration config)

Description copied from interface: StreamsTask

Set the configuration object that will shared and passed to all instances of StreamsTask.

Specified by:

setStreamConfig in interface StreamsTask

Parameters:

config - optional configuration information

addInputQueue

public void addInputQueue(BlockingQueue<StreamsDatum> inputQueue)

Description copied from interface: StreamsTask

Add an input Queue for this task.

Specified by:

addInputQueue in interface StreamsTask

Overrides:

addInputQueue in class BaseStreamsTask

isRunning

public boolean isRunning()

Description copied from interface: StreamsTask

Returns true when the task has not completed. Returns false otherwise

Specified by:

isRunning in interface StreamsTask

Returns:

true when the task has not completed. Returns false otherwise

run

public void run()

Specified by:

run in interface Runnable

getInputQueues

public List<BlockingQueue<StreamsDatum>> getInputQueues()

Description copied from interface: StreamsTask

Returns the input queues that have been set for this task.

Specified by:

getInputQueues in interface StreamsTask

Overrides:

getInputQueues in class BaseStreamsTask

Returns:

list of input queues

setStreamsTaskCounter

public void setStreamsTaskCounter(StreamsTaskCounter counter)

Specified by:

setStreamsTaskCounter in interface StreamsTask