class AssignedStreamsTasks extends AssignedTasks<StreamTask> implements RestoringTasks {

    Set<TaskId> suspendedTaskIds() {
        return suspended.keySet();
    }

      AssignedStreamsTasks(final LogContext logContext);

}