org.apache.reef.driver.context

Interface ActiveContext

All Superinterfaces:

AutoCloseable, ContextBase, ContextSubmittable, Identifiable, TaskSubmittable

All Known Implementing Classes:

EvaluatorContext

public interface ActiveContext
extends Identifiable, AutoCloseable, ContextBase, TaskSubmittable, ContextSubmittable

Represents an active context on an Evaluator.

A context consists of two configurations:

1. ContextConfiguration: Its visibility is limited to the context itself and tasks spawned from it.
2. ServiceConfiguration: This is "inherited" by child context spawned.

Contexts have identifiers. A context is instantiated on a single Evaluator. Contexts are either created on an AllocatedEvaluator (for what is called the "root Context") or by forming sub-Contexts.

Contexts form a stack. Only the topmost context is active. Child Contexts or Tasks can be submitted to the active Context. Contexts can be closed, in which case their parent becomes active. In the case of the root context, closing is equivalent to releasing the Evaluator. A child context "sees" all Configuration in its parent Contexts.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	sendMessage(byte[] message) Send the active context the message, which will be delivered to all registered ContextMessageHandler, for this context.
void	submitContext(Configuration contextConfiguration) Submit a Context.
void	submitContextAndService(Configuration contextConfiguration, Configuration serviceConfiguration) Submit a Context and a Service Configuration.
void	submitTask(Configuration taskConf) Submits a Task (encoded in the Configuration) for execution.

Methods inherited from interface org.apache.reef.driver.context.ContextBase

getEvaluatorDescriptor, getEvaluatorId, getId, getParentId

Method Detail

close

void close()

Specified by:

close in interface AutoCloseable

submitTask

void submitTask(Configuration taskConf)

Description copied from interface: TaskSubmittable

Submits a Task (encoded in the Configuration) for execution.

Specified by:

submitTask in interface TaskSubmittable

Parameters:

taskConf - the Configuration. See TaskConfiguration for details

submitContext

void submitContext(Configuration contextConfiguration)

Description copied from interface: ContextSubmittable

Submit a Context.

Specified by:

submitContext in interface ContextSubmittable

Parameters:

contextConfiguration - the Configuration of the EvaluatorContext. See ContextConfiguration for details.

submitContextAndService

void submitContextAndService(Configuration contextConfiguration,
                           Configuration serviceConfiguration)

Description copied from interface: ContextSubmittable

Submit a Context and a Service Configuration.

Specified by:

submitContextAndService in interface ContextSubmittable

Parameters:

contextConfiguration - the Configuration of the EvaluatorContext. See ContextConfiguration for details.

serviceConfiguration - the Configuration for the Services. See ServiceConfiguration for details.

sendMessage

void sendMessage(byte[] message)

Send the active context the message, which will be delivered to all registered ContextMessageHandler, for this context.

Parameters:

message - The message to be sent.