public void writeExecutionEnvironmentContainerIdMapping(String processorId, String executionEnvContainerId) {
    Preconditions.checkNotNull(processorId, "Container's logical processor id can not be null.");
    Preconditions.checkNotNull(executionEnvContainerId, "Container's physical execution environment container id can not be null.");
    LOG.info("Processor {} has executionEnvContainerId as {}", processorId, executionEnvContainerId);
    metadataStore.put(processorId, valueSerde.toBytes(executionEnvContainerId));
    metadataStore.flush();
  }
Builds the ExecutionContainerIdManager based upon the provided {@link MetadataStore} that is instantiated.
Uses the {@link CoordinatorStreamValueSerde} to serialize messages before reading/writing into metadata store.
@param metadataStore an instance of {@link MetadataStore} to read/write the processor container id mapping.
samza-core/src/main/java/org/apache/samza/container/ExecutionContainerIdManager.java