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

WorkflowContext.setFinishTime介绍

暂无

代码示例

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

private void markJobComplete(String jobName, JobContext jobContext,
  WorkflowConfig workflowConfig, WorkflowContext workflowContext) {
 long currentTime = System.currentTimeMillis();
 workflowContext.setJobState(jobName, TaskState.COMPLETED);
 jobContext.setFinishTime(currentTime);
 if (isWorkflowFinished(workflowContext, workflowConfig)) {
  workflowContext.setFinishTime(currentTime);
 }
}

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

protected void markJobComplete(String jobName, JobContext jobContext,
  WorkflowConfig workflowConfig, WorkflowContext workflowContext,
  Map<String, JobConfig> jobConfigMap, ClusterDataCache clusterDataCache) {
 long currentTime = System.currentTimeMillis();
 workflowContext.setJobState(jobName, TaskState.COMPLETED);
 jobContext.setFinishTime(currentTime);
 if (isWorkflowFinished(workflowContext, workflowConfig, jobConfigMap, clusterDataCache)) {
  workflowContext.setFinishTime(currentTime);
  updateWorkflowMonitor(workflowContext, workflowConfig);
 }
 scheduleJobCleanUp(jobConfigMap.get(jobName), workflowConfig, currentTime);
}

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

protected void markJobFailed(String jobName, JobContext jobContext, WorkflowConfig workflowConfig,
  WorkflowContext workflowContext, Map<String, JobConfig> jobConfigMap,
  ClusterDataCache clusterDataCache) {
 long currentTime = System.currentTimeMillis();
 workflowContext.setJobState(jobName, TaskState.FAILED);
 if (jobContext != null) {
  jobContext.setFinishTime(currentTime);
 }
 if (isWorkflowFinished(workflowContext, workflowConfig, jobConfigMap, clusterDataCache)) {
  workflowContext.setFinishTime(currentTime);
  updateWorkflowMonitor(workflowContext, workflowConfig);
 }
 scheduleJobCleanUp(jobConfigMap.get(jobName), workflowConfig, currentTime);
}

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

protected void markJobFailed(String jobName, JobContext jobContext, WorkflowConfig workflowConfig,
  WorkflowContext workflowContext, Map<String, JobConfig> jobConfigMap,
  TaskDataCache clusterDataCache) {
 long currentTime = System.currentTimeMillis();
 workflowContext.setJobState(jobName, TaskState.FAILED);
 if (jobContext != null) {
  jobContext.setFinishTime(currentTime);
 }
 if (isWorkflowFinished(workflowContext, workflowConfig, jobConfigMap, clusterDataCache)) {
  workflowContext.setFinishTime(currentTime);
  updateWorkflowMonitor(workflowContext, workflowConfig);
 }
 scheduleJobCleanUp(jobConfigMap.get(jobName), workflowConfig, currentTime);
}

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

protected void markJobComplete(String jobName, JobContext jobContext,
  WorkflowConfig workflowConfig, WorkflowContext workflowContext,
  Map<String, JobConfig> jobConfigMap, ClusterDataCache clusterDataCache) {
 long currentTime = System.currentTimeMillis();
 workflowContext.setJobState(jobName, TaskState.COMPLETED);
 jobContext.setFinishTime(currentTime);
 if (isWorkflowFinished(workflowContext, workflowConfig, jobConfigMap, clusterDataCache.getTaskDataCache())) {
  workflowContext.setFinishTime(currentTime);
  updateWorkflowMonitor(workflowContext, workflowConfig);
 }
 scheduleJobCleanUp(jobConfigMap.get(jobName), workflowConfig, currentTime);
}

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

if (workflowConfig.isTerminable()) {
     workflowCtx.setWorkflowState(TaskState.FAILED);
     workflowCtx.setFinishTime(finishTime);
if (isWorkflowComplete(workflowCtx, workflowConfig)) {
 workflowCtx.setWorkflowState(TaskState.COMPLETED);
 workflowCtx.setFinishTime(currentTime);

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

if (workflowConfig.isTerminable()) {
     workflowCtx.setWorkflowState(TaskState.FAILED);
     workflowCtx.setFinishTime(finishTime);
if (isWorkflowComplete(workflowCtx, workflowConfig)) {
 workflowCtx.setWorkflowState(TaskState.COMPLETED);
 workflowCtx.setFinishTime(currentTime);

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

workflowCtx.setFinishTime(currentTime);
updateWorkflowMonitor(workflowCtx, workflowCfg);
_taskDataCache.updateWorkflowContext(workflow, workflowCtx);

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

workflowCtx.setFinishTime(currentTime);
updateWorkflowMonitor(workflowCtx, workflowCfg);
clusterData.updateWorkflowContext(workflow, workflowCtx, _manager.getHelixDataAccessor());