org.apache.helix.task.WorkflowContext.getScheduledWorkflows()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(2.1k)|赞(0)|评价(0)|浏览(140)

本文整理了Java中org.apache.helix.task.WorkflowContext.getScheduledWorkflows()方法的一些代码示例,展示了WorkflowContext.getScheduledWorkflows()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WorkflowContext.getScheduledWorkflows()方法的具体详情如下:
包路径:org.apache.helix.task.WorkflowContext
类名称:WorkflowContext
方法名:getScheduledWorkflows

WorkflowContext.getScheduledWorkflows介绍

暂无

代码示例

代码示例来源:origin: org.apache.helix/helix-core

public void setLastScheduledSingleWorkflow(String workflow) {
 _record.setSimpleField(WorkflowContextProperties.LAST_SCHEDULED_WORKFLOW.name(), workflow);
 // Record scheduled workflow into the history list as well
 List<String> workflows = getScheduledWorkflows();
 if (workflows == null) {
  workflows = new ArrayList<String>();
  _record.setListField(WorkflowContextProperties.SCHEDULED_WORKFLOWS.name(), workflows);
 }
 workflows.add(workflow);
}

代码示例来源:origin: apache/helix

public void setLastScheduledSingleWorkflow(String workflow) {
 _record.setSimpleField(WorkflowContextProperties.LAST_SCHEDULED_WORKFLOW.name(), workflow);
 // Record scheduled workflow into the history list as well
 List<String> workflows = getScheduledWorkflows();
 if (workflows == null) {
  workflows = new ArrayList<String>();
  _record.setListField(WorkflowContextProperties.SCHEDULED_WORKFLOWS.name(), workflows);
 }
 workflows.add(workflow);
}

代码示例来源:origin: apache/helix

if (wCtx != null && wCtx.getScheduledWorkflows() != null) {
 for (String scheduledWorkflow : wCtx.getScheduledWorkflows()) {
  WorkflowContext scheduledWorkflowCtx =
    TaskUtil.getWorkflowContext(_propertyStore, scheduledWorkflow);

代码示例来源:origin: org.apache.helix/helix-core

if (wCtx != null && wCtx.getScheduledWorkflows() != null) {
 for (String scheduledWorkflow : wCtx.getScheduledWorkflows()) {
  WorkflowContext scheduledWorkflowCtx =
    TaskUtil.getWorkflowContext(_propertyStore, scheduledWorkflow);

代码示例来源:origin: apache/helix

Thread.sleep(60000);
 wCtx = TaskTestUtil.pollForWorkflowContext(_driver, queueName);
} while (wCtx.getScheduledWorkflows().size() < 2);
List<String> scheduledWorkflows = new ArrayList<String>(wCtx.getScheduledWorkflows());
final String lastScheduledWorkflow = wCtx.getLastScheduledSingleWorkflow();

相关文章