Java WorkflowAction类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.oozie.client.WorkflowAction类的典型用法代码示例。如果您正苦于以下问题：Java WorkflowAction类的具体用法？Java WorkflowAction怎么用？Java WorkflowAction使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

WorkflowAction类属于org.apache.oozie.client包，在下文中一共展示了WorkflowAction类的10个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: asAction

import org.apache.oozie.client.WorkflowAction; //导入依赖的package包/类
/**
 * Copy WorkflowAction information in OOZIE to OozieAction we defined
 *
 * @param temp WorkflowAction in OOZIE
 * @param jobid Oozie job id
 * @return OozieAction
 */
public static OozieAction asAction(WorkflowAction temp, String jobid) {
	OozieAction tempAct = new OozieAction();
	tempAct.setJobId( jobid );
	tempAct.setName(temp.getName());
	tempAct.setType(temp.getType());
	tempAct.setConf(temp.getConf());
	tempAct.setStatus(temp.getStatus().toString());
	tempAct.setRetries(temp.getRetries());
	tempAct.setStartTime(temp.getStartTime());
	tempAct.setEndTime(temp.getEndTime());
	tempAct.setTransition(temp.getTransition());
	tempAct.setData(temp.getData());
	tempAct.setStats(temp.getStats());
	tempAct.setExternalChildIDs(temp.getExternalChildIDs());
	tempAct.setExternalId(temp.getExternalId());
	tempAct.setExternalStatus(temp.getExternalStatus());
	tempAct.setTrackerUri(temp.getTrackerUri());
	tempAct.setConsoleUrl(temp.getConsoleUrl());
	tempAct.setErrorCode(temp.getErrorCode());
	tempAct.setErrorMessage(temp.getErrorMessage());
	return tempAct;
}

开发者ID:ICT-BDA，项目名称:EasyML，代码行数:30，代码来源:OozieUtil.java

示例2: setWorkflowjob

import org.apache.oozie.client.WorkflowAction; //导入依赖的package包/类
/**
 * Copy WorkflowJob information in OOZIE to Oozie we defined
 * @param job WorkflowJob
 * @return OozieJob
 */
public static OozieJob setWorkflowjob(WorkflowJob job) {
	OozieJob oozieJob = new OozieJob();
	oozieJob.setAcl(job.getAcl());
	for (WorkflowAction temp : job.getActions()) {
		OozieAction a = asAction(temp, job.getId() );
		oozieJob.addAction(a);
	}
	oozieJob.setAppName(job.getAppName());
	oozieJob.setAppPath(job.getAppPath());
	oozieJob.setConf(job.getConf());
	oozieJob.setConsoleUrl(job.getConsoleUrl());
	oozieJob.setCreatedTime(job.getCreatedTime());
	oozieJob.setEndTime(job.getEndTime());
	oozieJob.setExternalId(job.getExternalId());
	oozieJob.setGroup(job.getGroup());
	oozieJob.setId(job.getId());
	oozieJob.setLastModifiedTime(job.getLastModifiedTime());
	oozieJob.setParentId(job.getParentId());
	oozieJob.setRun(job.getRun());
	oozieJob.setStartTime(job.getStartTime());
	oozieJob.setStatus(job.getStatus().toString());
	oozieJob.setUser(job.getUser());
	return oozieJob;
}

开发者ID:ICT-BDA，项目名称:EasyML，代码行数:30，代码来源:OozieUtil.java

示例3: copyTTlogs

import org.apache.oozie.client.WorkflowAction; //导入依赖的package包/类
private void copyTTlogs(ARGS args, FileSystem fs, Path path,
		WorkflowAction action) throws Exception {
	String ttLogURL = getTTlogURL(action.getExternalId());
	if (ttLogURL != null) {
		LOG.info("Fetching log for action: " + action.getExternalId()
				+ " from url: " + ttLogURL);
		InputStream in = getURLinputStream(new URL(ttLogURL));
		OutputStream out = fs.create(new Path(path, action.getName() + "_"
				+ getMappedStatus(action.getStatus()) + ".log"));
		IOUtils.copyBytes(in, out, 4096, true);
		LOG.info("Copied log to " + path);
	}
}

开发者ID:sriksun，项目名称:ivry-security，代码行数:14，代码来源:LogMover.java

示例4: getMappedStatus

import org.apache.oozie.client.WorkflowAction; //导入依赖的package包/类
private String getMappedStatus(WorkflowAction.Status status) {
	if (status == WorkflowAction.Status.FAILED
			|| status == WorkflowAction.Status.KILLED
			|| status == WorkflowAction.Status.ERROR) {
		return "FAILED";
	} else {
		return "SUCCEEDED";
	}
}

开发者ID:sriksun，项目名称:ivry-security，代码行数:10，代码来源:LogMover.java

示例5: getWorkflowActionInfo

import org.apache.oozie.client.WorkflowAction; //导入依赖的package包/类
@Override
public WorkflowAction getWorkflowActionInfo(String actionId)
    throws OozieClientException {
  synchronized (lock) {
    return client.getWorkflowActionInfo(actionId);
  }
}

开发者ID:blackberry，项目名称:hadoop-logdriver，代码行数:8，代码来源:SynchronizedOozieClient.java

示例6: copyTTlogs

import org.apache.oozie.client.WorkflowAction; //导入依赖的package包/类
private void copyTTlogs(ARGS args, FileSystem fs, Path path,
                        WorkflowAction action) throws Exception {
    String ttLogURL = getTTlogURL(action.getExternalId());
    if (ttLogURL != null) {
        LOG.info("Fetching log for action: " + action.getExternalId()
                + " from url: " + ttLogURL);
        InputStream in = getURLinputStream(new URL(ttLogURL));
        OutputStream out = fs.create(new Path(path, action.getName() + "_"
                + getMappedStatus(action.getStatus()) + ".log"));
        IOUtils.copyBytes(in, out, 4096, true);
        LOG.info("Copied log to " + path);
    }
}

开发者ID:shaikidris，项目名称:incubator-falcon，代码行数:14，代码来源:LogMover.java

示例7: getMappedStatus

import org.apache.oozie.client.WorkflowAction; //导入依赖的package包/类
private String getMappedStatus(WorkflowAction.Status status) {
    if (status == WorkflowAction.Status.FAILED
            || status == WorkflowAction.Status.KILLED
            || status == WorkflowAction.Status.ERROR) {
        return "FAILED";
    } else {
        return "SUCCEEDED";
    }
}

开发者ID:shaikidris，项目名称:incubator-falcon，代码行数:10，代码来源:LogMover.java

示例8: fetchActionDuration

import org.apache.oozie.client.WorkflowAction; //导入依赖的package包/类
private long fetchActionDuration(List<WorkflowAction> actions, String actionName) {
    
    for (WorkflowAction action : actions) {
        
        if (actionName.equals(action.getName())) {
            
            Date startDate = action.getStartTime();
            Date endDate = action.getEndTime();
            
            return endDate.getTime() - startDate.getTime();
        }
        
    }
    
    log.warn("no action with the name has been specified or executed: " + actionName);
    
    return 0;
}

开发者ID:openaire，项目名称:iis，代码行数:19，代码来源:OozieTimeReportGenerator.java

示例9: run

import org.apache.oozie.client.WorkflowAction; //导入依赖的package包/类
@Override
public void run(PortBindings portBindings, Configuration conf, Map<String, String> parameters) throws Exception {
    
    List<WorkflowAction> actions = fetchWorkflowActions(parameters.get(OOZIE_SERVICE_LOC_PARAM), parameters.get(WORKFLOW_JOB_ID_PARAM));
    
    Map<String, List<String>> reportKeysToActionNames = mapReportKeysToActionNames(parameters);
    
    
    List<ReportEntry> reportEntries = Lists.newArrayList();
    
    for (Map.Entry<String, List<String>> reportKeyToActionNamesEntry : reportKeysToActionNames.entrySet()) {
        
        long totalDuration = 0L;
        
        for (String actionName : reportKeyToActionNamesEntry.getValue()) {
            
            totalDuration += fetchActionDuration(actions, actionName);
        }
        
        if (totalDuration > 0) {
            reportEntries.add(ReportEntryFactory.createDurationReportEntry(reportKeyToActionNamesEntry.getKey(), totalDuration));
        }
    }
    
    
    
    FileSystem fs = FileSystem.get(conf);
    
    Path reportPath = portBindings.getOutput().get(REPORT_PORT_OUT_NAME);
    
    DataStore.create(reportEntries, new FileSystemPath(fs, reportPath));
}

开发者ID:openaire，项目名称:iis，代码行数:33，代码来源:OozieTimeReportGenerator.java

示例10: fetchWorkflowActions

import org.apache.oozie.client.WorkflowAction; //导入依赖的package包/类
private List<WorkflowAction> fetchWorkflowActions(String oozieUrl, String workflowId) throws OozieClientException {
    
    OozieClient oozieClient = oozieClientFactory.createOozieClient(oozieUrl);
    
    WorkflowJob job = oozieClient.getJobInfo(workflowId);
    
    return job.getActions();
}

开发者ID:openaire，项目名称:iis，代码行数:9，代码来源:OozieTimeReportGenerator.java

注：本文中的org.apache.oozie.client.WorkflowAction类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java SendEmailResult类代码示例发布时间：2022-05-22

Java ContainerFinishDataProto类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：19174|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9986|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8325|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8695|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8638|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9654|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8621|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7998|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8652|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7535|2022-11-06

客服电话

电子邮件

Java WorkflowAction类代码示例

示例1: asAction

示例2: setWorkflowjob

示例3: copyTTlogs

示例4: getMappedStatus

示例5: getWorkflowActionInfo

示例6: copyTTlogs

示例7: getMappedStatus

示例8: fetchActionDuration

示例9: run

示例10: fetchWorkflowActions

请发表评论

全部评论

上一篇：

下一篇：

xorrior/macOSTools: macOS Offensive Tool

caseypugh/minecraft: Some scripts to mak

Testinium/MobileDeviceInfo

xsfelvis/MaterialDesignStudy: A practic

delphi 数据导出进度条自己生成

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053

客服电话

电子邮件

Java WorkflowAction类代码示例

示例1: asAction

示例2: setWorkflowjob

示例3: copyTTlogs

示例4: getMappedStatus

示例5: getWorkflowActionInfo

示例6: copyTTlogs

示例7: getMappedStatus

示例8: fetchActionDuration

示例9: run

示例10: fetchWorkflowActions

请发表评论

全部评论

上一篇：

下一篇：

xorrior/macOSTools: macOS Offensive Tool

caseypugh/minecraft: Some scripts to mak

Testinium/MobileDeviceInfo

xsfelvis/MaterialDesignStudy: A practic

delphi 数据导出 进度条自己生成

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053

delphi 数据导出进度条自己生成