You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2017/06/05 05:23:39 UTC
[51/67] [abbrv] kylin git commit: minor, api to get AbstractExecutable
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 <li...@apache.org>
Authored: Tue May 30 00:10:41 2017 +0800
Committer: Dong Li <li...@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();