minor, api to get AbstractExecutable
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/361ac006 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/361ac006 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/361ac006 Branch: refs/heads/master Commit: 361ac0068661ad5627bc590b5174eb2b57c6ea60 Parents: afaa95a Author: lidongsjtu <lid...@apache.org> Authored: Tue May 30 00:10:41 2017 +0800 Committer: Dong Li <lid...@apache.org> Committed: Tue May 30 14:04:27 2017 +0800 ---------------------------------------------------------------------- .../kylin/job/execution/ExecutableManager.java | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/361ac006/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java ---------------------------------------------------------------------- diff --git a/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java b/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java index 2272582..170a254 100644 --- a/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java +++ b/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java @@ -18,6 +18,10 @@ package org.apache.kylin.job.execution; +import static org.apache.kylin.job.constant.ExecutableConstants.MR_JOB_ID; +import static org.apache.kylin.job.constant.ExecutableConstants.YARN_APP_ID; +import static org.apache.kylin.job.constant.ExecutableConstants.YARN_APP_URL; + import java.lang.reflect.Constructor; import java.util.HashMap; import java.util.IllegalFormatException; @@ -42,10 +46,6 @@ import com.google.common.base.Preconditions; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import static org.apache.kylin.job.constant.ExecutableConstants.MR_JOB_ID; -import static org.apache.kylin.job.constant.ExecutableConstants.YARN_APP_ID; -import static org.apache.kylin.job.constant.ExecutableConstants.YARN_APP_URL; - /** */ public class ExecutableManager { @@ -253,6 +253,15 @@ public class ExecutableManager { } } + public AbstractExecutable getAbstractExecutable(String uuid, Class<? extends AbstractExecutable> expectedClass) { + try { + return parseToAbstract(executableDao.getJob(uuid), expectedClass); + } catch (PersistentException e) { + logger.error("fail to get job:" + uuid, e); + throw new RuntimeException(e); + } + } + public List<String> getAllJobIds() { try { return executableDao.getJobIds();
