public void addProcessorEntity(String jmVersion, String pid, boolean isLeader) {
    ProcessorEntity entity = new ProcessorEntity(jmVersion, pid);
    entity.setIsLeader(isLeader);
    entity.updateLiveness();
    TableOperation add = TableOperation.insert(entity);
    try {
      table.execute(add);
    } catch (StorageException e) {
      LOG.error("Azure storage exception while adding processor entity with job model version: " + jmVersion + "and pid: " + pid, e);
      throw new AzureException(e);
    }
  }
Add a row which denotes an active processor to the processor table.
@param jmVersion Job model version that the processor is operating on.
@param pid Unique processor ID.
@param isLeader Denotes whether the processor is a leader or not.
@throws AzureException If an Azure storage service error occurred.
samza-azure/src/main/java/org/apache/samza/util/TableUtils.java