/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.dolphinscheduler.remote.command; import com.fasterxml.jackson.annotation.JsonFormat; import java.io.Serializable; import java.util.Date; /** * master/worker task transport */ public class TaskInfo implements Serializable{ /** * task instance id */ private Integer taskId; /** * task name */ private String taskName; /** * task start time */ @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone="GMT+8") private Date startTime; /** * task type */ private String taskType; /** * task execute path */ private String executePath; /** * task json */ private String taskJson; /** * process instance id */ private Integer processInstanceId; /** * process instance schedule time */ @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone="GMT+8") private Date scheduleTime; /** * process instance global parameters */ private String globalParams; /** * execute user id */ private Integer executorId; /** * command type if complement */ private Integer cmdTypeIfComplement; /** * tenant code */ private String tenantCode; /** * task queue */ private String queue; /** * process define id */ private Integer processDefineId; /** * project id */ private Integer projectId; public Integer getTaskId() { return taskId; } public void setTaskId(Integer taskId) { this.taskId = taskId; } public String getTaskName() { return taskName; } public void setTaskName(String taskName) { this.taskName = taskName; } public Date getStartTime() { return startTime; } public void setStartTime(Date startTime) { this.startTime = startTime; } public String getTaskType() { return taskType; } public void setTaskType(String taskType) { this.taskType = taskType; } public String getExecutePath() { return executePath; } public void setExecutePath(String executePath) { this.executePath = executePath; } public String getTaskJson() { return taskJson; } public void setTaskJson(String taskJson) { this.taskJson = taskJson; } public Integer getProcessInstanceId() { return processInstanceId; } public void setProcessInstanceId(Integer processInstanceId) { this.processInstanceId = processInstanceId; } public Date getScheduleTime() { return scheduleTime; } public void setScheduleTime(Date scheduleTime) { this.scheduleTime = scheduleTime; } public String getGlobalParams() { return globalParams; } public void setGlobalParams(String globalParams) { this.globalParams = globalParams; } public String getTenantCode() { return tenantCode; } public void setTenantCode(String tenantCode) { this.tenantCode = tenantCode; } public String getQueue() { return queue; } public void setQueue(String queue) { this.queue = queue; } public Integer getProcessDefineId() { return processDefineId; } public void setProcessDefineId(Integer processDefineId) { this.processDefineId = processDefineId; } public Integer getProjectId() { return projectId; } public void setProjectId(Integer projectId) { this.projectId = projectId; } public Integer getExecutorId() { return executorId; } public void setExecutorId(Integer executorId) { this.executorId = executorId; } public Integer getCmdTypeIfComplement() { return cmdTypeIfComplement; } public void setCmdTypeIfComplement(Integer cmdTypeIfComplement) { this.cmdTypeIfComplement = cmdTypeIfComplement; } @Override public String toString() { return "TaskInfo{" + "taskId=" + taskId + ", taskName='" + taskName + '\'' + ", startTime=" + startTime + ", taskType='" + taskType + '\'' + ", executePath='" + executePath + '\'' + ", taskJson='" + taskJson + '\'' + ", processInstanceId=" + processInstanceId + ", scheduleTime=" + scheduleTime + ", globalParams='" + globalParams + '\'' + ", executorId=" + executorId + ", cmdTypeIfComplement=" + cmdTypeIfComplement + ", tenantCode='" + tenantCode + '\'' + ", queue='" + queue + '\'' + ", processDefineId=" + processDefineId + ", projectId=" + projectId + '}'; } }