我正在尝试实现一个多资源分区器。现在这是我正在使用的代码:
@Bean
@StepScope
public MultiResourcePartitioner multiResourcePartitioner(@Value("#{jobParameters['inputFiles']}")Resource[] resources){
MultiResourcePartitioner partitioner = new MultiResourcePartitioner();
partitioner.setKeyName("file");
partitioner.setResources(resources);
return partitioner;
}
这应该向每个步骤发送要读取和处理的文件的名称。为了传递参数,我正在执行以下操作:
Map<String, JobParameter> parameters = new HashMap<>();
JobParameter parameter = new JobParameter(new Date());
parameters.put("currentTime", parameter);
parameters.put("inputFiles", new JobParameter("1.csv;2.csv"));
但是当我调试 MultiResourcePartitioner 类时,我看到的是:
有谁知道获取资源数组作为 MultiResourcePartitioner 类的输入的语法是什么?
书中所说的内容如下:“我们需要在此分区器上设置的另一个值是资源数组。一旦完成,我们就可以返回实例”