gpt4 book ai didi

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

转载 作者:知者 更新时间:2024-03-24 02:23:05 24 4
gpt4 key购买 nike

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

WorkflowConfig.getScheduleConfig介绍

暂无

代码示例

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

String workflowResource, String jobResource, ClusterDataCache cache) {
if (workflowCfg == null || workflowCfg.getScheduleConfig() == null) {
 return true;
ScheduleConfig scheduleConfig = workflowCfg.getScheduleConfig();
Date startTime = scheduleConfig.getStartTime();
long currentTime = new Date().getTime();

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

String workflowResource, String jobResource, ClusterDataCache cache) {
if (workflowCfg == null || workflowCfg.getScheduleConfig() == null) {
 return true;
ScheduleConfig scheduleConfig = workflowCfg.getScheduleConfig();
Date startTime = scheduleConfig.getStartTime();
long currentTime = new Date().getTime();

代码示例来源:origin: com.linkedin.gobblin/gobblin-cluster

(workflowCfg.getScheduleConfig() != null && workflowCfg.getScheduleConfig().isRecurring());

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

WorkflowContext workflowCtx, TaskDataCache cache) {
if (workflowCfg == null || workflowCfg.getScheduleConfig() == null) {
 return true;
ScheduleConfig scheduleConfig = workflowCfg.getScheduleConfig();
Date startTime = scheduleConfig.getStartTime();
long currentTime = new Date().getTime();

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

WorkflowContext workflowCtx, ClusterDataCache cache) {
if (workflowCfg == null || workflowCfg.getScheduleConfig() == null) {
 return true;
ScheduleConfig scheduleConfig = workflowCfg.getScheduleConfig();
Date startTime = scheduleConfig.getStartTime();
long currentTime = new Date().getTime();

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

(workflowCfg.getScheduleConfig() != null && workflowCfg.getScheduleConfig().isRecurring());

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

(workflowCfg.getScheduleConfig() != null && workflowCfg.getScheduleConfig().isRecurring());

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

WorkflowContext workflowCtx, Map<String, JobConfig> jobConfigMap,
 ClusterDataCache clusterDataCache) {
ScheduleConfig scheduleConfig = workflowCfg.getScheduleConfig();
if (scheduleConfig != null && scheduleConfig.isRecurring()) {
 LOG.debug("Jobs from recurring workflow are not schedule-able");

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

WorkflowContext workflowCtx, Map<String, JobConfig> jobConfigMap,
 TaskDataCache clusterDataCache) {
ScheduleConfig scheduleConfig = workflowCfg.getScheduleConfig();
if (scheduleConfig != null && scheduleConfig.isRecurring()) {
 LOG.debug("Jobs from recurring workflow are not schedule-able");

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

public WorkflowConfig(WorkflowConfig cfg, String workflowId) {
 this(workflowId, cfg.getJobDag(), cfg.getParallelJobs(), cfg.getTargetState(), cfg.getExpiry(),
   cfg.getFailureThreshold(), cfg.isTerminable(), cfg.getScheduleConfig(), cfg.getCapacity(),
   cfg.getWorkflowType(), cfg.isJobQueue(), cfg.getJobTypes(), cfg.getJobPurgeInterval(),
   cfg.isAllowOverlapJobAssignment(), cfg.getTimeout());
}

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

public WorkflowConfig(WorkflowConfig cfg, String workflowId) {
 this(workflowId, cfg.getJobDag(), cfg.getParallelJobs(), cfg.getTargetState(), cfg.getExpiry(),
   cfg.getFailureThreshold(), cfg.isTerminable(), cfg.getScheduleConfig(), cfg.getCapacity(),
   cfg.getWorkflowType(), cfg.isJobQueue(), cfg.getJobTypes(), cfg.getJobPurgeInterval(),
   cfg.isAllowOverlapJobAssignment(), cfg.getTimeout());
}

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

public Builder(WorkflowConfig workflowConfig) {
 _workflowId = workflowConfig.getWorkflowId();
 _taskDag = workflowConfig.getJobDag();
 _parallelJobs = workflowConfig.getParallelJobs();
 _targetState = workflowConfig.getTargetState();
 _expiry = workflowConfig.getExpiry();
 _isTerminable = workflowConfig.isTerminable();
 _scheduleConfig = workflowConfig.getScheduleConfig();
 _capacity = workflowConfig.getCapacity();
 _failureThreshold = workflowConfig.getFailureThreshold();
 _workflowType = workflowConfig.getWorkflowType();
 _isJobQueue = workflowConfig.isJobQueue();
 _jobTypes = workflowConfig.getJobTypes();
 _jobPurgeInterval = workflowConfig.getJobPurgeInterval();
 _allowOverlapJobAssignment = workflowConfig.isAllowOverlapJobAssignment();
 _timeout = workflowConfig.getTimeout();
}

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

public Builder(WorkflowConfig workflowConfig) {
 _workflowId = workflowConfig.getWorkflowId();
 _taskDag = workflowConfig.getJobDag();
 _parallelJobs = workflowConfig.getParallelJobs();
 _targetState = workflowConfig.getTargetState();
 _expiry = workflowConfig.getExpiry();
 _isTerminable = workflowConfig.isTerminable();
 _scheduleConfig = workflowConfig.getScheduleConfig();
 _capacity = workflowConfig.getCapacity();
 _failureThreshold = workflowConfig.getFailureThreshold();
 _workflowType = workflowConfig.getWorkflowType();
 _isJobQueue = workflowConfig.isJobQueue();
 _jobTypes = workflowConfig.getJobTypes();
 _jobPurgeInterval = workflowConfig.getJobPurgeInterval();
 _allowOverlapJobAssignment = workflowConfig.isAllowOverlapJobAssignment();
 _timeout = workflowConfig.getTimeout();
}

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com