com.hazelcast.jet.impl.util.Util.toLocalDateTime()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(4.6k)|赞(0)|评价(0)|浏览(569)

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

Util.toLocalDateTime介绍

暂无

代码示例

代码示例来源:origin: hazelcast/hazelcast-jet-demos

  1. @Override
  2. public String toString() {
  3. return "CarCount{" +
  4. "location='" + location + '\'' +
  5. ", time=" + toLocalDateTime(time) +
  6. ", count=" + count +
  7. '}';
  8. }
  9. }

代码示例来源:origin: hazelcast/hazelcast-jet-demos

  1. @Override
  2. public String toString() {
  3. return "TrendKey{" +
  4. "location='" + location + '\'' +
  5. ", time=" + toLocalDateTime(time) +
  6. '}';
  7. }
  8. }

代码示例来源:origin: hazelcast/hazelcast-jet-demos

  1. @Override
  2. public String toString() {
  3. return "Prediction{" +
  4. "location='" + location + '\'' +
  5. ", time=" + toLocalDateTime(time) + " (" + time + ")" +
  6. ", predictedCounts=" + Arrays.toString(predictedCounts) +
  7. '}';
  8. }
  9. }

代码示例来源:origin: hazelcast/hazelcast-jet

  1. @Override
  2. public String toString() {
  3. return "JobResult{" +
  4. "coordinatorUUID='" + coordinatorUUID + '\'' +
  5. ", jobId=" + idToString(jobId) +
  6. ", name=" + jobConfig.getName() +
  7. ", creationTime=" + toLocalDateTime(creationTime) +
  8. ", completionTime=" + toLocalDateTime(completionTime) +
  9. ", failureText=" + failureText +
  10. '}';
  11. }

代码示例来源:origin: hazelcast/hazelcast-jet

  1. @Override
  2. public String toString() {
  3. StringJoiner sj = new StringJoiner(", ", getClass().getSimpleName() + '{', "}");
  4. for (int i = 0; i < size; i++) {
  5. sj.add("[s=" + toLocalDateTime(starts[i]).toLocalTime()
  6. + ", e=" + toLocalDateTime(ends[i]).toLocalTime()
  7. + ", a=" + accs[i] + ']');
  8. }
  9. return sj.toString();
  10. }
  11. }

代码示例来源:origin: hazelcast/hazelcast-jet-demos

  1. @Override
  2. public String toString() {
  3. return "Aircraft{" +
  4. "reg='" + reg + '\'' +
  5. ", alt=" + alt +
  6. ", coord=" + String.format("%.2f,%.2f", lat, lon) +
  7. ", mdl='" + mdl + '\'' +
  8. ", city='" + airport + '\'' +
  9. ", posTime=" + Util.toLocalDateTime(posTime).toLocalTime() +
  10. '}';
  11. }

代码示例来源:origin: hazelcast/hazelcast-jet-demos

  1. ", lon=" + lon +
  2. ", city=" + airport +
  3. ", posTime=" + Util.toLocalDateTime(posTime) +
  4. ", posTimeTs=" + posTime +
  5. ", posStale=" + posStale +

代码示例来源:origin: hazelcast/hazelcast-jet

  1. @Override
  2. public String toString() {
  3. return "JobRecord{" +
  4. "jobId=" + idToString(jobId) +
  5. ", name=" + getConfig().getName() +
  6. ", creationTime=" + toLocalDateTime(creationTime) +
  7. ", dagJson=" + dagJson +
  8. ", config=" + config +
  9. '}';
  10. }
  11. }

代码示例来源:origin: hazelcast/hazelcast-jet

  1. private static String formatJob(Job job) {
  2. return "id=" + idToString(job.getId())
  3. + ", name=" + job.getName()
  4. + ", submissionTime=" + toLocalDateTime(job.getSubmissionTime());
  5. }

代码示例来源:origin: hazelcast/hazelcast-jet

  1. @Override
  2. public String toString() {
  3. return "Job{id=" + getIdString()
  4. + ", name=" + getName()
  5. + ", submissionTime=" + toLocalDateTime(getSubmissionTime())
  6. + ", status=" + getStatus()
  7. + "}";
  8. }

代码示例来源:origin: hazelcast/hazelcast-jet

  1. @Command(
  2. description = "Lists running jobs on the cluster"
  3. )
  4. public void jobs(
  5. @Option(names = {"-a", "--all"},
  6. description = "Lists all jobs including completed and failed ones")
  7. boolean listAll
  8. ) throws IOException {
  9. runWithJet(jet -> {
  10. JetClientInstanceImpl client = (JetClientInstanceImpl) jet;
  11. List<JobSummary> summaries = client.getJobSummaryList();
  12. String format = "%-24s %-19s %-18s %-23s%n";
  13. printf(format, "NAME", "ID", "STATUS", "SUBMISSION TIME");
  14. summaries.stream()
  15. .filter(job -> listAll || isActive(job.getStatus()))
  16. .forEach(job -> {
  17. String idString = idToString(job.getJobId());
  18. String name = job.getName().equals(idString) ? "N/A" : shorten(job.getName(), MAX_STR_LENGTH);
  19. printf(format,
  20. name, idString, job.getStatus(), toLocalDateTime(job.getSubmissionTime())
  21. );
  22. });
  23. });
  24. }

代码示例来源:origin: hazelcast/hazelcast-jet

  1. @Command(
  2. description = "Lists saved snapshots on the cluster"
  3. )
  4. public void snapshots() throws IOException {
  5. runWithJet(jet -> {
  6. Collection<JobStateSnapshot> snapshots = jet.getJobStateSnapshots();
  7. printf("%-24s %-15s %-23s %-24s%n", "NAME", "SIZE (bytes)", "TIME", "JOB NAME");
  8. snapshots.forEach(ss -> {
  9. String jobName = ss.jobName() == null ? Util.idToString(ss.jobId()) : ss.jobName();
  10. jobName = shorten(jobName, MAX_STR_LENGTH);
  11. String ssName = shorten(ss.name(), MAX_STR_LENGTH);
  12. LocalDateTime creationTime = toLocalDateTime(ss.creationTime());
  13. printf("%-24s %-,15d %-23s %-24s%n", ssName, ss.payloadSize(), creationTime, jobName);
  14. });
  15. });
  16. }

相关文章