Uses of Interface
org.apache.reef.driver.evaluator.FailedEvaluator

Packages that use FailedEvaluator

Package	Description
org.apache.reef.client	Client APIs for REEF.
org.apache.reef.driver.restart	This package provides restart event service handlers.
org.apache.reef.io.data.loading.api	Data Loading Service API.
org.apache.reef.io.network.group.api.driver	Elastic Group Communications Driver-side API Interfaces.
org.apache.reef.io.network.group.impl.driver	This package contains the implementation of the driver side of the Group Communication Service using the tree/flat topology.
org.apache.reef.io.watcher	Watcher subscribes events and writes them to the destination using a certain EventStream.
org.apache.reef.io.watcher.util	Utility classes for Watcher.
org.apache.reef.javabridge	The Java-side of the CLR/Java bridge.
org.apache.reef.javabridge.generic	Generic java bridge driver/client.
org.apache.reef.runtime.common.driver.defaults	Default implementations for the optional driver-side event handlers.
org.apache.reef.runtime.common.driver.evaluator	Driver-Side representations of Evaluators.
org.apache.reef.tests.watcher	Test reef.io.watcher.

Uses of FailedEvaluator in org.apache.reef.client

Fields in org.apache.reef.client with type parameters of type FailedEvaluator

Modifier and Type	Field and Description
static OptionalImpl<EventHandler<FailedEvaluator>>	DriverRestartConfiguration.ON_DRIVER_RESTART_EVALUATOR_FAILED Event handler for the event of driver restart completion, default to logging if not bound.
static OptionalImpl<EventHandler<FailedEvaluator>>	DriverServiceConfiguration.ON_EVALUATOR_FAILED Event handler for failed evaluators.
static OptionalImpl<EventHandler<FailedEvaluator>>	DriverConfiguration.ON_EVALUATOR_FAILED Event handler for failed evaluators.

Uses of FailedEvaluator in org.apache.reef.driver.restart

Methods in org.apache.reef.driver.restart with parameters of type FailedEvaluator

Modifier and Type	Method and Description
void	EvaluatorPreservingEvaluatorFailedHandler.onNext(FailedEvaluator value) Removes the completed evaluator from the list of evaluators to recover once it is failed.

Uses of FailedEvaluator in org.apache.reef.io.data.loading.api

Methods in org.apache.reef.io.data.loading.api with parameters of type FailedEvaluator

Modifier and Type	Method and Description
void	DataLoader.EvaluatorFailedHandler.onNext(FailedEvaluator failedEvaluator)

Uses of FailedEvaluator in org.apache.reef.io.network.group.api.driver

Methods in org.apache.reef.io.network.group.api.driver that return types with arguments of type FailedEvaluator

Modifier and Type	Method and Description
EStage<FailedEvaluator>	GroupCommServiceDriver.getGroupCommFailedEvaluatorStage() Not user facing but used the Group Communication Service class.

Uses of FailedEvaluator in org.apache.reef.io.network.group.impl.driver

Methods in org.apache.reef.io.network.group.impl.driver that return types with arguments of type FailedEvaluator

Modifier and Type	Method and Description
EStage<FailedEvaluator>	GroupCommDriverImpl.getGroupCommFailedEvaluatorStage()

Methods in org.apache.reef.io.network.group.impl.driver with parameters of type FailedEvaluator

Modifier and Type	Method and Description
void	TopologyFailedEvaluatorHandler.onNext(FailedEvaluator failedEvaluator)
void	GroupCommService.FailedEvaluatorHandler.onNext(FailedEvaluator failedEvaluator)

Constructor parameters in org.apache.reef.io.network.group.impl.driver with type arguments of type FailedEvaluator

Constructor and Description

CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName, ConfigurationSerializer confSerializer, EStage<GroupCommunicationMessage> senderStage, BroadcastingEventHandler<RunningTask> groupCommRunningTaskHandler, BroadcastingEventHandler<FailedTask> groupCommFailedTaskHandler, BroadcastingEventHandler<FailedEvaluator> groupCommFailedEvaluatorHandler, BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler, String driverId, int numberOfTasks, int fanOut) Deprecated. in 0.14. Use Tang to obtain an instance of this instead.

Uses of FailedEvaluator in org.apache.reef.io.watcher

Methods in org.apache.reef.io.watcher with parameters of type FailedEvaluator

Modifier and Type	Method and Description
void	Watcher.EvaluatorFailedHandler.onNext(FailedEvaluator failedEvaluator)

Uses of FailedEvaluator in org.apache.reef.io.watcher.util

Methods in org.apache.reef.io.watcher.util with parameters of type FailedEvaluator

Modifier and Type	Method and Description
static AvroFailedEvaluator	WatcherAvroUtil.toAvroFailedEvaluator(FailedEvaluator failedEvaluator)

Uses of FailedEvaluator in org.apache.reef.javabridge

Constructors in org.apache.reef.javabridge with parameters of type FailedEvaluator

Constructor and Description
FailedEvaluatorBridge(FailedEvaluator failedEvaluator, EvaluatorRequestor evaluatorRequestor, boolean blockedForAdditionalEvaluator, LoggingScopeFactory loggingScopeFactory)

Uses of FailedEvaluator in org.apache.reef.javabridge.generic

Methods in org.apache.reef.javabridge.generic with parameters of type FailedEvaluator

Modifier and Type	Method and Description
void	JobDriver.FailedEvaluatorHandler.onNext(FailedEvaluator eval)
void	JobDriver.DriverRestartFailedEvaluatorHandler.onNext(FailedEvaluator eval)

Uses of FailedEvaluator in org.apache.reef.runtime.common.driver.defaults

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

Modifier and Type	Method and Description
void	DefaultEvaluatorFailureHandler.onNext(FailedEvaluator failedEvaluator)

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

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

Modifier and Type	Method and Description
void	EvaluatorMessageDispatcher.onDriverRestartEvaluatorFailed(FailedEvaluator failedEvaluator)
void	EvaluatorMessageDispatcher.onEvaluatorFailed(FailedEvaluator failedEvaluator)

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

Methods in org.apache.reef.tests.watcher with parameters of type FailedEvaluator

Modifier and Type	Method and Description
void	WatcherTestDriver.EvaluatorFailedHandler.onNext(FailedEvaluator failedEvaluator)