public final class LocalEngineUtil
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private static org.apache.log4j.Logger |
log |
Constructor and Description |
---|
LocalEngineUtil() |
Modifier and Type | Method and Description |
---|---|
static boolean |
cancelJob(java.util.concurrent.Future<ConfiguredExecutable<?>> future,
java.lang.String workDirectory) |
static boolean |
cleanup(ConfiguredExecutable<?> confExecutable) |
static JobStatus |
getJobStatus(java.util.concurrent.Future<ConfiguredExecutable<?>> future) |
static JobStatus |
getRecordedJobStatus(java.lang.String jobId) |
static ConfiguredExecutable<?> |
getResults(java.util.concurrent.Future<ConfiguredExecutable<?>> future,
java.lang.String taskId) |
(package private) static java.lang.RuntimeException |
launderThrowable(java.lang.Throwable throwable)
Coerce an unchecked Throwable to a RuntimeException or Error
|
static java.lang.RuntimeException launderThrowable(java.lang.Throwable throwable)
throwable
- public static boolean cancelJob(java.util.concurrent.Future<ConfiguredExecutable<?>> future, java.lang.String workDirectory)
public static JobStatus getJobStatus(java.util.concurrent.Future<ConfiguredExecutable<?>> future)
public static JobStatus getRecordedJobStatus(java.lang.String jobId)
public static boolean cleanup(ConfiguredExecutable<?> confExecutable)
public static ConfiguredExecutable<?> getResults(java.util.concurrent.Future<ConfiguredExecutable<?>> future, java.lang.String taskId) throws ResultNotAvailableException
ResultNotAvailableException