public void updateHeartbeat(String jmVersion, String pid) {
    try {
      TableOperation retrieveEntity = TableOperation.retrieve(jmVersion, pid, ProcessorEntity.class);
      ProcessorEntity entity = table.execute(retrieveEntity).getResultAsType();
      entity.updateLiveness();
      TableOperation update = TableOperation.replace(entity);
      table.execute(update);
    } catch (StorageException e) {
      LOG.error("Azure storage exception while updating heartbeat for job model version: " + jmVersion + "and pid: " + pid, e);
    }
  }
Updates the liveness value of a particular processor with a randomly generated integer, which in turn updates the last modified since timestamp of the row.
@param jmVersion Job model version of the processor row to be updated.
@param pid Unique processor ID of the processor row to be updated.
samza-azure/src/main/java/org/apache/samza/util/TableUtils.java