org.apache.reef.runtime.common.driver

Class EvaluatorRequestorImpl

java.lang.Object

org.apache.reef.runtime.common.driver.EvaluatorRequestorImpl

All Implemented Interfaces:

EvaluatorRequestor

public final class EvaluatorRequestorImpl
extends Object
implements EvaluatorRequestor

Implementation of the EvaluatorRequestor that translates the request and hands it down to the underlying RM.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	EvaluatorRequestorImpl.Builder EvaluatorRequest.Builder extended with a new submit method.

Constructor Summary

Constructors

Constructor and Description
EvaluatorRequestorImpl(ResourceCatalog resourceCatalog, ResourceRequestHandler resourceRequestHandler, LoggingScopeFactory loggingScopeFactory)

Method Summary

Methods

Modifier and Type	Method and Description
EvaluatorRequestorImpl.Builder	newRequest() Get a new builder.
void	submit(EvaluatorRequest req) Submit the request for new evaluator.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EvaluatorRequestorImpl

@Inject
public EvaluatorRequestorImpl(ResourceCatalog resourceCatalog,
                             ResourceRequestHandler resourceRequestHandler,
                             LoggingScopeFactory loggingScopeFactory)

Parameters:

resourceCatalog -

resourceRequestHandler -

loggingScopeFactory -

Method Detail

submit

public void submit(EvaluatorRequest req)

Description copied from interface: EvaluatorRequestor

Submit the request for new evaluator. The response will surface in the AllocatedEvaluator message handler.

Specified by:

submit in interface EvaluatorRequestor

newRequest

public EvaluatorRequestorImpl.Builder newRequest()

Get a new builder.

Specified by:

newRequest in interface EvaluatorRequestor

Returns:

a new EvaluatorRequest Builder extended with the new submit method.