TPipelineFragmentParamsList.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 TPipelineFragmentParamsList implements org.apache.thrift.TBase<TPipelineFragmentParamsList, TPipelineFragmentParamsList._Fields>, java.io.Serializable, Cloneable, Comparable<TPipelineFragmentParamsList> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TPipelineFragmentParamsList");
private static final org.apache.thrift.protocol.TField PARAMS_LIST_FIELD_DESC = new org.apache.thrift.protocol.TField("params_list", org.apache.thrift.protocol.TType.LIST, (short)1);
private static final org.apache.thrift.protocol.TField DESC_TBL_FIELD_DESC = new org.apache.thrift.protocol.TField("desc_tbl", org.apache.thrift.protocol.TType.STRUCT, (short)2);
private static final org.apache.thrift.protocol.TField FILE_SCAN_PARAMS_FIELD_DESC = new org.apache.thrift.protocol.TField("file_scan_params", org.apache.thrift.protocol.TType.MAP, (short)3);
private static final org.apache.thrift.protocol.TField COORD_FIELD_DESC = new org.apache.thrift.protocol.TField("coord", org.apache.thrift.protocol.TType.STRUCT, (short)4);
private static final org.apache.thrift.protocol.TField QUERY_GLOBALS_FIELD_DESC = new org.apache.thrift.protocol.TField("query_globals", org.apache.thrift.protocol.TType.STRUCT, (short)5);
private static final org.apache.thrift.protocol.TField RESOURCE_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("resource_info", org.apache.thrift.protocol.TType.STRUCT, (short)6);
private static final org.apache.thrift.protocol.TField FRAGMENT_NUM_ON_HOST_FIELD_DESC = new org.apache.thrift.protocol.TField("fragment_num_on_host", org.apache.thrift.protocol.TType.I32, (short)7);
private static final org.apache.thrift.protocol.TField QUERY_OPTIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("query_options", org.apache.thrift.protocol.TType.STRUCT, (short)8);
private static final org.apache.thrift.protocol.TField IS_NEREIDS_FIELD_DESC = new org.apache.thrift.protocol.TField("is_nereids", org.apache.thrift.protocol.TType.BOOL, (short)9);
private static final org.apache.thrift.protocol.TField WORKLOAD_GROUPS_FIELD_DESC = new org.apache.thrift.protocol.TField("workload_groups", org.apache.thrift.protocol.TType.LIST, (short)10);
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)11);
private static final org.apache.thrift.protocol.TField TOPN_FILTER_SOURCE_NODE_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("topn_filter_source_node_ids", org.apache.thrift.protocol.TType.LIST, (short)12);
private static final org.apache.thrift.protocol.TField RUNTIME_FILTER_MERGE_ADDR_FIELD_DESC = new org.apache.thrift.protocol.TField("runtime_filter_merge_addr", org.apache.thrift.protocol.TType.STRUCT, (short)13);
private static final org.apache.thrift.protocol.TField RUNTIME_FILTER_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("runtime_filter_info", org.apache.thrift.protocol.TType.STRUCT, (short)14);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TPipelineFragmentParamsListStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TPipelineFragmentParamsListTupleSchemeFactory();
public @org.apache.thrift.annotation.Nullable java.util.List<TPipelineFragmentParams> params_list; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TDescriptorTable desc_tbl; // optional
public @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.Integer,org.apache.doris.thrift.TFileScanRangeParams> file_scan_params; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TNetworkAddress coord; // optional
public @org.apache.thrift.annotation.Nullable TQueryGlobals query_globals; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TResourceInfo resource_info; // optional
public int fragment_num_on_host; // optional
public @org.apache.thrift.annotation.Nullable TQueryOptions query_options; // optional
public boolean is_nereids; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<TPipelineWorkloadGroup> workload_groups; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TUniqueId query_id; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<java.lang.Integer> topn_filter_source_node_ids; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TNetworkAddress runtime_filter_merge_addr; // optional
public @org.apache.thrift.annotation.Nullable TRuntimeFilterInfo runtime_filter_info; // 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 {
PARAMS_LIST((short)1, "params_list"),
DESC_TBL((short)2, "desc_tbl"),
FILE_SCAN_PARAMS((short)3, "file_scan_params"),
COORD((short)4, "coord"),
QUERY_GLOBALS((short)5, "query_globals"),
RESOURCE_INFO((short)6, "resource_info"),
FRAGMENT_NUM_ON_HOST((short)7, "fragment_num_on_host"),
QUERY_OPTIONS((short)8, "query_options"),
IS_NEREIDS((short)9, "is_nereids"),
WORKLOAD_GROUPS((short)10, "workload_groups"),
QUERY_ID((short)11, "query_id"),
TOPN_FILTER_SOURCE_NODE_IDS((short)12, "topn_filter_source_node_ids"),
RUNTIME_FILTER_MERGE_ADDR((short)13, "runtime_filter_merge_addr"),
RUNTIME_FILTER_INFO((short)14, "runtime_filter_info");
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: // PARAMS_LIST
return PARAMS_LIST;
case 2: // DESC_TBL
return DESC_TBL;
case 3: // FILE_SCAN_PARAMS
return FILE_SCAN_PARAMS;
case 4: // COORD
return COORD;
case 5: // QUERY_GLOBALS
return QUERY_GLOBALS;
case 6: // RESOURCE_INFO
return RESOURCE_INFO;
case 7: // FRAGMENT_NUM_ON_HOST
return FRAGMENT_NUM_ON_HOST;
case 8: // QUERY_OPTIONS
return QUERY_OPTIONS;
case 9: // IS_NEREIDS
return IS_NEREIDS;
case 10: // WORKLOAD_GROUPS
return WORKLOAD_GROUPS;
case 11: // QUERY_ID
return QUERY_ID;
case 12: // TOPN_FILTER_SOURCE_NODE_IDS
return TOPN_FILTER_SOURCE_NODE_IDS;
case 13: // RUNTIME_FILTER_MERGE_ADDR
return RUNTIME_FILTER_MERGE_ADDR;
case 14: // RUNTIME_FILTER_INFO
return RUNTIME_FILTER_INFO;
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 __FRAGMENT_NUM_ON_HOST_ISSET_ID = 0;
private static final int __IS_NEREIDS_ISSET_ID = 1;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.PARAMS_LIST,_Fields.DESC_TBL,_Fields.FILE_SCAN_PARAMS,_Fields.COORD,_Fields.QUERY_GLOBALS,_Fields.RESOURCE_INFO,_Fields.FRAGMENT_NUM_ON_HOST,_Fields.QUERY_OPTIONS,_Fields.IS_NEREIDS,_Fields.WORKLOAD_GROUPS,_Fields.QUERY_ID,_Fields.TOPN_FILTER_SOURCE_NODE_IDS,_Fields.RUNTIME_FILTER_MERGE_ADDR,_Fields.RUNTIME_FILTER_INFO};
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.PARAMS_LIST, new org.apache.thrift.meta_data.FieldMetaData("params_list", 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, TPipelineFragmentParams.class))));
tmpMap.put(_Fields.DESC_TBL, new org.apache.thrift.meta_data.FieldMetaData("desc_tbl", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TDescriptorTable.class)));
tmpMap.put(_Fields.FILE_SCAN_PARAMS, new org.apache.thrift.meta_data.FieldMetaData("file_scan_params", 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.I32 , "TPlanNodeId"),
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TFileScanRangeParams.class))));
tmpMap.put(_Fields.COORD, new org.apache.thrift.meta_data.FieldMetaData("coord", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TNetworkAddress.class)));
tmpMap.put(_Fields.QUERY_GLOBALS, new org.apache.thrift.meta_data.FieldMetaData("query_globals", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TQueryGlobals.class)));
tmpMap.put(_Fields.RESOURCE_INFO, new org.apache.thrift.meta_data.FieldMetaData("resource_info", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TResourceInfo.class)));
tmpMap.put(_Fields.FRAGMENT_NUM_ON_HOST, new org.apache.thrift.meta_data.FieldMetaData("fragment_num_on_host", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.QUERY_OPTIONS, new org.apache.thrift.meta_data.FieldMetaData("query_options", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TQueryOptions.class)));
tmpMap.put(_Fields.IS_NEREIDS, new org.apache.thrift.meta_data.FieldMetaData("is_nereids", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.WORKLOAD_GROUPS, new org.apache.thrift.meta_data.FieldMetaData("workload_groups", 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, TPipelineWorkloadGroup.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.TOPN_FILTER_SOURCE_NODE_IDS, new org.apache.thrift.meta_data.FieldMetaData("topn_filter_source_node_ids", 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.I32))));
tmpMap.put(_Fields.RUNTIME_FILTER_MERGE_ADDR, new org.apache.thrift.meta_data.FieldMetaData("runtime_filter_merge_addr", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TNetworkAddress.class)));
tmpMap.put(_Fields.RUNTIME_FILTER_INFO, new org.apache.thrift.meta_data.FieldMetaData("runtime_filter_info", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TRuntimeFilterInfo.class)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TPipelineFragmentParamsList.class, metaDataMap);
}
public TPipelineFragmentParamsList() {
this.is_nereids = true;
}
/**
* Performs a deep copy on <i>other</i>.
*/
public TPipelineFragmentParamsList(TPipelineFragmentParamsList other) {
__isset_bitfield = other.__isset_bitfield;
if (other.isSetParamsList()) {
java.util.List<TPipelineFragmentParams> __this__params_list = new java.util.ArrayList<TPipelineFragmentParams>(other.params_list.size());
for (TPipelineFragmentParams other_element : other.params_list) {
__this__params_list.add(new TPipelineFragmentParams(other_element));
}
this.params_list = __this__params_list;
}
if (other.isSetDescTbl()) {
this.desc_tbl = new org.apache.doris.thrift.TDescriptorTable(other.desc_tbl);
}
if (other.isSetFileScanParams()) {
java.util.Map<java.lang.Integer,org.apache.doris.thrift.TFileScanRangeParams> __this__file_scan_params = new java.util.HashMap<java.lang.Integer,org.apache.doris.thrift.TFileScanRangeParams>(other.file_scan_params.size());
for (java.util.Map.Entry<java.lang.Integer, org.apache.doris.thrift.TFileScanRangeParams> other_element : other.file_scan_params.entrySet()) {
java.lang.Integer other_element_key = other_element.getKey();
org.apache.doris.thrift.TFileScanRangeParams other_element_value = other_element.getValue();
java.lang.Integer __this__file_scan_params_copy_key = other_element_key;
org.apache.doris.thrift.TFileScanRangeParams __this__file_scan_params_copy_value = new org.apache.doris.thrift.TFileScanRangeParams(other_element_value);
__this__file_scan_params.put(__this__file_scan_params_copy_key, __this__file_scan_params_copy_value);
}
this.file_scan_params = __this__file_scan_params;
}
if (other.isSetCoord()) {
this.coord = new org.apache.doris.thrift.TNetworkAddress(other.coord);
}
if (other.isSetQueryGlobals()) {
this.query_globals = new TQueryGlobals(other.query_globals);
}
if (other.isSetResourceInfo()) {
this.resource_info = new org.apache.doris.thrift.TResourceInfo(other.resource_info);
}
this.fragment_num_on_host = other.fragment_num_on_host;
if (other.isSetQueryOptions()) {
this.query_options = new TQueryOptions(other.query_options);
}
this.is_nereids = other.is_nereids;
if (other.isSetWorkloadGroups()) {
java.util.List<TPipelineWorkloadGroup> __this__workload_groups = new java.util.ArrayList<TPipelineWorkloadGroup>(other.workload_groups.size());
for (TPipelineWorkloadGroup other_element : other.workload_groups) {
__this__workload_groups.add(new TPipelineWorkloadGroup(other_element));
}
this.workload_groups = __this__workload_groups;
}
if (other.isSetQueryId()) {
this.query_id = new org.apache.doris.thrift.TUniqueId(other.query_id);
}
if (other.isSetTopnFilterSourceNodeIds()) {
java.util.List<java.lang.Integer> __this__topn_filter_source_node_ids = new java.util.ArrayList<java.lang.Integer>(other.topn_filter_source_node_ids);
this.topn_filter_source_node_ids = __this__topn_filter_source_node_ids;
}
if (other.isSetRuntimeFilterMergeAddr()) {
this.runtime_filter_merge_addr = new org.apache.doris.thrift.TNetworkAddress(other.runtime_filter_merge_addr);
}
if (other.isSetRuntimeFilterInfo()) {
this.runtime_filter_info = new TRuntimeFilterInfo(other.runtime_filter_info);
}
}
public TPipelineFragmentParamsList deepCopy() {
return new TPipelineFragmentParamsList(this);
}
@Override
public void clear() {
this.params_list = null;
this.desc_tbl = null;
this.file_scan_params = null;
this.coord = null;
this.query_globals = null;
this.resource_info = null;
setFragmentNumOnHostIsSet(false);
this.fragment_num_on_host = 0;
this.query_options = null;
this.is_nereids = true;
this.workload_groups = null;
this.query_id = null;
this.topn_filter_source_node_ids = null;
this.runtime_filter_merge_addr = null;
this.runtime_filter_info = null;
}
public int getParamsListSize() {
return (this.params_list == null) ? 0 : this.params_list.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<TPipelineFragmentParams> getParamsListIterator() {
return (this.params_list == null) ? null : this.params_list.iterator();
}
public void addToParamsList(TPipelineFragmentParams elem) {
if (this.params_list == null) {
this.params_list = new java.util.ArrayList<TPipelineFragmentParams>();
}
this.params_list.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<TPipelineFragmentParams> getParamsList() {
return this.params_list;
}
public TPipelineFragmentParamsList setParamsList(@org.apache.thrift.annotation.Nullable java.util.List<TPipelineFragmentParams> params_list) {
this.params_list = params_list;
return this;
}
public void unsetParamsList() {
this.params_list = null;
}
/** Returns true if field params_list is set (has been assigned a value) and false otherwise */
public boolean isSetParamsList() {
return this.params_list != null;
}
public void setParamsListIsSet(boolean value) {
if (!value) {
this.params_list = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TDescriptorTable getDescTbl() {
return this.desc_tbl;
}
public TPipelineFragmentParamsList setDescTbl(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TDescriptorTable desc_tbl) {
this.desc_tbl = desc_tbl;
return this;
}
public void unsetDescTbl() {
this.desc_tbl = null;
}
/** Returns true if field desc_tbl is set (has been assigned a value) and false otherwise */
public boolean isSetDescTbl() {
return this.desc_tbl != null;
}
public void setDescTblIsSet(boolean value) {
if (!value) {
this.desc_tbl = null;
}
}
public int getFileScanParamsSize() {
return (this.file_scan_params == null) ? 0 : this.file_scan_params.size();
}
public void putToFileScanParams(int key, org.apache.doris.thrift.TFileScanRangeParams val) {
if (this.file_scan_params == null) {
this.file_scan_params = new java.util.HashMap<java.lang.Integer,org.apache.doris.thrift.TFileScanRangeParams>();
}
this.file_scan_params.put(key, val);
}
@org.apache.thrift.annotation.Nullable
public java.util.Map<java.lang.Integer,org.apache.doris.thrift.TFileScanRangeParams> getFileScanParams() {
return this.file_scan_params;
}
public TPipelineFragmentParamsList setFileScanParams(@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.Integer,org.apache.doris.thrift.TFileScanRangeParams> file_scan_params) {
this.file_scan_params = file_scan_params;
return this;
}
public void unsetFileScanParams() {
this.file_scan_params = null;
}
/** Returns true if field file_scan_params is set (has been assigned a value) and false otherwise */
public boolean isSetFileScanParams() {
return this.file_scan_params != null;
}
public void setFileScanParamsIsSet(boolean value) {
if (!value) {
this.file_scan_params = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TNetworkAddress getCoord() {
return this.coord;
}
public TPipelineFragmentParamsList setCoord(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TNetworkAddress coord) {
this.coord = coord;
return this;
}
public void unsetCoord() {
this.coord = null;
}
/** Returns true if field coord is set (has been assigned a value) and false otherwise */
public boolean isSetCoord() {
return this.coord != null;
}
public void setCoordIsSet(boolean value) {
if (!value) {
this.coord = null;
}
}
@org.apache.thrift.annotation.Nullable
public TQueryGlobals getQueryGlobals() {
return this.query_globals;
}
public TPipelineFragmentParamsList setQueryGlobals(@org.apache.thrift.annotation.Nullable TQueryGlobals query_globals) {
this.query_globals = query_globals;
return this;
}
public void unsetQueryGlobals() {
this.query_globals = null;
}
/** Returns true if field query_globals is set (has been assigned a value) and false otherwise */
public boolean isSetQueryGlobals() {
return this.query_globals != null;
}
public void setQueryGlobalsIsSet(boolean value) {
if (!value) {
this.query_globals = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TResourceInfo getResourceInfo() {
return this.resource_info;
}
public TPipelineFragmentParamsList setResourceInfo(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TResourceInfo resource_info) {
this.resource_info = resource_info;
return this;
}
public void unsetResourceInfo() {
this.resource_info = null;
}
/** Returns true if field resource_info is set (has been assigned a value) and false otherwise */
public boolean isSetResourceInfo() {
return this.resource_info != null;
}
public void setResourceInfoIsSet(boolean value) {
if (!value) {
this.resource_info = null;
}
}
public int getFragmentNumOnHost() {
return this.fragment_num_on_host;
}
public TPipelineFragmentParamsList setFragmentNumOnHost(int fragment_num_on_host) {
this.fragment_num_on_host = fragment_num_on_host;
setFragmentNumOnHostIsSet(true);
return this;
}
public void unsetFragmentNumOnHost() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __FRAGMENT_NUM_ON_HOST_ISSET_ID);
}
/** Returns true if field fragment_num_on_host is set (has been assigned a value) and false otherwise */
public boolean isSetFragmentNumOnHost() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __FRAGMENT_NUM_ON_HOST_ISSET_ID);
}
public void setFragmentNumOnHostIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __FRAGMENT_NUM_ON_HOST_ISSET_ID, value);
}
@org.apache.thrift.annotation.Nullable
public TQueryOptions getQueryOptions() {
return this.query_options;
}
public TPipelineFragmentParamsList setQueryOptions(@org.apache.thrift.annotation.Nullable TQueryOptions query_options) {
this.query_options = query_options;
return this;
}
public void unsetQueryOptions() {
this.query_options = null;
}
/** Returns true if field query_options is set (has been assigned a value) and false otherwise */
public boolean isSetQueryOptions() {
return this.query_options != null;
}
public void setQueryOptionsIsSet(boolean value) {
if (!value) {
this.query_options = null;
}
}
public boolean isIsNereids() {
return this.is_nereids;
}
public TPipelineFragmentParamsList setIsNereids(boolean is_nereids) {
this.is_nereids = is_nereids;
setIsNereidsIsSet(true);
return this;
}
public void unsetIsNereids() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __IS_NEREIDS_ISSET_ID);
}
/** Returns true if field is_nereids is set (has been assigned a value) and false otherwise */
public boolean isSetIsNereids() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __IS_NEREIDS_ISSET_ID);
}
public void setIsNereidsIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __IS_NEREIDS_ISSET_ID, value);
}
public int getWorkloadGroupsSize() {
return (this.workload_groups == null) ? 0 : this.workload_groups.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<TPipelineWorkloadGroup> getWorkloadGroupsIterator() {
return (this.workload_groups == null) ? null : this.workload_groups.iterator();
}
public void addToWorkloadGroups(TPipelineWorkloadGroup elem) {
if (this.workload_groups == null) {
this.workload_groups = new java.util.ArrayList<TPipelineWorkloadGroup>();
}
this.workload_groups.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<TPipelineWorkloadGroup> getWorkloadGroups() {
return this.workload_groups;
}
public TPipelineFragmentParamsList setWorkloadGroups(@org.apache.thrift.annotation.Nullable java.util.List<TPipelineWorkloadGroup> workload_groups) {
this.workload_groups = workload_groups;
return this;
}
public void unsetWorkloadGroups() {
this.workload_groups = null;
}
/** Returns true if field workload_groups is set (has been assigned a value) and false otherwise */
public boolean isSetWorkloadGroups() {
return this.workload_groups != null;
}
public void setWorkloadGroupsIsSet(boolean value) {
if (!value) {
this.workload_groups = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TUniqueId getQueryId() {
return this.query_id;
}
public TPipelineFragmentParamsList 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 getTopnFilterSourceNodeIdsSize() {
return (this.topn_filter_source_node_ids == null) ? 0 : this.topn_filter_source_node_ids.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<java.lang.Integer> getTopnFilterSourceNodeIdsIterator() {
return (this.topn_filter_source_node_ids == null) ? null : this.topn_filter_source_node_ids.iterator();
}
public void addToTopnFilterSourceNodeIds(int elem) {
if (this.topn_filter_source_node_ids == null) {
this.topn_filter_source_node_ids = new java.util.ArrayList<java.lang.Integer>();
}
this.topn_filter_source_node_ids.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<java.lang.Integer> getTopnFilterSourceNodeIds() {
return this.topn_filter_source_node_ids;
}
public TPipelineFragmentParamsList setTopnFilterSourceNodeIds(@org.apache.thrift.annotation.Nullable java.util.List<java.lang.Integer> topn_filter_source_node_ids) {
this.topn_filter_source_node_ids = topn_filter_source_node_ids;
return this;
}
public void unsetTopnFilterSourceNodeIds() {
this.topn_filter_source_node_ids = null;
}
/** Returns true if field topn_filter_source_node_ids is set (has been assigned a value) and false otherwise */
public boolean isSetTopnFilterSourceNodeIds() {
return this.topn_filter_source_node_ids != null;
}
public void setTopnFilterSourceNodeIdsIsSet(boolean value) {
if (!value) {
this.topn_filter_source_node_ids = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TNetworkAddress getRuntimeFilterMergeAddr() {
return this.runtime_filter_merge_addr;
}
public TPipelineFragmentParamsList setRuntimeFilterMergeAddr(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TNetworkAddress runtime_filter_merge_addr) {
this.runtime_filter_merge_addr = runtime_filter_merge_addr;
return this;
}
public void unsetRuntimeFilterMergeAddr() {
this.runtime_filter_merge_addr = null;
}
/** Returns true if field runtime_filter_merge_addr is set (has been assigned a value) and false otherwise */
public boolean isSetRuntimeFilterMergeAddr() {
return this.runtime_filter_merge_addr != null;
}
public void setRuntimeFilterMergeAddrIsSet(boolean value) {
if (!value) {
this.runtime_filter_merge_addr = null;
}
}
@org.apache.thrift.annotation.Nullable
public TRuntimeFilterInfo getRuntimeFilterInfo() {
return this.runtime_filter_info;
}
public TPipelineFragmentParamsList setRuntimeFilterInfo(@org.apache.thrift.annotation.Nullable TRuntimeFilterInfo runtime_filter_info) {
this.runtime_filter_info = runtime_filter_info;
return this;
}
public void unsetRuntimeFilterInfo() {
this.runtime_filter_info = null;
}
/** Returns true if field runtime_filter_info is set (has been assigned a value) and false otherwise */
public boolean isSetRuntimeFilterInfo() {
return this.runtime_filter_info != null;
}
public void setRuntimeFilterInfoIsSet(boolean value) {
if (!value) {
this.runtime_filter_info = null;
}
}
public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case PARAMS_LIST:
if (value == null) {
unsetParamsList();
} else {
setParamsList((java.util.List<TPipelineFragmentParams>)value);
}
break;
case DESC_TBL:
if (value == null) {
unsetDescTbl();
} else {
setDescTbl((org.apache.doris.thrift.TDescriptorTable)value);
}
break;
case FILE_SCAN_PARAMS:
if (value == null) {
unsetFileScanParams();
} else {
setFileScanParams((java.util.Map<java.lang.Integer,org.apache.doris.thrift.TFileScanRangeParams>)value);
}
break;
case COORD:
if (value == null) {
unsetCoord();
} else {
setCoord((org.apache.doris.thrift.TNetworkAddress)value);
}
break;
case QUERY_GLOBALS:
if (value == null) {
unsetQueryGlobals();
} else {
setQueryGlobals((TQueryGlobals)value);
}
break;
case RESOURCE_INFO:
if (value == null) {
unsetResourceInfo();
} else {
setResourceInfo((org.apache.doris.thrift.TResourceInfo)value);
}
break;
case FRAGMENT_NUM_ON_HOST:
if (value == null) {
unsetFragmentNumOnHost();
} else {
setFragmentNumOnHost((java.lang.Integer)value);
}
break;
case QUERY_OPTIONS:
if (value == null) {
unsetQueryOptions();
} else {
setQueryOptions((TQueryOptions)value);
}
break;
case IS_NEREIDS:
if (value == null) {
unsetIsNereids();
} else {
setIsNereids((java.lang.Boolean)value);
}
break;
case WORKLOAD_GROUPS:
if (value == null) {
unsetWorkloadGroups();
} else {
setWorkloadGroups((java.util.List<TPipelineWorkloadGroup>)value);
}
break;
case QUERY_ID:
if (value == null) {
unsetQueryId();
} else {
setQueryId((org.apache.doris.thrift.TUniqueId)value);
}
break;
case TOPN_FILTER_SOURCE_NODE_IDS:
if (value == null) {
unsetTopnFilterSourceNodeIds();
} else {
setTopnFilterSourceNodeIds((java.util.List<java.lang.Integer>)value);
}
break;
case RUNTIME_FILTER_MERGE_ADDR:
if (value == null) {
unsetRuntimeFilterMergeAddr();
} else {
setRuntimeFilterMergeAddr((org.apache.doris.thrift.TNetworkAddress)value);
}
break;
case RUNTIME_FILTER_INFO:
if (value == null) {
unsetRuntimeFilterInfo();
} else {
setRuntimeFilterInfo((TRuntimeFilterInfo)value);
}
break;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case PARAMS_LIST:
return getParamsList();
case DESC_TBL:
return getDescTbl();
case FILE_SCAN_PARAMS:
return getFileScanParams();
case COORD:
return getCoord();
case QUERY_GLOBALS:
return getQueryGlobals();
case RESOURCE_INFO:
return getResourceInfo();
case FRAGMENT_NUM_ON_HOST:
return getFragmentNumOnHost();
case QUERY_OPTIONS:
return getQueryOptions();
case IS_NEREIDS:
return isIsNereids();
case WORKLOAD_GROUPS:
return getWorkloadGroups();
case QUERY_ID:
return getQueryId();
case TOPN_FILTER_SOURCE_NODE_IDS:
return getTopnFilterSourceNodeIds();
case RUNTIME_FILTER_MERGE_ADDR:
return getRuntimeFilterMergeAddr();
case RUNTIME_FILTER_INFO:
return getRuntimeFilterInfo();
}
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 PARAMS_LIST:
return isSetParamsList();
case DESC_TBL:
return isSetDescTbl();
case FILE_SCAN_PARAMS:
return isSetFileScanParams();
case COORD:
return isSetCoord();
case QUERY_GLOBALS:
return isSetQueryGlobals();
case RESOURCE_INFO:
return isSetResourceInfo();
case FRAGMENT_NUM_ON_HOST:
return isSetFragmentNumOnHost();
case QUERY_OPTIONS:
return isSetQueryOptions();
case IS_NEREIDS:
return isSetIsNereids();
case WORKLOAD_GROUPS:
return isSetWorkloadGroups();
case QUERY_ID:
return isSetQueryId();
case TOPN_FILTER_SOURCE_NODE_IDS:
return isSetTopnFilterSourceNodeIds();
case RUNTIME_FILTER_MERGE_ADDR:
return isSetRuntimeFilterMergeAddr();
case RUNTIME_FILTER_INFO:
return isSetRuntimeFilterInfo();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof TPipelineFragmentParamsList)
return this.equals((TPipelineFragmentParamsList)that);
return false;
}
public boolean equals(TPipelineFragmentParamsList that) {
if (that == null)
return false;
if (this == that)
return true;
boolean this_present_params_list = true && this.isSetParamsList();
boolean that_present_params_list = true && that.isSetParamsList();
if (this_present_params_list || that_present_params_list) {
if (!(this_present_params_list && that_present_params_list))
return false;
if (!this.params_list.equals(that.params_list))
return false;
}
boolean this_present_desc_tbl = true && this.isSetDescTbl();
boolean that_present_desc_tbl = true && that.isSetDescTbl();
if (this_present_desc_tbl || that_present_desc_tbl) {
if (!(this_present_desc_tbl && that_present_desc_tbl))
return false;
if (!this.desc_tbl.equals(that.desc_tbl))
return false;
}
boolean this_present_file_scan_params = true && this.isSetFileScanParams();
boolean that_present_file_scan_params = true && that.isSetFileScanParams();
if (this_present_file_scan_params || that_present_file_scan_params) {
if (!(this_present_file_scan_params && that_present_file_scan_params))
return false;
if (!this.file_scan_params.equals(that.file_scan_params))
return false;
}
boolean this_present_coord = true && this.isSetCoord();
boolean that_present_coord = true && that.isSetCoord();
if (this_present_coord || that_present_coord) {
if (!(this_present_coord && that_present_coord))
return false;
if (!this.coord.equals(that.coord))
return false;
}
boolean this_present_query_globals = true && this.isSetQueryGlobals();
boolean that_present_query_globals = true && that.isSetQueryGlobals();
if (this_present_query_globals || that_present_query_globals) {
if (!(this_present_query_globals && that_present_query_globals))
return false;
if (!this.query_globals.equals(that.query_globals))
return false;
}
boolean this_present_resource_info = true && this.isSetResourceInfo();
boolean that_present_resource_info = true && that.isSetResourceInfo();
if (this_present_resource_info || that_present_resource_info) {
if (!(this_present_resource_info && that_present_resource_info))
return false;
if (!this.resource_info.equals(that.resource_info))
return false;
}
boolean this_present_fragment_num_on_host = true && this.isSetFragmentNumOnHost();
boolean that_present_fragment_num_on_host = true && that.isSetFragmentNumOnHost();
if (this_present_fragment_num_on_host || that_present_fragment_num_on_host) {
if (!(this_present_fragment_num_on_host && that_present_fragment_num_on_host))
return false;
if (this.fragment_num_on_host != that.fragment_num_on_host)
return false;
}
boolean this_present_query_options = true && this.isSetQueryOptions();
boolean that_present_query_options = true && that.isSetQueryOptions();
if (this_present_query_options || that_present_query_options) {
if (!(this_present_query_options && that_present_query_options))
return false;
if (!this.query_options.equals(that.query_options))
return false;
}
boolean this_present_is_nereids = true && this.isSetIsNereids();
boolean that_present_is_nereids = true && that.isSetIsNereids();
if (this_present_is_nereids || that_present_is_nereids) {
if (!(this_present_is_nereids && that_present_is_nereids))
return false;
if (this.is_nereids != that.is_nereids)
return false;
}
boolean this_present_workload_groups = true && this.isSetWorkloadGroups();
boolean that_present_workload_groups = true && that.isSetWorkloadGroups();
if (this_present_workload_groups || that_present_workload_groups) {
if (!(this_present_workload_groups && that_present_workload_groups))
return false;
if (!this.workload_groups.equals(that.workload_groups))
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_topn_filter_source_node_ids = true && this.isSetTopnFilterSourceNodeIds();
boolean that_present_topn_filter_source_node_ids = true && that.isSetTopnFilterSourceNodeIds();
if (this_present_topn_filter_source_node_ids || that_present_topn_filter_source_node_ids) {
if (!(this_present_topn_filter_source_node_ids && that_present_topn_filter_source_node_ids))
return false;
if (!this.topn_filter_source_node_ids.equals(that.topn_filter_source_node_ids))
return false;
}
boolean this_present_runtime_filter_merge_addr = true && this.isSetRuntimeFilterMergeAddr();
boolean that_present_runtime_filter_merge_addr = true && that.isSetRuntimeFilterMergeAddr();
if (this_present_runtime_filter_merge_addr || that_present_runtime_filter_merge_addr) {
if (!(this_present_runtime_filter_merge_addr && that_present_runtime_filter_merge_addr))
return false;
if (!this.runtime_filter_merge_addr.equals(that.runtime_filter_merge_addr))
return false;
}
boolean this_present_runtime_filter_info = true && this.isSetRuntimeFilterInfo();
boolean that_present_runtime_filter_info = true && that.isSetRuntimeFilterInfo();
if (this_present_runtime_filter_info || that_present_runtime_filter_info) {
if (!(this_present_runtime_filter_info && that_present_runtime_filter_info))
return false;
if (!this.runtime_filter_info.equals(that.runtime_filter_info))
return false;
}
return true;
}
@Override
public int hashCode() {
int hashCode = 1;
hashCode = hashCode * 8191 + ((isSetParamsList()) ? 131071 : 524287);
if (isSetParamsList())
hashCode = hashCode * 8191 + params_list.hashCode();
hashCode = hashCode * 8191 + ((isSetDescTbl()) ? 131071 : 524287);
if (isSetDescTbl())
hashCode = hashCode * 8191 + desc_tbl.hashCode();
hashCode = hashCode * 8191 + ((isSetFileScanParams()) ? 131071 : 524287);
if (isSetFileScanParams())
hashCode = hashCode * 8191 + file_scan_params.hashCode();
hashCode = hashCode * 8191 + ((isSetCoord()) ? 131071 : 524287);
if (isSetCoord())
hashCode = hashCode * 8191 + coord.hashCode();
hashCode = hashCode * 8191 + ((isSetQueryGlobals()) ? 131071 : 524287);
if (isSetQueryGlobals())
hashCode = hashCode * 8191 + query_globals.hashCode();
hashCode = hashCode * 8191 + ((isSetResourceInfo()) ? 131071 : 524287);
if (isSetResourceInfo())
hashCode = hashCode * 8191 + resource_info.hashCode();
hashCode = hashCode * 8191 + ((isSetFragmentNumOnHost()) ? 131071 : 524287);
if (isSetFragmentNumOnHost())
hashCode = hashCode * 8191 + fragment_num_on_host;
hashCode = hashCode * 8191 + ((isSetQueryOptions()) ? 131071 : 524287);
if (isSetQueryOptions())
hashCode = hashCode * 8191 + query_options.hashCode();
hashCode = hashCode * 8191 + ((isSetIsNereids()) ? 131071 : 524287);
if (isSetIsNereids())
hashCode = hashCode * 8191 + ((is_nereids) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetWorkloadGroups()) ? 131071 : 524287);
if (isSetWorkloadGroups())
hashCode = hashCode * 8191 + workload_groups.hashCode();
hashCode = hashCode * 8191 + ((isSetQueryId()) ? 131071 : 524287);
if (isSetQueryId())
hashCode = hashCode * 8191 + query_id.hashCode();
hashCode = hashCode * 8191 + ((isSetTopnFilterSourceNodeIds()) ? 131071 : 524287);
if (isSetTopnFilterSourceNodeIds())
hashCode = hashCode * 8191 + topn_filter_source_node_ids.hashCode();
hashCode = hashCode * 8191 + ((isSetRuntimeFilterMergeAddr()) ? 131071 : 524287);
if (isSetRuntimeFilterMergeAddr())
hashCode = hashCode * 8191 + runtime_filter_merge_addr.hashCode();
hashCode = hashCode * 8191 + ((isSetRuntimeFilterInfo()) ? 131071 : 524287);
if (isSetRuntimeFilterInfo())
hashCode = hashCode * 8191 + runtime_filter_info.hashCode();
return hashCode;
}
@Override
public int compareTo(TPipelineFragmentParamsList other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = java.lang.Boolean.compare(isSetParamsList(), other.isSetParamsList());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetParamsList()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.params_list, other.params_list);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetDescTbl(), other.isSetDescTbl());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetDescTbl()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.desc_tbl, other.desc_tbl);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetFileScanParams(), other.isSetFileScanParams());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetFileScanParams()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.file_scan_params, other.file_scan_params);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetCoord(), other.isSetCoord());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetCoord()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.coord, other.coord);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetQueryGlobals(), other.isSetQueryGlobals());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetQueryGlobals()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.query_globals, other.query_globals);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetResourceInfo(), other.isSetResourceInfo());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetResourceInfo()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.resource_info, other.resource_info);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetFragmentNumOnHost(), other.isSetFragmentNumOnHost());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetFragmentNumOnHost()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fragment_num_on_host, other.fragment_num_on_host);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetQueryOptions(), other.isSetQueryOptions());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetQueryOptions()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.query_options, other.query_options);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetIsNereids(), other.isSetIsNereids());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetIsNereids()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.is_nereids, other.is_nereids);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetWorkloadGroups(), other.isSetWorkloadGroups());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetWorkloadGroups()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.workload_groups, other.workload_groups);
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(isSetTopnFilterSourceNodeIds(), other.isSetTopnFilterSourceNodeIds());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTopnFilterSourceNodeIds()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.topn_filter_source_node_ids, other.topn_filter_source_node_ids);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetRuntimeFilterMergeAddr(), other.isSetRuntimeFilterMergeAddr());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetRuntimeFilterMergeAddr()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.runtime_filter_merge_addr, other.runtime_filter_merge_addr);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetRuntimeFilterInfo(), other.isSetRuntimeFilterInfo());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetRuntimeFilterInfo()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.runtime_filter_info, other.runtime_filter_info);
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("TPipelineFragmentParamsList(");
boolean first = true;
if (isSetParamsList()) {
sb.append("params_list:");
if (this.params_list == null) {
sb.append("null");
} else {
sb.append(this.params_list);
}
first = false;
}
if (isSetDescTbl()) {
if (!first) sb.append(", ");
sb.append("desc_tbl:");
if (this.desc_tbl == null) {
sb.append("null");
} else {
sb.append(this.desc_tbl);
}
first = false;
}
if (isSetFileScanParams()) {
if (!first) sb.append(", ");
sb.append("file_scan_params:");
if (this.file_scan_params == null) {
sb.append("null");
} else {
sb.append(this.file_scan_params);
}
first = false;
}
if (isSetCoord()) {
if (!first) sb.append(", ");
sb.append("coord:");
if (this.coord == null) {
sb.append("null");
} else {
sb.append(this.coord);
}
first = false;
}
if (isSetQueryGlobals()) {
if (!first) sb.append(", ");
sb.append("query_globals:");
if (this.query_globals == null) {
sb.append("null");
} else {
sb.append(this.query_globals);
}
first = false;
}
if (isSetResourceInfo()) {
if (!first) sb.append(", ");
sb.append("resource_info:");
if (this.resource_info == null) {
sb.append("null");
} else {
sb.append(this.resource_info);
}
first = false;
}
if (isSetFragmentNumOnHost()) {
if (!first) sb.append(", ");
sb.append("fragment_num_on_host:");
sb.append(this.fragment_num_on_host);
first = false;
}
if (isSetQueryOptions()) {
if (!first) sb.append(", ");
sb.append("query_options:");
if (this.query_options == null) {
sb.append("null");
} else {
sb.append(this.query_options);
}
first = false;
}
if (isSetIsNereids()) {
if (!first) sb.append(", ");
sb.append("is_nereids:");
sb.append(this.is_nereids);
first = false;
}
if (isSetWorkloadGroups()) {
if (!first) sb.append(", ");
sb.append("workload_groups:");
if (this.workload_groups == null) {
sb.append("null");
} else {
sb.append(this.workload_groups);
}
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 (isSetTopnFilterSourceNodeIds()) {
if (!first) sb.append(", ");
sb.append("topn_filter_source_node_ids:");
if (this.topn_filter_source_node_ids == null) {
sb.append("null");
} else {
sb.append(this.topn_filter_source_node_ids);
}
first = false;
}
if (isSetRuntimeFilterMergeAddr()) {
if (!first) sb.append(", ");
sb.append("runtime_filter_merge_addr:");
if (this.runtime_filter_merge_addr == null) {
sb.append("null");
} else {
sb.append(this.runtime_filter_merge_addr);
}
first = false;
}
if (isSetRuntimeFilterInfo()) {
if (!first) sb.append(", ");
sb.append("runtime_filter_info:");
if (this.runtime_filter_info == null) {
sb.append("null");
} else {
sb.append(this.runtime_filter_info);
}
first = false;
}
sb.append(")");
return sb.toString();
}
public void validate() throws org.apache.thrift.TException {
// check for required fields
// check for sub-struct validity
if (desc_tbl != null) {
desc_tbl.validate();
}
if (coord != null) {
coord.validate();
}
if (query_globals != null) {
query_globals.validate();
}
if (resource_info != null) {
resource_info.validate();
}
if (query_options != null) {
query_options.validate();
}
if (query_id != null) {
query_id.validate();
}
if (runtime_filter_merge_addr != null) {
runtime_filter_merge_addr.validate();
}
if (runtime_filter_info != null) {
runtime_filter_info.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 TPipelineFragmentParamsListStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TPipelineFragmentParamsListStandardScheme getScheme() {
return new TPipelineFragmentParamsListStandardScheme();
}
}
private static class TPipelineFragmentParamsListStandardScheme extends org.apache.thrift.scheme.StandardScheme<TPipelineFragmentParamsList> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TPipelineFragmentParamsList 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: // PARAMS_LIST
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list308 = iprot.readListBegin();
struct.params_list = new java.util.ArrayList<TPipelineFragmentParams>(_list308.size);
@org.apache.thrift.annotation.Nullable TPipelineFragmentParams _elem309;
for (int _i310 = 0; _i310 < _list308.size; ++_i310)
{
_elem309 = new TPipelineFragmentParams();
_elem309.read(iprot);
struct.params_list.add(_elem309);
}
iprot.readListEnd();
}
struct.setParamsListIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // DESC_TBL
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.desc_tbl = new org.apache.doris.thrift.TDescriptorTable();
struct.desc_tbl.read(iprot);
struct.setDescTblIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // FILE_SCAN_PARAMS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map311 = iprot.readMapBegin();
struct.file_scan_params = new java.util.HashMap<java.lang.Integer,org.apache.doris.thrift.TFileScanRangeParams>(2*_map311.size);
int _key312;
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TFileScanRangeParams _val313;
for (int _i314 = 0; _i314 < _map311.size; ++_i314)
{
_key312 = iprot.readI32();
_val313 = new org.apache.doris.thrift.TFileScanRangeParams();
_val313.read(iprot);
struct.file_scan_params.put(_key312, _val313);
}
iprot.readMapEnd();
}
struct.setFileScanParamsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // COORD
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.coord = new org.apache.doris.thrift.TNetworkAddress();
struct.coord.read(iprot);
struct.setCoordIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // QUERY_GLOBALS
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.query_globals = new TQueryGlobals();
struct.query_globals.read(iprot);
struct.setQueryGlobalsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // RESOURCE_INFO
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.resource_info = new org.apache.doris.thrift.TResourceInfo();
struct.resource_info.read(iprot);
struct.setResourceInfoIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // FRAGMENT_NUM_ON_HOST
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.fragment_num_on_host = iprot.readI32();
struct.setFragmentNumOnHostIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // QUERY_OPTIONS
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.query_options = new TQueryOptions();
struct.query_options.read(iprot);
struct.setQueryOptionsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // IS_NEREIDS
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.is_nereids = iprot.readBool();
struct.setIsNereidsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 10: // WORKLOAD_GROUPS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list315 = iprot.readListBegin();
struct.workload_groups = new java.util.ArrayList<TPipelineWorkloadGroup>(_list315.size);
@org.apache.thrift.annotation.Nullable TPipelineWorkloadGroup _elem316;
for (int _i317 = 0; _i317 < _list315.size; ++_i317)
{
_elem316 = new TPipelineWorkloadGroup();
_elem316.read(iprot);
struct.workload_groups.add(_elem316);
}
iprot.readListEnd();
}
struct.setWorkloadGroupsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 11: // 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 12: // TOPN_FILTER_SOURCE_NODE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list318 = iprot.readListBegin();
struct.topn_filter_source_node_ids = new java.util.ArrayList<java.lang.Integer>(_list318.size);
int _elem319;
for (int _i320 = 0; _i320 < _list318.size; ++_i320)
{
_elem319 = iprot.readI32();
struct.topn_filter_source_node_ids.add(_elem319);
}
iprot.readListEnd();
}
struct.setTopnFilterSourceNodeIdsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 13: // RUNTIME_FILTER_MERGE_ADDR
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.runtime_filter_merge_addr = new org.apache.doris.thrift.TNetworkAddress();
struct.runtime_filter_merge_addr.read(iprot);
struct.setRuntimeFilterMergeAddrIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 14: // RUNTIME_FILTER_INFO
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.runtime_filter_info = new TRuntimeFilterInfo();
struct.runtime_filter_info.read(iprot);
struct.setRuntimeFilterInfoIsSet(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, TPipelineFragmentParamsList struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.params_list != null) {
if (struct.isSetParamsList()) {
oprot.writeFieldBegin(PARAMS_LIST_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.params_list.size()));
for (TPipelineFragmentParams _iter321 : struct.params_list)
{
_iter321.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.desc_tbl != null) {
if (struct.isSetDescTbl()) {
oprot.writeFieldBegin(DESC_TBL_FIELD_DESC);
struct.desc_tbl.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.file_scan_params != null) {
if (struct.isSetFileScanParams()) {
oprot.writeFieldBegin(FILE_SCAN_PARAMS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.STRUCT, struct.file_scan_params.size()));
for (java.util.Map.Entry<java.lang.Integer, org.apache.doris.thrift.TFileScanRangeParams> _iter322 : struct.file_scan_params.entrySet())
{
oprot.writeI32(_iter322.getKey());
_iter322.getValue().write(oprot);
}
oprot.writeMapEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.coord != null) {
if (struct.isSetCoord()) {
oprot.writeFieldBegin(COORD_FIELD_DESC);
struct.coord.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.query_globals != null) {
if (struct.isSetQueryGlobals()) {
oprot.writeFieldBegin(QUERY_GLOBALS_FIELD_DESC);
struct.query_globals.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.resource_info != null) {
if (struct.isSetResourceInfo()) {
oprot.writeFieldBegin(RESOURCE_INFO_FIELD_DESC);
struct.resource_info.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.isSetFragmentNumOnHost()) {
oprot.writeFieldBegin(FRAGMENT_NUM_ON_HOST_FIELD_DESC);
oprot.writeI32(struct.fragment_num_on_host);
oprot.writeFieldEnd();
}
if (struct.query_options != null) {
if (struct.isSetQueryOptions()) {
oprot.writeFieldBegin(QUERY_OPTIONS_FIELD_DESC);
struct.query_options.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.isSetIsNereids()) {
oprot.writeFieldBegin(IS_NEREIDS_FIELD_DESC);
oprot.writeBool(struct.is_nereids);
oprot.writeFieldEnd();
}
if (struct.workload_groups != null) {
if (struct.isSetWorkloadGroups()) {
oprot.writeFieldBegin(WORKLOAD_GROUPS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.workload_groups.size()));
for (TPipelineWorkloadGroup _iter323 : struct.workload_groups)
{
_iter323.write(oprot);
}
oprot.writeListEnd();
}
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.topn_filter_source_node_ids != null) {
if (struct.isSetTopnFilterSourceNodeIds()) {
oprot.writeFieldBegin(TOPN_FILTER_SOURCE_NODE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, struct.topn_filter_source_node_ids.size()));
for (int _iter324 : struct.topn_filter_source_node_ids)
{
oprot.writeI32(_iter324);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.runtime_filter_merge_addr != null) {
if (struct.isSetRuntimeFilterMergeAddr()) {
oprot.writeFieldBegin(RUNTIME_FILTER_MERGE_ADDR_FIELD_DESC);
struct.runtime_filter_merge_addr.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.runtime_filter_info != null) {
if (struct.isSetRuntimeFilterInfo()) {
oprot.writeFieldBegin(RUNTIME_FILTER_INFO_FIELD_DESC);
struct.runtime_filter_info.write(oprot);
oprot.writeFieldEnd();
}
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class TPipelineFragmentParamsListTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TPipelineFragmentParamsListTupleScheme getScheme() {
return new TPipelineFragmentParamsListTupleScheme();
}
}
private static class TPipelineFragmentParamsListTupleScheme extends org.apache.thrift.scheme.TupleScheme<TPipelineFragmentParamsList> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TPipelineFragmentParamsList struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetParamsList()) {
optionals.set(0);
}
if (struct.isSetDescTbl()) {
optionals.set(1);
}
if (struct.isSetFileScanParams()) {
optionals.set(2);
}
if (struct.isSetCoord()) {
optionals.set(3);
}
if (struct.isSetQueryGlobals()) {
optionals.set(4);
}
if (struct.isSetResourceInfo()) {
optionals.set(5);
}
if (struct.isSetFragmentNumOnHost()) {
optionals.set(6);
}
if (struct.isSetQueryOptions()) {
optionals.set(7);
}
if (struct.isSetIsNereids()) {
optionals.set(8);
}
if (struct.isSetWorkloadGroups()) {
optionals.set(9);
}
if (struct.isSetQueryId()) {
optionals.set(10);
}
if (struct.isSetTopnFilterSourceNodeIds()) {
optionals.set(11);
}
if (struct.isSetRuntimeFilterMergeAddr()) {
optionals.set(12);
}
if (struct.isSetRuntimeFilterInfo()) {
optionals.set(13);
}
oprot.writeBitSet(optionals, 14);
if (struct.isSetParamsList()) {
{
oprot.writeI32(struct.params_list.size());
for (TPipelineFragmentParams _iter325 : struct.params_list)
{
_iter325.write(oprot);
}
}
}
if (struct.isSetDescTbl()) {
struct.desc_tbl.write(oprot);
}
if (struct.isSetFileScanParams()) {
{
oprot.writeI32(struct.file_scan_params.size());
for (java.util.Map.Entry<java.lang.Integer, org.apache.doris.thrift.TFileScanRangeParams> _iter326 : struct.file_scan_params.entrySet())
{
oprot.writeI32(_iter326.getKey());
_iter326.getValue().write(oprot);
}
}
}
if (struct.isSetCoord()) {
struct.coord.write(oprot);
}
if (struct.isSetQueryGlobals()) {
struct.query_globals.write(oprot);
}
if (struct.isSetResourceInfo()) {
struct.resource_info.write(oprot);
}
if (struct.isSetFragmentNumOnHost()) {
oprot.writeI32(struct.fragment_num_on_host);
}
if (struct.isSetQueryOptions()) {
struct.query_options.write(oprot);
}
if (struct.isSetIsNereids()) {
oprot.writeBool(struct.is_nereids);
}
if (struct.isSetWorkloadGroups()) {
{
oprot.writeI32(struct.workload_groups.size());
for (TPipelineWorkloadGroup _iter327 : struct.workload_groups)
{
_iter327.write(oprot);
}
}
}
if (struct.isSetQueryId()) {
struct.query_id.write(oprot);
}
if (struct.isSetTopnFilterSourceNodeIds()) {
{
oprot.writeI32(struct.topn_filter_source_node_ids.size());
for (int _iter328 : struct.topn_filter_source_node_ids)
{
oprot.writeI32(_iter328);
}
}
}
if (struct.isSetRuntimeFilterMergeAddr()) {
struct.runtime_filter_merge_addr.write(oprot);
}
if (struct.isSetRuntimeFilterInfo()) {
struct.runtime_filter_info.write(oprot);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TPipelineFragmentParamsList struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet incoming = iprot.readBitSet(14);
if (incoming.get(0)) {
{
org.apache.thrift.protocol.TList _list329 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.params_list = new java.util.ArrayList<TPipelineFragmentParams>(_list329.size);
@org.apache.thrift.annotation.Nullable TPipelineFragmentParams _elem330;
for (int _i331 = 0; _i331 < _list329.size; ++_i331)
{
_elem330 = new TPipelineFragmentParams();
_elem330.read(iprot);
struct.params_list.add(_elem330);
}
}
struct.setParamsListIsSet(true);
}
if (incoming.get(1)) {
struct.desc_tbl = new org.apache.doris.thrift.TDescriptorTable();
struct.desc_tbl.read(iprot);
struct.setDescTblIsSet(true);
}
if (incoming.get(2)) {
{
org.apache.thrift.protocol.TMap _map332 = iprot.readMapBegin(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.STRUCT);
struct.file_scan_params = new java.util.HashMap<java.lang.Integer,org.apache.doris.thrift.TFileScanRangeParams>(2*_map332.size);
int _key333;
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TFileScanRangeParams _val334;
for (int _i335 = 0; _i335 < _map332.size; ++_i335)
{
_key333 = iprot.readI32();
_val334 = new org.apache.doris.thrift.TFileScanRangeParams();
_val334.read(iprot);
struct.file_scan_params.put(_key333, _val334);
}
}
struct.setFileScanParamsIsSet(true);
}
if (incoming.get(3)) {
struct.coord = new org.apache.doris.thrift.TNetworkAddress();
struct.coord.read(iprot);
struct.setCoordIsSet(true);
}
if (incoming.get(4)) {
struct.query_globals = new TQueryGlobals();
struct.query_globals.read(iprot);
struct.setQueryGlobalsIsSet(true);
}
if (incoming.get(5)) {
struct.resource_info = new org.apache.doris.thrift.TResourceInfo();
struct.resource_info.read(iprot);
struct.setResourceInfoIsSet(true);
}
if (incoming.get(6)) {
struct.fragment_num_on_host = iprot.readI32();
struct.setFragmentNumOnHostIsSet(true);
}
if (incoming.get(7)) {
struct.query_options = new TQueryOptions();
struct.query_options.read(iprot);
struct.setQueryOptionsIsSet(true);
}
if (incoming.get(8)) {
struct.is_nereids = iprot.readBool();
struct.setIsNereidsIsSet(true);
}
if (incoming.get(9)) {
{
org.apache.thrift.protocol.TList _list336 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.workload_groups = new java.util.ArrayList<TPipelineWorkloadGroup>(_list336.size);
@org.apache.thrift.annotation.Nullable TPipelineWorkloadGroup _elem337;
for (int _i338 = 0; _i338 < _list336.size; ++_i338)
{
_elem337 = new TPipelineWorkloadGroup();
_elem337.read(iprot);
struct.workload_groups.add(_elem337);
}
}
struct.setWorkloadGroupsIsSet(true);
}
if (incoming.get(10)) {
struct.query_id = new org.apache.doris.thrift.TUniqueId();
struct.query_id.read(iprot);
struct.setQueryIdIsSet(true);
}
if (incoming.get(11)) {
{
org.apache.thrift.protocol.TList _list339 = iprot.readListBegin(org.apache.thrift.protocol.TType.I32);
struct.topn_filter_source_node_ids = new java.util.ArrayList<java.lang.Integer>(_list339.size);
int _elem340;
for (int _i341 = 0; _i341 < _list339.size; ++_i341)
{
_elem340 = iprot.readI32();
struct.topn_filter_source_node_ids.add(_elem340);
}
}
struct.setTopnFilterSourceNodeIdsIsSet(true);
}
if (incoming.get(12)) {
struct.runtime_filter_merge_addr = new org.apache.doris.thrift.TNetworkAddress();
struct.runtime_filter_merge_addr.read(iprot);
struct.setRuntimeFilterMergeAddrIsSet(true);
}
if (incoming.get(13)) {
struct.runtime_filter_info = new TRuntimeFilterInfo();
struct.runtime_filter_info.read(iprot);
struct.setRuntimeFilterInfoIsSet(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();
}
}