code: @NotNull
      public static <Key extends Serializable, ValueIn, MapOutput extends Serializable, ReducerResult extends Serializable> ReducerResult compute(@NotNull AnalyticsContext analyticsContext,
                                                                                                                                                  @NotNull MapReduceTask<Key, ValueIn, MapOutput, ReducerResult> mapReduceTask) {
  
          Timer timer = MetricsFactory.getMetrics().getTimer("analytics.compute");
  
          ClusterGroup clusterGroup = analyticsContext.getIgnite()
                                                      .cluster()
                                                      .forServers();
  
  
          ReducerResult execute = analyticsContext.getIgnite()
                                                  .compute(clusterGroup)
                                                  .execute(mapReduceTask, null);
  
          timer.stop();
  
          LOGGER.debug("Complete compute operation in {}", timer);
  
          return execute;
      }
docs: Execute compute operation with MR paradigm
  
  @param analyticsContext Analytics context instance for retrieving distributed executor service and cassandra factory
  @param <ValueIn>        Entity class type
  
  @return Reduce result