class AssignedStreamsTasks extends AssignedTasks<StreamTask> implements RestoringTasks {

    @Override
    public void shutdown(final boolean clean) {
        final String shutdownType = clean ? "Clean" : "Unclean";
        log.debug("{} shutdown of all active tasks" + "\n" +
                      "non-initialized stream tasks to close: {}" + "\n" +
                      "restoring tasks to close: {}" + "\n" +
                      "running stream tasks to close: {}" + "\n" +
                      "suspended stream tasks to close: {}",
            shutdownType, created.keySet(), restoring.keySet(), running.keySet(), suspended.keySet());
        super.shutdown(clean);
    }

      AssignedStreamsTasks(final LogContext logContext);

}