public final class Evaluators extends Object implements AutoCloseable
Modifier and Type | Method and Description |
---|---|
boolean |
allEvaluatorsAreClosed()
Return true if all evaluators are in closed state
(and their processing queues are empty).
|
void |
close()
Closes all EvaluatorManager instances managed.
|
Optional<EvaluatorManager> |
get(String evaluatorId) |
void |
put(EvaluatorManager evaluatorManager)
Adds an EvaluatorManager.
|
void |
put(EvaluatorManagerFactory evaluatorManagerFactory,
ResourceAllocationEvent evaluatorMsg)
Create new EvaluatorManager and add it to the collection.
|
void |
removeClosedEvaluator(EvaluatorManager evaluatorManager)
Moves evaluator from map of active evaluators to set of closed evaluators.
|
boolean |
wasClosed(String evaluatorId) |
public void close()
close
in interface AutoCloseable
public boolean allEvaluatorsAreClosed()
public Optional<EvaluatorManager> get(String evaluatorId)
evaluatorId
- public boolean wasClosed(String evaluatorId)
evaluatorId
- public void put(EvaluatorManagerFactory evaluatorManagerFactory, ResourceAllocationEvent evaluatorMsg)
FIXME: This method is a temporary fix for the race condition described in issues #828 and #839.
evaluatorManagerFactory
- Factory that builds new EvaluatorManager objects.evaluatorMsg
- Resource allocation message that contains data on the new evaluator.IllegalArgumentException
- if the EvaluatorManager is already known.public void put(EvaluatorManager evaluatorManager)
evaluatorManager
- IllegalArgumentException
- if the EvaluatorManager is already known.public void removeClosedEvaluator(EvaluatorManager evaluatorManager)
Copyright © 2017 The Apache Software Foundation. All rights reserved.