Class DefaultExecutorRepresenter

  • All Implemented Interfaces:
    ExecutorRepresenter

    @NotThreadSafe
    public final class DefaultExecutorRepresenter
    extends Object
    implements ExecutorRepresenter
    (WARNING) This class is not thread-safe, and thus should only be accessed through ExecutorRegistry.

    Implements ExecutorRepresenter that communicates with Executors running on traditional resources (e.g., virtual machines or cluster resources).

    • Constructor Detail

      • DefaultExecutorRepresenter

        public DefaultExecutorRepresenter​(String executorId,
                                          ResourceSpecification resourceSpecification,
                                          MessageSender<ControlMessage.Message> messageSender,
                                          org.apache.reef.driver.context.ActiveContext activeContext,
                                          ExecutorService serializationExecutorService,
                                          String nodeName)
        Creates a reference to the specified executor.
        Parameters:
        executorId - the executor id
        resourceSpecification - specification for the executor
        messageSender - provides communication context for this executor
        activeContext - context on the corresponding REEF evaluator
        serializationExecutorService - provides threads for message serialization
        nodeName - physical name of the node where this executor resides