private String getPendingProcessorId(String containerId) {
    for (Map.Entry<String, SamzaResource> entry: state.pendingProcessors.entrySet()) {
      if (entry.getValue().getContainerId().equals(containerId)) {
        LOG.info("Container ID: {} matched pending Processor ID: {} on host: {}", containerId, entry.getKey(), entry.getValue().getHost());
        return entry.getKey();
      }
    }
    return null;
  }
Obtains the ID of the Samza processor pending launch on the provided resource (container).

ContainerProcessManager [INFO] Container ID: container_e66_1569376389369_0221_01_000049 matched pending Processor ID: 0 on host: ltx1-app0772.stg.linkedin.com

@param containerId last known id of the container deployed
@return the logical processorId of the processor (e.g., 0, 1, 2 ...)
samza-core/src/main/java/org/apache/samza/clustermanager/ContainerProcessManager.java