@Deprecated public class StreamsMergeTask extends BaseStreamsTask
streamConfig
Constructor and Description |
---|
StreamsMergeTask()
Deprecated.
|
StreamsMergeTask(org.apache.streams.config.StreamsConfiguration streamConfig)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
isRunning()
Deprecated.
Returns true when the task has not completed.
|
void |
run()
Deprecated.
|
void |
setStreamConfig(org.apache.streams.config.StreamsConfiguration config)
Deprecated.
Set the configuration object that will shared and passed to all instances of StreamsTask.
|
void |
setStreamsTaskCounter(StreamsTaskCounter counter)
Deprecated.
|
void |
stopTask()
Deprecated.
Informs the task to stop.
|
addInputQueue, addOutputQueue, addToOutgoingQueue, cloneStreamsDatum, getInputQueues, getNextDatum, getOutputQueues, getStartedAt, getStreamIdentifier, isWaiting, setStartedAt
public StreamsMergeTask()
public StreamsMergeTask(org.apache.streams.config.StreamsConfiguration streamConfig)
public void stopTask()
StreamsTask
public void setStreamConfig(org.apache.streams.config.StreamsConfiguration config)
StreamsTask
config
- optional configuration informationpublic boolean isRunning()
StreamsTask
public void run()
public void setStreamsTaskCounter(StreamsTaskCounter counter)
Copyright © 2017 The Apache Software Foundation. All rights reserved.