public void updateTaskData() {
        // Only update the local task list of topologyContext here. Because
        // other
        // relative parts in context shall be updated while the updating of
        // WorkerData (Task2Component and Component2Task map)
        List<Integer> localTasks = JStormUtils.mk_list(workerData.getTaskIds());
        topologyContext.setThisWorkerTasks(localTasks);
        userContext.setThisWorkerTasks(localTasks);

        // Update the TaskSendTargets
        updateSendTargets();
    }
public void updateTaskData ( ) { List < Integer > localTasks = JStormUtils . mk_list ( workerData . getTaskIds ( ) ) ; topologyContext . setThisWorkerTasks ( localTasks ) ; userContext . setThisWorkerTasks ( localTasks ) ; updateSendTargets ( ) ; }
Update task data which can be changed dynamically e.g. when scale-out of a task parallelism