Есть ли «правильный» способ, чтобы весенний пакетный разделитель запускал дочерние шаги при создании разделов?

Question

Контракт раздела создает все контексты выполнения раздела перед возвратом.С очень большими наборами данных вы тратите много времени на ожидание возврата разделителя.

@Override
public Map<String, ExecutionContext> partition(int gridSize) {
    Map<String, ExecutionContext> out = new LinkedHashMap<String, ExecutionContext>();
    ... stuff to create execution contexts ...
    return out;
}

Существует ли модель, встроенная в подпружиненную партию, которая позволяет разделять разделы на подчиненные процессы каккак только они будут определены разделителем, вместо того, чтобы ждать возврата всех контекстов раздела?

Результат, который я ищу: даже если моему разделителю требуется 15 минут, чтобы вернуться, удаленные шагибудет поставлен в очередь, как только они будут сгенерированы, вместо ожидания 15 минут для генерации всех контекстов раздела перед началом работы

Answer 1

Существует ли модель, встроенная в пакетную пружину, которая позволяет разделам запускаться в подчиненные процессы, как только они будут определены разделителем, вместо ожидания возврата всех контекстов раздела?

Это невозможно. Секционер должен завершить весь процесс секционирования, прежде чем работники смогут начать работать с секциями.