Apache Ignite Quick Start Guide

Task Adapter

We implemented the map, reduce, and result methods of the ComputeTask interface; unless we need a special failover logic, we can reuse the result logic. The ComputeTaskAdapter class provides the default implementation of the result() method for reuse. In this section, we are going to re-implement our MapReduce job with the help of ComputeTaskAdapter.

The following are the steps:

1. Create a class, ClubExpenseTaskAdapter, which extends from ComputeTaskAdapter. As the result() method is already implemented in ComputeTaskAdapter, we'll just implement the map() and reduce(). The map method will be changed a little to use the subgrids, instead of the balancer:

      public class ClubExpenseTaskAdapter extends  ComputeTaskAdapter<String[], ...