Uses of Class
org.apache.reef.util.Optional

Packages that use Optional

Package	Description
org.apache.reef.client	Client APIs for REEF.
org.apache.reef.common	REEF Common.
org.apache.reef.driver.context	Driver Contexts and their configurations.
org.apache.reef.driver.evaluator	Evaluator-related utilities.
org.apache.reef.driver.task	Tasks and their configurations.
org.apache.reef.evaluator.context	Evaluator Contexts.
org.apache.reef.examples.suspend	Suspend/resume demo.
org.apache.reef.javabridge	The Java-side of the CLR/Java bridge.
org.apache.reef.runtime.common.client.api	Client-Side Event Handlers to be implemented by a specific resourcemanager.
org.apache.reef.runtime.common.driver	Implementation of the Driver-side REEF APIs.
org.apache.reef.runtime.common.driver.api	Driver-Side Event Handlers to be implemented by a specific resource manager.
org.apache.reef.runtime.common.driver.context	Implementations of Driver-Side representations of Contexts running on an Evaluator.
org.apache.reef.runtime.common.driver.evaluator	Driver-Side representations of Evaluators.
org.apache.reef.runtime.common.driver.resourcemanager	Classes that interface with the resourcemanager (Local, YARN, ...) in the Driver.
org.apache.reef.runtime.common.evaluator.context	Context implementation of the Evaluator resourcemanager.
org.apache.reef.runtime.common.evaluator.context.defaults	Default implementations for the optional context interfaces.
org.apache.reef.runtime.common.utils	Runtime utilities used by various REEF modules.
org.apache.reef.task	Tasks.
org.apache.reef.task.events	Task-related events.
org.apache.reef.tests.fail.driver	Tests for Driver-side failures.
org.apache.reef.tests.messaging.task	Test message exchange between the Task and the Driver.
org.apache.reef.tests.watcher	Test reef.io.watcher.
org.apache.reef.util	Utilities for using REEF on Hadoop.
org.apache.reef.vortex.api	Vortex user api for running jobs on Vortex.
org.apache.reef.vortex.driver	Vortex Code that runs as part of REEF Driver.
org.apache.reef.vortex.evaluator	Vortex Code that runs as part of REEF Evaluator.

Uses of Optional in org.apache.reef.client

Methods in org.apache.reef.client that return Optional

Modifier and Type	Method and Description
Optional<Throwable>	LauncherStatus.getError()

Methods in org.apache.reef.client with parameters of type Optional

Modifier and Type	Method and Description
static LauncherStatus	LauncherStatus.failed(Optional<Throwable> ex)

Constructors in org.apache.reef.client with parameters of type Optional

Constructor and Description
FailedJob(String id, String message, Optional<String> description, Optional<Throwable> cause, Optional<byte[]> data)
FailedJob(String id, String message, Optional<String> description, Optional<Throwable> cause, Optional<byte[]> data)
FailedJob(String id, String message, Optional<String> description, Optional<Throwable> cause, Optional<byte[]> data)

Uses of Optional in org.apache.reef.common

Methods in org.apache.reef.common that return Optional

Modifier and Type	Method and Description
Optional<byte[]>	Failure.getData()
Optional<byte[]>	AbstractFailure.getData()
Optional<String>	Failure.getDescription()
Optional<String>	AbstractFailure.getDescription()
Optional<Throwable>	Failure.getReason()
Optional<Throwable>	AbstractFailure.getReason()

Uses of Optional in org.apache.reef.driver.context

Methods in org.apache.reef.driver.context that return Optional

Modifier and Type	Method and Description
Optional<ActiveContext>	FailedContext.getParentContext()
Optional<String>	ContextBase.getParentId()

Uses of Optional in org.apache.reef.driver.evaluator

Methods in org.apache.reef.driver.evaluator that return Optional

Modifier and Type	Method and Description
Optional<FailedTask>	FailedEvaluator.getFailedTask()

Uses of Optional in org.apache.reef.driver.task

Methods in org.apache.reef.driver.task that return Optional

Modifier and Type	Method and Description
Optional<ActiveContext>	FailedTask.getActiveContext() Access the context the task ran (and crashed) on, if it could be recovered.

Constructors in org.apache.reef.driver.task with parameters of type Optional

Constructor and Description
FailedTask(String id, String message, Optional<String> description, Optional<Throwable> cause, Optional<byte[]> data, Optional<ActiveContext> context)
FailedTask(String id, String message, Optional<String> description, Optional<Throwable> cause, Optional<byte[]> data, Optional<ActiveContext> context)
FailedTask(String id, String message, Optional<String> description, Optional<Throwable> cause, Optional<byte[]> data, Optional<ActiveContext> context)
FailedTask(String id, String message, Optional<String> description, Optional<Throwable> cause, Optional<byte[]> data, Optional<ActiveContext> context)

Uses of Optional in org.apache.reef.evaluator.context

Methods in org.apache.reef.evaluator.context that return Optional

Modifier and Type	Method and Description
Optional<ContextMessage>	ContextMessageSource.getMessage()

Uses of Optional in org.apache.reef.examples.suspend

Methods in org.apache.reef.examples.suspend that return Optional

Modifier and Type	Method and Description
Optional<TaskMessage>	SuspendTestTask.getMessage() Update driver on current state of the task.

Uses of Optional in org.apache.reef.javabridge

Methods in org.apache.reef.javabridge that return Optional

Modifier and Type	Method and Description
Optional<String>	FailedContextBridge.getParentId()
Optional<String>	ClosedContextBridge.getParentId()

Uses of Optional in org.apache.reef.runtime.common.client.api

Methods in org.apache.reef.runtime.common.client.api that return Optional

Modifier and Type	Method and Description
Optional<Integer>	JobSubmissionEventImpl.getDriverMemory()
Optional<Integer>	JobSubmissionEvent.getDriverMemory()
Optional<Integer>	JobSubmissionEventImpl.getMaxApplicationSubmissions()
Optional<Integer>	JobSubmissionEvent.getMaxApplicationSubmissions() Returns the number of time that the driver should be started by the resource manager if it fails unexpectedly.
Optional<Boolean>	JobSubmissionEventImpl.getPreserveEvaluators()
Optional<Boolean>	JobSubmissionEvent.getPreserveEvaluators()
Optional<Integer>	JobSubmissionEventImpl.getPriority()
Optional<Integer>	JobSubmissionEvent.getPriority()

Uses of Optional in org.apache.reef.runtime.common.driver

Methods in org.apache.reef.runtime.common.driver with parameters of type Optional

Modifier and Type	Method and Description
void	DriverStatusManager.sendJobEndingMessageToClient(Optional<Throwable> exception) Sends the final message to the Driver.

Uses of Optional in org.apache.reef.runtime.common.driver.api

Methods in org.apache.reef.runtime.common.driver.api that return Optional

Modifier and Type	Method and Description
Optional<Integer>	ResourceRequestEventImpl.getMemorySize()
Optional<Integer>	ResourceRequestEvent.getMemorySize()
Optional<Integer>	ResourceRequestEventImpl.getPriority()
Optional<Integer>	ResourceRequestEvent.getPriority()
Optional<Boolean>	ResourceRequestEventImpl.getRelaxLocality()
Optional<Boolean>	ResourceRequestEvent.getRelaxLocality()
Optional<Integer>	ResourceRequestEventImpl.getVirtualCores()
Optional<Integer>	ResourceRequestEvent.getVirtualCores()

Uses of Optional in org.apache.reef.runtime.common.driver.context

Methods in org.apache.reef.runtime.common.driver.context that return Optional

Modifier and Type	Method and Description
Optional<ActiveContext>	FailedContextImpl.getParentContext()
Optional<String>	FailedContextImpl.getParentId()
Optional<String>	EvaluatorContext.getParentId()
Optional<String>	ClosedContextImpl.getParentId()

Constructors in org.apache.reef.runtime.common.driver.context with parameters of type Optional

Constructor and Description
EvaluatorContext(String contextIdentifier, String evaluatorIdentifier, EvaluatorDescriptor evaluatorDescriptor, Optional<String> parentID, ConfigurationSerializer configurationSerializer, ContextControlHandler contextControlHandler, EvaluatorMessageDispatcher messageDispatcher, ExceptionCodec exceptionCodec, ContextRepresenters contextRepresenters)
FailedContextImpl(String id, String message, Optional<String> description, Optional<Throwable> cause, Optional<byte[]> data, Optional<ActiveContext> parentContext, EvaluatorDescriptor evaluatorDescriptor, String evaluatorID)
FailedContextImpl(String id, String message, Optional<String> description, Optional<Throwable> cause, Optional<byte[]> data, Optional<ActiveContext> parentContext, EvaluatorDescriptor evaluatorDescriptor, String evaluatorID)
FailedContextImpl(String id, String message, Optional<String> description, Optional<Throwable> cause, Optional<byte[]> data, Optional<ActiveContext> parentContext, EvaluatorDescriptor evaluatorDescriptor, String evaluatorID)
FailedContextImpl(String id, String message, Optional<String> description, Optional<Throwable> cause, Optional<byte[]> data, Optional<ActiveContext> parentContext, EvaluatorDescriptor evaluatorDescriptor, String evaluatorID)

Uses of Optional in org.apache.reef.runtime.common.driver.evaluator

Methods in org.apache.reef.runtime.common.driver.evaluator that return Optional

Modifier and Type	Method and Description
Optional<EvaluatorManager>	Evaluators.get(String evaluatorId)

Uses of Optional in org.apache.reef.runtime.common.driver.resourcemanager

Methods in org.apache.reef.runtime.common.driver.resourcemanager that return Optional

Modifier and Type	Method and Description
Optional<String>	ResourceStatusEventImpl.getDiagnostics()
Optional<String>	ResourceStatusEvent.getDiagnostics()
Optional<ReefServiceProtos.RuntimeErrorProto>	RuntimeStatusEventImpl.getError()
Optional<ReefServiceProtos.RuntimeErrorProto>	RuntimeStatusEvent.getError()
Optional<Integer>	ResourceStatusEventImpl.getExitCode()
Optional<Integer>	ResourceStatusEvent.getExitCode()
Optional<Integer>	RuntimeStatusEventImpl.getOutstandingContainerRequests()
Optional<Integer>	RuntimeStatusEvent.getOutstandingContainerRequests()
Optional<String>	ResourceEventImpl.getRackName()
Optional<String>	ResourceEvent.getRackName()
Optional<String>	NodeDescriptorEventImpl.getRackName()
Optional<String>	NodeDescriptorEvent.getRackName()
Optional<Integer>	ResourceEventImpl.getVirtualCores()
Optional<Integer>	ResourceEvent.getVirtualCores()

Uses of Optional in org.apache.reef.runtime.common.evaluator.context

Methods in org.apache.reef.runtime.common.evaluator.context that return Optional

Modifier and Type	Method and Description
Optional<String>	ContextClientCodeException.getParentID()
Optional<ReefServiceProtos.TaskStatusProto>	ContextManager.getTaskStatus()

Constructors in org.apache.reef.runtime.common.evaluator.context with parameters of type Optional

Constructor and Description
ContextClientCodeException(String contextID, Optional<String> parentID, String message, Throwable cause)

Uses of Optional in org.apache.reef.runtime.common.evaluator.context.defaults

Methods in org.apache.reef.runtime.common.evaluator.context.defaults that return Optional

Modifier and Type	Method and Description
Optional<ContextMessage>	DefaultContextMessageSource.getMessage()

Uses of Optional in org.apache.reef.runtime.common.utils

Methods in org.apache.reef.runtime.common.utils that return Optional

Modifier and Type	Method and Description
Optional<Throwable>	ExceptionCodec.fromBytes(byte[] bytes) Deserializes a Throwable that has been serialized using toBytes().
Optional<Throwable>	ExceptionCodec.fromBytes(Optional<byte[]> bytes)

Methods in org.apache.reef.runtime.common.utils with parameters of type Optional

Modifier and Type	Method and Description
Optional<Throwable>	ExceptionCodec.fromBytes(Optional<byte[]> bytes)

Uses of Optional in org.apache.reef.task

Methods in org.apache.reef.task that return Optional

Modifier and Type	Method and Description
Optional<TaskMessage>	TaskMessageSource.getMessage()

Uses of Optional in org.apache.reef.task.events

Methods in org.apache.reef.task.events that return Optional

Modifier and Type	Method and Description
Optional<byte[]>	SuspendEvent.get()
Optional<byte[]>	DriverMessage.get()
Optional<byte[]>	CloseEvent.get()

Uses of Optional in org.apache.reef.tests.fail.driver

Methods in org.apache.reef.tests.fail.driver that return Optional

Modifier and Type	Method and Description
Optional<TaskMessage>	NoopTask.getMessage()

Uses of Optional in org.apache.reef.tests.messaging.task

Methods in org.apache.reef.tests.messaging.task that return Optional

Modifier and Type	Method and Description
Optional<TaskMessage>	TaskMessagingTask.getMessage()

Uses of Optional in org.apache.reef.tests.watcher

Methods in org.apache.reef.tests.watcher that return Optional

Modifier and Type	Method and Description
Optional<TaskMessage>	WatcherTestTask.getMessage()

Uses of Optional in org.apache.reef.util

Methods in org.apache.reef.util that return Optional

Modifier and Type	Method and Description
static <T> Optional<T>	Optional.empty()
static <T> Optional<T>	Optional.of(T value)
static <T> Optional<T>	Optional.ofNullable(T value)

Uses of Optional in org.apache.reef.vortex.api

Methods in org.apache.reef.vortex.api that return Optional

Modifier and Type	Method and Description
Optional<Integer>	VortexAggregatePolicy.getCount()
Optional<Exception>	AggregateResultSynchronous.getException() If an aggregation fails, VortexAggregateException will be thrown, otherwise the Exception that caused the Tasklet to fail will be thrown directly.
Optional<Exception>	AggregateResult.getException() If an aggregation fails, VortexAggregateException will be thrown, otherwise the Exception that caused the Tasklet to fail will be thrown directly.

Uses of Optional in org.apache.reef.vortex.driver

Methods in org.apache.reef.vortex.driver with parameters of type Optional

Modifier and Type	Method and Description
<TInput,TOutput> VortexFuture<TOutput>	VortexMaster.enqueueTasklet(VortexFunction<TInput,TOutput> vortexFunction, TInput input, Optional<FutureCallback<TOutput>> callback) Submit a new Tasklet to be run sometime in the future, with an optional callback function on the result.
<TInput,TOutput> VortexAggregateFuture<TInput,TOutput>	VortexMaster.enqueueTasklets(VortexAggregateFunction<TOutput> aggregateFunction, VortexFunction<TInput,TOutput> vortexFunction, VortexAggregatePolicy policy, List<TInput> inputs, Optional<FutureCallback<AggregateResult<TInput,TOutput>>> callback) Submits aggregate-able Tasklets to be run sometime in the future, with an optional callback function on the aggregation progress.

Uses of Optional in org.apache.reef.vortex.evaluator

Methods in org.apache.reef.vortex.evaluator that return Optional

Modifier and Type	Method and Description
Optional<TaskMessage>	VortexWorker.getMessage()