public class StreamsPersistWriterTask extends BaseStreamsTask implements DatumStatusCountable
Constructor and Description |
---|
StreamsPersistWriterTask(StreamsPersistWriter writer)
Default constructor.
|
StreamsPersistWriterTask(StreamsPersistWriter writer,
org.apache.streams.config.StreamsConfiguration streamConfig) |
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. |
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.
|
addToOutgoingQueue, cloneStreamsDatum, getNextDatum, getOutputQueues, getStartedAt, getStreamIdentifier, setStartedAt
public StreamsPersistWriterTask(StreamsPersistWriter writer)
writer
- writer to execute in taskpublic StreamsPersistWriterTask(StreamsPersistWriter writer, org.apache.streams.config.StreamsConfiguration streamConfig)
writer
- writer to execute in taskstreamConfig
- stream configpublic DatumStatusCounter getDatumStatusCounter()
getDatumStatusCounter
in interface DatumStatusCountable
public boolean isWaiting()
StreamsTask
isWaiting
in interface StreamsTask
isWaiting
in class BaseStreamsTask
public void setStreamConfig(org.apache.streams.config.StreamsConfiguration config)
StreamsTask
setStreamConfig
in interface StreamsTask
config
- optional configuration informationpublic void addInputQueue(BlockingQueue<StreamsDatum> inputQueue)
StreamsTask
Queue
for this task.addInputQueue
in interface StreamsTask
addInputQueue
in class BaseStreamsTask
public boolean isRunning()
StreamsTask
isRunning
in interface StreamsTask
public void stopTask()
StreamsTask
stopTask
in interface StreamsTask
public void addOutputQueue(BlockingQueue<StreamsDatum> outputQueue)
StreamsTask
Queue
for this task.addOutputQueue
in interface StreamsTask
addOutputQueue
in class BaseStreamsTask
public List<BlockingQueue<StreamsDatum>> getInputQueues()
StreamsTask
getInputQueues
in interface StreamsTask
getInputQueues
in class BaseStreamsTask
public void setStreamsTaskCounter(StreamsTaskCounter counter)
setStreamsTaskCounter
in interface StreamsTask
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.