本文整理了Java中org.apache.helix.task.WorkflowContext.getScheduledWorkflows()
方法的一些代码示例,展示了WorkflowContext.getScheduledWorkflows()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WorkflowContext.getScheduledWorkflows()
方法的具体详情如下:
包路径:org.apache.helix.task.WorkflowContext
类名称: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();
内容来源于网络,如有侵权,请联系作者删除!