TReportExecStatusParams.java
/**
* Autogenerated by Thrift Compiler (0.16.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.doris.thrift;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.16.0)", date = "2026-05-14")
public class TReportExecStatusParams implements org.apache.thrift.TBase<TReportExecStatusParams, TReportExecStatusParams._Fields>, java.io.Serializable, Cloneable, Comparable<TReportExecStatusParams> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TReportExecStatusParams");
private static final org.apache.thrift.protocol.TField PROTOCOL_VERSION_FIELD_DESC = new org.apache.thrift.protocol.TField("protocol_version", org.apache.thrift.protocol.TType.I32, (short)1);
private static final org.apache.thrift.protocol.TField QUERY_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("query_id", org.apache.thrift.protocol.TType.STRUCT, (short)2);
private static final org.apache.thrift.protocol.TField BACKEND_NUM_FIELD_DESC = new org.apache.thrift.protocol.TField("backend_num", org.apache.thrift.protocol.TType.I32, (short)3);
private static final org.apache.thrift.protocol.TField FRAGMENT_INSTANCE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("fragment_instance_id", org.apache.thrift.protocol.TType.STRUCT, (short)4);
private static final org.apache.thrift.protocol.TField STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("status", org.apache.thrift.protocol.TType.STRUCT, (short)5);
private static final org.apache.thrift.protocol.TField DONE_FIELD_DESC = new org.apache.thrift.protocol.TField("done", org.apache.thrift.protocol.TType.BOOL, (short)6);
private static final org.apache.thrift.protocol.TField PROFILE_FIELD_DESC = new org.apache.thrift.protocol.TField("profile", org.apache.thrift.protocol.TType.STRUCT, (short)7);
private static final org.apache.thrift.protocol.TField ERROR_LOG_FIELD_DESC = new org.apache.thrift.protocol.TField("error_log", org.apache.thrift.protocol.TType.LIST, (short)9);
private static final org.apache.thrift.protocol.TField DELTA_URLS_FIELD_DESC = new org.apache.thrift.protocol.TField("delta_urls", org.apache.thrift.protocol.TType.LIST, (short)10);
private static final org.apache.thrift.protocol.TField LOAD_COUNTERS_FIELD_DESC = new org.apache.thrift.protocol.TField("load_counters", org.apache.thrift.protocol.TType.MAP, (short)11);
private static final org.apache.thrift.protocol.TField TRACKING_URL_FIELD_DESC = new org.apache.thrift.protocol.TField("tracking_url", org.apache.thrift.protocol.TType.STRING, (short)12);
private static final org.apache.thrift.protocol.TField EXPORT_FILES_FIELD_DESC = new org.apache.thrift.protocol.TField("export_files", org.apache.thrift.protocol.TType.LIST, (short)13);
private static final org.apache.thrift.protocol.TField COMMIT_INFOS_FIELD_DESC = new org.apache.thrift.protocol.TField("commitInfos", org.apache.thrift.protocol.TType.LIST, (short)14);
private static final org.apache.thrift.protocol.TField LOADED_ROWS_FIELD_DESC = new org.apache.thrift.protocol.TField("loaded_rows", org.apache.thrift.protocol.TType.I64, (short)15);
private static final org.apache.thrift.protocol.TField BACKEND_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("backend_id", org.apache.thrift.protocol.TType.I64, (short)16);
private static final org.apache.thrift.protocol.TField LOADED_BYTES_FIELD_DESC = new org.apache.thrift.protocol.TField("loaded_bytes", org.apache.thrift.protocol.TType.I64, (short)17);
private static final org.apache.thrift.protocol.TField ERROR_TABLET_INFOS_FIELD_DESC = new org.apache.thrift.protocol.TField("errorTabletInfos", org.apache.thrift.protocol.TType.LIST, (short)18);
private static final org.apache.thrift.protocol.TField FRAGMENT_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("fragment_id", org.apache.thrift.protocol.TType.I32, (short)19);
private static final org.apache.thrift.protocol.TField QUERY_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("query_type", org.apache.thrift.protocol.TType.I32, (short)20);
private static final org.apache.thrift.protocol.TField LOAD_CHANNEL_PROFILE_FIELD_DESC = new org.apache.thrift.protocol.TField("loadChannelProfile", org.apache.thrift.protocol.TType.STRUCT, (short)21);
private static final org.apache.thrift.protocol.TField FINISHED_SCAN_RANGES_FIELD_DESC = new org.apache.thrift.protocol.TField("finished_scan_ranges", org.apache.thrift.protocol.TType.I32, (short)22);
private static final org.apache.thrift.protocol.TField DETAILED_REPORT_FIELD_DESC = new org.apache.thrift.protocol.TField("detailed_report", org.apache.thrift.protocol.TType.LIST, (short)23);
private static final org.apache.thrift.protocol.TField QUERY_STATISTICS_FIELD_DESC = new org.apache.thrift.protocol.TField("query_statistics", org.apache.thrift.protocol.TType.STRUCT, (short)24);
private static final org.apache.thrift.protocol.TField REPORT_WORKLOAD_RUNTIME_STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("report_workload_runtime_status", org.apache.thrift.protocol.TType.STRUCT, (short)25);
private static final org.apache.thrift.protocol.TField HIVE_PARTITION_UPDATES_FIELD_DESC = new org.apache.thrift.protocol.TField("hive_partition_updates", org.apache.thrift.protocol.TType.LIST, (short)26);
private static final org.apache.thrift.protocol.TField QUERY_PROFILE_FIELD_DESC = new org.apache.thrift.protocol.TField("query_profile", org.apache.thrift.protocol.TType.STRUCT, (short)27);
private static final org.apache.thrift.protocol.TField ICEBERG_COMMIT_DATAS_FIELD_DESC = new org.apache.thrift.protocol.TField("iceberg_commit_datas", org.apache.thrift.protocol.TType.LIST, (short)28);
private static final org.apache.thrift.protocol.TField TXN_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("txn_id", org.apache.thrift.protocol.TType.I64, (short)29);
private static final org.apache.thrift.protocol.TField LABEL_FIELD_DESC = new org.apache.thrift.protocol.TField("label", org.apache.thrift.protocol.TType.STRING, (short)30);
private static final org.apache.thrift.protocol.TField FRAGMENT_INSTANCE_REPORTS_FIELD_DESC = new org.apache.thrift.protocol.TField("fragment_instance_reports", org.apache.thrift.protocol.TType.LIST, (short)31);
private static final org.apache.thrift.protocol.TField MC_COMMIT_DATAS_FIELD_DESC = new org.apache.thrift.protocol.TField("mc_commit_datas", org.apache.thrift.protocol.TType.LIST, (short)32);
private static final org.apache.thrift.protocol.TField FIRST_ERROR_MSG_FIELD_DESC = new org.apache.thrift.protocol.TField("first_error_msg", org.apache.thrift.protocol.TType.STRING, (short)33);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TReportExecStatusParamsStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TReportExecStatusParamsTupleSchemeFactory();
/**
*
* @see FrontendServiceVersion
*/
public @org.apache.thrift.annotation.Nullable FrontendServiceVersion protocol_version; // required
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TUniqueId query_id; // optional
public int backend_num; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TUniqueId fragment_instance_id; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TStatus status; // optional
public boolean done; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TRuntimeProfileTree profile; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<java.lang.String> error_log; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<java.lang.String> delta_urls; // optional
public @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> load_counters; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String tracking_url; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<java.lang.String> export_files; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TTabletCommitInfo> commitInfos; // optional
public long loaded_rows; // optional
public long backend_id; // optional
public long loaded_bytes; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TErrorTabletInfo> errorTabletInfos; // optional
public int fragment_id; // optional
/**
*
* @see org.apache.doris.thrift.TQueryType
*/
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TQueryType query_type; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TRuntimeProfileTree loadChannelProfile; // optional
public int finished_scan_ranges; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<TDetailedReportParams> detailed_report; // optional
public @org.apache.thrift.annotation.Nullable TQueryStatistics query_statistics; // optional
public @org.apache.thrift.annotation.Nullable TReportWorkloadRuntimeStatusParams report_workload_runtime_status; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.THivePartitionUpdate> hive_partition_updates; // optional
public @org.apache.thrift.annotation.Nullable TQueryProfile query_profile; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TIcebergCommitData> iceberg_commit_datas; // optional
public long txn_id; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String label; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<TFragmentInstanceReport> fragment_instance_reports; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TMCCommitData> mc_commit_datas; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String first_error_msg; // optional
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
/**
*
* @see FrontendServiceVersion
*/
PROTOCOL_VERSION((short)1, "protocol_version"),
QUERY_ID((short)2, "query_id"),
BACKEND_NUM((short)3, "backend_num"),
FRAGMENT_INSTANCE_ID((short)4, "fragment_instance_id"),
STATUS((short)5, "status"),
DONE((short)6, "done"),
PROFILE((short)7, "profile"),
ERROR_LOG((short)9, "error_log"),
DELTA_URLS((short)10, "delta_urls"),
LOAD_COUNTERS((short)11, "load_counters"),
TRACKING_URL((short)12, "tracking_url"),
EXPORT_FILES((short)13, "export_files"),
COMMIT_INFOS((short)14, "commitInfos"),
LOADED_ROWS((short)15, "loaded_rows"),
BACKEND_ID((short)16, "backend_id"),
LOADED_BYTES((short)17, "loaded_bytes"),
ERROR_TABLET_INFOS((short)18, "errorTabletInfos"),
FRAGMENT_ID((short)19, "fragment_id"),
/**
*
* @see org.apache.doris.thrift.TQueryType
*/
QUERY_TYPE((short)20, "query_type"),
LOAD_CHANNEL_PROFILE((short)21, "loadChannelProfile"),
FINISHED_SCAN_RANGES((short)22, "finished_scan_ranges"),
DETAILED_REPORT((short)23, "detailed_report"),
QUERY_STATISTICS((short)24, "query_statistics"),
REPORT_WORKLOAD_RUNTIME_STATUS((short)25, "report_workload_runtime_status"),
HIVE_PARTITION_UPDATES((short)26, "hive_partition_updates"),
QUERY_PROFILE((short)27, "query_profile"),
ICEBERG_COMMIT_DATAS((short)28, "iceberg_commit_datas"),
TXN_ID((short)29, "txn_id"),
LABEL((short)30, "label"),
FRAGMENT_INSTANCE_REPORTS((short)31, "fragment_instance_reports"),
MC_COMMIT_DATAS((short)32, "mc_commit_datas"),
FIRST_ERROR_MSG((short)33, "first_error_msg");
private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>();
static {
for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
/**
* Find the _Fields constant that matches fieldId, or null if its not found.
*/
@org.apache.thrift.annotation.Nullable
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
case 1: // PROTOCOL_VERSION
return PROTOCOL_VERSION;
case 2: // QUERY_ID
return QUERY_ID;
case 3: // BACKEND_NUM
return BACKEND_NUM;
case 4: // FRAGMENT_INSTANCE_ID
return FRAGMENT_INSTANCE_ID;
case 5: // STATUS
return STATUS;
case 6: // DONE
return DONE;
case 7: // PROFILE
return PROFILE;
case 9: // ERROR_LOG
return ERROR_LOG;
case 10: // DELTA_URLS
return DELTA_URLS;
case 11: // LOAD_COUNTERS
return LOAD_COUNTERS;
case 12: // TRACKING_URL
return TRACKING_URL;
case 13: // EXPORT_FILES
return EXPORT_FILES;
case 14: // COMMIT_INFOS
return COMMIT_INFOS;
case 15: // LOADED_ROWS
return LOADED_ROWS;
case 16: // BACKEND_ID
return BACKEND_ID;
case 17: // LOADED_BYTES
return LOADED_BYTES;
case 18: // ERROR_TABLET_INFOS
return ERROR_TABLET_INFOS;
case 19: // FRAGMENT_ID
return FRAGMENT_ID;
case 20: // QUERY_TYPE
return QUERY_TYPE;
case 21: // LOAD_CHANNEL_PROFILE
return LOAD_CHANNEL_PROFILE;
case 22: // FINISHED_SCAN_RANGES
return FINISHED_SCAN_RANGES;
case 23: // DETAILED_REPORT
return DETAILED_REPORT;
case 24: // QUERY_STATISTICS
return QUERY_STATISTICS;
case 25: // REPORT_WORKLOAD_RUNTIME_STATUS
return REPORT_WORKLOAD_RUNTIME_STATUS;
case 26: // HIVE_PARTITION_UPDATES
return HIVE_PARTITION_UPDATES;
case 27: // QUERY_PROFILE
return QUERY_PROFILE;
case 28: // ICEBERG_COMMIT_DATAS
return ICEBERG_COMMIT_DATAS;
case 29: // TXN_ID
return TXN_ID;
case 30: // LABEL
return LABEL;
case 31: // FRAGMENT_INSTANCE_REPORTS
return FRAGMENT_INSTANCE_REPORTS;
case 32: // MC_COMMIT_DATAS
return MC_COMMIT_DATAS;
case 33: // FIRST_ERROR_MSG
return FIRST_ERROR_MSG;
default:
return null;
}
}
/**
* Find the _Fields constant that matches fieldId, throwing an exception
* if it is not found.
*/
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
if (fields == null) throw new java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!");
return fields;
}
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
@org.apache.thrift.annotation.Nullable
public static _Fields findByName(java.lang.String name) {
return byName.get(name);
}
private final short _thriftId;
private final java.lang.String _fieldName;
_Fields(short thriftId, java.lang.String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
public short getThriftFieldId() {
return _thriftId;
}
public java.lang.String getFieldName() {
return _fieldName;
}
}
// isset id assignments
private static final int __BACKEND_NUM_ISSET_ID = 0;
private static final int __DONE_ISSET_ID = 1;
private static final int __LOADED_ROWS_ISSET_ID = 2;
private static final int __BACKEND_ID_ISSET_ID = 3;
private static final int __LOADED_BYTES_ISSET_ID = 4;
private static final int __FRAGMENT_ID_ISSET_ID = 5;
private static final int __FINISHED_SCAN_RANGES_ISSET_ID = 6;
private static final int __TXN_ID_ISSET_ID = 7;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.QUERY_ID,_Fields.BACKEND_NUM,_Fields.FRAGMENT_INSTANCE_ID,_Fields.STATUS,_Fields.DONE,_Fields.PROFILE,_Fields.ERROR_LOG,_Fields.DELTA_URLS,_Fields.LOAD_COUNTERS,_Fields.TRACKING_URL,_Fields.EXPORT_FILES,_Fields.COMMIT_INFOS,_Fields.LOADED_ROWS,_Fields.BACKEND_ID,_Fields.LOADED_BYTES,_Fields.ERROR_TABLET_INFOS,_Fields.FRAGMENT_ID,_Fields.QUERY_TYPE,_Fields.LOAD_CHANNEL_PROFILE,_Fields.FINISHED_SCAN_RANGES,_Fields.DETAILED_REPORT,_Fields.QUERY_STATISTICS,_Fields.REPORT_WORKLOAD_RUNTIME_STATUS,_Fields.HIVE_PARTITION_UPDATES,_Fields.QUERY_PROFILE,_Fields.ICEBERG_COMMIT_DATAS,_Fields.TXN_ID,_Fields.LABEL,_Fields.FRAGMENT_INSTANCE_REPORTS,_Fields.MC_COMMIT_DATAS,_Fields.FIRST_ERROR_MSG};
public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.PROTOCOL_VERSION, new org.apache.thrift.meta_data.FieldMetaData("protocol_version", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, FrontendServiceVersion.class)));
tmpMap.put(_Fields.QUERY_ID, new org.apache.thrift.meta_data.FieldMetaData("query_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TUniqueId.class)));
tmpMap.put(_Fields.BACKEND_NUM, new org.apache.thrift.meta_data.FieldMetaData("backend_num", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.FRAGMENT_INSTANCE_ID, new org.apache.thrift.meta_data.FieldMetaData("fragment_instance_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TUniqueId.class)));
tmpMap.put(_Fields.STATUS, new org.apache.thrift.meta_data.FieldMetaData("status", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TStatus.class)));
tmpMap.put(_Fields.DONE, new org.apache.thrift.meta_data.FieldMetaData("done", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.PROFILE, new org.apache.thrift.meta_data.FieldMetaData("profile", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TRuntimeProfileTree.class)));
tmpMap.put(_Fields.ERROR_LOG, new org.apache.thrift.meta_data.FieldMetaData("error_log", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
tmpMap.put(_Fields.DELTA_URLS, new org.apache.thrift.meta_data.FieldMetaData("delta_urls", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
tmpMap.put(_Fields.LOAD_COUNTERS, new org.apache.thrift.meta_data.FieldMetaData("load_counters", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING),
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
tmpMap.put(_Fields.TRACKING_URL, new org.apache.thrift.meta_data.FieldMetaData("tracking_url", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.EXPORT_FILES, new org.apache.thrift.meta_data.FieldMetaData("export_files", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
tmpMap.put(_Fields.COMMIT_INFOS, new org.apache.thrift.meta_data.FieldMetaData("commitInfos", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TTabletCommitInfo.class))));
tmpMap.put(_Fields.LOADED_ROWS, new org.apache.thrift.meta_data.FieldMetaData("loaded_rows", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.BACKEND_ID, new org.apache.thrift.meta_data.FieldMetaData("backend_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.LOADED_BYTES, new org.apache.thrift.meta_data.FieldMetaData("loaded_bytes", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.ERROR_TABLET_INFOS, new org.apache.thrift.meta_data.FieldMetaData("errorTabletInfos", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TErrorTabletInfo.class))));
tmpMap.put(_Fields.FRAGMENT_ID, new org.apache.thrift.meta_data.FieldMetaData("fragment_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.QUERY_TYPE, new org.apache.thrift.meta_data.FieldMetaData("query_type", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, org.apache.doris.thrift.TQueryType.class)));
tmpMap.put(_Fields.LOAD_CHANNEL_PROFILE, new org.apache.thrift.meta_data.FieldMetaData("loadChannelProfile", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TRuntimeProfileTree.class)));
tmpMap.put(_Fields.FINISHED_SCAN_RANGES, new org.apache.thrift.meta_data.FieldMetaData("finished_scan_ranges", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.DETAILED_REPORT, new org.apache.thrift.meta_data.FieldMetaData("detailed_report", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TDetailedReportParams.class))));
tmpMap.put(_Fields.QUERY_STATISTICS, new org.apache.thrift.meta_data.FieldMetaData("query_statistics", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TQueryStatistics.class)));
tmpMap.put(_Fields.REPORT_WORKLOAD_RUNTIME_STATUS, new org.apache.thrift.meta_data.FieldMetaData("report_workload_runtime_status", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TReportWorkloadRuntimeStatusParams.class)));
tmpMap.put(_Fields.HIVE_PARTITION_UPDATES, new org.apache.thrift.meta_data.FieldMetaData("hive_partition_updates", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.THivePartitionUpdate.class))));
tmpMap.put(_Fields.QUERY_PROFILE, new org.apache.thrift.meta_data.FieldMetaData("query_profile", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TQueryProfile.class)));
tmpMap.put(_Fields.ICEBERG_COMMIT_DATAS, new org.apache.thrift.meta_data.FieldMetaData("iceberg_commit_datas", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TIcebergCommitData.class))));
tmpMap.put(_Fields.TXN_ID, new org.apache.thrift.meta_data.FieldMetaData("txn_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.LABEL, new org.apache.thrift.meta_data.FieldMetaData("label", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.FRAGMENT_INSTANCE_REPORTS, new org.apache.thrift.meta_data.FieldMetaData("fragment_instance_reports", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TFragmentInstanceReport.class))));
tmpMap.put(_Fields.MC_COMMIT_DATAS, new org.apache.thrift.meta_data.FieldMetaData("mc_commit_datas", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TMCCommitData.class))));
tmpMap.put(_Fields.FIRST_ERROR_MSG, new org.apache.thrift.meta_data.FieldMetaData("first_error_msg", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TReportExecStatusParams.class, metaDataMap);
}
public TReportExecStatusParams() {
}
public TReportExecStatusParams(
FrontendServiceVersion protocol_version)
{
this();
this.protocol_version = protocol_version;
}
/**
* Performs a deep copy on <i>other</i>.
*/
public TReportExecStatusParams(TReportExecStatusParams other) {
__isset_bitfield = other.__isset_bitfield;
if (other.isSetProtocolVersion()) {
this.protocol_version = other.protocol_version;
}
if (other.isSetQueryId()) {
this.query_id = new org.apache.doris.thrift.TUniqueId(other.query_id);
}
this.backend_num = other.backend_num;
if (other.isSetFragmentInstanceId()) {
this.fragment_instance_id = new org.apache.doris.thrift.TUniqueId(other.fragment_instance_id);
}
if (other.isSetStatus()) {
this.status = new org.apache.doris.thrift.TStatus(other.status);
}
this.done = other.done;
if (other.isSetProfile()) {
this.profile = new org.apache.doris.thrift.TRuntimeProfileTree(other.profile);
}
if (other.isSetErrorLog()) {
java.util.List<java.lang.String> __this__error_log = new java.util.ArrayList<java.lang.String>(other.error_log);
this.error_log = __this__error_log;
}
if (other.isSetDeltaUrls()) {
java.util.List<java.lang.String> __this__delta_urls = new java.util.ArrayList<java.lang.String>(other.delta_urls);
this.delta_urls = __this__delta_urls;
}
if (other.isSetLoadCounters()) {
java.util.Map<java.lang.String,java.lang.String> __this__load_counters = new java.util.HashMap<java.lang.String,java.lang.String>(other.load_counters);
this.load_counters = __this__load_counters;
}
if (other.isSetTrackingUrl()) {
this.tracking_url = other.tracking_url;
}
if (other.isSetExportFiles()) {
java.util.List<java.lang.String> __this__export_files = new java.util.ArrayList<java.lang.String>(other.export_files);
this.export_files = __this__export_files;
}
if (other.isSetCommitInfos()) {
java.util.List<org.apache.doris.thrift.TTabletCommitInfo> __this__commitInfos = new java.util.ArrayList<org.apache.doris.thrift.TTabletCommitInfo>(other.commitInfos.size());
for (org.apache.doris.thrift.TTabletCommitInfo other_element : other.commitInfos) {
__this__commitInfos.add(new org.apache.doris.thrift.TTabletCommitInfo(other_element));
}
this.commitInfos = __this__commitInfos;
}
this.loaded_rows = other.loaded_rows;
this.backend_id = other.backend_id;
this.loaded_bytes = other.loaded_bytes;
if (other.isSetErrorTabletInfos()) {
java.util.List<org.apache.doris.thrift.TErrorTabletInfo> __this__errorTabletInfos = new java.util.ArrayList<org.apache.doris.thrift.TErrorTabletInfo>(other.errorTabletInfos.size());
for (org.apache.doris.thrift.TErrorTabletInfo other_element : other.errorTabletInfos) {
__this__errorTabletInfos.add(new org.apache.doris.thrift.TErrorTabletInfo(other_element));
}
this.errorTabletInfos = __this__errorTabletInfos;
}
this.fragment_id = other.fragment_id;
if (other.isSetQueryType()) {
this.query_type = other.query_type;
}
if (other.isSetLoadChannelProfile()) {
this.loadChannelProfile = new org.apache.doris.thrift.TRuntimeProfileTree(other.loadChannelProfile);
}
this.finished_scan_ranges = other.finished_scan_ranges;
if (other.isSetDetailedReport()) {
java.util.List<TDetailedReportParams> __this__detailed_report = new java.util.ArrayList<TDetailedReportParams>(other.detailed_report.size());
for (TDetailedReportParams other_element : other.detailed_report) {
__this__detailed_report.add(new TDetailedReportParams(other_element));
}
this.detailed_report = __this__detailed_report;
}
if (other.isSetQueryStatistics()) {
this.query_statistics = new TQueryStatistics(other.query_statistics);
}
if (other.isSetReportWorkloadRuntimeStatus()) {
this.report_workload_runtime_status = new TReportWorkloadRuntimeStatusParams(other.report_workload_runtime_status);
}
if (other.isSetHivePartitionUpdates()) {
java.util.List<org.apache.doris.thrift.THivePartitionUpdate> __this__hive_partition_updates = new java.util.ArrayList<org.apache.doris.thrift.THivePartitionUpdate>(other.hive_partition_updates.size());
for (org.apache.doris.thrift.THivePartitionUpdate other_element : other.hive_partition_updates) {
__this__hive_partition_updates.add(new org.apache.doris.thrift.THivePartitionUpdate(other_element));
}
this.hive_partition_updates = __this__hive_partition_updates;
}
if (other.isSetQueryProfile()) {
this.query_profile = new TQueryProfile(other.query_profile);
}
if (other.isSetIcebergCommitDatas()) {
java.util.List<org.apache.doris.thrift.TIcebergCommitData> __this__iceberg_commit_datas = new java.util.ArrayList<org.apache.doris.thrift.TIcebergCommitData>(other.iceberg_commit_datas.size());
for (org.apache.doris.thrift.TIcebergCommitData other_element : other.iceberg_commit_datas) {
__this__iceberg_commit_datas.add(new org.apache.doris.thrift.TIcebergCommitData(other_element));
}
this.iceberg_commit_datas = __this__iceberg_commit_datas;
}
this.txn_id = other.txn_id;
if (other.isSetLabel()) {
this.label = other.label;
}
if (other.isSetFragmentInstanceReports()) {
java.util.List<TFragmentInstanceReport> __this__fragment_instance_reports = new java.util.ArrayList<TFragmentInstanceReport>(other.fragment_instance_reports.size());
for (TFragmentInstanceReport other_element : other.fragment_instance_reports) {
__this__fragment_instance_reports.add(new TFragmentInstanceReport(other_element));
}
this.fragment_instance_reports = __this__fragment_instance_reports;
}
if (other.isSetMcCommitDatas()) {
java.util.List<org.apache.doris.thrift.TMCCommitData> __this__mc_commit_datas = new java.util.ArrayList<org.apache.doris.thrift.TMCCommitData>(other.mc_commit_datas.size());
for (org.apache.doris.thrift.TMCCommitData other_element : other.mc_commit_datas) {
__this__mc_commit_datas.add(new org.apache.doris.thrift.TMCCommitData(other_element));
}
this.mc_commit_datas = __this__mc_commit_datas;
}
if (other.isSetFirstErrorMsg()) {
this.first_error_msg = other.first_error_msg;
}
}
public TReportExecStatusParams deepCopy() {
return new TReportExecStatusParams(this);
}
@Override
public void clear() {
this.protocol_version = null;
this.query_id = null;
setBackendNumIsSet(false);
this.backend_num = 0;
this.fragment_instance_id = null;
this.status = null;
setDoneIsSet(false);
this.done = false;
this.profile = null;
this.error_log = null;
this.delta_urls = null;
this.load_counters = null;
this.tracking_url = null;
this.export_files = null;
this.commitInfos = null;
setLoadedRowsIsSet(false);
this.loaded_rows = 0;
setBackendIdIsSet(false);
this.backend_id = 0;
setLoadedBytesIsSet(false);
this.loaded_bytes = 0;
this.errorTabletInfos = null;
setFragmentIdIsSet(false);
this.fragment_id = 0;
this.query_type = null;
this.loadChannelProfile = null;
setFinishedScanRangesIsSet(false);
this.finished_scan_ranges = 0;
this.detailed_report = null;
this.query_statistics = null;
this.report_workload_runtime_status = null;
this.hive_partition_updates = null;
this.query_profile = null;
this.iceberg_commit_datas = null;
setTxnIdIsSet(false);
this.txn_id = 0;
this.label = null;
this.fragment_instance_reports = null;
this.mc_commit_datas = null;
this.first_error_msg = null;
}
/**
*
* @see FrontendServiceVersion
*/
@org.apache.thrift.annotation.Nullable
public FrontendServiceVersion getProtocolVersion() {
return this.protocol_version;
}
/**
*
* @see FrontendServiceVersion
*/
public TReportExecStatusParams setProtocolVersion(@org.apache.thrift.annotation.Nullable FrontendServiceVersion protocol_version) {
this.protocol_version = protocol_version;
return this;
}
public void unsetProtocolVersion() {
this.protocol_version = null;
}
/** Returns true if field protocol_version is set (has been assigned a value) and false otherwise */
public boolean isSetProtocolVersion() {
return this.protocol_version != null;
}
public void setProtocolVersionIsSet(boolean value) {
if (!value) {
this.protocol_version = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TUniqueId getQueryId() {
return this.query_id;
}
public TReportExecStatusParams setQueryId(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TUniqueId query_id) {
this.query_id = query_id;
return this;
}
public void unsetQueryId() {
this.query_id = null;
}
/** Returns true if field query_id is set (has been assigned a value) and false otherwise */
public boolean isSetQueryId() {
return this.query_id != null;
}
public void setQueryIdIsSet(boolean value) {
if (!value) {
this.query_id = null;
}
}
public int getBackendNum() {
return this.backend_num;
}
public TReportExecStatusParams setBackendNum(int backend_num) {
this.backend_num = backend_num;
setBackendNumIsSet(true);
return this;
}
public void unsetBackendNum() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __BACKEND_NUM_ISSET_ID);
}
/** Returns true if field backend_num is set (has been assigned a value) and false otherwise */
public boolean isSetBackendNum() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __BACKEND_NUM_ISSET_ID);
}
public void setBackendNumIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __BACKEND_NUM_ISSET_ID, value);
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TUniqueId getFragmentInstanceId() {
return this.fragment_instance_id;
}
public TReportExecStatusParams setFragmentInstanceId(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TUniqueId fragment_instance_id) {
this.fragment_instance_id = fragment_instance_id;
return this;
}
public void unsetFragmentInstanceId() {
this.fragment_instance_id = null;
}
/** Returns true if field fragment_instance_id is set (has been assigned a value) and false otherwise */
public boolean isSetFragmentInstanceId() {
return this.fragment_instance_id != null;
}
public void setFragmentInstanceIdIsSet(boolean value) {
if (!value) {
this.fragment_instance_id = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TStatus getStatus() {
return this.status;
}
public TReportExecStatusParams setStatus(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TStatus status) {
this.status = status;
return this;
}
public void unsetStatus() {
this.status = null;
}
/** Returns true if field status is set (has been assigned a value) and false otherwise */
public boolean isSetStatus() {
return this.status != null;
}
public void setStatusIsSet(boolean value) {
if (!value) {
this.status = null;
}
}
public boolean isDone() {
return this.done;
}
public TReportExecStatusParams setDone(boolean done) {
this.done = done;
setDoneIsSet(true);
return this;
}
public void unsetDone() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __DONE_ISSET_ID);
}
/** Returns true if field done is set (has been assigned a value) and false otherwise */
public boolean isSetDone() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __DONE_ISSET_ID);
}
public void setDoneIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __DONE_ISSET_ID, value);
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TRuntimeProfileTree getProfile() {
return this.profile;
}
public TReportExecStatusParams setProfile(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TRuntimeProfileTree profile) {
this.profile = profile;
return this;
}
public void unsetProfile() {
this.profile = null;
}
/** Returns true if field profile is set (has been assigned a value) and false otherwise */
public boolean isSetProfile() {
return this.profile != null;
}
public void setProfileIsSet(boolean value) {
if (!value) {
this.profile = null;
}
}
public int getErrorLogSize() {
return (this.error_log == null) ? 0 : this.error_log.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<java.lang.String> getErrorLogIterator() {
return (this.error_log == null) ? null : this.error_log.iterator();
}
public void addToErrorLog(java.lang.String elem) {
if (this.error_log == null) {
this.error_log = new java.util.ArrayList<java.lang.String>();
}
this.error_log.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<java.lang.String> getErrorLog() {
return this.error_log;
}
public TReportExecStatusParams setErrorLog(@org.apache.thrift.annotation.Nullable java.util.List<java.lang.String> error_log) {
this.error_log = error_log;
return this;
}
public void unsetErrorLog() {
this.error_log = null;
}
/** Returns true if field error_log is set (has been assigned a value) and false otherwise */
public boolean isSetErrorLog() {
return this.error_log != null;
}
public void setErrorLogIsSet(boolean value) {
if (!value) {
this.error_log = null;
}
}
public int getDeltaUrlsSize() {
return (this.delta_urls == null) ? 0 : this.delta_urls.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<java.lang.String> getDeltaUrlsIterator() {
return (this.delta_urls == null) ? null : this.delta_urls.iterator();
}
public void addToDeltaUrls(java.lang.String elem) {
if (this.delta_urls == null) {
this.delta_urls = new java.util.ArrayList<java.lang.String>();
}
this.delta_urls.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<java.lang.String> getDeltaUrls() {
return this.delta_urls;
}
public TReportExecStatusParams setDeltaUrls(@org.apache.thrift.annotation.Nullable java.util.List<java.lang.String> delta_urls) {
this.delta_urls = delta_urls;
return this;
}
public void unsetDeltaUrls() {
this.delta_urls = null;
}
/** Returns true if field delta_urls is set (has been assigned a value) and false otherwise */
public boolean isSetDeltaUrls() {
return this.delta_urls != null;
}
public void setDeltaUrlsIsSet(boolean value) {
if (!value) {
this.delta_urls = null;
}
}
public int getLoadCountersSize() {
return (this.load_counters == null) ? 0 : this.load_counters.size();
}
public void putToLoadCounters(java.lang.String key, java.lang.String val) {
if (this.load_counters == null) {
this.load_counters = new java.util.HashMap<java.lang.String,java.lang.String>();
}
this.load_counters.put(key, val);
}
@org.apache.thrift.annotation.Nullable
public java.util.Map<java.lang.String,java.lang.String> getLoadCounters() {
return this.load_counters;
}
public TReportExecStatusParams setLoadCounters(@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> load_counters) {
this.load_counters = load_counters;
return this;
}
public void unsetLoadCounters() {
this.load_counters = null;
}
/** Returns true if field load_counters is set (has been assigned a value) and false otherwise */
public boolean isSetLoadCounters() {
return this.load_counters != null;
}
public void setLoadCountersIsSet(boolean value) {
if (!value) {
this.load_counters = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getTrackingUrl() {
return this.tracking_url;
}
public TReportExecStatusParams setTrackingUrl(@org.apache.thrift.annotation.Nullable java.lang.String tracking_url) {
this.tracking_url = tracking_url;
return this;
}
public void unsetTrackingUrl() {
this.tracking_url = null;
}
/** Returns true if field tracking_url is set (has been assigned a value) and false otherwise */
public boolean isSetTrackingUrl() {
return this.tracking_url != null;
}
public void setTrackingUrlIsSet(boolean value) {
if (!value) {
this.tracking_url = null;
}
}
public int getExportFilesSize() {
return (this.export_files == null) ? 0 : this.export_files.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<java.lang.String> getExportFilesIterator() {
return (this.export_files == null) ? null : this.export_files.iterator();
}
public void addToExportFiles(java.lang.String elem) {
if (this.export_files == null) {
this.export_files = new java.util.ArrayList<java.lang.String>();
}
this.export_files.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<java.lang.String> getExportFiles() {
return this.export_files;
}
public TReportExecStatusParams setExportFiles(@org.apache.thrift.annotation.Nullable java.util.List<java.lang.String> export_files) {
this.export_files = export_files;
return this;
}
public void unsetExportFiles() {
this.export_files = null;
}
/** Returns true if field export_files is set (has been assigned a value) and false otherwise */
public boolean isSetExportFiles() {
return this.export_files != null;
}
public void setExportFilesIsSet(boolean value) {
if (!value) {
this.export_files = null;
}
}
public int getCommitInfosSize() {
return (this.commitInfos == null) ? 0 : this.commitInfos.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TTabletCommitInfo> getCommitInfosIterator() {
return (this.commitInfos == null) ? null : this.commitInfos.iterator();
}
public void addToCommitInfos(org.apache.doris.thrift.TTabletCommitInfo elem) {
if (this.commitInfos == null) {
this.commitInfos = new java.util.ArrayList<org.apache.doris.thrift.TTabletCommitInfo>();
}
this.commitInfos.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TTabletCommitInfo> getCommitInfos() {
return this.commitInfos;
}
public TReportExecStatusParams setCommitInfos(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TTabletCommitInfo> commitInfos) {
this.commitInfos = commitInfos;
return this;
}
public void unsetCommitInfos() {
this.commitInfos = null;
}
/** Returns true if field commitInfos is set (has been assigned a value) and false otherwise */
public boolean isSetCommitInfos() {
return this.commitInfos != null;
}
public void setCommitInfosIsSet(boolean value) {
if (!value) {
this.commitInfos = null;
}
}
public long getLoadedRows() {
return this.loaded_rows;
}
public TReportExecStatusParams setLoadedRows(long loaded_rows) {
this.loaded_rows = loaded_rows;
setLoadedRowsIsSet(true);
return this;
}
public void unsetLoadedRows() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __LOADED_ROWS_ISSET_ID);
}
/** Returns true if field loaded_rows is set (has been assigned a value) and false otherwise */
public boolean isSetLoadedRows() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __LOADED_ROWS_ISSET_ID);
}
public void setLoadedRowsIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __LOADED_ROWS_ISSET_ID, value);
}
public long getBackendId() {
return this.backend_id;
}
public TReportExecStatusParams setBackendId(long backend_id) {
this.backend_id = backend_id;
setBackendIdIsSet(true);
return this;
}
public void unsetBackendId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __BACKEND_ID_ISSET_ID);
}
/** Returns true if field backend_id is set (has been assigned a value) and false otherwise */
public boolean isSetBackendId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __BACKEND_ID_ISSET_ID);
}
public void setBackendIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __BACKEND_ID_ISSET_ID, value);
}
public long getLoadedBytes() {
return this.loaded_bytes;
}
public TReportExecStatusParams setLoadedBytes(long loaded_bytes) {
this.loaded_bytes = loaded_bytes;
setLoadedBytesIsSet(true);
return this;
}
public void unsetLoadedBytes() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __LOADED_BYTES_ISSET_ID);
}
/** Returns true if field loaded_bytes is set (has been assigned a value) and false otherwise */
public boolean isSetLoadedBytes() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __LOADED_BYTES_ISSET_ID);
}
public void setLoadedBytesIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __LOADED_BYTES_ISSET_ID, value);
}
public int getErrorTabletInfosSize() {
return (this.errorTabletInfos == null) ? 0 : this.errorTabletInfos.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TErrorTabletInfo> getErrorTabletInfosIterator() {
return (this.errorTabletInfos == null) ? null : this.errorTabletInfos.iterator();
}
public void addToErrorTabletInfos(org.apache.doris.thrift.TErrorTabletInfo elem) {
if (this.errorTabletInfos == null) {
this.errorTabletInfos = new java.util.ArrayList<org.apache.doris.thrift.TErrorTabletInfo>();
}
this.errorTabletInfos.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TErrorTabletInfo> getErrorTabletInfos() {
return this.errorTabletInfos;
}
public TReportExecStatusParams setErrorTabletInfos(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TErrorTabletInfo> errorTabletInfos) {
this.errorTabletInfos = errorTabletInfos;
return this;
}
public void unsetErrorTabletInfos() {
this.errorTabletInfos = null;
}
/** Returns true if field errorTabletInfos is set (has been assigned a value) and false otherwise */
public boolean isSetErrorTabletInfos() {
return this.errorTabletInfos != null;
}
public void setErrorTabletInfosIsSet(boolean value) {
if (!value) {
this.errorTabletInfos = null;
}
}
public int getFragmentId() {
return this.fragment_id;
}
public TReportExecStatusParams setFragmentId(int fragment_id) {
this.fragment_id = fragment_id;
setFragmentIdIsSet(true);
return this;
}
public void unsetFragmentId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __FRAGMENT_ID_ISSET_ID);
}
/** Returns true if field fragment_id is set (has been assigned a value) and false otherwise */
public boolean isSetFragmentId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __FRAGMENT_ID_ISSET_ID);
}
public void setFragmentIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __FRAGMENT_ID_ISSET_ID, value);
}
/**
*
* @see org.apache.doris.thrift.TQueryType
*/
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TQueryType getQueryType() {
return this.query_type;
}
/**
*
* @see org.apache.doris.thrift.TQueryType
*/
public TReportExecStatusParams setQueryType(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TQueryType query_type) {
this.query_type = query_type;
return this;
}
public void unsetQueryType() {
this.query_type = null;
}
/** Returns true if field query_type is set (has been assigned a value) and false otherwise */
public boolean isSetQueryType() {
return this.query_type != null;
}
public void setQueryTypeIsSet(boolean value) {
if (!value) {
this.query_type = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TRuntimeProfileTree getLoadChannelProfile() {
return this.loadChannelProfile;
}
public TReportExecStatusParams setLoadChannelProfile(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TRuntimeProfileTree loadChannelProfile) {
this.loadChannelProfile = loadChannelProfile;
return this;
}
public void unsetLoadChannelProfile() {
this.loadChannelProfile = null;
}
/** Returns true if field loadChannelProfile is set (has been assigned a value) and false otherwise */
public boolean isSetLoadChannelProfile() {
return this.loadChannelProfile != null;
}
public void setLoadChannelProfileIsSet(boolean value) {
if (!value) {
this.loadChannelProfile = null;
}
}
public int getFinishedScanRanges() {
return this.finished_scan_ranges;
}
public TReportExecStatusParams setFinishedScanRanges(int finished_scan_ranges) {
this.finished_scan_ranges = finished_scan_ranges;
setFinishedScanRangesIsSet(true);
return this;
}
public void unsetFinishedScanRanges() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __FINISHED_SCAN_RANGES_ISSET_ID);
}
/** Returns true if field finished_scan_ranges is set (has been assigned a value) and false otherwise */
public boolean isSetFinishedScanRanges() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __FINISHED_SCAN_RANGES_ISSET_ID);
}
public void setFinishedScanRangesIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __FINISHED_SCAN_RANGES_ISSET_ID, value);
}
public int getDetailedReportSize() {
return (this.detailed_report == null) ? 0 : this.detailed_report.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<TDetailedReportParams> getDetailedReportIterator() {
return (this.detailed_report == null) ? null : this.detailed_report.iterator();
}
public void addToDetailedReport(TDetailedReportParams elem) {
if (this.detailed_report == null) {
this.detailed_report = new java.util.ArrayList<TDetailedReportParams>();
}
this.detailed_report.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<TDetailedReportParams> getDetailedReport() {
return this.detailed_report;
}
public TReportExecStatusParams setDetailedReport(@org.apache.thrift.annotation.Nullable java.util.List<TDetailedReportParams> detailed_report) {
this.detailed_report = detailed_report;
return this;
}
public void unsetDetailedReport() {
this.detailed_report = null;
}
/** Returns true if field detailed_report is set (has been assigned a value) and false otherwise */
public boolean isSetDetailedReport() {
return this.detailed_report != null;
}
public void setDetailedReportIsSet(boolean value) {
if (!value) {
this.detailed_report = null;
}
}
@org.apache.thrift.annotation.Nullable
public TQueryStatistics getQueryStatistics() {
return this.query_statistics;
}
public TReportExecStatusParams setQueryStatistics(@org.apache.thrift.annotation.Nullable TQueryStatistics query_statistics) {
this.query_statistics = query_statistics;
return this;
}
public void unsetQueryStatistics() {
this.query_statistics = null;
}
/** Returns true if field query_statistics is set (has been assigned a value) and false otherwise */
public boolean isSetQueryStatistics() {
return this.query_statistics != null;
}
public void setQueryStatisticsIsSet(boolean value) {
if (!value) {
this.query_statistics = null;
}
}
@org.apache.thrift.annotation.Nullable
public TReportWorkloadRuntimeStatusParams getReportWorkloadRuntimeStatus() {
return this.report_workload_runtime_status;
}
public TReportExecStatusParams setReportWorkloadRuntimeStatus(@org.apache.thrift.annotation.Nullable TReportWorkloadRuntimeStatusParams report_workload_runtime_status) {
this.report_workload_runtime_status = report_workload_runtime_status;
return this;
}
public void unsetReportWorkloadRuntimeStatus() {
this.report_workload_runtime_status = null;
}
/** Returns true if field report_workload_runtime_status is set (has been assigned a value) and false otherwise */
public boolean isSetReportWorkloadRuntimeStatus() {
return this.report_workload_runtime_status != null;
}
public void setReportWorkloadRuntimeStatusIsSet(boolean value) {
if (!value) {
this.report_workload_runtime_status = null;
}
}
public int getHivePartitionUpdatesSize() {
return (this.hive_partition_updates == null) ? 0 : this.hive_partition_updates.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.THivePartitionUpdate> getHivePartitionUpdatesIterator() {
return (this.hive_partition_updates == null) ? null : this.hive_partition_updates.iterator();
}
public void addToHivePartitionUpdates(org.apache.doris.thrift.THivePartitionUpdate elem) {
if (this.hive_partition_updates == null) {
this.hive_partition_updates = new java.util.ArrayList<org.apache.doris.thrift.THivePartitionUpdate>();
}
this.hive_partition_updates.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.THivePartitionUpdate> getHivePartitionUpdates() {
return this.hive_partition_updates;
}
public TReportExecStatusParams setHivePartitionUpdates(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.THivePartitionUpdate> hive_partition_updates) {
this.hive_partition_updates = hive_partition_updates;
return this;
}
public void unsetHivePartitionUpdates() {
this.hive_partition_updates = null;
}
/** Returns true if field hive_partition_updates is set (has been assigned a value) and false otherwise */
public boolean isSetHivePartitionUpdates() {
return this.hive_partition_updates != null;
}
public void setHivePartitionUpdatesIsSet(boolean value) {
if (!value) {
this.hive_partition_updates = null;
}
}
@org.apache.thrift.annotation.Nullable
public TQueryProfile getQueryProfile() {
return this.query_profile;
}
public TReportExecStatusParams setQueryProfile(@org.apache.thrift.annotation.Nullable TQueryProfile query_profile) {
this.query_profile = query_profile;
return this;
}
public void unsetQueryProfile() {
this.query_profile = null;
}
/** Returns true if field query_profile is set (has been assigned a value) and false otherwise */
public boolean isSetQueryProfile() {
return this.query_profile != null;
}
public void setQueryProfileIsSet(boolean value) {
if (!value) {
this.query_profile = null;
}
}
public int getIcebergCommitDatasSize() {
return (this.iceberg_commit_datas == null) ? 0 : this.iceberg_commit_datas.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TIcebergCommitData> getIcebergCommitDatasIterator() {
return (this.iceberg_commit_datas == null) ? null : this.iceberg_commit_datas.iterator();
}
public void addToIcebergCommitDatas(org.apache.doris.thrift.TIcebergCommitData elem) {
if (this.iceberg_commit_datas == null) {
this.iceberg_commit_datas = new java.util.ArrayList<org.apache.doris.thrift.TIcebergCommitData>();
}
this.iceberg_commit_datas.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TIcebergCommitData> getIcebergCommitDatas() {
return this.iceberg_commit_datas;
}
public TReportExecStatusParams setIcebergCommitDatas(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TIcebergCommitData> iceberg_commit_datas) {
this.iceberg_commit_datas = iceberg_commit_datas;
return this;
}
public void unsetIcebergCommitDatas() {
this.iceberg_commit_datas = null;
}
/** Returns true if field iceberg_commit_datas is set (has been assigned a value) and false otherwise */
public boolean isSetIcebergCommitDatas() {
return this.iceberg_commit_datas != null;
}
public void setIcebergCommitDatasIsSet(boolean value) {
if (!value) {
this.iceberg_commit_datas = null;
}
}
public long getTxnId() {
return this.txn_id;
}
public TReportExecStatusParams setTxnId(long txn_id) {
this.txn_id = txn_id;
setTxnIdIsSet(true);
return this;
}
public void unsetTxnId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __TXN_ID_ISSET_ID);
}
/** Returns true if field txn_id is set (has been assigned a value) and false otherwise */
public boolean isSetTxnId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __TXN_ID_ISSET_ID);
}
public void setTxnIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __TXN_ID_ISSET_ID, value);
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getLabel() {
return this.label;
}
public TReportExecStatusParams setLabel(@org.apache.thrift.annotation.Nullable java.lang.String label) {
this.label = label;
return this;
}
public void unsetLabel() {
this.label = null;
}
/** Returns true if field label is set (has been assigned a value) and false otherwise */
public boolean isSetLabel() {
return this.label != null;
}
public void setLabelIsSet(boolean value) {
if (!value) {
this.label = null;
}
}
public int getFragmentInstanceReportsSize() {
return (this.fragment_instance_reports == null) ? 0 : this.fragment_instance_reports.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<TFragmentInstanceReport> getFragmentInstanceReportsIterator() {
return (this.fragment_instance_reports == null) ? null : this.fragment_instance_reports.iterator();
}
public void addToFragmentInstanceReports(TFragmentInstanceReport elem) {
if (this.fragment_instance_reports == null) {
this.fragment_instance_reports = new java.util.ArrayList<TFragmentInstanceReport>();
}
this.fragment_instance_reports.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<TFragmentInstanceReport> getFragmentInstanceReports() {
return this.fragment_instance_reports;
}
public TReportExecStatusParams setFragmentInstanceReports(@org.apache.thrift.annotation.Nullable java.util.List<TFragmentInstanceReport> fragment_instance_reports) {
this.fragment_instance_reports = fragment_instance_reports;
return this;
}
public void unsetFragmentInstanceReports() {
this.fragment_instance_reports = null;
}
/** Returns true if field fragment_instance_reports is set (has been assigned a value) and false otherwise */
public boolean isSetFragmentInstanceReports() {
return this.fragment_instance_reports != null;
}
public void setFragmentInstanceReportsIsSet(boolean value) {
if (!value) {
this.fragment_instance_reports = null;
}
}
public int getMcCommitDatasSize() {
return (this.mc_commit_datas == null) ? 0 : this.mc_commit_datas.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TMCCommitData> getMcCommitDatasIterator() {
return (this.mc_commit_datas == null) ? null : this.mc_commit_datas.iterator();
}
public void addToMcCommitDatas(org.apache.doris.thrift.TMCCommitData elem) {
if (this.mc_commit_datas == null) {
this.mc_commit_datas = new java.util.ArrayList<org.apache.doris.thrift.TMCCommitData>();
}
this.mc_commit_datas.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TMCCommitData> getMcCommitDatas() {
return this.mc_commit_datas;
}
public TReportExecStatusParams setMcCommitDatas(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TMCCommitData> mc_commit_datas) {
this.mc_commit_datas = mc_commit_datas;
return this;
}
public void unsetMcCommitDatas() {
this.mc_commit_datas = null;
}
/** Returns true if field mc_commit_datas is set (has been assigned a value) and false otherwise */
public boolean isSetMcCommitDatas() {
return this.mc_commit_datas != null;
}
public void setMcCommitDatasIsSet(boolean value) {
if (!value) {
this.mc_commit_datas = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getFirstErrorMsg() {
return this.first_error_msg;
}
public TReportExecStatusParams setFirstErrorMsg(@org.apache.thrift.annotation.Nullable java.lang.String first_error_msg) {
this.first_error_msg = first_error_msg;
return this;
}
public void unsetFirstErrorMsg() {
this.first_error_msg = null;
}
/** Returns true if field first_error_msg is set (has been assigned a value) and false otherwise */
public boolean isSetFirstErrorMsg() {
return this.first_error_msg != null;
}
public void setFirstErrorMsgIsSet(boolean value) {
if (!value) {
this.first_error_msg = null;
}
}
public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case PROTOCOL_VERSION:
if (value == null) {
unsetProtocolVersion();
} else {
setProtocolVersion((FrontendServiceVersion)value);
}
break;
case QUERY_ID:
if (value == null) {
unsetQueryId();
} else {
setQueryId((org.apache.doris.thrift.TUniqueId)value);
}
break;
case BACKEND_NUM:
if (value == null) {
unsetBackendNum();
} else {
setBackendNum((java.lang.Integer)value);
}
break;
case FRAGMENT_INSTANCE_ID:
if (value == null) {
unsetFragmentInstanceId();
} else {
setFragmentInstanceId((org.apache.doris.thrift.TUniqueId)value);
}
break;
case STATUS:
if (value == null) {
unsetStatus();
} else {
setStatus((org.apache.doris.thrift.TStatus)value);
}
break;
case DONE:
if (value == null) {
unsetDone();
} else {
setDone((java.lang.Boolean)value);
}
break;
case PROFILE:
if (value == null) {
unsetProfile();
} else {
setProfile((org.apache.doris.thrift.TRuntimeProfileTree)value);
}
break;
case ERROR_LOG:
if (value == null) {
unsetErrorLog();
} else {
setErrorLog((java.util.List<java.lang.String>)value);
}
break;
case DELTA_URLS:
if (value == null) {
unsetDeltaUrls();
} else {
setDeltaUrls((java.util.List<java.lang.String>)value);
}
break;
case LOAD_COUNTERS:
if (value == null) {
unsetLoadCounters();
} else {
setLoadCounters((java.util.Map<java.lang.String,java.lang.String>)value);
}
break;
case TRACKING_URL:
if (value == null) {
unsetTrackingUrl();
} else {
setTrackingUrl((java.lang.String)value);
}
break;
case EXPORT_FILES:
if (value == null) {
unsetExportFiles();
} else {
setExportFiles((java.util.List<java.lang.String>)value);
}
break;
case COMMIT_INFOS:
if (value == null) {
unsetCommitInfos();
} else {
setCommitInfos((java.util.List<org.apache.doris.thrift.TTabletCommitInfo>)value);
}
break;
case LOADED_ROWS:
if (value == null) {
unsetLoadedRows();
} else {
setLoadedRows((java.lang.Long)value);
}
break;
case BACKEND_ID:
if (value == null) {
unsetBackendId();
} else {
setBackendId((java.lang.Long)value);
}
break;
case LOADED_BYTES:
if (value == null) {
unsetLoadedBytes();
} else {
setLoadedBytes((java.lang.Long)value);
}
break;
case ERROR_TABLET_INFOS:
if (value == null) {
unsetErrorTabletInfos();
} else {
setErrorTabletInfos((java.util.List<org.apache.doris.thrift.TErrorTabletInfo>)value);
}
break;
case FRAGMENT_ID:
if (value == null) {
unsetFragmentId();
} else {
setFragmentId((java.lang.Integer)value);
}
break;
case QUERY_TYPE:
if (value == null) {
unsetQueryType();
} else {
setQueryType((org.apache.doris.thrift.TQueryType)value);
}
break;
case LOAD_CHANNEL_PROFILE:
if (value == null) {
unsetLoadChannelProfile();
} else {
setLoadChannelProfile((org.apache.doris.thrift.TRuntimeProfileTree)value);
}
break;
case FINISHED_SCAN_RANGES:
if (value == null) {
unsetFinishedScanRanges();
} else {
setFinishedScanRanges((java.lang.Integer)value);
}
break;
case DETAILED_REPORT:
if (value == null) {
unsetDetailedReport();
} else {
setDetailedReport((java.util.List<TDetailedReportParams>)value);
}
break;
case QUERY_STATISTICS:
if (value == null) {
unsetQueryStatistics();
} else {
setQueryStatistics((TQueryStatistics)value);
}
break;
case REPORT_WORKLOAD_RUNTIME_STATUS:
if (value == null) {
unsetReportWorkloadRuntimeStatus();
} else {
setReportWorkloadRuntimeStatus((TReportWorkloadRuntimeStatusParams)value);
}
break;
case HIVE_PARTITION_UPDATES:
if (value == null) {
unsetHivePartitionUpdates();
} else {
setHivePartitionUpdates((java.util.List<org.apache.doris.thrift.THivePartitionUpdate>)value);
}
break;
case QUERY_PROFILE:
if (value == null) {
unsetQueryProfile();
} else {
setQueryProfile((TQueryProfile)value);
}
break;
case ICEBERG_COMMIT_DATAS:
if (value == null) {
unsetIcebergCommitDatas();
} else {
setIcebergCommitDatas((java.util.List<org.apache.doris.thrift.TIcebergCommitData>)value);
}
break;
case TXN_ID:
if (value == null) {
unsetTxnId();
} else {
setTxnId((java.lang.Long)value);
}
break;
case LABEL:
if (value == null) {
unsetLabel();
} else {
setLabel((java.lang.String)value);
}
break;
case FRAGMENT_INSTANCE_REPORTS:
if (value == null) {
unsetFragmentInstanceReports();
} else {
setFragmentInstanceReports((java.util.List<TFragmentInstanceReport>)value);
}
break;
case MC_COMMIT_DATAS:
if (value == null) {
unsetMcCommitDatas();
} else {
setMcCommitDatas((java.util.List<org.apache.doris.thrift.TMCCommitData>)value);
}
break;
case FIRST_ERROR_MSG:
if (value == null) {
unsetFirstErrorMsg();
} else {
setFirstErrorMsg((java.lang.String)value);
}
break;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case PROTOCOL_VERSION:
return getProtocolVersion();
case QUERY_ID:
return getQueryId();
case BACKEND_NUM:
return getBackendNum();
case FRAGMENT_INSTANCE_ID:
return getFragmentInstanceId();
case STATUS:
return getStatus();
case DONE:
return isDone();
case PROFILE:
return getProfile();
case ERROR_LOG:
return getErrorLog();
case DELTA_URLS:
return getDeltaUrls();
case LOAD_COUNTERS:
return getLoadCounters();
case TRACKING_URL:
return getTrackingUrl();
case EXPORT_FILES:
return getExportFiles();
case COMMIT_INFOS:
return getCommitInfos();
case LOADED_ROWS:
return getLoadedRows();
case BACKEND_ID:
return getBackendId();
case LOADED_BYTES:
return getLoadedBytes();
case ERROR_TABLET_INFOS:
return getErrorTabletInfos();
case FRAGMENT_ID:
return getFragmentId();
case QUERY_TYPE:
return getQueryType();
case LOAD_CHANNEL_PROFILE:
return getLoadChannelProfile();
case FINISHED_SCAN_RANGES:
return getFinishedScanRanges();
case DETAILED_REPORT:
return getDetailedReport();
case QUERY_STATISTICS:
return getQueryStatistics();
case REPORT_WORKLOAD_RUNTIME_STATUS:
return getReportWorkloadRuntimeStatus();
case HIVE_PARTITION_UPDATES:
return getHivePartitionUpdates();
case QUERY_PROFILE:
return getQueryProfile();
case ICEBERG_COMMIT_DATAS:
return getIcebergCommitDatas();
case TXN_ID:
return getTxnId();
case LABEL:
return getLabel();
case FRAGMENT_INSTANCE_REPORTS:
return getFragmentInstanceReports();
case MC_COMMIT_DATAS:
return getMcCommitDatas();
case FIRST_ERROR_MSG:
return getFirstErrorMsg();
}
throw new java.lang.IllegalStateException();
}
/** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
public boolean isSet(_Fields field) {
if (field == null) {
throw new java.lang.IllegalArgumentException();
}
switch (field) {
case PROTOCOL_VERSION:
return isSetProtocolVersion();
case QUERY_ID:
return isSetQueryId();
case BACKEND_NUM:
return isSetBackendNum();
case FRAGMENT_INSTANCE_ID:
return isSetFragmentInstanceId();
case STATUS:
return isSetStatus();
case DONE:
return isSetDone();
case PROFILE:
return isSetProfile();
case ERROR_LOG:
return isSetErrorLog();
case DELTA_URLS:
return isSetDeltaUrls();
case LOAD_COUNTERS:
return isSetLoadCounters();
case TRACKING_URL:
return isSetTrackingUrl();
case EXPORT_FILES:
return isSetExportFiles();
case COMMIT_INFOS:
return isSetCommitInfos();
case LOADED_ROWS:
return isSetLoadedRows();
case BACKEND_ID:
return isSetBackendId();
case LOADED_BYTES:
return isSetLoadedBytes();
case ERROR_TABLET_INFOS:
return isSetErrorTabletInfos();
case FRAGMENT_ID:
return isSetFragmentId();
case QUERY_TYPE:
return isSetQueryType();
case LOAD_CHANNEL_PROFILE:
return isSetLoadChannelProfile();
case FINISHED_SCAN_RANGES:
return isSetFinishedScanRanges();
case DETAILED_REPORT:
return isSetDetailedReport();
case QUERY_STATISTICS:
return isSetQueryStatistics();
case REPORT_WORKLOAD_RUNTIME_STATUS:
return isSetReportWorkloadRuntimeStatus();
case HIVE_PARTITION_UPDATES:
return isSetHivePartitionUpdates();
case QUERY_PROFILE:
return isSetQueryProfile();
case ICEBERG_COMMIT_DATAS:
return isSetIcebergCommitDatas();
case TXN_ID:
return isSetTxnId();
case LABEL:
return isSetLabel();
case FRAGMENT_INSTANCE_REPORTS:
return isSetFragmentInstanceReports();
case MC_COMMIT_DATAS:
return isSetMcCommitDatas();
case FIRST_ERROR_MSG:
return isSetFirstErrorMsg();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof TReportExecStatusParams)
return this.equals((TReportExecStatusParams)that);
return false;
}
public boolean equals(TReportExecStatusParams that) {
if (that == null)
return false;
if (this == that)
return true;
boolean this_present_protocol_version = true && this.isSetProtocolVersion();
boolean that_present_protocol_version = true && that.isSetProtocolVersion();
if (this_present_protocol_version || that_present_protocol_version) {
if (!(this_present_protocol_version && that_present_protocol_version))
return false;
if (!this.protocol_version.equals(that.protocol_version))
return false;
}
boolean this_present_query_id = true && this.isSetQueryId();
boolean that_present_query_id = true && that.isSetQueryId();
if (this_present_query_id || that_present_query_id) {
if (!(this_present_query_id && that_present_query_id))
return false;
if (!this.query_id.equals(that.query_id))
return false;
}
boolean this_present_backend_num = true && this.isSetBackendNum();
boolean that_present_backend_num = true && that.isSetBackendNum();
if (this_present_backend_num || that_present_backend_num) {
if (!(this_present_backend_num && that_present_backend_num))
return false;
if (this.backend_num != that.backend_num)
return false;
}
boolean this_present_fragment_instance_id = true && this.isSetFragmentInstanceId();
boolean that_present_fragment_instance_id = true && that.isSetFragmentInstanceId();
if (this_present_fragment_instance_id || that_present_fragment_instance_id) {
if (!(this_present_fragment_instance_id && that_present_fragment_instance_id))
return false;
if (!this.fragment_instance_id.equals(that.fragment_instance_id))
return false;
}
boolean this_present_status = true && this.isSetStatus();
boolean that_present_status = true && that.isSetStatus();
if (this_present_status || that_present_status) {
if (!(this_present_status && that_present_status))
return false;
if (!this.status.equals(that.status))
return false;
}
boolean this_present_done = true && this.isSetDone();
boolean that_present_done = true && that.isSetDone();
if (this_present_done || that_present_done) {
if (!(this_present_done && that_present_done))
return false;
if (this.done != that.done)
return false;
}
boolean this_present_profile = true && this.isSetProfile();
boolean that_present_profile = true && that.isSetProfile();
if (this_present_profile || that_present_profile) {
if (!(this_present_profile && that_present_profile))
return false;
if (!this.profile.equals(that.profile))
return false;
}
boolean this_present_error_log = true && this.isSetErrorLog();
boolean that_present_error_log = true && that.isSetErrorLog();
if (this_present_error_log || that_present_error_log) {
if (!(this_present_error_log && that_present_error_log))
return false;
if (!this.error_log.equals(that.error_log))
return false;
}
boolean this_present_delta_urls = true && this.isSetDeltaUrls();
boolean that_present_delta_urls = true && that.isSetDeltaUrls();
if (this_present_delta_urls || that_present_delta_urls) {
if (!(this_present_delta_urls && that_present_delta_urls))
return false;
if (!this.delta_urls.equals(that.delta_urls))
return false;
}
boolean this_present_load_counters = true && this.isSetLoadCounters();
boolean that_present_load_counters = true && that.isSetLoadCounters();
if (this_present_load_counters || that_present_load_counters) {
if (!(this_present_load_counters && that_present_load_counters))
return false;
if (!this.load_counters.equals(that.load_counters))
return false;
}
boolean this_present_tracking_url = true && this.isSetTrackingUrl();
boolean that_present_tracking_url = true && that.isSetTrackingUrl();
if (this_present_tracking_url || that_present_tracking_url) {
if (!(this_present_tracking_url && that_present_tracking_url))
return false;
if (!this.tracking_url.equals(that.tracking_url))
return false;
}
boolean this_present_export_files = true && this.isSetExportFiles();
boolean that_present_export_files = true && that.isSetExportFiles();
if (this_present_export_files || that_present_export_files) {
if (!(this_present_export_files && that_present_export_files))
return false;
if (!this.export_files.equals(that.export_files))
return false;
}
boolean this_present_commitInfos = true && this.isSetCommitInfos();
boolean that_present_commitInfos = true && that.isSetCommitInfos();
if (this_present_commitInfos || that_present_commitInfos) {
if (!(this_present_commitInfos && that_present_commitInfos))
return false;
if (!this.commitInfos.equals(that.commitInfos))
return false;
}
boolean this_present_loaded_rows = true && this.isSetLoadedRows();
boolean that_present_loaded_rows = true && that.isSetLoadedRows();
if (this_present_loaded_rows || that_present_loaded_rows) {
if (!(this_present_loaded_rows && that_present_loaded_rows))
return false;
if (this.loaded_rows != that.loaded_rows)
return false;
}
boolean this_present_backend_id = true && this.isSetBackendId();
boolean that_present_backend_id = true && that.isSetBackendId();
if (this_present_backend_id || that_present_backend_id) {
if (!(this_present_backend_id && that_present_backend_id))
return false;
if (this.backend_id != that.backend_id)
return false;
}
boolean this_present_loaded_bytes = true && this.isSetLoadedBytes();
boolean that_present_loaded_bytes = true && that.isSetLoadedBytes();
if (this_present_loaded_bytes || that_present_loaded_bytes) {
if (!(this_present_loaded_bytes && that_present_loaded_bytes))
return false;
if (this.loaded_bytes != that.loaded_bytes)
return false;
}
boolean this_present_errorTabletInfos = true && this.isSetErrorTabletInfos();
boolean that_present_errorTabletInfos = true && that.isSetErrorTabletInfos();
if (this_present_errorTabletInfos || that_present_errorTabletInfos) {
if (!(this_present_errorTabletInfos && that_present_errorTabletInfos))
return false;
if (!this.errorTabletInfos.equals(that.errorTabletInfos))
return false;
}
boolean this_present_fragment_id = true && this.isSetFragmentId();
boolean that_present_fragment_id = true && that.isSetFragmentId();
if (this_present_fragment_id || that_present_fragment_id) {
if (!(this_present_fragment_id && that_present_fragment_id))
return false;
if (this.fragment_id != that.fragment_id)
return false;
}
boolean this_present_query_type = true && this.isSetQueryType();
boolean that_present_query_type = true && that.isSetQueryType();
if (this_present_query_type || that_present_query_type) {
if (!(this_present_query_type && that_present_query_type))
return false;
if (!this.query_type.equals(that.query_type))
return false;
}
boolean this_present_loadChannelProfile = true && this.isSetLoadChannelProfile();
boolean that_present_loadChannelProfile = true && that.isSetLoadChannelProfile();
if (this_present_loadChannelProfile || that_present_loadChannelProfile) {
if (!(this_present_loadChannelProfile && that_present_loadChannelProfile))
return false;
if (!this.loadChannelProfile.equals(that.loadChannelProfile))
return false;
}
boolean this_present_finished_scan_ranges = true && this.isSetFinishedScanRanges();
boolean that_present_finished_scan_ranges = true && that.isSetFinishedScanRanges();
if (this_present_finished_scan_ranges || that_present_finished_scan_ranges) {
if (!(this_present_finished_scan_ranges && that_present_finished_scan_ranges))
return false;
if (this.finished_scan_ranges != that.finished_scan_ranges)
return false;
}
boolean this_present_detailed_report = true && this.isSetDetailedReport();
boolean that_present_detailed_report = true && that.isSetDetailedReport();
if (this_present_detailed_report || that_present_detailed_report) {
if (!(this_present_detailed_report && that_present_detailed_report))
return false;
if (!this.detailed_report.equals(that.detailed_report))
return false;
}
boolean this_present_query_statistics = true && this.isSetQueryStatistics();
boolean that_present_query_statistics = true && that.isSetQueryStatistics();
if (this_present_query_statistics || that_present_query_statistics) {
if (!(this_present_query_statistics && that_present_query_statistics))
return false;
if (!this.query_statistics.equals(that.query_statistics))
return false;
}
boolean this_present_report_workload_runtime_status = true && this.isSetReportWorkloadRuntimeStatus();
boolean that_present_report_workload_runtime_status = true && that.isSetReportWorkloadRuntimeStatus();
if (this_present_report_workload_runtime_status || that_present_report_workload_runtime_status) {
if (!(this_present_report_workload_runtime_status && that_present_report_workload_runtime_status))
return false;
if (!this.report_workload_runtime_status.equals(that.report_workload_runtime_status))
return false;
}
boolean this_present_hive_partition_updates = true && this.isSetHivePartitionUpdates();
boolean that_present_hive_partition_updates = true && that.isSetHivePartitionUpdates();
if (this_present_hive_partition_updates || that_present_hive_partition_updates) {
if (!(this_present_hive_partition_updates && that_present_hive_partition_updates))
return false;
if (!this.hive_partition_updates.equals(that.hive_partition_updates))
return false;
}
boolean this_present_query_profile = true && this.isSetQueryProfile();
boolean that_present_query_profile = true && that.isSetQueryProfile();
if (this_present_query_profile || that_present_query_profile) {
if (!(this_present_query_profile && that_present_query_profile))
return false;
if (!this.query_profile.equals(that.query_profile))
return false;
}
boolean this_present_iceberg_commit_datas = true && this.isSetIcebergCommitDatas();
boolean that_present_iceberg_commit_datas = true && that.isSetIcebergCommitDatas();
if (this_present_iceberg_commit_datas || that_present_iceberg_commit_datas) {
if (!(this_present_iceberg_commit_datas && that_present_iceberg_commit_datas))
return false;
if (!this.iceberg_commit_datas.equals(that.iceberg_commit_datas))
return false;
}
boolean this_present_txn_id = true && this.isSetTxnId();
boolean that_present_txn_id = true && that.isSetTxnId();
if (this_present_txn_id || that_present_txn_id) {
if (!(this_present_txn_id && that_present_txn_id))
return false;
if (this.txn_id != that.txn_id)
return false;
}
boolean this_present_label = true && this.isSetLabel();
boolean that_present_label = true && that.isSetLabel();
if (this_present_label || that_present_label) {
if (!(this_present_label && that_present_label))
return false;
if (!this.label.equals(that.label))
return false;
}
boolean this_present_fragment_instance_reports = true && this.isSetFragmentInstanceReports();
boolean that_present_fragment_instance_reports = true && that.isSetFragmentInstanceReports();
if (this_present_fragment_instance_reports || that_present_fragment_instance_reports) {
if (!(this_present_fragment_instance_reports && that_present_fragment_instance_reports))
return false;
if (!this.fragment_instance_reports.equals(that.fragment_instance_reports))
return false;
}
boolean this_present_mc_commit_datas = true && this.isSetMcCommitDatas();
boolean that_present_mc_commit_datas = true && that.isSetMcCommitDatas();
if (this_present_mc_commit_datas || that_present_mc_commit_datas) {
if (!(this_present_mc_commit_datas && that_present_mc_commit_datas))
return false;
if (!this.mc_commit_datas.equals(that.mc_commit_datas))
return false;
}
boolean this_present_first_error_msg = true && this.isSetFirstErrorMsg();
boolean that_present_first_error_msg = true && that.isSetFirstErrorMsg();
if (this_present_first_error_msg || that_present_first_error_msg) {
if (!(this_present_first_error_msg && that_present_first_error_msg))
return false;
if (!this.first_error_msg.equals(that.first_error_msg))
return false;
}
return true;
}
@Override
public int hashCode() {
int hashCode = 1;
hashCode = hashCode * 8191 + ((isSetProtocolVersion()) ? 131071 : 524287);
if (isSetProtocolVersion())
hashCode = hashCode * 8191 + protocol_version.getValue();
hashCode = hashCode * 8191 + ((isSetQueryId()) ? 131071 : 524287);
if (isSetQueryId())
hashCode = hashCode * 8191 + query_id.hashCode();
hashCode = hashCode * 8191 + ((isSetBackendNum()) ? 131071 : 524287);
if (isSetBackendNum())
hashCode = hashCode * 8191 + backend_num;
hashCode = hashCode * 8191 + ((isSetFragmentInstanceId()) ? 131071 : 524287);
if (isSetFragmentInstanceId())
hashCode = hashCode * 8191 + fragment_instance_id.hashCode();
hashCode = hashCode * 8191 + ((isSetStatus()) ? 131071 : 524287);
if (isSetStatus())
hashCode = hashCode * 8191 + status.hashCode();
hashCode = hashCode * 8191 + ((isSetDone()) ? 131071 : 524287);
if (isSetDone())
hashCode = hashCode * 8191 + ((done) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetProfile()) ? 131071 : 524287);
if (isSetProfile())
hashCode = hashCode * 8191 + profile.hashCode();
hashCode = hashCode * 8191 + ((isSetErrorLog()) ? 131071 : 524287);
if (isSetErrorLog())
hashCode = hashCode * 8191 + error_log.hashCode();
hashCode = hashCode * 8191 + ((isSetDeltaUrls()) ? 131071 : 524287);
if (isSetDeltaUrls())
hashCode = hashCode * 8191 + delta_urls.hashCode();
hashCode = hashCode * 8191 + ((isSetLoadCounters()) ? 131071 : 524287);
if (isSetLoadCounters())
hashCode = hashCode * 8191 + load_counters.hashCode();
hashCode = hashCode * 8191 + ((isSetTrackingUrl()) ? 131071 : 524287);
if (isSetTrackingUrl())
hashCode = hashCode * 8191 + tracking_url.hashCode();
hashCode = hashCode * 8191 + ((isSetExportFiles()) ? 131071 : 524287);
if (isSetExportFiles())
hashCode = hashCode * 8191 + export_files.hashCode();
hashCode = hashCode * 8191 + ((isSetCommitInfos()) ? 131071 : 524287);
if (isSetCommitInfos())
hashCode = hashCode * 8191 + commitInfos.hashCode();
hashCode = hashCode * 8191 + ((isSetLoadedRows()) ? 131071 : 524287);
if (isSetLoadedRows())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(loaded_rows);
hashCode = hashCode * 8191 + ((isSetBackendId()) ? 131071 : 524287);
if (isSetBackendId())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(backend_id);
hashCode = hashCode * 8191 + ((isSetLoadedBytes()) ? 131071 : 524287);
if (isSetLoadedBytes())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(loaded_bytes);
hashCode = hashCode * 8191 + ((isSetErrorTabletInfos()) ? 131071 : 524287);
if (isSetErrorTabletInfos())
hashCode = hashCode * 8191 + errorTabletInfos.hashCode();
hashCode = hashCode * 8191 + ((isSetFragmentId()) ? 131071 : 524287);
if (isSetFragmentId())
hashCode = hashCode * 8191 + fragment_id;
hashCode = hashCode * 8191 + ((isSetQueryType()) ? 131071 : 524287);
if (isSetQueryType())
hashCode = hashCode * 8191 + query_type.getValue();
hashCode = hashCode * 8191 + ((isSetLoadChannelProfile()) ? 131071 : 524287);
if (isSetLoadChannelProfile())
hashCode = hashCode * 8191 + loadChannelProfile.hashCode();
hashCode = hashCode * 8191 + ((isSetFinishedScanRanges()) ? 131071 : 524287);
if (isSetFinishedScanRanges())
hashCode = hashCode * 8191 + finished_scan_ranges;
hashCode = hashCode * 8191 + ((isSetDetailedReport()) ? 131071 : 524287);
if (isSetDetailedReport())
hashCode = hashCode * 8191 + detailed_report.hashCode();
hashCode = hashCode * 8191 + ((isSetQueryStatistics()) ? 131071 : 524287);
if (isSetQueryStatistics())
hashCode = hashCode * 8191 + query_statistics.hashCode();
hashCode = hashCode * 8191 + ((isSetReportWorkloadRuntimeStatus()) ? 131071 : 524287);
if (isSetReportWorkloadRuntimeStatus())
hashCode = hashCode * 8191 + report_workload_runtime_status.hashCode();
hashCode = hashCode * 8191 + ((isSetHivePartitionUpdates()) ? 131071 : 524287);
if (isSetHivePartitionUpdates())
hashCode = hashCode * 8191 + hive_partition_updates.hashCode();
hashCode = hashCode * 8191 + ((isSetQueryProfile()) ? 131071 : 524287);
if (isSetQueryProfile())
hashCode = hashCode * 8191 + query_profile.hashCode();
hashCode = hashCode * 8191 + ((isSetIcebergCommitDatas()) ? 131071 : 524287);
if (isSetIcebergCommitDatas())
hashCode = hashCode * 8191 + iceberg_commit_datas.hashCode();
hashCode = hashCode * 8191 + ((isSetTxnId()) ? 131071 : 524287);
if (isSetTxnId())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(txn_id);
hashCode = hashCode * 8191 + ((isSetLabel()) ? 131071 : 524287);
if (isSetLabel())
hashCode = hashCode * 8191 + label.hashCode();
hashCode = hashCode * 8191 + ((isSetFragmentInstanceReports()) ? 131071 : 524287);
if (isSetFragmentInstanceReports())
hashCode = hashCode * 8191 + fragment_instance_reports.hashCode();
hashCode = hashCode * 8191 + ((isSetMcCommitDatas()) ? 131071 : 524287);
if (isSetMcCommitDatas())
hashCode = hashCode * 8191 + mc_commit_datas.hashCode();
hashCode = hashCode * 8191 + ((isSetFirstErrorMsg()) ? 131071 : 524287);
if (isSetFirstErrorMsg())
hashCode = hashCode * 8191 + first_error_msg.hashCode();
return hashCode;
}
@Override
public int compareTo(TReportExecStatusParams other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = java.lang.Boolean.compare(isSetProtocolVersion(), other.isSetProtocolVersion());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetProtocolVersion()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.protocol_version, other.protocol_version);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetQueryId(), other.isSetQueryId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetQueryId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.query_id, other.query_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetBackendNum(), other.isSetBackendNum());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetBackendNum()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.backend_num, other.backend_num);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetFragmentInstanceId(), other.isSetFragmentInstanceId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetFragmentInstanceId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fragment_instance_id, other.fragment_instance_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetStatus(), other.isSetStatus());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetStatus()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.status, other.status);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetDone(), other.isSetDone());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetDone()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.done, other.done);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetProfile(), other.isSetProfile());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetProfile()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.profile, other.profile);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetErrorLog(), other.isSetErrorLog());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetErrorLog()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.error_log, other.error_log);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetDeltaUrls(), other.isSetDeltaUrls());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetDeltaUrls()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.delta_urls, other.delta_urls);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetLoadCounters(), other.isSetLoadCounters());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetLoadCounters()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.load_counters, other.load_counters);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTrackingUrl(), other.isSetTrackingUrl());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTrackingUrl()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tracking_url, other.tracking_url);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetExportFiles(), other.isSetExportFiles());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetExportFiles()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.export_files, other.export_files);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetCommitInfos(), other.isSetCommitInfos());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetCommitInfos()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.commitInfos, other.commitInfos);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetLoadedRows(), other.isSetLoadedRows());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetLoadedRows()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.loaded_rows, other.loaded_rows);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetBackendId(), other.isSetBackendId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetBackendId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.backend_id, other.backend_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetLoadedBytes(), other.isSetLoadedBytes());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetLoadedBytes()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.loaded_bytes, other.loaded_bytes);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetErrorTabletInfos(), other.isSetErrorTabletInfos());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetErrorTabletInfos()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.errorTabletInfos, other.errorTabletInfos);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetFragmentId(), other.isSetFragmentId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetFragmentId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fragment_id, other.fragment_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetQueryType(), other.isSetQueryType());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetQueryType()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.query_type, other.query_type);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetLoadChannelProfile(), other.isSetLoadChannelProfile());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetLoadChannelProfile()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.loadChannelProfile, other.loadChannelProfile);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetFinishedScanRanges(), other.isSetFinishedScanRanges());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetFinishedScanRanges()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.finished_scan_ranges, other.finished_scan_ranges);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetDetailedReport(), other.isSetDetailedReport());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetDetailedReport()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.detailed_report, other.detailed_report);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetQueryStatistics(), other.isSetQueryStatistics());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetQueryStatistics()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.query_statistics, other.query_statistics);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetReportWorkloadRuntimeStatus(), other.isSetReportWorkloadRuntimeStatus());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetReportWorkloadRuntimeStatus()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.report_workload_runtime_status, other.report_workload_runtime_status);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetHivePartitionUpdates(), other.isSetHivePartitionUpdates());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetHivePartitionUpdates()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.hive_partition_updates, other.hive_partition_updates);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetQueryProfile(), other.isSetQueryProfile());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetQueryProfile()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.query_profile, other.query_profile);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetIcebergCommitDatas(), other.isSetIcebergCommitDatas());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetIcebergCommitDatas()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.iceberg_commit_datas, other.iceberg_commit_datas);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTxnId(), other.isSetTxnId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTxnId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.txn_id, other.txn_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetLabel(), other.isSetLabel());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetLabel()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.label, other.label);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetFragmentInstanceReports(), other.isSetFragmentInstanceReports());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetFragmentInstanceReports()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fragment_instance_reports, other.fragment_instance_reports);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetMcCommitDatas(), other.isSetMcCommitDatas());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetMcCommitDatas()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.mc_commit_datas, other.mc_commit_datas);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetFirstErrorMsg(), other.isSetFirstErrorMsg());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetFirstErrorMsg()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.first_error_msg, other.first_error_msg);
if (lastComparison != 0) {
return lastComparison;
}
}
return 0;
}
@org.apache.thrift.annotation.Nullable
public _Fields fieldForId(int fieldId) {
return _Fields.findByThriftId(fieldId);
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
scheme(iprot).read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
scheme(oprot).write(oprot, this);
}
@Override
public java.lang.String toString() {
java.lang.StringBuilder sb = new java.lang.StringBuilder("TReportExecStatusParams(");
boolean first = true;
sb.append("protocol_version:");
if (this.protocol_version == null) {
sb.append("null");
} else {
sb.append(this.protocol_version);
}
first = false;
if (isSetQueryId()) {
if (!first) sb.append(", ");
sb.append("query_id:");
if (this.query_id == null) {
sb.append("null");
} else {
sb.append(this.query_id);
}
first = false;
}
if (isSetBackendNum()) {
if (!first) sb.append(", ");
sb.append("backend_num:");
sb.append(this.backend_num);
first = false;
}
if (isSetFragmentInstanceId()) {
if (!first) sb.append(", ");
sb.append("fragment_instance_id:");
if (this.fragment_instance_id == null) {
sb.append("null");
} else {
sb.append(this.fragment_instance_id);
}
first = false;
}
if (isSetStatus()) {
if (!first) sb.append(", ");
sb.append("status:");
if (this.status == null) {
sb.append("null");
} else {
sb.append(this.status);
}
first = false;
}
if (isSetDone()) {
if (!first) sb.append(", ");
sb.append("done:");
sb.append(this.done);
first = false;
}
if (isSetProfile()) {
if (!first) sb.append(", ");
sb.append("profile:");
if (this.profile == null) {
sb.append("null");
} else {
sb.append(this.profile);
}
first = false;
}
if (isSetErrorLog()) {
if (!first) sb.append(", ");
sb.append("error_log:");
if (this.error_log == null) {
sb.append("null");
} else {
sb.append(this.error_log);
}
first = false;
}
if (isSetDeltaUrls()) {
if (!first) sb.append(", ");
sb.append("delta_urls:");
if (this.delta_urls == null) {
sb.append("null");
} else {
sb.append(this.delta_urls);
}
first = false;
}
if (isSetLoadCounters()) {
if (!first) sb.append(", ");
sb.append("load_counters:");
if (this.load_counters == null) {
sb.append("null");
} else {
sb.append(this.load_counters);
}
first = false;
}
if (isSetTrackingUrl()) {
if (!first) sb.append(", ");
sb.append("tracking_url:");
if (this.tracking_url == null) {
sb.append("null");
} else {
sb.append(this.tracking_url);
}
first = false;
}
if (isSetExportFiles()) {
if (!first) sb.append(", ");
sb.append("export_files:");
if (this.export_files == null) {
sb.append("null");
} else {
sb.append(this.export_files);
}
first = false;
}
if (isSetCommitInfos()) {
if (!first) sb.append(", ");
sb.append("commitInfos:");
if (this.commitInfos == null) {
sb.append("null");
} else {
sb.append(this.commitInfos);
}
first = false;
}
if (isSetLoadedRows()) {
if (!first) sb.append(", ");
sb.append("loaded_rows:");
sb.append(this.loaded_rows);
first = false;
}
if (isSetBackendId()) {
if (!first) sb.append(", ");
sb.append("backend_id:");
sb.append(this.backend_id);
first = false;
}
if (isSetLoadedBytes()) {
if (!first) sb.append(", ");
sb.append("loaded_bytes:");
sb.append(this.loaded_bytes);
first = false;
}
if (isSetErrorTabletInfos()) {
if (!first) sb.append(", ");
sb.append("errorTabletInfos:");
if (this.errorTabletInfos == null) {
sb.append("null");
} else {
sb.append(this.errorTabletInfos);
}
first = false;
}
if (isSetFragmentId()) {
if (!first) sb.append(", ");
sb.append("fragment_id:");
sb.append(this.fragment_id);
first = false;
}
if (isSetQueryType()) {
if (!first) sb.append(", ");
sb.append("query_type:");
if (this.query_type == null) {
sb.append("null");
} else {
sb.append(this.query_type);
}
first = false;
}
if (isSetLoadChannelProfile()) {
if (!first) sb.append(", ");
sb.append("loadChannelProfile:");
if (this.loadChannelProfile == null) {
sb.append("null");
} else {
sb.append(this.loadChannelProfile);
}
first = false;
}
if (isSetFinishedScanRanges()) {
if (!first) sb.append(", ");
sb.append("finished_scan_ranges:");
sb.append(this.finished_scan_ranges);
first = false;
}
if (isSetDetailedReport()) {
if (!first) sb.append(", ");
sb.append("detailed_report:");
if (this.detailed_report == null) {
sb.append("null");
} else {
sb.append(this.detailed_report);
}
first = false;
}
if (isSetQueryStatistics()) {
if (!first) sb.append(", ");
sb.append("query_statistics:");
if (this.query_statistics == null) {
sb.append("null");
} else {
sb.append(this.query_statistics);
}
first = false;
}
if (isSetReportWorkloadRuntimeStatus()) {
if (!first) sb.append(", ");
sb.append("report_workload_runtime_status:");
if (this.report_workload_runtime_status == null) {
sb.append("null");
} else {
sb.append(this.report_workload_runtime_status);
}
first = false;
}
if (isSetHivePartitionUpdates()) {
if (!first) sb.append(", ");
sb.append("hive_partition_updates:");
if (this.hive_partition_updates == null) {
sb.append("null");
} else {
sb.append(this.hive_partition_updates);
}
first = false;
}
if (isSetQueryProfile()) {
if (!first) sb.append(", ");
sb.append("query_profile:");
if (this.query_profile == null) {
sb.append("null");
} else {
sb.append(this.query_profile);
}
first = false;
}
if (isSetIcebergCommitDatas()) {
if (!first) sb.append(", ");
sb.append("iceberg_commit_datas:");
if (this.iceberg_commit_datas == null) {
sb.append("null");
} else {
sb.append(this.iceberg_commit_datas);
}
first = false;
}
if (isSetTxnId()) {
if (!first) sb.append(", ");
sb.append("txn_id:");
sb.append(this.txn_id);
first = false;
}
if (isSetLabel()) {
if (!first) sb.append(", ");
sb.append("label:");
if (this.label == null) {
sb.append("null");
} else {
sb.append(this.label);
}
first = false;
}
if (isSetFragmentInstanceReports()) {
if (!first) sb.append(", ");
sb.append("fragment_instance_reports:");
if (this.fragment_instance_reports == null) {
sb.append("null");
} else {
sb.append(this.fragment_instance_reports);
}
first = false;
}
if (isSetMcCommitDatas()) {
if (!first) sb.append(", ");
sb.append("mc_commit_datas:");
if (this.mc_commit_datas == null) {
sb.append("null");
} else {
sb.append(this.mc_commit_datas);
}
first = false;
}
if (isSetFirstErrorMsg()) {
if (!first) sb.append(", ");
sb.append("first_error_msg:");
if (this.first_error_msg == null) {
sb.append("null");
} else {
sb.append(this.first_error_msg);
}
first = false;
}
sb.append(")");
return sb.toString();
}
public void validate() throws org.apache.thrift.TException {
// check for required fields
if (protocol_version == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'protocol_version' was not present! Struct: " + toString());
}
// check for sub-struct validity
if (query_id != null) {
query_id.validate();
}
if (fragment_instance_id != null) {
fragment_instance_id.validate();
}
if (status != null) {
status.validate();
}
if (profile != null) {
profile.validate();
}
if (loadChannelProfile != null) {
loadChannelProfile.validate();
}
if (query_statistics != null) {
query_statistics.validate();
}
if (report_workload_runtime_status != null) {
report_workload_runtime_status.validate();
}
if (query_profile != null) {
query_profile.validate();
}
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private static class TReportExecStatusParamsStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TReportExecStatusParamsStandardScheme getScheme() {
return new TReportExecStatusParamsStandardScheme();
}
}
private static class TReportExecStatusParamsStandardScheme extends org.apache.thrift.scheme.StandardScheme<TReportExecStatusParams> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TReportExecStatusParams struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
{
schemeField = iprot.readFieldBegin();
if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (schemeField.id) {
case 1: // PROTOCOL_VERSION
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.protocol_version = org.apache.doris.thrift.FrontendServiceVersion.findByValue(iprot.readI32());
struct.setProtocolVersionIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // QUERY_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.query_id = new org.apache.doris.thrift.TUniqueId();
struct.query_id.read(iprot);
struct.setQueryIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // BACKEND_NUM
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.backend_num = iprot.readI32();
struct.setBackendNumIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // FRAGMENT_INSTANCE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.fragment_instance_id = new org.apache.doris.thrift.TUniqueId();
struct.fragment_instance_id.read(iprot);
struct.setFragmentInstanceIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // STATUS
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.status = new org.apache.doris.thrift.TStatus();
struct.status.read(iprot);
struct.setStatusIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // DONE
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.done = iprot.readBool();
struct.setDoneIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // PROFILE
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.profile = new org.apache.doris.thrift.TRuntimeProfileTree();
struct.profile.read(iprot);
struct.setProfileIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // ERROR_LOG
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list174 = iprot.readListBegin();
struct.error_log = new java.util.ArrayList<java.lang.String>(_list174.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem175;
for (int _i176 = 0; _i176 < _list174.size; ++_i176)
{
_elem175 = iprot.readString();
struct.error_log.add(_elem175);
}
iprot.readListEnd();
}
struct.setErrorLogIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 10: // DELTA_URLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list177 = iprot.readListBegin();
struct.delta_urls = new java.util.ArrayList<java.lang.String>(_list177.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem178;
for (int _i179 = 0; _i179 < _list177.size; ++_i179)
{
_elem178 = iprot.readString();
struct.delta_urls.add(_elem178);
}
iprot.readListEnd();
}
struct.setDeltaUrlsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 11: // LOAD_COUNTERS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map180 = iprot.readMapBegin();
struct.load_counters = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map180.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key181;
@org.apache.thrift.annotation.Nullable java.lang.String _val182;
for (int _i183 = 0; _i183 < _map180.size; ++_i183)
{
_key181 = iprot.readString();
_val182 = iprot.readString();
struct.load_counters.put(_key181, _val182);
}
iprot.readMapEnd();
}
struct.setLoadCountersIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 12: // TRACKING_URL
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.tracking_url = iprot.readString();
struct.setTrackingUrlIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 13: // EXPORT_FILES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list184 = iprot.readListBegin();
struct.export_files = new java.util.ArrayList<java.lang.String>(_list184.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem185;
for (int _i186 = 0; _i186 < _list184.size; ++_i186)
{
_elem185 = iprot.readString();
struct.export_files.add(_elem185);
}
iprot.readListEnd();
}
struct.setExportFilesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 14: // COMMIT_INFOS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list187 = iprot.readListBegin();
struct.commitInfos = new java.util.ArrayList<org.apache.doris.thrift.TTabletCommitInfo>(_list187.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TTabletCommitInfo _elem188;
for (int _i189 = 0; _i189 < _list187.size; ++_i189)
{
_elem188 = new org.apache.doris.thrift.TTabletCommitInfo();
_elem188.read(iprot);
struct.commitInfos.add(_elem188);
}
iprot.readListEnd();
}
struct.setCommitInfosIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 15: // LOADED_ROWS
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.loaded_rows = iprot.readI64();
struct.setLoadedRowsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 16: // BACKEND_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.backend_id = iprot.readI64();
struct.setBackendIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 17: // LOADED_BYTES
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.loaded_bytes = iprot.readI64();
struct.setLoadedBytesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 18: // ERROR_TABLET_INFOS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list190 = iprot.readListBegin();
struct.errorTabletInfos = new java.util.ArrayList<org.apache.doris.thrift.TErrorTabletInfo>(_list190.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TErrorTabletInfo _elem191;
for (int _i192 = 0; _i192 < _list190.size; ++_i192)
{
_elem191 = new org.apache.doris.thrift.TErrorTabletInfo();
_elem191.read(iprot);
struct.errorTabletInfos.add(_elem191);
}
iprot.readListEnd();
}
struct.setErrorTabletInfosIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 19: // FRAGMENT_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.fragment_id = iprot.readI32();
struct.setFragmentIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 20: // QUERY_TYPE
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.query_type = org.apache.doris.thrift.TQueryType.findByValue(iprot.readI32());
struct.setQueryTypeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 21: // LOAD_CHANNEL_PROFILE
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.loadChannelProfile = new org.apache.doris.thrift.TRuntimeProfileTree();
struct.loadChannelProfile.read(iprot);
struct.setLoadChannelProfileIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 22: // FINISHED_SCAN_RANGES
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.finished_scan_ranges = iprot.readI32();
struct.setFinishedScanRangesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 23: // DETAILED_REPORT
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list193 = iprot.readListBegin();
struct.detailed_report = new java.util.ArrayList<TDetailedReportParams>(_list193.size);
@org.apache.thrift.annotation.Nullable TDetailedReportParams _elem194;
for (int _i195 = 0; _i195 < _list193.size; ++_i195)
{
_elem194 = new TDetailedReportParams();
_elem194.read(iprot);
struct.detailed_report.add(_elem194);
}
iprot.readListEnd();
}
struct.setDetailedReportIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 24: // QUERY_STATISTICS
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.query_statistics = new TQueryStatistics();
struct.query_statistics.read(iprot);
struct.setQueryStatisticsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 25: // REPORT_WORKLOAD_RUNTIME_STATUS
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.report_workload_runtime_status = new TReportWorkloadRuntimeStatusParams();
struct.report_workload_runtime_status.read(iprot);
struct.setReportWorkloadRuntimeStatusIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 26: // HIVE_PARTITION_UPDATES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list196 = iprot.readListBegin();
struct.hive_partition_updates = new java.util.ArrayList<org.apache.doris.thrift.THivePartitionUpdate>(_list196.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.THivePartitionUpdate _elem197;
for (int _i198 = 0; _i198 < _list196.size; ++_i198)
{
_elem197 = new org.apache.doris.thrift.THivePartitionUpdate();
_elem197.read(iprot);
struct.hive_partition_updates.add(_elem197);
}
iprot.readListEnd();
}
struct.setHivePartitionUpdatesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 27: // QUERY_PROFILE
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.query_profile = new TQueryProfile();
struct.query_profile.read(iprot);
struct.setQueryProfileIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 28: // ICEBERG_COMMIT_DATAS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list199 = iprot.readListBegin();
struct.iceberg_commit_datas = new java.util.ArrayList<org.apache.doris.thrift.TIcebergCommitData>(_list199.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TIcebergCommitData _elem200;
for (int _i201 = 0; _i201 < _list199.size; ++_i201)
{
_elem200 = new org.apache.doris.thrift.TIcebergCommitData();
_elem200.read(iprot);
struct.iceberg_commit_datas.add(_elem200);
}
iprot.readListEnd();
}
struct.setIcebergCommitDatasIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 29: // TXN_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.txn_id = iprot.readI64();
struct.setTxnIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 30: // LABEL
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.label = iprot.readString();
struct.setLabelIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 31: // FRAGMENT_INSTANCE_REPORTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list202 = iprot.readListBegin();
struct.fragment_instance_reports = new java.util.ArrayList<TFragmentInstanceReport>(_list202.size);
@org.apache.thrift.annotation.Nullable TFragmentInstanceReport _elem203;
for (int _i204 = 0; _i204 < _list202.size; ++_i204)
{
_elem203 = new TFragmentInstanceReport();
_elem203.read(iprot);
struct.fragment_instance_reports.add(_elem203);
}
iprot.readListEnd();
}
struct.setFragmentInstanceReportsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 32: // MC_COMMIT_DATAS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list205 = iprot.readListBegin();
struct.mc_commit_datas = new java.util.ArrayList<org.apache.doris.thrift.TMCCommitData>(_list205.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TMCCommitData _elem206;
for (int _i207 = 0; _i207 < _list205.size; ++_i207)
{
_elem206 = new org.apache.doris.thrift.TMCCommitData();
_elem206.read(iprot);
struct.mc_commit_datas.add(_elem206);
}
iprot.readListEnd();
}
struct.setMcCommitDatasIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 33: // FIRST_ERROR_MSG
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.first_error_msg = iprot.readString();
struct.setFirstErrorMsgIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
iprot.readFieldEnd();
}
iprot.readStructEnd();
// check for required fields of primitive type, which can't be checked in the validate method
struct.validate();
}
public void write(org.apache.thrift.protocol.TProtocol oprot, TReportExecStatusParams struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.protocol_version != null) {
oprot.writeFieldBegin(PROTOCOL_VERSION_FIELD_DESC);
oprot.writeI32(struct.protocol_version.getValue());
oprot.writeFieldEnd();
}
if (struct.query_id != null) {
if (struct.isSetQueryId()) {
oprot.writeFieldBegin(QUERY_ID_FIELD_DESC);
struct.query_id.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.isSetBackendNum()) {
oprot.writeFieldBegin(BACKEND_NUM_FIELD_DESC);
oprot.writeI32(struct.backend_num);
oprot.writeFieldEnd();
}
if (struct.fragment_instance_id != null) {
if (struct.isSetFragmentInstanceId()) {
oprot.writeFieldBegin(FRAGMENT_INSTANCE_ID_FIELD_DESC);
struct.fragment_instance_id.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.status != null) {
if (struct.isSetStatus()) {
oprot.writeFieldBegin(STATUS_FIELD_DESC);
struct.status.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.isSetDone()) {
oprot.writeFieldBegin(DONE_FIELD_DESC);
oprot.writeBool(struct.done);
oprot.writeFieldEnd();
}
if (struct.profile != null) {
if (struct.isSetProfile()) {
oprot.writeFieldBegin(PROFILE_FIELD_DESC);
struct.profile.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.error_log != null) {
if (struct.isSetErrorLog()) {
oprot.writeFieldBegin(ERROR_LOG_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.error_log.size()));
for (java.lang.String _iter208 : struct.error_log)
{
oprot.writeString(_iter208);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.delta_urls != null) {
if (struct.isSetDeltaUrls()) {
oprot.writeFieldBegin(DELTA_URLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.delta_urls.size()));
for (java.lang.String _iter209 : struct.delta_urls)
{
oprot.writeString(_iter209);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.load_counters != null) {
if (struct.isSetLoadCounters()) {
oprot.writeFieldBegin(LOAD_COUNTERS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.load_counters.size()));
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter210 : struct.load_counters.entrySet())
{
oprot.writeString(_iter210.getKey());
oprot.writeString(_iter210.getValue());
}
oprot.writeMapEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.tracking_url != null) {
if (struct.isSetTrackingUrl()) {
oprot.writeFieldBegin(TRACKING_URL_FIELD_DESC);
oprot.writeString(struct.tracking_url);
oprot.writeFieldEnd();
}
}
if (struct.export_files != null) {
if (struct.isSetExportFiles()) {
oprot.writeFieldBegin(EXPORT_FILES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.export_files.size()));
for (java.lang.String _iter211 : struct.export_files)
{
oprot.writeString(_iter211);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.commitInfos != null) {
if (struct.isSetCommitInfos()) {
oprot.writeFieldBegin(COMMIT_INFOS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.commitInfos.size()));
for (org.apache.doris.thrift.TTabletCommitInfo _iter212 : struct.commitInfos)
{
_iter212.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.isSetLoadedRows()) {
oprot.writeFieldBegin(LOADED_ROWS_FIELD_DESC);
oprot.writeI64(struct.loaded_rows);
oprot.writeFieldEnd();
}
if (struct.isSetBackendId()) {
oprot.writeFieldBegin(BACKEND_ID_FIELD_DESC);
oprot.writeI64(struct.backend_id);
oprot.writeFieldEnd();
}
if (struct.isSetLoadedBytes()) {
oprot.writeFieldBegin(LOADED_BYTES_FIELD_DESC);
oprot.writeI64(struct.loaded_bytes);
oprot.writeFieldEnd();
}
if (struct.errorTabletInfos != null) {
if (struct.isSetErrorTabletInfos()) {
oprot.writeFieldBegin(ERROR_TABLET_INFOS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.errorTabletInfos.size()));
for (org.apache.doris.thrift.TErrorTabletInfo _iter213 : struct.errorTabletInfos)
{
_iter213.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.isSetFragmentId()) {
oprot.writeFieldBegin(FRAGMENT_ID_FIELD_DESC);
oprot.writeI32(struct.fragment_id);
oprot.writeFieldEnd();
}
if (struct.query_type != null) {
if (struct.isSetQueryType()) {
oprot.writeFieldBegin(QUERY_TYPE_FIELD_DESC);
oprot.writeI32(struct.query_type.getValue());
oprot.writeFieldEnd();
}
}
if (struct.loadChannelProfile != null) {
if (struct.isSetLoadChannelProfile()) {
oprot.writeFieldBegin(LOAD_CHANNEL_PROFILE_FIELD_DESC);
struct.loadChannelProfile.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.isSetFinishedScanRanges()) {
oprot.writeFieldBegin(FINISHED_SCAN_RANGES_FIELD_DESC);
oprot.writeI32(struct.finished_scan_ranges);
oprot.writeFieldEnd();
}
if (struct.detailed_report != null) {
if (struct.isSetDetailedReport()) {
oprot.writeFieldBegin(DETAILED_REPORT_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.detailed_report.size()));
for (TDetailedReportParams _iter214 : struct.detailed_report)
{
_iter214.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.query_statistics != null) {
if (struct.isSetQueryStatistics()) {
oprot.writeFieldBegin(QUERY_STATISTICS_FIELD_DESC);
struct.query_statistics.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.report_workload_runtime_status != null) {
if (struct.isSetReportWorkloadRuntimeStatus()) {
oprot.writeFieldBegin(REPORT_WORKLOAD_RUNTIME_STATUS_FIELD_DESC);
struct.report_workload_runtime_status.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.hive_partition_updates != null) {
if (struct.isSetHivePartitionUpdates()) {
oprot.writeFieldBegin(HIVE_PARTITION_UPDATES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.hive_partition_updates.size()));
for (org.apache.doris.thrift.THivePartitionUpdate _iter215 : struct.hive_partition_updates)
{
_iter215.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.query_profile != null) {
if (struct.isSetQueryProfile()) {
oprot.writeFieldBegin(QUERY_PROFILE_FIELD_DESC);
struct.query_profile.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.iceberg_commit_datas != null) {
if (struct.isSetIcebergCommitDatas()) {
oprot.writeFieldBegin(ICEBERG_COMMIT_DATAS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.iceberg_commit_datas.size()));
for (org.apache.doris.thrift.TIcebergCommitData _iter216 : struct.iceberg_commit_datas)
{
_iter216.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.isSetTxnId()) {
oprot.writeFieldBegin(TXN_ID_FIELD_DESC);
oprot.writeI64(struct.txn_id);
oprot.writeFieldEnd();
}
if (struct.label != null) {
if (struct.isSetLabel()) {
oprot.writeFieldBegin(LABEL_FIELD_DESC);
oprot.writeString(struct.label);
oprot.writeFieldEnd();
}
}
if (struct.fragment_instance_reports != null) {
if (struct.isSetFragmentInstanceReports()) {
oprot.writeFieldBegin(FRAGMENT_INSTANCE_REPORTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.fragment_instance_reports.size()));
for (TFragmentInstanceReport _iter217 : struct.fragment_instance_reports)
{
_iter217.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.mc_commit_datas != null) {
if (struct.isSetMcCommitDatas()) {
oprot.writeFieldBegin(MC_COMMIT_DATAS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.mc_commit_datas.size()));
for (org.apache.doris.thrift.TMCCommitData _iter218 : struct.mc_commit_datas)
{
_iter218.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.first_error_msg != null) {
if (struct.isSetFirstErrorMsg()) {
oprot.writeFieldBegin(FIRST_ERROR_MSG_FIELD_DESC);
oprot.writeString(struct.first_error_msg);
oprot.writeFieldEnd();
}
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class TReportExecStatusParamsTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TReportExecStatusParamsTupleScheme getScheme() {
return new TReportExecStatusParamsTupleScheme();
}
}
private static class TReportExecStatusParamsTupleScheme extends org.apache.thrift.scheme.TupleScheme<TReportExecStatusParams> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TReportExecStatusParams struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
oprot.writeI32(struct.protocol_version.getValue());
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetQueryId()) {
optionals.set(0);
}
if (struct.isSetBackendNum()) {
optionals.set(1);
}
if (struct.isSetFragmentInstanceId()) {
optionals.set(2);
}
if (struct.isSetStatus()) {
optionals.set(3);
}
if (struct.isSetDone()) {
optionals.set(4);
}
if (struct.isSetProfile()) {
optionals.set(5);
}
if (struct.isSetErrorLog()) {
optionals.set(6);
}
if (struct.isSetDeltaUrls()) {
optionals.set(7);
}
if (struct.isSetLoadCounters()) {
optionals.set(8);
}
if (struct.isSetTrackingUrl()) {
optionals.set(9);
}
if (struct.isSetExportFiles()) {
optionals.set(10);
}
if (struct.isSetCommitInfos()) {
optionals.set(11);
}
if (struct.isSetLoadedRows()) {
optionals.set(12);
}
if (struct.isSetBackendId()) {
optionals.set(13);
}
if (struct.isSetLoadedBytes()) {
optionals.set(14);
}
if (struct.isSetErrorTabletInfos()) {
optionals.set(15);
}
if (struct.isSetFragmentId()) {
optionals.set(16);
}
if (struct.isSetQueryType()) {
optionals.set(17);
}
if (struct.isSetLoadChannelProfile()) {
optionals.set(18);
}
if (struct.isSetFinishedScanRanges()) {
optionals.set(19);
}
if (struct.isSetDetailedReport()) {
optionals.set(20);
}
if (struct.isSetQueryStatistics()) {
optionals.set(21);
}
if (struct.isSetReportWorkloadRuntimeStatus()) {
optionals.set(22);
}
if (struct.isSetHivePartitionUpdates()) {
optionals.set(23);
}
if (struct.isSetQueryProfile()) {
optionals.set(24);
}
if (struct.isSetIcebergCommitDatas()) {
optionals.set(25);
}
if (struct.isSetTxnId()) {
optionals.set(26);
}
if (struct.isSetLabel()) {
optionals.set(27);
}
if (struct.isSetFragmentInstanceReports()) {
optionals.set(28);
}
if (struct.isSetMcCommitDatas()) {
optionals.set(29);
}
if (struct.isSetFirstErrorMsg()) {
optionals.set(30);
}
oprot.writeBitSet(optionals, 31);
if (struct.isSetQueryId()) {
struct.query_id.write(oprot);
}
if (struct.isSetBackendNum()) {
oprot.writeI32(struct.backend_num);
}
if (struct.isSetFragmentInstanceId()) {
struct.fragment_instance_id.write(oprot);
}
if (struct.isSetStatus()) {
struct.status.write(oprot);
}
if (struct.isSetDone()) {
oprot.writeBool(struct.done);
}
if (struct.isSetProfile()) {
struct.profile.write(oprot);
}
if (struct.isSetErrorLog()) {
{
oprot.writeI32(struct.error_log.size());
for (java.lang.String _iter219 : struct.error_log)
{
oprot.writeString(_iter219);
}
}
}
if (struct.isSetDeltaUrls()) {
{
oprot.writeI32(struct.delta_urls.size());
for (java.lang.String _iter220 : struct.delta_urls)
{
oprot.writeString(_iter220);
}
}
}
if (struct.isSetLoadCounters()) {
{
oprot.writeI32(struct.load_counters.size());
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter221 : struct.load_counters.entrySet())
{
oprot.writeString(_iter221.getKey());
oprot.writeString(_iter221.getValue());
}
}
}
if (struct.isSetTrackingUrl()) {
oprot.writeString(struct.tracking_url);
}
if (struct.isSetExportFiles()) {
{
oprot.writeI32(struct.export_files.size());
for (java.lang.String _iter222 : struct.export_files)
{
oprot.writeString(_iter222);
}
}
}
if (struct.isSetCommitInfos()) {
{
oprot.writeI32(struct.commitInfos.size());
for (org.apache.doris.thrift.TTabletCommitInfo _iter223 : struct.commitInfos)
{
_iter223.write(oprot);
}
}
}
if (struct.isSetLoadedRows()) {
oprot.writeI64(struct.loaded_rows);
}
if (struct.isSetBackendId()) {
oprot.writeI64(struct.backend_id);
}
if (struct.isSetLoadedBytes()) {
oprot.writeI64(struct.loaded_bytes);
}
if (struct.isSetErrorTabletInfos()) {
{
oprot.writeI32(struct.errorTabletInfos.size());
for (org.apache.doris.thrift.TErrorTabletInfo _iter224 : struct.errorTabletInfos)
{
_iter224.write(oprot);
}
}
}
if (struct.isSetFragmentId()) {
oprot.writeI32(struct.fragment_id);
}
if (struct.isSetQueryType()) {
oprot.writeI32(struct.query_type.getValue());
}
if (struct.isSetLoadChannelProfile()) {
struct.loadChannelProfile.write(oprot);
}
if (struct.isSetFinishedScanRanges()) {
oprot.writeI32(struct.finished_scan_ranges);
}
if (struct.isSetDetailedReport()) {
{
oprot.writeI32(struct.detailed_report.size());
for (TDetailedReportParams _iter225 : struct.detailed_report)
{
_iter225.write(oprot);
}
}
}
if (struct.isSetQueryStatistics()) {
struct.query_statistics.write(oprot);
}
if (struct.isSetReportWorkloadRuntimeStatus()) {
struct.report_workload_runtime_status.write(oprot);
}
if (struct.isSetHivePartitionUpdates()) {
{
oprot.writeI32(struct.hive_partition_updates.size());
for (org.apache.doris.thrift.THivePartitionUpdate _iter226 : struct.hive_partition_updates)
{
_iter226.write(oprot);
}
}
}
if (struct.isSetQueryProfile()) {
struct.query_profile.write(oprot);
}
if (struct.isSetIcebergCommitDatas()) {
{
oprot.writeI32(struct.iceberg_commit_datas.size());
for (org.apache.doris.thrift.TIcebergCommitData _iter227 : struct.iceberg_commit_datas)
{
_iter227.write(oprot);
}
}
}
if (struct.isSetTxnId()) {
oprot.writeI64(struct.txn_id);
}
if (struct.isSetLabel()) {
oprot.writeString(struct.label);
}
if (struct.isSetFragmentInstanceReports()) {
{
oprot.writeI32(struct.fragment_instance_reports.size());
for (TFragmentInstanceReport _iter228 : struct.fragment_instance_reports)
{
_iter228.write(oprot);
}
}
}
if (struct.isSetMcCommitDatas()) {
{
oprot.writeI32(struct.mc_commit_datas.size());
for (org.apache.doris.thrift.TMCCommitData _iter229 : struct.mc_commit_datas)
{
_iter229.write(oprot);
}
}
}
if (struct.isSetFirstErrorMsg()) {
oprot.writeString(struct.first_error_msg);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TReportExecStatusParams struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
struct.protocol_version = org.apache.doris.thrift.FrontendServiceVersion.findByValue(iprot.readI32());
struct.setProtocolVersionIsSet(true);
java.util.BitSet incoming = iprot.readBitSet(31);
if (incoming.get(0)) {
struct.query_id = new org.apache.doris.thrift.TUniqueId();
struct.query_id.read(iprot);
struct.setQueryIdIsSet(true);
}
if (incoming.get(1)) {
struct.backend_num = iprot.readI32();
struct.setBackendNumIsSet(true);
}
if (incoming.get(2)) {
struct.fragment_instance_id = new org.apache.doris.thrift.TUniqueId();
struct.fragment_instance_id.read(iprot);
struct.setFragmentInstanceIdIsSet(true);
}
if (incoming.get(3)) {
struct.status = new org.apache.doris.thrift.TStatus();
struct.status.read(iprot);
struct.setStatusIsSet(true);
}
if (incoming.get(4)) {
struct.done = iprot.readBool();
struct.setDoneIsSet(true);
}
if (incoming.get(5)) {
struct.profile = new org.apache.doris.thrift.TRuntimeProfileTree();
struct.profile.read(iprot);
struct.setProfileIsSet(true);
}
if (incoming.get(6)) {
{
org.apache.thrift.protocol.TList _list230 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRING);
struct.error_log = new java.util.ArrayList<java.lang.String>(_list230.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem231;
for (int _i232 = 0; _i232 < _list230.size; ++_i232)
{
_elem231 = iprot.readString();
struct.error_log.add(_elem231);
}
}
struct.setErrorLogIsSet(true);
}
if (incoming.get(7)) {
{
org.apache.thrift.protocol.TList _list233 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRING);
struct.delta_urls = new java.util.ArrayList<java.lang.String>(_list233.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem234;
for (int _i235 = 0; _i235 < _list233.size; ++_i235)
{
_elem234 = iprot.readString();
struct.delta_urls.add(_elem234);
}
}
struct.setDeltaUrlsIsSet(true);
}
if (incoming.get(8)) {
{
org.apache.thrift.protocol.TMap _map236 = iprot.readMapBegin(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING);
struct.load_counters = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map236.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key237;
@org.apache.thrift.annotation.Nullable java.lang.String _val238;
for (int _i239 = 0; _i239 < _map236.size; ++_i239)
{
_key237 = iprot.readString();
_val238 = iprot.readString();
struct.load_counters.put(_key237, _val238);
}
}
struct.setLoadCountersIsSet(true);
}
if (incoming.get(9)) {
struct.tracking_url = iprot.readString();
struct.setTrackingUrlIsSet(true);
}
if (incoming.get(10)) {
{
org.apache.thrift.protocol.TList _list240 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRING);
struct.export_files = new java.util.ArrayList<java.lang.String>(_list240.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem241;
for (int _i242 = 0; _i242 < _list240.size; ++_i242)
{
_elem241 = iprot.readString();
struct.export_files.add(_elem241);
}
}
struct.setExportFilesIsSet(true);
}
if (incoming.get(11)) {
{
org.apache.thrift.protocol.TList _list243 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.commitInfos = new java.util.ArrayList<org.apache.doris.thrift.TTabletCommitInfo>(_list243.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TTabletCommitInfo _elem244;
for (int _i245 = 0; _i245 < _list243.size; ++_i245)
{
_elem244 = new org.apache.doris.thrift.TTabletCommitInfo();
_elem244.read(iprot);
struct.commitInfos.add(_elem244);
}
}
struct.setCommitInfosIsSet(true);
}
if (incoming.get(12)) {
struct.loaded_rows = iprot.readI64();
struct.setLoadedRowsIsSet(true);
}
if (incoming.get(13)) {
struct.backend_id = iprot.readI64();
struct.setBackendIdIsSet(true);
}
if (incoming.get(14)) {
struct.loaded_bytes = iprot.readI64();
struct.setLoadedBytesIsSet(true);
}
if (incoming.get(15)) {
{
org.apache.thrift.protocol.TList _list246 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.errorTabletInfos = new java.util.ArrayList<org.apache.doris.thrift.TErrorTabletInfo>(_list246.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TErrorTabletInfo _elem247;
for (int _i248 = 0; _i248 < _list246.size; ++_i248)
{
_elem247 = new org.apache.doris.thrift.TErrorTabletInfo();
_elem247.read(iprot);
struct.errorTabletInfos.add(_elem247);
}
}
struct.setErrorTabletInfosIsSet(true);
}
if (incoming.get(16)) {
struct.fragment_id = iprot.readI32();
struct.setFragmentIdIsSet(true);
}
if (incoming.get(17)) {
struct.query_type = org.apache.doris.thrift.TQueryType.findByValue(iprot.readI32());
struct.setQueryTypeIsSet(true);
}
if (incoming.get(18)) {
struct.loadChannelProfile = new org.apache.doris.thrift.TRuntimeProfileTree();
struct.loadChannelProfile.read(iprot);
struct.setLoadChannelProfileIsSet(true);
}
if (incoming.get(19)) {
struct.finished_scan_ranges = iprot.readI32();
struct.setFinishedScanRangesIsSet(true);
}
if (incoming.get(20)) {
{
org.apache.thrift.protocol.TList _list249 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.detailed_report = new java.util.ArrayList<TDetailedReportParams>(_list249.size);
@org.apache.thrift.annotation.Nullable TDetailedReportParams _elem250;
for (int _i251 = 0; _i251 < _list249.size; ++_i251)
{
_elem250 = new TDetailedReportParams();
_elem250.read(iprot);
struct.detailed_report.add(_elem250);
}
}
struct.setDetailedReportIsSet(true);
}
if (incoming.get(21)) {
struct.query_statistics = new TQueryStatistics();
struct.query_statistics.read(iprot);
struct.setQueryStatisticsIsSet(true);
}
if (incoming.get(22)) {
struct.report_workload_runtime_status = new TReportWorkloadRuntimeStatusParams();
struct.report_workload_runtime_status.read(iprot);
struct.setReportWorkloadRuntimeStatusIsSet(true);
}
if (incoming.get(23)) {
{
org.apache.thrift.protocol.TList _list252 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.hive_partition_updates = new java.util.ArrayList<org.apache.doris.thrift.THivePartitionUpdate>(_list252.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.THivePartitionUpdate _elem253;
for (int _i254 = 0; _i254 < _list252.size; ++_i254)
{
_elem253 = new org.apache.doris.thrift.THivePartitionUpdate();
_elem253.read(iprot);
struct.hive_partition_updates.add(_elem253);
}
}
struct.setHivePartitionUpdatesIsSet(true);
}
if (incoming.get(24)) {
struct.query_profile = new TQueryProfile();
struct.query_profile.read(iprot);
struct.setQueryProfileIsSet(true);
}
if (incoming.get(25)) {
{
org.apache.thrift.protocol.TList _list255 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.iceberg_commit_datas = new java.util.ArrayList<org.apache.doris.thrift.TIcebergCommitData>(_list255.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TIcebergCommitData _elem256;
for (int _i257 = 0; _i257 < _list255.size; ++_i257)
{
_elem256 = new org.apache.doris.thrift.TIcebergCommitData();
_elem256.read(iprot);
struct.iceberg_commit_datas.add(_elem256);
}
}
struct.setIcebergCommitDatasIsSet(true);
}
if (incoming.get(26)) {
struct.txn_id = iprot.readI64();
struct.setTxnIdIsSet(true);
}
if (incoming.get(27)) {
struct.label = iprot.readString();
struct.setLabelIsSet(true);
}
if (incoming.get(28)) {
{
org.apache.thrift.protocol.TList _list258 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.fragment_instance_reports = new java.util.ArrayList<TFragmentInstanceReport>(_list258.size);
@org.apache.thrift.annotation.Nullable TFragmentInstanceReport _elem259;
for (int _i260 = 0; _i260 < _list258.size; ++_i260)
{
_elem259 = new TFragmentInstanceReport();
_elem259.read(iprot);
struct.fragment_instance_reports.add(_elem259);
}
}
struct.setFragmentInstanceReportsIsSet(true);
}
if (incoming.get(29)) {
{
org.apache.thrift.protocol.TList _list261 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.mc_commit_datas = new java.util.ArrayList<org.apache.doris.thrift.TMCCommitData>(_list261.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TMCCommitData _elem262;
for (int _i263 = 0; _i263 < _list261.size; ++_i263)
{
_elem262 = new org.apache.doris.thrift.TMCCommitData();
_elem262.read(iprot);
struct.mc_commit_datas.add(_elem262);
}
}
struct.setMcCommitDatasIsSet(true);
}
if (incoming.get(30)) {
struct.first_error_msg = iprot.readString();
struct.setFirstErrorMsgIsSet(true);
}
}
}
private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) {
return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
}
}