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

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

本文整理了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

  1. public void setLastScheduledSingleWorkflow(String workflow) {
  2. _record.setSimpleField(WorkflowContextProperties.LAST_SCHEDULED_WORKFLOW.name(), workflow);
  3. // Record scheduled workflow into the history list as well
  4. List<String> workflows = getScheduledWorkflows();
  5. if (workflows == null) {
  6. workflows = new ArrayList<String>();
  7. _record.setListField(WorkflowContextProperties.SCHEDULED_WORKFLOWS.name(), workflows);
  8. }
  9. workflows.add(workflow);
  10. }

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

  1. public void setLastScheduledSingleWorkflow(String workflow) {
  2. _record.setSimpleField(WorkflowContextProperties.LAST_SCHEDULED_WORKFLOW.name(), workflow);
  3. // Record scheduled workflow into the history list as well
  4. List<String> workflows = getScheduledWorkflows();
  5. if (workflows == null) {
  6. workflows = new ArrayList<String>();
  7. _record.setListField(WorkflowContextProperties.SCHEDULED_WORKFLOWS.name(), workflows);
  8. }
  9. workflows.add(workflow);
  10. }

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

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

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

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

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

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

相关文章