public class StreamsProviderTask extends BaseStreamsTask implements DatumStatusCountable
streamConfig
Constructor and Description |
---|
StreamsProviderTask(StreamsProvider provider,
BigInteger sequence,
org.apache.streams.config.StreamsConfiguration streamConfig)
Constructor for a StreamsProvider to execute
org.apache.streams.core.StreamsProvider:readNew(BigInteger) |
StreamsProviderTask(StreamsProvider provider,
boolean perpetual,
org.apache.streams.config.StreamsConfiguration streamConfig)
Constructor for a StreamsProvider to execute
org.apache.streams.core.StreamsProvider:readCurrent() |
StreamsProviderTask(StreamsProvider provider,
org.joda.time.DateTime start,
org.joda.time.DateTime end,
org.apache.streams.config.StreamsConfiguration streamConfig)
Constructor for a StreamsProvider to execute
org.apache.streams.core.StreamsProvider:readRange(DateTime,DateTime) |
Modifier and Type | Method and Description |
---|---|
void |
addInputQueue(BlockingQueue<StreamsDatum> inputQueue)
Add an input
Queue for this task. |
void |
flushResults(StreamsResultSet resultSet) |
DatumStatusCounter |
getDatumStatusCounter() |
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 |
setSleepTime(long sleepTime) |
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 |
setTimeout(int timeout) |
void |
stopTask()
Informs the task to stop.
|
addOutputQueue, addToOutgoingQueue, cloneStreamsDatum, getInputQueues, getNextDatum, getOutputQueues, getStartedAt, getStreamIdentifier, setStartedAt
public StreamsProviderTask(StreamsProvider provider, boolean perpetual, org.apache.streams.config.StreamsConfiguration streamConfig)
org.apache.streams.core.StreamsProvider:readCurrent()
provider
- public StreamsProviderTask(StreamsProvider provider, BigInteger sequence, org.apache.streams.config.StreamsConfiguration streamConfig)
org.apache.streams.core.StreamsProvider:readNew(BigInteger)
provider
- sequence
- public StreamsProviderTask(StreamsProvider provider, org.joda.time.DateTime start, org.joda.time.DateTime end, org.apache.streams.config.StreamsConfiguration streamConfig)
org.apache.streams.core.StreamsProvider:readRange(DateTime,DateTime)
provider
- start
- end
- public DatumStatusCounter getDatumStatusCounter()
getDatumStatusCounter
in interface DatumStatusCountable
public void setTimeout(int timeout)
public void setSleepTime(long sleepTime)
public boolean isWaiting()
StreamsTask
isWaiting
in interface StreamsTask
isWaiting
in class BaseStreamsTask
public void stopTask()
StreamsTask
stopTask
in interface StreamsTask
public void addInputQueue(BlockingQueue<StreamsDatum> inputQueue)
StreamsTask
Queue
for this task.addInputQueue
in interface StreamsTask
addInputQueue
in class BaseStreamsTask
public void setStreamConfig(org.apache.streams.config.StreamsConfiguration config)
StreamsTask
setStreamConfig
in interface StreamsTask
config
- optional configuration informationpublic boolean isRunning()
StreamsTask
isRunning
in interface StreamsTask
public void flushResults(StreamsResultSet resultSet)
public void setStreamsTaskCounter(StreamsTaskCounter counter)
setStreamsTaskCounter
in interface StreamsTask
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.