public Set<String> getActiveProcessorsList(AtomicReference<String> currentJMVersion) {
    Iterable<ProcessorEntity> tableList = getEntitiesWithPartition(currentJMVersion.get());
    Set<String> activeProcessorsList = new HashSet<>();
    for (ProcessorEntity entity: tableList) {
      if (System.currentTimeMillis() - entity.getTimestamp().getTime() <= (LIVENESS_DEBOUNCE_TIME_SEC * 1000)) {
        activeProcessorsList.add(entity.getRowKey());
      }
    }

    Iterable<ProcessorEntity> unassignedList = getEntitiesWithPartition(initialState);
    for (ProcessorEntity entity: unassignedList) {
      long temp = System.currentTimeMillis() - entity.getTimestamp().getTime();
      LOG.info("Time elapsed since last heartbeat: {}", temp);
      if (temp <= (LIVENESS_DEBOUNCE_TIME_SEC * 1000)) {
        activeProcessorsList.add(entity.getRowKey());
      }
    }
    LOG.info("Active processors list: {}", activeProcessorsList);
    return activeProcessorsList;
  }
Gets the list of all active processors that are heartbeating to the processor table.
@param currentJMVersion Current job model version that the processors in the application are operating on.
@return List of ids of currently active processors in the application, retrieved from the processor table.
samza-azure/src/main/java/org/apache/samza/util/TableUtils.java