@Deprecated public abstract class TSetStreamingWorker extends TaskWorker implements java.io.Serializable
StreamingTSetEnvironment
instead!computeEnvironment, config, persistentVolume, taskExecutor, volatileVolume, workerController, workerEnvironment, workerId
Constructor and Description |
---|
TSetStreamingWorker()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
execute()
Deprecated.
A user needs to implement this method to create the task graph and execute it
|
abstract void |
execute(TwisterStreamingContext tc)
Deprecated.
|
execute
public void execute()
TaskWorker
execute
in class TaskWorker
public abstract void execute(TwisterStreamingContext tc)