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

WorkflowConfig.getWorkflowType介绍

暂无

代码示例

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

public void updateWorkflowCounters(WorkflowConfig workflowConfig, TaskState to, long latency) {
 String workflowType = workflowConfig.getWorkflowType();
 workflowType = preProcessWorkflow(workflowType);
 WorkflowMonitor workflowMonitor = _perTypeWorkflowMonitorMap.get(workflowType);
 if (workflowMonitor != null) {
  workflowMonitor.updateWorkflowCounters(to, latency);
 }
}

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

/**
  * Returns the correct type for this job. Note that if the parent workflow has a type, then all of
  * its jobs will inherit the type from the workflow.
  * @param workflowConfig
  * @param jobConfig
  * @return
  */
 String getQuotaType(WorkflowConfig workflowConfig, JobConfig jobConfig) {
  String workflowType = workflowConfig.getWorkflowType();
  if (workflowType == null || workflowType.equals("")) {
   // Workflow type is null, so we go by the job type
   String jobType = jobConfig.getJobType();
   if (jobType == null || jobType.equals("")) {
    // Job type is null, so we use DEFAULT
    return AssignableInstance.DEFAULT_QUOTA_TYPE;
   }
   return jobType;
  }
  return workflowType;
 }
}

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

/**
  * Returns the correct type for this job. Note that if the parent workflow has a type, then all of
  * its jobs will inherit the type from the workflow.
  * @param workflowConfig
  * @param jobConfig
  * @return
  */
 String getQuotaType(WorkflowConfig workflowConfig, JobConfig jobConfig) {
  String workflowType = workflowConfig.getWorkflowType();
  if (workflowType == null || workflowType.equals("")) {
   // Workflow type is null, so we go by the job type
   String jobType = jobConfig.getJobType();
   if (jobType == null || jobType.equals("")) {
    // Job type is null, so we use DEFAULT
    return AssignableInstance.DEFAULT_QUOTA_TYPE;
   }
   return jobType;
  }
  return workflowType;
 }
}

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

private void updateWorkflowGauges(WorkflowConfig workflowConfig, TaskState current) {
 String workflowType = workflowConfig.getWorkflowType();
 workflowType = preProcessWorkflow(workflowType);
 _perTypeWorkflowMonitorMap.get(workflowType).updateWorkflowGauges(current);
}

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

public void updateWorkflowCounters(WorkflowConfig workflowConfig, TaskState to, long latency) {
 String workflowType = workflowConfig.getWorkflowType();
 workflowType = preProcessWorkflow(workflowType);
 _perTypeWorkflowMonitorMap.get(workflowType).updateWorkflowCounters(to, latency);
}

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

private void updateWorkflowGauges(WorkflowConfig workflowConfig, TaskState current) {
 String workflowType = workflowConfig.getWorkflowType();
 workflowType = preProcessWorkflow(workflowType);
 WorkflowMonitor workflowMonitor = _perTypeWorkflowMonitorMap.get(workflowType);
 if (workflowMonitor != null) {
  workflowMonitor.updateWorkflowGauges(current);
 }
}

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

@Test
 public void testJobAndWorkflowType() throws InterruptedException {
  LOG.info("Start testing job and workflow type");
  String jobName = TestHelper.getTestMethodName();
  JobConfig.Builder jobConfig = JobConfig.Builder.fromMap(WorkflowGenerator.DEFAULT_JOB_CONFIG)
    .setJobCommandConfigMap(WorkflowGenerator.DEFAULT_COMMAND_CONFIG).setJobType(DEFAULT_TYPE);

  Map<String, String> tmp = new HashMap<>();
  tmp.put("WorkflowType", DEFAULT_TYPE);
  Workflow.Builder builder =
    WorkflowGenerator.generateSingleJobWorkflowBuilder(jobName, jobConfig).fromMap(tmp);

  // Start workflow
  _driver.start(builder.build());

  _driver.pollForWorkflowState(jobName, TaskState.COMPLETED);
  String fetchedJobType =
    _driver.getJobConfig(String.format("%s_%s", jobName, jobName)).getJobType();
  String fetchedWorkflowType =
    _driver.getWorkflowConfig(jobName).getWorkflowType();

  Assert.assertEquals(fetchedJobType, DEFAULT_TYPE);
  Assert.assertEquals(fetchedWorkflowType, DEFAULT_TYPE);
 }
}

代码示例来源：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: 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();
}

代码示例来源：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();
}