in manager/manager/src/main/java/org/apache/doris/stack/model/palo/HdfsImportTaskInfo.java [79:140]
public HdfsImportTaskInfo(NativeQueryResp result) {
List<NativeQueryResp.Meta> metaList = result.getMeta();
List<String> data = result.getData().get(0);
int index = 0;
for (NativeQueryResp.Meta meta : metaList) {
if (data.get(index) == null || data.get(index).isEmpty()) {
index++;
continue;
}
switch (meta.getName()) {
case "JobId":
this.jobId = data.get(index);
break;
case "Label":
this.label = data.get(index);
break;
case "State":
this.state = data.get(index);
break;
case "Progress":
this.progress = data.get(index);
break;
case "Type":
this.type = data.get(index);
break;
case "EtlInfo":
this.etlInfo = data.get(index);
break;
case "TaskInfo":
this.taskInfo = data.get(index);
break;
case "ErrorMsg":
this.errorMsg = data.get(index);
break;
case "CreateTime":
this.createTime = Timestamp.valueOf(data.get(index));
break;
case "EtlStartTime":
this.etlStartTime = Timestamp.valueOf(data.get(index));
break;
case "EtlFinishTime":
this.etlFinishTime = Timestamp.valueOf(data.get(index));
break;
case "LoadStartTime":
this.loadStartTime = Timestamp.valueOf(data.get(index));
break;
case "LoadFinishTime":
this.loadFinishTime = Timestamp.valueOf(data.get(index));
break;
case "URL":
this.url = data.get(index);
break;
case "JobDetails":
String details = data.get(index).replaceAll(" ", "");
this.jobDetails = JSON.parseObject(details, JobDetails.class);
break;
default:
break;
}
index++;
}
}