нужна ясность в реализации интерфейса GridTask <T,R>

Question

мне нужна ясность в осуществлении уменьшения() и карта() методы GridTask,

Как мы можем передать аргументы этих методов,

Map<? extends GridJob, GridNode> 
    map(List<GridNode> subgrid, T arg) throws GridException 

R reduce(List<GridJobResult> results) throws GridException 

В частности, мне нужно знать, как передавать/вызывать метод уменьшения, или если он вызывается неявно, то как и какие аргументы передаются ему.

Answer 1

Аргументы передаются из метода GridProjection.execute (...).

Каждый раз, когда GridJob завершается, его результат передается методу GridTask.result (...). Метод reduce() вызывается всякий раз, когда все результаты из GridJobs принимаются. Вы также можете принудить к сокращению раньше, возвращая метод политики REDUCE GridTask.result (...).