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

ZkWorker.setLastCompletedTaskTime介绍

暂无

代码示例

代码示例来源：origin: com.n3twork.druid/druid-indexing-service

private void taskComplete(
   RemoteTaskRunnerWorkItem taskRunnerWorkItem,
   ZkWorker zkWorker,
   TaskStatus taskStatus
 )
 {
  Preconditions.checkNotNull(taskRunnerWorkItem, "taskRunnerWorkItem");
  Preconditions.checkNotNull(zkWorker, "zkWorker");
  Preconditions.checkNotNull(taskStatus, "taskStatus");
  log.info(
    "Worker[%s] completed task[%s] with status[%s]",
    zkWorker.getWorker().getHost(),
    taskStatus.getId(),
    taskStatus.getStatusCode()
  );
  // Worker is done with this task
  zkWorker.setLastCompletedTaskTime(new DateTime());
  // Move from running -> complete
  completeTasks.put(taskStatus.getId(), taskRunnerWorkItem);
  runningTasks.remove(taskStatus.getId());
  // Notify interested parties
  final ListenableFuture<TaskStatus> result = taskRunnerWorkItem.getResult();
  if (result != null) {
   ((SettableFuture<TaskStatus>) result).set(taskStatus);
  }
 }
}

代码示例来源：origin: io.druid/druid-indexing-service

);
 zkWorker.setLastCompletedTaskTime(DateTimes.nowUtc());
} else {
 log.info("Workerless task[%s] completed with status[%s]", taskStatus.getId(), taskStatus.getStatusCode());