Apache Ignite Quick Start Guide

Task Split

The ComputeTaskSplitAdapter offers more flexibility over the ComputeTaskAdapter to reduce boilerplate code. This class defines a simplified adapter for ComputeTask where it implements the job mapping to available cluster nodes. We need to consider splitting tasks and returning a list of ComputeJobs. This section implements the ComputeTaskSplitAdapter:

1. Create a class, ClubExpenseTaskSplitAdapter, and extend it from ComputeTaskSplitAdapter. You need to implement the Collection<? extends ComputeJob> split(int gridSize, T arg) and reduce(List<ComputeJobResult> results) methods. The reduce logic remains the same, the split logic loops through the list of clubs and for each club creates a ClubExpenseCalculatorJob instance, adds it to ...