docs: private void replayEventsOverResultSet(QueryResult queryResult) throws Exception {
          Map<Integer, Future<Object>> future = readAccumulators();
          for (Map.Entry<Integer, Future<Object>> entry : future.entrySet()) {
              int partitionId = entry.getKey();
              Object eventsInOneAcc = entry.getValue().get();
              if (eventsInOneAcc == null) {
                  continue;
              }
              eventsInOneAcc = mapServiceContext.toObject(eventsInOneAcc);
              List<QueryCacheEventData> eventDataList = (List<QueryCacheEventData>) eventsInOneAcc;
              for (QueryCacheEventData eventData : eventDataList) {
                  if (eventData.getDataKey() == null) {
                      // this means a map-wide event like clear-all or evict-all
                      // is inside the accumulator buffers
                      removePartitionResults(queryResult, partitionId);
                  } else {
                      add(queryResult, newQueryResultRow(eventData));
                  }
              }
          }
      }