public interface StreamsTask extends Runnable
StreamsOperation
in local mode.Modifier and Type | Method and Description |
---|---|
void |
addInputQueue(BlockingQueue<StreamsDatum> inputQueue)
Add an input
Queue for this task. |
void |
addOutputQueue(BlockingQueue<StreamsDatum> outputQueue)
Add an output
Queue for this task. |
List<BlockingQueue<StreamsDatum>> |
getInputQueues()
Returns the input queues that have been set for this task.
|
List<BlockingQueue<StreamsDatum>> |
getOutputQueues()
Returns the output 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 |
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.
|
void stopTask()
boolean isWaiting()
void addInputQueue(BlockingQueue<StreamsDatum> inputQueue)
Queue
for this task.inputQueue
- void addOutputQueue(BlockingQueue<StreamsDatum> outputQueue)
Queue
for this task.outputQueue
- void setStreamConfig(org.apache.streams.config.StreamsConfiguration config)
config
- optional configuration informationboolean isRunning()
List<BlockingQueue<StreamsDatum>> getInputQueues()
List<BlockingQueue<StreamsDatum>> getOutputQueues()
void setStreamsTaskCounter(StreamsTaskCounter counter)
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.