hazelcast-jet - 单个顶点中的合作和非合作“处理器”

Question

s可以Processor在单个顶点上既合作又不合作？因为协同性是 的属性Processor，并且ProcessorSupplier不需要返回Processor相同类型的 s。或者是吗？

这个用例很奇怪并且可以避免，但只是想知道......

Answer 1

鉴于此代码ExecutionService：

Map<Boolean, List<Tasklet>> byCooperation = 
     tasklets.stream().collect(partitioningBy(Tasklet::isCooperative));

并给出ProcessorTasklet::isCooperative：

return processor.isCooperative();

每个单独的处理器实例将根据其协作性进行处理。执行服务实际上并不关心哪些小任务属于同一个顶点，而是根据其合作声明来处理每个小任务。

简而言之：是的，您可以为同一个顶点混合使用协作/非协作处理器。