public final class JobListeningContext extends Object
Constructor and Description |
---|
JobListeningContext(JobID jobID,
scala.concurrent.Future<Object> jobResultFuture,
akka.actor.ActorRef jobClientActor,
scala.concurrent.duration.FiniteDuration timeout,
akka.actor.ActorSystem actorSystem,
Configuration configuration,
HighAvailabilityServices highAvailabilityServices)
Constructor to use when the class loader is not available.
|
JobListeningContext(JobID jobID,
scala.concurrent.Future<Object> jobResultFuture,
akka.actor.ActorRef jobClientActor,
scala.concurrent.duration.FiniteDuration timeout,
ClassLoader classLoader,
HighAvailabilityServices highAvailabilityServices)
Constructor to use when the class loader is available.
|
Modifier and Type | Method and Description |
---|---|
ClassLoader |
getClassLoader()
The class loader necessary to deserialize the result of a job execution,
i.e.
|
akka.actor.ActorRef |
getJobClientActor() |
JobID |
getJobID() |
scala.concurrent.Future<Object> |
getJobResultFuture() |
scala.concurrent.duration.FiniteDuration |
getTimeout() |
public JobListeningContext(JobID jobID, scala.concurrent.Future<Object> jobResultFuture, akka.actor.ActorRef jobClientActor, scala.concurrent.duration.FiniteDuration timeout, ClassLoader classLoader, HighAvailabilityServices highAvailabilityServices)
public JobListeningContext(JobID jobID, scala.concurrent.Future<Object> jobResultFuture, akka.actor.ActorRef jobClientActor, scala.concurrent.duration.FiniteDuration timeout, akka.actor.ActorSystem actorSystem, Configuration configuration, HighAvailabilityServices highAvailabilityServices)
public JobID getJobID()
public scala.concurrent.Future<Object> getJobResultFuture()
public akka.actor.ActorRef getJobClientActor()
public scala.concurrent.duration.FiniteDuration getTimeout()
public ClassLoader getClassLoader() throws JobRetrievalException
JobRetrievalException
- if anything goes wrongCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.