MaxComputeDetailOutput.java 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104
  1. package com.winhc.bigdata.task.entity;
  2. import com.baomidou.mybatisplus.annotation.TableField;
  3. import com.baomidou.mybatisplus.annotation.TableId;
  4. import com.baomidou.mybatisplus.annotation.TableLogic;
  5. import com.baomidou.mybatisplus.annotation.TableName;
  6. import com.winhc.bigdata.task.enums.TaskStatusEnum;
  7. import com.winhc.bigdata.task.util.JsonUtils;
  8. import lombok.Builder;
  9. import lombok.Data;
  10. import org.apache.commons.lang3.builder.EqualsBuilder;
  11. import org.apache.commons.lang3.builder.HashCodeBuilder;
  12. import java.io.Serializable;
  13. import java.util.Date;
  14. /**
  15. * max compute输出表详细信息
  16. *
  17. * @author x
  18. * @TableName max_compute_detail_output
  19. */
  20. @Builder
  21. @TableName(value = "max_compute_detail_output")
  22. @Data
  23. public class MaxComputeDetailOutput implements Serializable {
  24. /**
  25. *
  26. */
  27. @TableId
  28. private Long id;
  29. /**
  30. * pull data task 任务id
  31. */
  32. private String taskId;
  33. private Long dagId;
  34. /**
  35. * max compute table name
  36. */
  37. private String maxComputeTableName;
  38. /**
  39. * 分区名
  40. */
  41. private String partitionName;
  42. /**
  43. * 该分区数量
  44. */
  45. private Long recordCount;
  46. /**
  47. * 优先级
  48. */
  49. private Integer priorityLevel;
  50. /**
  51. * 该分区任务状态
  52. */
  53. private TaskStatusEnum partitionTaskStatus;
  54. /**
  55. *
  56. */
  57. private Date updateTime;
  58. /**
  59. *
  60. */
  61. private Date createTime;
  62. /**
  63. *
  64. */
  65. @TableLogic
  66. private Integer deleted;
  67. @TableField(exist = false)
  68. private static final long serialVersionUID = 112L;
  69. @Override
  70. public boolean equals(Object o) {
  71. if (this == o) return true;
  72. if (o == null || getClass() != o.getClass()) return false;
  73. MaxComputeDetailOutput that = (MaxComputeDetailOutput) o;
  74. return new EqualsBuilder().append(id, that.id).append(taskId, that.taskId).append(dagId, that.dagId).append(maxComputeTableName, that.maxComputeTableName).append(partitionName, that.partitionName).append(recordCount, that.recordCount).append(priorityLevel, that.priorityLevel).append(partitionTaskStatus, that.partitionTaskStatus).append(updateTime, that.updateTime).append(createTime, that.createTime).append(deleted, that.deleted).isEquals();
  75. }
  76. @Override
  77. public int hashCode() {
  78. return new HashCodeBuilder(17, 37).append(id).append(taskId).append(dagId).append(maxComputeTableName).append(partitionName).append(recordCount).append(priorityLevel).append(partitionTaskStatus).append(updateTime).append(createTime).append(deleted).toHashCode();
  79. }
  80. @Override
  81. public String toString() {
  82. return JsonUtils.jsonObjToString(this);
  83. }
  84. }