- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.oozie.client.WorkflowAction.getConsoleUrl()
方法的一些代码示例,展示了WorkflowAction.getConsoleUrl()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WorkflowAction.getConsoleUrl()
方法的具体详情如下:
包路径:org.apache.oozie.client.WorkflowAction
类名称:WorkflowAction
方法名:getConsoleUrl
[英]Return the URL to the web console of the system executing the action.
[中]将URL返回到执行操作的系统的web控制台。
代码示例来源:origin: apache/oozie
private void swapMRActionID(WorkflowAction waBean) {
if (waBean.getType().equals("map-reduce")) {
String childId = waBean.getExternalChildIDs();
if (childId != null && !childId.equals("")) {
String consoleBase = getConsoleBase(waBean.getConsoleUrl());
((WorkflowActionBean) waBean).setConsoleUrl(consoleBase + childId);
((WorkflowActionBean) waBean).setExternalId(childId);
((WorkflowActionBean) waBean).setExternalChildIDs("");
}
}
}
代码示例来源:origin: org.apache.oozie/oozie-core
private void swapMRActionID(WorkflowAction waBean) {
if (waBean.getType().equals("map-reduce")) {
String childId = waBean.getExternalChildIDs();
if (childId != null && !childId.equals("")) {
String consoleBase = getConsoleBase(waBean.getConsoleUrl());
((WorkflowActionBean) waBean).setConsoleUrl(consoleBase + childId);
((WorkflowActionBean) waBean).setExternalId(childId);
((WorkflowActionBean) waBean).setExternalChildIDs("");
}
}
}
代码示例来源:origin: YahooArchive/oozie
private void printWorkflowAction(WorkflowAction action, boolean contains) {
System.out.println("ID : " + maskIfNull(action.getId()));
System.out.println(RULER);
System.out.println("Console URL : " + maskIfNull(action.getConsoleUrl()));
System.out.println("Error Code : " + maskIfNull(action.getErrorCode()));
System.out.println("Error Message : " + maskIfNull(action.getErrorMessage()));
System.out.println("External ID : " + maskIfNull(action.getExternalId()));
System.out.println("External Status : " + maskIfNull(action.getExternalStatus()));
System.out.println("Name : " + maskIfNull(action.getName()));
System.out.println("Retries : " + action.getRetries());
System.out.println("Tracker URI : " + maskIfNull(action.getTrackerUri()));
System.out.println("Type : " + maskIfNull(action.getType()));
System.out.println("Started : " + maskDate(action.getStartTime(), contains));
System.out.println("Status : " + action.getStatus());
System.out.println("Ended : " + maskDate(action.getEndTime(), contains));
System.out.println(RULER);
}
代码示例来源:origin: com.yahoo.oozie/oozie-client
private void printWorkflowAction(WorkflowAction action, boolean contains) {
System.out.println("ID : " + maskIfNull(action.getId()));
System.out.println(RULER);
System.out.println("Console URL : " + maskIfNull(action.getConsoleUrl()));
System.out.println("Error Code : " + maskIfNull(action.getErrorCode()));
System.out.println("Error Message : " + maskIfNull(action.getErrorMessage()));
System.out.println("External ID : " + maskIfNull(action.getExternalId()));
System.out.println("External Status : " + maskIfNull(action.getExternalStatus()));
System.out.println("Name : " + maskIfNull(action.getName()));
System.out.println("Retries : " + action.getRetries());
System.out.println("Tracker URI : " + maskIfNull(action.getTrackerUri()));
System.out.println("Type : " + maskIfNull(action.getType()));
System.out.println("Started : " + maskDate(action.getStartTime(), contains));
System.out.println("Status : " + action.getStatus());
System.out.println("Ended : " + maskDate(action.getEndTime(), contains));
System.out.println(RULER);
}
代码示例来源:origin: apache/oozie
@VisibleForTesting
void printWorkflowAction(WorkflowAction action, String timeZoneId, boolean verbose) {
System.out.println("ID : " + maskIfNull(action.getId()));
System.out.println(RULER);
System.out.println("Console URL : " + maskIfNull(action.getConsoleUrl()));
System.out.println("Error Code : " + maskIfNull(action.getErrorCode()));
System.out.println("Error Message : " + maskIfNull(action.getErrorMessage()));
System.out.println("External ID : " + maskIfNull(action.getExternalId()));
System.out.println("External Status : " + maskIfNull(action.getExternalStatus()));
System.out.println("Name : " + maskIfNull(action.getName()));
System.out.println("Retries : " + action.getUserRetryCount());
System.out.println("Tracker URI : " + maskIfNull(action.getTrackerUri()));
System.out.println("Type : " + maskIfNull(action.getType()));
System.out.println("Started : " + maskDate(action.getStartTime(), timeZoneId, verbose));
System.out.println("Status : " + action.getStatus());
System.out.println("Ended : " + maskDate(action.getEndTime(), timeZoneId, verbose));
if (verbose) {
System.out.println("External Stats : " + action.getStats());
System.out.println("External ChildIDs : " + action.getExternalChildIDs());
}
System.out.println(RULER);
}
代码示例来源:origin: org.apache.oozie/oozie-client
@VisibleForTesting
void printWorkflowAction(WorkflowAction action, String timeZoneId, boolean verbose) {
System.out.println("ID : " + maskIfNull(action.getId()));
System.out.println(RULER);
System.out.println("Console URL : " + maskIfNull(action.getConsoleUrl()));
System.out.println("Error Code : " + maskIfNull(action.getErrorCode()));
System.out.println("Error Message : " + maskIfNull(action.getErrorMessage()));
System.out.println("External ID : " + maskIfNull(action.getExternalId()));
System.out.println("External Status : " + maskIfNull(action.getExternalStatus()));
System.out.println("Name : " + maskIfNull(action.getName()));
System.out.println("Retries : " + action.getUserRetryCount());
System.out.println("Tracker URI : " + maskIfNull(action.getTrackerUri()));
System.out.println("Type : " + maskIfNull(action.getType()));
System.out.println("Started : " + maskDate(action.getStartTime(), timeZoneId, verbose));
System.out.println("Status : " + action.getStatus());
System.out.println("Ended : " + maskDate(action.getEndTime(), timeZoneId, verbose));
if (verbose) {
System.out.println("External Stats : " + action.getStats());
System.out.println("External ChildIDs : " + action.getExternalChildIDs());
}
System.out.println(RULER);
}
代码示例来源:origin: jaibeermalik/searchanalytics-bigdata
workflowAction.getConsoleUrl());
LOG.debug("HiveActionWorkflowJob Action Name: {}",
workflowAction.getName());
代码示例来源:origin: com.yahoo.oozie/oozie-client
+ maskIfNull(action.getConsoleUrl()) + VERBOSE_DELIMITER
+ maskIfNull(action.getErrorCode()) + VERBOSE_DELIMITER
+ maskIfNull(action.getErrorMessage()) + VERBOSE_DELIMITER
代码示例来源:origin: apache/oozie
public void testProperties() {
WorkflowAction action = createNode();
Assert.assertEquals("a", action.getId());
Assert.assertEquals("b", action.getName());
Assert.assertEquals("c", action.getType());
Assert.assertEquals("d", action.getConf());
Assert.assertEquals(WorkflowAction.Status.RUNNING, action.getStatus());
Assert.assertEquals(1, action.getRetries());
Assert.assertEquals(JsonUtils.parseDateRfc822(START_TIME), action.getStartTime());
Assert.assertEquals(JsonUtils.parseDateRfc822(END_TIME), action.getEndTime());
Assert.assertEquals("e", action.getTransition());
Assert.assertEquals("ee", action.getData());
Assert.assertEquals("stats", action.getStats());
Assert.assertEquals("extChIDs", action.getExternalChildIDs());
Assert.assertEquals("f", action.getExternalId());
Assert.assertEquals("g", action.getExternalStatus());
Assert.assertEquals("h", action.getTrackerUri());
Assert.assertEquals("i", action.getConsoleUrl());
Assert.assertEquals("j", action.getErrorCode());
Assert.assertEquals("k", action.getErrorMessage());
}
代码示例来源:origin: apache/oozie
+ maskIfNull(action.getConsoleUrl()) + VERBOSE_DELIMITER
+ maskIfNull(action.getErrorCode()) + VERBOSE_DELIMITER
+ maskIfNull(action.getErrorMessage()) + VERBOSE_DELIMITER
代码示例来源:origin: YahooArchive/oozie
+ maskIfNull(action.getConsoleUrl()) + VERBOSE_DELIMITER
+ maskIfNull(action.getErrorCode()) + VERBOSE_DELIMITER
+ maskIfNull(action.getErrorMessage()) + VERBOSE_DELIMITER
代码示例来源:origin: org.apache.oozie/oozie-client
+ maskIfNull(action.getConsoleUrl()) + VERBOSE_DELIMITER
+ maskIfNull(action.getErrorCode()) + VERBOSE_DELIMITER
+ maskIfNull(action.getErrorMessage()) + VERBOSE_DELIMITER
代码示例来源:origin: apache/oozie
protected String submitAction(Context context, JavaActionExecutor javaActionExecutor) throws ActionExecutorException {
WorkflowAction action = context.getAction();
javaActionExecutor.prepareActionDir(getFileSystem(), context);
javaActionExecutor.submitLauncher(getFileSystem(), context, action);
String jobId = action.getExternalId();
String jobTracker = action.getTrackerUri();
String consoleUrl = action.getConsoleUrl();
assertNotNull(jobId);
assertNotNull(jobTracker);
assertNotNull(consoleUrl);
return jobId;
}
代码示例来源:origin: apache/oozie
/**
* Submit the Shell action using Shell ActionExecutor
*
* @param context
* @return The RunningJob of the Launcher Mapper
* @throws Exception
*/
private String submitAction(Context context) throws Exception {
ShellActionExecutor ae = new ShellActionExecutor();
WorkflowAction action = context.getAction();
ae.prepareActionDir(getFileSystem(), context);
ae.submitLauncher(getFileSystem(), context, action); // Submit the action
String jobId = action.getExternalId();
String jobTracker = action.getTrackerUri();
String consoleUrl = action.getConsoleUrl();
assertNotNull(jobId);
assertNotNull(jobTracker);
assertNotNull(consoleUrl);
return jobId;
}
}
代码示例来源:origin: apache/oozie
protected String submitAction(Context context) throws Exception {
DistcpActionExecutor ae = new DistcpActionExecutor();
WorkflowAction action = context.getAction();
ae.prepareActionDir(getFileSystem(), context);
ae.submitLauncher(getFileSystem(), context, action);
String jobId = action.getExternalId();
String jobTracker = action.getTrackerUri();
String consoleUrl = action.getConsoleUrl();
assertNotNull(jobId);
assertNotNull(jobTracker);
assertNotNull(consoleUrl);
ae.submitLauncher(getFileSystem(), context, context.getAction());
return context.getAction().getExternalId();
}
代码示例来源:origin: org.apache.oozie/oozie-tools
.writeStringValue("Error Code : ", action.getErrorCode())
.writeStringValue("Error Message : ", action.getErrorMessage())
.writeStringValue("Console URL : ", action.getConsoleUrl())
.writeStringValue("Tracker URI : ", action.getTrackerUri())
.writeStringValue("External Child Ids : ", action.getExternalChildIDs())
本文整理了Java中org.apache.oozie.client.WorkflowAction.getExternalStatus()方法的一些代码示例,展示了WorkflowAction.getE
本文整理了Java中org.apache.oozie.client.WorkflowAction.getData()方法的一些代码示例,展示了WorkflowAction.getData()的具体用法
本文整理了Java中org.apache.oozie.client.WorkflowAction.getConf()方法的一些代码示例,展示了WorkflowAction.getConf()的具体用法
本文整理了Java中org.apache.oozie.client.WorkflowAction.getUserRetryCount()方法的一些代码示例,展示了WorkflowAction.getU
本文整理了Java中org.apache.oozie.client.WorkflowAction.getTransition()方法的一些代码示例,展示了WorkflowAction.getTrans
本文整理了Java中org.apache.oozie.client.WorkflowAction.getRetries()方法的一些代码示例,展示了WorkflowAction.getRetries(
本文整理了Java中org.apache.oozie.client.WorkflowAction.getExternalId()方法的一些代码示例,展示了WorkflowAction.getExter
本文整理了Java中org.apache.oozie.client.WorkflowAction.getExternalChildIDs()方法的一些代码示例,展示了WorkflowAction.ge
本文整理了Java中org.apache.oozie.client.WorkflowAction.getTrackerUri()方法的一些代码示例,展示了WorkflowAction.getTrack
本文整理了Java中org.apache.oozie.client.WorkflowAction.getName()方法的一些代码示例,展示了WorkflowAction.getName()的具体用法
本文整理了Java中org.apache.oozie.client.WorkflowAction.getErrorCode()方法的一些代码示例,展示了WorkflowAction.getErrorC
本文整理了Java中org.apache.oozie.client.WorkflowAction.getConsoleUrl()方法的一些代码示例,展示了WorkflowAction.getConso
本文整理了Java中org.apache.oozie.client.WorkflowAction.getEndTime()方法的一些代码示例,展示了WorkflowAction.getEndTime(
本文整理了Java中org.apache.oozie.client.WorkflowAction.getType()方法的一些代码示例,展示了WorkflowAction.getType()的具体用法
本文整理了Java中org.apache.oozie.client.WorkflowAction.getId()方法的一些代码示例,展示了WorkflowAction.getId()的具体用法。这些代
本文整理了Java中org.apache.oozie.client.WorkflowAction.getStartTime()方法的一些代码示例,展示了WorkflowAction.getStartT
本文整理了Java中org.apache.oozie.client.WorkflowAction.getErrorMessage()方法的一些代码示例,展示了WorkflowAction.getErr
本文整理了Java中org.apache.oozie.client.WorkflowAction.getStatus()方法的一些代码示例,展示了WorkflowAction.getStatus()的
本文整理了Java中org.apache.oozie.client.WorkflowAction.getStats()方法的一些代码示例,展示了WorkflowAction.getStats()的具体
我是一名优秀的程序员,十分优秀!