分区契约在返回之前构建所有分区执行上下文。使用非常大的数据集,您将花费大量的时间等待分区器返回。
@Override
public Map<String, ExecutionContext> partition(int gridSize) {
Map<String, ExecutionContext> out = new LinkedHashMap<String, ExecutionContext>();
... stuff to create execution contexts ...
return out;
}是否有一个内置在spring批处理中的模型,允许分区在分区处理程序标识后立即发送到从进程,而不是等待所有分区上下文的返回?
我正在寻找的结果是:即使返回我的分区程序需要15分钟,远程步骤一生成就会排队,而不是在开始工作之前等待所有分区上下文生成15分钟。
发布于 2019-05-13 13:15:16
是否有一个内置在spring批处理中的模型,允许分区在分区处理程序标识后立即发送到从进程,而不是等待所有分区上下文的返回?
这是不可能的分区处理程序应该在工作人员开始处理分区之前完成所有的分区过程。
https://stackoverflow.com/questions/56094944
复制相似问题