- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.oozie.client.WorkflowAction.getType()
方法的一些代码示例,展示了WorkflowAction.getType()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WorkflowAction.getType()
方法的具体详情如下:
包路径:org.apache.oozie.client.WorkflowAction
类名称:WorkflowAction
方法名:getType
[英]Return the action type.
[中]返回操作类型。
代码示例来源:origin: org.apache.oozie/oozie-examples
private static void printWorkflowInfo(WorkflowJob wf) {
System.out.println("Application Path : " + wf.getAppPath());
System.out.println("Application Name : " + wf.getAppName());
System.out.println("Application Status : " + wf.getStatus());
System.out.println("Application Actions:");
for (WorkflowAction action : wf.getActions()) {
System.out.println(MessageFormat.format(" Name: {0} Type: {1} Status: {2}", action.getName(),
action.getType(), action.getStatus()));
}
System.out.println();
}
}
代码示例来源:origin: com.yahoo.oozie/oozie-examples
private static void printWorkflowInfo(WorkflowJob wf) {
System.out.println("Application Path : " + wf.getAppPath());
System.out.println("Application Name : " + wf.getAppName());
System.out.println("Application Status : " + wf.getStatus());
System.out.println("Application Actions:");
for (WorkflowAction action : wf.getActions()) {
System.out.println(MessageFormat.format(" Name: {0} Type: {1} Status: {2}", action.getName(),
action.getType(), action.getStatus()));
}
System.out.println();
}
代码示例来源:origin: apache/oozie
protected WorkflowAction getJavaAction(WorkflowJob workflowJob){
List<WorkflowAction> actions = workflowJob.getActions();
for(WorkflowAction wa : actions){
if(wa.getType().equals("java")){
return wa;
}
}
return null;
}
/**
代码示例来源:origin: apache/oozie
private void addActionInfo(StringBuffer sb) {
addJobInfo(sb, ACTION_NAME, action.getName());
addJobInfo(sb, ACTION_TYPE, action.getType());
}
代码示例来源:origin: org.apache.oozie/oozie-core
private void addActionInfo(StringBuffer sb) {
addJobInfo(sb, ACTION_NAME, action.getName());
addJobInfo(sb, ACTION_TYPE, action.getType());
}
代码示例来源: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: com.yahoo.oozie/oozie-client
+ maskIfNull(action.getExternalStatus()) + VERBOSE_DELIMITER + maskIfNull(action.getName())
+ VERBOSE_DELIMITER + action.getRetries() + VERBOSE_DELIMITER
+ maskIfNull(action.getTrackerUri()) + VERBOSE_DELIMITER + maskIfNull(action.getType())
+ VERBOSE_DELIMITER + maskDate(action.getStartTime(), localtime) + VERBOSE_DELIMITER
+ action.getStatus() + VERBOSE_DELIMITER + maskDate(action.getEndTime(), localtime));
代码示例来源:origin: apache/oozie
+ maskIfNull(action.getExternalStatus()) + VERBOSE_DELIMITER + maskIfNull(action.getName())
+ VERBOSE_DELIMITER + action.getRetries() + VERBOSE_DELIMITER
+ maskIfNull(action.getTrackerUri()) + VERBOSE_DELIMITER + maskIfNull(action.getType())
+ VERBOSE_DELIMITER + maskDate(action.getStartTime(), timeZoneId, verbose)
+ VERBOSE_DELIMITER + action.getStatus() + 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: YahooArchive/oozie
+ maskIfNull(action.getExternalStatus()) + VERBOSE_DELIMITER + maskIfNull(action.getName())
+ VERBOSE_DELIMITER + action.getRetries() + VERBOSE_DELIMITER
+ maskIfNull(action.getTrackerUri()) + VERBOSE_DELIMITER + maskIfNull(action.getType())
+ VERBOSE_DELIMITER + maskDate(action.getStartTime(), localtime) + VERBOSE_DELIMITER
+ action.getStatus() + VERBOSE_DELIMITER + maskDate(action.getEndTime(), localtime));
代码示例来源:origin: org.apache.oozie/oozie-client
+ maskIfNull(action.getExternalStatus()) + VERBOSE_DELIMITER + maskIfNull(action.getName())
+ VERBOSE_DELIMITER + action.getRetries() + VERBOSE_DELIMITER
+ maskIfNull(action.getTrackerUri()) + VERBOSE_DELIMITER + maskIfNull(action.getType())
+ VERBOSE_DELIMITER + maskDate(action.getStartTime(), timeZoneId, verbose)
+ VERBOSE_DELIMITER + action.getStatus() + VERBOSE_DELIMITER
代码示例来源:origin: org.apache.oozie/oozie-tools
bundleEntryWriter.writeStringValue("Action Id : ", action.getId())
.writeStringValue("Name : ", action.getName())
.writeStringValue("Type : ", action.getType())
.writeStringValue("Status : ", action.getStatus().toString())
.writeStringValue("Transition : ", action.getTransition())
.flush();
final String actionType = action.getType();
persistResolvedActionDefinition(action, resolvedActionsDir);
我已经阅读了“UnderlyingSystemType”的定义,即它“表示公共(public)语言运行时提供的表示此类型的类型”。 SO 上有一个相关链接 When does the Underlyi
以下代码会产生不同的结果: class X { public class Y { } } ... var t = typeof(X.Y); var n = t.ToString().Dump(
这个问题在这里已经有了答案: How costly is .NET reflection? (13 个答案) 关闭 9 年前。 我在 .NET/C# 中使用反射 API,例如 GetType() 和
private int buType=0; public int getType() { return buType; } 上述代码片段是在扩展 JDialog 类的类中编写的。它在 Java
我试图在运行时从程序集列表中定位一个类型;我的代码是这样的: foreach (Assembly assembly in assembliesToSearch) { Type t = asse
System.Object.GetType() 和 System.Type.GetType() 有区别吗 最佳答案 System.Type 派生自 System.Object。因此,它从 System
当我在 Powershell(已安装 v3)中观察到一些奇怪的行为时,我正在整理一个简单的演示脚本。 $file = ls 'C:\temp' | Where-Object {$_.Extension
我正在使用 Rome 和 SyndEntry(com.sun.syndicate.feed.synd.SyndEntry) 来检索 URL 的“getType”字段。 这是示例 xml feed。
我有一个 C# 程序集,但我没有它的依赖项程序集。 有没有办法在没有其依赖项程序集的情况下获取 .Net 程序集的 GetTypes()。 Assembly SampleAssembly; Sam
在 foreach 语句的帮助下,我在我的 WinForms 表单中的一些 controls 中搜索。我正在比较通过“is”-reference(a is DataGridView)找到的对象。 “a
我正在制作 XNA 游戏,每次更新我调用以下代码 2 到 20 次。我尝试使用谷歌搜索,这似乎有点慢,所以我只是想问问是否有更快的方法来比较类型? 代码: public Modifier th
我在 NewStarterTool 命名空间中有以下 Globals 类: static class Globals { static internal class FieldNames
这个问题在这里已经有了答案: 关闭 10 年前。 Possible Duplicate: .NET: Determine the type of “this” class in its static
为什么会这样: Object o = "my string"; Console.WriteLine(o.GetType()); 输出: System.String 如果函数调用被分派(dispatch
因此,我对自定义类型方面的数据如何存储在 .NET Framework 中没有深入的了解,但我一直在寻找关于转换系统如何工作的解释。 例如,如果要从像 Char 这样的 ValueType 结构显式转
我遇到了这段代码: int myInt = 0; textBox1.Text = myInt.GetType().Name; 根据.NET documentation , GetType() 是一个方
在处理嵌套类并将类型名称输出到控制台窗口时,我注意到了一些奇怪的事情。我想知道是否有人可以为我解释一下。在主类上调用 GetType() 时,它会返回我所期望的,即相关命名空间之后的类名。即 Name
这个问题在这里已经有了答案: 关闭 10 年前。 Possible Duplicate: .NET: Determine the type of “this” class in its static
我有一个可能不包含任何项目的初始化数组。 我们称它为a, 在a 上调用GetType() 显然会返回一种数组类型。是否可以获取数组包含的项的类型? 显然 a[0].GetType() 可以工作,但数组
基于几天前在 SO 中提出的以下问题:GetType() and polymorphism和阅读 Eric Lippert's回答,我开始考虑如果让 GetType() 不是虚拟的真的确保一个对象不能
我是一名优秀的程序员,十分优秀!