public void deleteProcessorEntity(String jmVersion, String pid, boolean force) {
    try {
      TableOperation retrieveEntity = TableOperation.retrieve(jmVersion, pid, ProcessorEntity.class);
      ProcessorEntity entity = table.execute(retrieveEntity).getResultAsType();
      if (force) {
        entity.setEtag("*");
      }
      TableOperation remove = TableOperation.delete(entity);
      table.execute(remove);
    } catch (StorageException e) {
      LOG.error("Azure storage exception while deleting processor entity with job model version: " + jmVersion + "and pid: " + pid, e);
      throw new AzureException(e);
    }
  }
Deletes a specified row in the processor table.

Note: Table service uses optimistic locking by default. Hence, if there is an update after retrieving the entity,
then the delete operation will fail.

@param jmVersion Job model version of the processor row to be deleted.
@param pid Unique processor ID of the processor row to be deleted.
@param force True, to disable optimistic locking on the table. False, otherwise. Setting to false may result in
             AzureException when there is concurrent access to the table.

@throws AzureException If an Azure storage service error occurred.
samza-azure/src/main/java/org/apache/samza/util/TableUtils.java