TPipelineFragmentParams.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 TPipelineFragmentParams implements org.apache.thrift.TBase<TPipelineFragmentParams, TPipelineFragmentParams._Fields>, java.io.Serializable, Cloneable, Comparable<TPipelineFragmentParams> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TPipelineFragmentParams");
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 FRAGMENT_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("fragment_id", org.apache.thrift.protocol.TType.I32, (short)3);
private static final org.apache.thrift.protocol.TField PER_EXCH_NUM_SENDERS_FIELD_DESC = new org.apache.thrift.protocol.TField("per_exch_num_senders", org.apache.thrift.protocol.TType.MAP, (short)4);
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)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 DESTINATIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("destinations", org.apache.thrift.protocol.TType.LIST, (short)7);
private static final org.apache.thrift.protocol.TField NUM_SENDERS_FIELD_DESC = new org.apache.thrift.protocol.TField("num_senders", org.apache.thrift.protocol.TType.I32, (short)8);
private static final org.apache.thrift.protocol.TField SEND_QUERY_STATISTICS_WITH_EVERY_BATCH_FIELD_DESC = new org.apache.thrift.protocol.TField("send_query_statistics_with_every_batch", org.apache.thrift.protocol.TType.BOOL, (short)9);
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)10);
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)11);
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)12);
private static final org.apache.thrift.protocol.TField IMPORT_LABEL_FIELD_DESC = new org.apache.thrift.protocol.TField("import_label", org.apache.thrift.protocol.TType.STRING, (short)13);
private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("db_name", org.apache.thrift.protocol.TType.STRING, (short)14);
private static final org.apache.thrift.protocol.TField LOAD_JOB_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("load_job_id", org.apache.thrift.protocol.TType.I64, (short)15);
private static final org.apache.thrift.protocol.TField LOAD_ERROR_HUB_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("load_error_hub_info", org.apache.thrift.protocol.TType.STRUCT, (short)16);
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)17);
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)18);
private static final org.apache.thrift.protocol.TField NEED_WAIT_EXECUTION_TRIGGER_FIELD_DESC = new org.apache.thrift.protocol.TField("need_wait_execution_trigger", org.apache.thrift.protocol.TType.BOOL, (short)19);
private static final org.apache.thrift.protocol.TField INSTANCES_SHARING_HASH_TABLE_FIELD_DESC = new org.apache.thrift.protocol.TField("instances_sharing_hash_table", org.apache.thrift.protocol.TType.LIST, (short)20);
private static final org.apache.thrift.protocol.TField IS_SIMPLIFIED_PARAM_FIELD_DESC = new org.apache.thrift.protocol.TField("is_simplified_param", org.apache.thrift.protocol.TType.BOOL, (short)21);
private static final org.apache.thrift.protocol.TField GLOBAL_DICT_FIELD_DESC = new org.apache.thrift.protocol.TField("global_dict", org.apache.thrift.protocol.TType.STRUCT, (short)22);
private static final org.apache.thrift.protocol.TField FRAGMENT_FIELD_DESC = new org.apache.thrift.protocol.TField("fragment", org.apache.thrift.protocol.TType.STRUCT, (short)23);
private static final org.apache.thrift.protocol.TField LOCAL_PARAMS_FIELD_DESC = new org.apache.thrift.protocol.TField("local_params", org.apache.thrift.protocol.TType.LIST, (short)24);
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)26);
private static final org.apache.thrift.protocol.TField TXN_CONF_FIELD_DESC = new org.apache.thrift.protocol.TField("txn_conf", org.apache.thrift.protocol.TType.STRUCT, (short)27);
private static final org.apache.thrift.protocol.TField TABLE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("table_name", org.apache.thrift.protocol.TType.STRING, (short)28);
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)29);
private static final org.apache.thrift.protocol.TField GROUP_COMMIT_FIELD_DESC = new org.apache.thrift.protocol.TField("group_commit", org.apache.thrift.protocol.TType.BOOL, (short)30);
private static final org.apache.thrift.protocol.TField LOAD_STREAM_PER_NODE_FIELD_DESC = new org.apache.thrift.protocol.TField("load_stream_per_node", org.apache.thrift.protocol.TType.I32, (short)31);
private static final org.apache.thrift.protocol.TField TOTAL_LOAD_STREAMS_FIELD_DESC = new org.apache.thrift.protocol.TField("total_load_streams", org.apache.thrift.protocol.TType.I32, (short)32);
private static final org.apache.thrift.protocol.TField NUM_LOCAL_SINK_FIELD_DESC = new org.apache.thrift.protocol.TField("num_local_sink", org.apache.thrift.protocol.TType.I32, (short)33);
private static final org.apache.thrift.protocol.TField NUM_BUCKETS_FIELD_DESC = new org.apache.thrift.protocol.TField("num_buckets", org.apache.thrift.protocol.TType.I32, (short)34);
private static final org.apache.thrift.protocol.TField BUCKET_SEQ_TO_INSTANCE_IDX_FIELD_DESC = new org.apache.thrift.protocol.TField("bucket_seq_to_instance_idx", org.apache.thrift.protocol.TType.MAP, (short)35);
private static final org.apache.thrift.protocol.TField PER_NODE_SHARED_SCANS_FIELD_DESC = new org.apache.thrift.protocol.TField("per_node_shared_scans", org.apache.thrift.protocol.TType.MAP, (short)36);
private static final org.apache.thrift.protocol.TField PARALLEL_INSTANCES_FIELD_DESC = new org.apache.thrift.protocol.TField("parallel_instances", org.apache.thrift.protocol.TType.I32, (short)37);
private static final org.apache.thrift.protocol.TField TOTAL_INSTANCES_FIELD_DESC = new org.apache.thrift.protocol.TField("total_instances", org.apache.thrift.protocol.TType.I32, (short)38);
private static final org.apache.thrift.protocol.TField SHUFFLE_IDX_TO_INSTANCE_IDX_FIELD_DESC = new org.apache.thrift.protocol.TField("shuffle_idx_to_instance_idx", org.apache.thrift.protocol.TType.MAP, (short)39);
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)40);
private static final org.apache.thrift.protocol.TField WAL_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("wal_id", org.apache.thrift.protocol.TType.I64, (short)41);
private static final org.apache.thrift.protocol.TField CONTENT_LENGTH_FIELD_DESC = new org.apache.thrift.protocol.TField("content_length", org.apache.thrift.protocol.TType.I64, (short)42);
private static final org.apache.thrift.protocol.TField CURRENT_CONNECT_FE_FIELD_DESC = new org.apache.thrift.protocol.TField("current_connect_fe", org.apache.thrift.protocol.TType.STRUCT, (short)43);
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)44);
private static final org.apache.thrift.protocol.TField AI_RESOURCES_FIELD_DESC = new org.apache.thrift.protocol.TField("ai_resources", org.apache.thrift.protocol.TType.MAP, (short)45);
private static final org.apache.thrift.protocol.TField NEED_NOTIFY_CLOSE_FIELD_DESC = new org.apache.thrift.protocol.TField("need_notify_close", org.apache.thrift.protocol.TType.BOOL, (short)46);
private static final org.apache.thrift.protocol.TField IS_MOW_TABLE_FIELD_DESC = new org.apache.thrift.protocol.TField("is_mow_table", org.apache.thrift.protocol.TType.BOOL, (short)1000);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TPipelineFragmentParamsStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TPipelineFragmentParamsTupleSchemeFactory();
/**
*
* @see PaloInternalServiceVersion
*/
public @org.apache.thrift.annotation.Nullable PaloInternalServiceVersion protocol_version; // required
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TUniqueId query_id; // required
public int fragment_id; // optional
public @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.Integer,java.lang.Integer> per_exch_num_senders; // required
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TDescriptorTable desc_tbl; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TResourceInfo resource_info; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TPlanFragmentDestination> destinations; // required
public int num_senders; // optional
public boolean send_query_statistics_with_every_batch; // 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 TQueryOptions query_options; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String import_label; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String db_name; // optional
public long load_job_id; // optional
public @org.apache.thrift.annotation.Nullable TLoadErrorHubInfo load_error_hub_info; // optional
public int fragment_num_on_host; // optional
public long backend_id; // optional
public boolean need_wait_execution_trigger; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TUniqueId> instances_sharing_hash_table; // optional
public boolean is_simplified_param; // optional
public @org.apache.thrift.annotation.Nullable TGlobalDict global_dict; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TPlanFragment fragment; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<TPipelineInstanceParams> local_params; // required
public @org.apache.thrift.annotation.Nullable java.util.List<TPipelineWorkloadGroup> workload_groups; // optional
public @org.apache.thrift.annotation.Nullable TTxnParams txn_conf; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String table_name; // optional
public @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.Integer,org.apache.doris.thrift.TFileScanRangeParams> file_scan_params; // optional
public boolean group_commit; // optional
public int load_stream_per_node; // optional
public int total_load_streams; // optional
public int num_local_sink; // optional
public int num_buckets; // optional
public @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.Integer,java.lang.Integer> bucket_seq_to_instance_idx; // optional
public @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.Integer,java.lang.Boolean> per_node_shared_scans; // optional
public int parallel_instances; // optional
public int total_instances; // optional
public @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.Integer,java.lang.Integer> shuffle_idx_to_instance_idx; // optional
public boolean is_nereids; // optional
public long wal_id; // optional
public long content_length; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TNetworkAddress current_connect_fe; // 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 java.util.Map<java.lang.String,TAIResource> ai_resources; // optional
public boolean need_notify_close; // optional
public boolean is_mow_table; // 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 PaloInternalServiceVersion
*/
PROTOCOL_VERSION((short)1, "protocol_version"),
QUERY_ID((short)2, "query_id"),
FRAGMENT_ID((short)3, "fragment_id"),
PER_EXCH_NUM_SENDERS((short)4, "per_exch_num_senders"),
DESC_TBL((short)5, "desc_tbl"),
RESOURCE_INFO((short)6, "resource_info"),
DESTINATIONS((short)7, "destinations"),
NUM_SENDERS((short)8, "num_senders"),
SEND_QUERY_STATISTICS_WITH_EVERY_BATCH((short)9, "send_query_statistics_with_every_batch"),
COORD((short)10, "coord"),
QUERY_GLOBALS((short)11, "query_globals"),
QUERY_OPTIONS((short)12, "query_options"),
IMPORT_LABEL((short)13, "import_label"),
DB_NAME((short)14, "db_name"),
LOAD_JOB_ID((short)15, "load_job_id"),
LOAD_ERROR_HUB_INFO((short)16, "load_error_hub_info"),
FRAGMENT_NUM_ON_HOST((short)17, "fragment_num_on_host"),
BACKEND_ID((short)18, "backend_id"),
NEED_WAIT_EXECUTION_TRIGGER((short)19, "need_wait_execution_trigger"),
INSTANCES_SHARING_HASH_TABLE((short)20, "instances_sharing_hash_table"),
IS_SIMPLIFIED_PARAM((short)21, "is_simplified_param"),
GLOBAL_DICT((short)22, "global_dict"),
FRAGMENT((short)23, "fragment"),
LOCAL_PARAMS((short)24, "local_params"),
WORKLOAD_GROUPS((short)26, "workload_groups"),
TXN_CONF((short)27, "txn_conf"),
TABLE_NAME((short)28, "table_name"),
FILE_SCAN_PARAMS((short)29, "file_scan_params"),
GROUP_COMMIT((short)30, "group_commit"),
LOAD_STREAM_PER_NODE((short)31, "load_stream_per_node"),
TOTAL_LOAD_STREAMS((short)32, "total_load_streams"),
NUM_LOCAL_SINK((short)33, "num_local_sink"),
NUM_BUCKETS((short)34, "num_buckets"),
BUCKET_SEQ_TO_INSTANCE_IDX((short)35, "bucket_seq_to_instance_idx"),
PER_NODE_SHARED_SCANS((short)36, "per_node_shared_scans"),
PARALLEL_INSTANCES((short)37, "parallel_instances"),
TOTAL_INSTANCES((short)38, "total_instances"),
SHUFFLE_IDX_TO_INSTANCE_IDX((short)39, "shuffle_idx_to_instance_idx"),
IS_NEREIDS((short)40, "is_nereids"),
WAL_ID((short)41, "wal_id"),
CONTENT_LENGTH((short)42, "content_length"),
CURRENT_CONNECT_FE((short)43, "current_connect_fe"),
TOPN_FILTER_SOURCE_NODE_IDS((short)44, "topn_filter_source_node_ids"),
AI_RESOURCES((short)45, "ai_resources"),
NEED_NOTIFY_CLOSE((short)46, "need_notify_close"),
IS_MOW_TABLE((short)1000, "is_mow_table");
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: // FRAGMENT_ID
return FRAGMENT_ID;
case 4: // PER_EXCH_NUM_SENDERS
return PER_EXCH_NUM_SENDERS;
case 5: // DESC_TBL
return DESC_TBL;
case 6: // RESOURCE_INFO
return RESOURCE_INFO;
case 7: // DESTINATIONS
return DESTINATIONS;
case 8: // NUM_SENDERS
return NUM_SENDERS;
case 9: // SEND_QUERY_STATISTICS_WITH_EVERY_BATCH
return SEND_QUERY_STATISTICS_WITH_EVERY_BATCH;
case 10: // COORD
return COORD;
case 11: // QUERY_GLOBALS
return QUERY_GLOBALS;
case 12: // QUERY_OPTIONS
return QUERY_OPTIONS;
case 13: // IMPORT_LABEL
return IMPORT_LABEL;
case 14: // DB_NAME
return DB_NAME;
case 15: // LOAD_JOB_ID
return LOAD_JOB_ID;
case 16: // LOAD_ERROR_HUB_INFO
return LOAD_ERROR_HUB_INFO;
case 17: // FRAGMENT_NUM_ON_HOST
return FRAGMENT_NUM_ON_HOST;
case 18: // BACKEND_ID
return BACKEND_ID;
case 19: // NEED_WAIT_EXECUTION_TRIGGER
return NEED_WAIT_EXECUTION_TRIGGER;
case 20: // INSTANCES_SHARING_HASH_TABLE
return INSTANCES_SHARING_HASH_TABLE;
case 21: // IS_SIMPLIFIED_PARAM
return IS_SIMPLIFIED_PARAM;
case 22: // GLOBAL_DICT
return GLOBAL_DICT;
case 23: // FRAGMENT
return FRAGMENT;
case 24: // LOCAL_PARAMS
return LOCAL_PARAMS;
case 26: // WORKLOAD_GROUPS
return WORKLOAD_GROUPS;
case 27: // TXN_CONF
return TXN_CONF;
case 28: // TABLE_NAME
return TABLE_NAME;
case 29: // FILE_SCAN_PARAMS
return FILE_SCAN_PARAMS;
case 30: // GROUP_COMMIT
return GROUP_COMMIT;
case 31: // LOAD_STREAM_PER_NODE
return LOAD_STREAM_PER_NODE;
case 32: // TOTAL_LOAD_STREAMS
return TOTAL_LOAD_STREAMS;
case 33: // NUM_LOCAL_SINK
return NUM_LOCAL_SINK;
case 34: // NUM_BUCKETS
return NUM_BUCKETS;
case 35: // BUCKET_SEQ_TO_INSTANCE_IDX
return BUCKET_SEQ_TO_INSTANCE_IDX;
case 36: // PER_NODE_SHARED_SCANS
return PER_NODE_SHARED_SCANS;
case 37: // PARALLEL_INSTANCES
return PARALLEL_INSTANCES;
case 38: // TOTAL_INSTANCES
return TOTAL_INSTANCES;
case 39: // SHUFFLE_IDX_TO_INSTANCE_IDX
return SHUFFLE_IDX_TO_INSTANCE_IDX;
case 40: // IS_NEREIDS
return IS_NEREIDS;
case 41: // WAL_ID
return WAL_ID;
case 42: // CONTENT_LENGTH
return CONTENT_LENGTH;
case 43: // CURRENT_CONNECT_FE
return CURRENT_CONNECT_FE;
case 44: // TOPN_FILTER_SOURCE_NODE_IDS
return TOPN_FILTER_SOURCE_NODE_IDS;
case 45: // AI_RESOURCES
return AI_RESOURCES;
case 46: // NEED_NOTIFY_CLOSE
return NEED_NOTIFY_CLOSE;
case 1000: // IS_MOW_TABLE
return IS_MOW_TABLE;
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_ID_ISSET_ID = 0;
private static final int __NUM_SENDERS_ISSET_ID = 1;
private static final int __SEND_QUERY_STATISTICS_WITH_EVERY_BATCH_ISSET_ID = 2;
private static final int __LOAD_JOB_ID_ISSET_ID = 3;
private static final int __FRAGMENT_NUM_ON_HOST_ISSET_ID = 4;
private static final int __BACKEND_ID_ISSET_ID = 5;
private static final int __NEED_WAIT_EXECUTION_TRIGGER_ISSET_ID = 6;
private static final int __IS_SIMPLIFIED_PARAM_ISSET_ID = 7;
private static final int __GROUP_COMMIT_ISSET_ID = 8;
private static final int __LOAD_STREAM_PER_NODE_ISSET_ID = 9;
private static final int __TOTAL_LOAD_STREAMS_ISSET_ID = 10;
private static final int __NUM_LOCAL_SINK_ISSET_ID = 11;
private static final int __NUM_BUCKETS_ISSET_ID = 12;
private static final int __PARALLEL_INSTANCES_ISSET_ID = 13;
private static final int __TOTAL_INSTANCES_ISSET_ID = 14;
private static final int __IS_NEREIDS_ISSET_ID = 15;
private static final int __WAL_ID_ISSET_ID = 16;
private static final int __CONTENT_LENGTH_ISSET_ID = 17;
private static final int __NEED_NOTIFY_CLOSE_ISSET_ID = 18;
private static final int __IS_MOW_TABLE_ISSET_ID = 19;
private int __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.FRAGMENT_ID,_Fields.DESC_TBL,_Fields.RESOURCE_INFO,_Fields.NUM_SENDERS,_Fields.SEND_QUERY_STATISTICS_WITH_EVERY_BATCH,_Fields.COORD,_Fields.QUERY_GLOBALS,_Fields.QUERY_OPTIONS,_Fields.IMPORT_LABEL,_Fields.DB_NAME,_Fields.LOAD_JOB_ID,_Fields.LOAD_ERROR_HUB_INFO,_Fields.FRAGMENT_NUM_ON_HOST,_Fields.BACKEND_ID,_Fields.NEED_WAIT_EXECUTION_TRIGGER,_Fields.INSTANCES_SHARING_HASH_TABLE,_Fields.IS_SIMPLIFIED_PARAM,_Fields.GLOBAL_DICT,_Fields.FRAGMENT,_Fields.WORKLOAD_GROUPS,_Fields.TXN_CONF,_Fields.TABLE_NAME,_Fields.FILE_SCAN_PARAMS,_Fields.GROUP_COMMIT,_Fields.LOAD_STREAM_PER_NODE,_Fields.TOTAL_LOAD_STREAMS,_Fields.NUM_LOCAL_SINK,_Fields.NUM_BUCKETS,_Fields.BUCKET_SEQ_TO_INSTANCE_IDX,_Fields.PER_NODE_SHARED_SCANS,_Fields.PARALLEL_INSTANCES,_Fields.TOTAL_INSTANCES,_Fields.SHUFFLE_IDX_TO_INSTANCE_IDX,_Fields.IS_NEREIDS,_Fields.WAL_ID,_Fields.CONTENT_LENGTH,_Fields.CURRENT_CONNECT_FE,_Fields.TOPN_FILTER_SOURCE_NODE_IDS,_Fields.AI_RESOURCES,_Fields.NEED_NOTIFY_CLOSE,_Fields.IS_MOW_TABLE};
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, PaloInternalServiceVersion.class)));
tmpMap.put(_Fields.QUERY_ID, new org.apache.thrift.meta_data.FieldMetaData("query_id", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TUniqueId.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.PER_EXCH_NUM_SENDERS, new org.apache.thrift.meta_data.FieldMetaData("per_exch_num_senders", org.apache.thrift.TFieldRequirementType.REQUIRED,
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.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))));
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.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.DESTINATIONS, new org.apache.thrift.meta_data.FieldMetaData("destinations", org.apache.thrift.TFieldRequirementType.DEFAULT,
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.TPlanFragmentDestination.class))));
tmpMap.put(_Fields.NUM_SENDERS, new org.apache.thrift.meta_data.FieldMetaData("num_senders", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.SEND_QUERY_STATISTICS_WITH_EVERY_BATCH, new org.apache.thrift.meta_data.FieldMetaData("send_query_statistics_with_every_batch", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
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.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.IMPORT_LABEL, new org.apache.thrift.meta_data.FieldMetaData("import_label", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("db_name", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.LOAD_JOB_ID, new org.apache.thrift.meta_data.FieldMetaData("load_job_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.LOAD_ERROR_HUB_INFO, new org.apache.thrift.meta_data.FieldMetaData("load_error_hub_info", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TLoadErrorHubInfo.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.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.NEED_WAIT_EXECUTION_TRIGGER, new org.apache.thrift.meta_data.FieldMetaData("need_wait_execution_trigger", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.INSTANCES_SHARING_HASH_TABLE, new org.apache.thrift.meta_data.FieldMetaData("instances_sharing_hash_table", 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.TUniqueId.class))));
tmpMap.put(_Fields.IS_SIMPLIFIED_PARAM, new org.apache.thrift.meta_data.FieldMetaData("is_simplified_param", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.GLOBAL_DICT, new org.apache.thrift.meta_data.FieldMetaData("global_dict", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TGlobalDict.class)));
tmpMap.put(_Fields.FRAGMENT, new org.apache.thrift.meta_data.FieldMetaData("fragment", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TPlanFragment.class)));
tmpMap.put(_Fields.LOCAL_PARAMS, new org.apache.thrift.meta_data.FieldMetaData("local_params", org.apache.thrift.TFieldRequirementType.DEFAULT,
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, TPipelineInstanceParams.class))));
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.TXN_CONF, new org.apache.thrift.meta_data.FieldMetaData("txn_conf", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TTxnParams.class)));
tmpMap.put(_Fields.TABLE_NAME, new org.apache.thrift.meta_data.FieldMetaData("table_name", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
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.GROUP_COMMIT, new org.apache.thrift.meta_data.FieldMetaData("group_commit", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.LOAD_STREAM_PER_NODE, new org.apache.thrift.meta_data.FieldMetaData("load_stream_per_node", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.TOTAL_LOAD_STREAMS, new org.apache.thrift.meta_data.FieldMetaData("total_load_streams", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.NUM_LOCAL_SINK, new org.apache.thrift.meta_data.FieldMetaData("num_local_sink", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.NUM_BUCKETS, new org.apache.thrift.meta_data.FieldMetaData("num_buckets", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.BUCKET_SEQ_TO_INSTANCE_IDX, new org.apache.thrift.meta_data.FieldMetaData("bucket_seq_to_instance_idx", 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),
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))));
tmpMap.put(_Fields.PER_NODE_SHARED_SCANS, new org.apache.thrift.meta_data.FieldMetaData("per_node_shared_scans", 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.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))));
tmpMap.put(_Fields.PARALLEL_INSTANCES, new org.apache.thrift.meta_data.FieldMetaData("parallel_instances", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.TOTAL_INSTANCES, new org.apache.thrift.meta_data.FieldMetaData("total_instances", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.SHUFFLE_IDX_TO_INSTANCE_IDX, new org.apache.thrift.meta_data.FieldMetaData("shuffle_idx_to_instance_idx", 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),
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))));
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.WAL_ID, new org.apache.thrift.meta_data.FieldMetaData("wal_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.CONTENT_LENGTH, new org.apache.thrift.meta_data.FieldMetaData("content_length", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.CURRENT_CONNECT_FE, new org.apache.thrift.meta_data.FieldMetaData("current_connect_fe", 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.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.AI_RESOURCES, new org.apache.thrift.meta_data.FieldMetaData("ai_resources", 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.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TAIResource.class))));
tmpMap.put(_Fields.NEED_NOTIFY_CLOSE, new org.apache.thrift.meta_data.FieldMetaData("need_notify_close", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.IS_MOW_TABLE, new org.apache.thrift.meta_data.FieldMetaData("is_mow_table", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TPipelineFragmentParams.class, metaDataMap);
}
public TPipelineFragmentParams() {
this.need_wait_execution_trigger = false;
this.is_simplified_param = false;
this.group_commit = false;
this.is_nereids = true;
}
public TPipelineFragmentParams(
PaloInternalServiceVersion protocol_version,
org.apache.doris.thrift.TUniqueId query_id,
java.util.Map<java.lang.Integer,java.lang.Integer> per_exch_num_senders,
java.util.List<org.apache.doris.thrift.TPlanFragmentDestination> destinations,
java.util.List<TPipelineInstanceParams> local_params)
{
this();
this.protocol_version = protocol_version;
this.query_id = query_id;
this.per_exch_num_senders = per_exch_num_senders;
this.destinations = destinations;
this.local_params = local_params;
}
/**
* Performs a deep copy on <i>other</i>.
*/
public TPipelineFragmentParams(TPipelineFragmentParams 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.fragment_id = other.fragment_id;
if (other.isSetPerExchNumSenders()) {
java.util.Map<java.lang.Integer,java.lang.Integer> __this__per_exch_num_senders = new java.util.HashMap<java.lang.Integer,java.lang.Integer>(other.per_exch_num_senders.size());
for (java.util.Map.Entry<java.lang.Integer, java.lang.Integer> other_element : other.per_exch_num_senders.entrySet()) {
java.lang.Integer other_element_key = other_element.getKey();
java.lang.Integer other_element_value = other_element.getValue();
java.lang.Integer __this__per_exch_num_senders_copy_key = other_element_key;
java.lang.Integer __this__per_exch_num_senders_copy_value = other_element_value;
__this__per_exch_num_senders.put(__this__per_exch_num_senders_copy_key, __this__per_exch_num_senders_copy_value);
}
this.per_exch_num_senders = __this__per_exch_num_senders;
}
if (other.isSetDescTbl()) {
this.desc_tbl = new org.apache.doris.thrift.TDescriptorTable(other.desc_tbl);
}
if (other.isSetResourceInfo()) {
this.resource_info = new org.apache.doris.thrift.TResourceInfo(other.resource_info);
}
if (other.isSetDestinations()) {
java.util.List<org.apache.doris.thrift.TPlanFragmentDestination> __this__destinations = new java.util.ArrayList<org.apache.doris.thrift.TPlanFragmentDestination>(other.destinations.size());
for (org.apache.doris.thrift.TPlanFragmentDestination other_element : other.destinations) {
__this__destinations.add(new org.apache.doris.thrift.TPlanFragmentDestination(other_element));
}
this.destinations = __this__destinations;
}
this.num_senders = other.num_senders;
this.send_query_statistics_with_every_batch = other.send_query_statistics_with_every_batch;
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.isSetQueryOptions()) {
this.query_options = new TQueryOptions(other.query_options);
}
if (other.isSetImportLabel()) {
this.import_label = other.import_label;
}
if (other.isSetDbName()) {
this.db_name = other.db_name;
}
this.load_job_id = other.load_job_id;
if (other.isSetLoadErrorHubInfo()) {
this.load_error_hub_info = new TLoadErrorHubInfo(other.load_error_hub_info);
}
this.fragment_num_on_host = other.fragment_num_on_host;
this.backend_id = other.backend_id;
this.need_wait_execution_trigger = other.need_wait_execution_trigger;
if (other.isSetInstancesSharingHashTable()) {
java.util.List<org.apache.doris.thrift.TUniqueId> __this__instances_sharing_hash_table = new java.util.ArrayList<org.apache.doris.thrift.TUniqueId>(other.instances_sharing_hash_table.size());
for (org.apache.doris.thrift.TUniqueId other_element : other.instances_sharing_hash_table) {
__this__instances_sharing_hash_table.add(new org.apache.doris.thrift.TUniqueId(other_element));
}
this.instances_sharing_hash_table = __this__instances_sharing_hash_table;
}
this.is_simplified_param = other.is_simplified_param;
if (other.isSetGlobalDict()) {
this.global_dict = new TGlobalDict(other.global_dict);
}
if (other.isSetFragment()) {
this.fragment = new org.apache.doris.thrift.TPlanFragment(other.fragment);
}
if (other.isSetLocalParams()) {
java.util.List<TPipelineInstanceParams> __this__local_params = new java.util.ArrayList<TPipelineInstanceParams>(other.local_params.size());
for (TPipelineInstanceParams other_element : other.local_params) {
__this__local_params.add(new TPipelineInstanceParams(other_element));
}
this.local_params = __this__local_params;
}
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.isSetTxnConf()) {
this.txn_conf = new TTxnParams(other.txn_conf);
}
if (other.isSetTableName()) {
this.table_name = other.table_name;
}
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;
}
this.group_commit = other.group_commit;
this.load_stream_per_node = other.load_stream_per_node;
this.total_load_streams = other.total_load_streams;
this.num_local_sink = other.num_local_sink;
this.num_buckets = other.num_buckets;
if (other.isSetBucketSeqToInstanceIdx()) {
java.util.Map<java.lang.Integer,java.lang.Integer> __this__bucket_seq_to_instance_idx = new java.util.HashMap<java.lang.Integer,java.lang.Integer>(other.bucket_seq_to_instance_idx);
this.bucket_seq_to_instance_idx = __this__bucket_seq_to_instance_idx;
}
if (other.isSetPerNodeSharedScans()) {
java.util.Map<java.lang.Integer,java.lang.Boolean> __this__per_node_shared_scans = new java.util.HashMap<java.lang.Integer,java.lang.Boolean>(other.per_node_shared_scans.size());
for (java.util.Map.Entry<java.lang.Integer, java.lang.Boolean> other_element : other.per_node_shared_scans.entrySet()) {
java.lang.Integer other_element_key = other_element.getKey();
java.lang.Boolean other_element_value = other_element.getValue();
java.lang.Integer __this__per_node_shared_scans_copy_key = other_element_key;
java.lang.Boolean __this__per_node_shared_scans_copy_value = other_element_value;
__this__per_node_shared_scans.put(__this__per_node_shared_scans_copy_key, __this__per_node_shared_scans_copy_value);
}
this.per_node_shared_scans = __this__per_node_shared_scans;
}
this.parallel_instances = other.parallel_instances;
this.total_instances = other.total_instances;
if (other.isSetShuffleIdxToInstanceIdx()) {
java.util.Map<java.lang.Integer,java.lang.Integer> __this__shuffle_idx_to_instance_idx = new java.util.HashMap<java.lang.Integer,java.lang.Integer>(other.shuffle_idx_to_instance_idx);
this.shuffle_idx_to_instance_idx = __this__shuffle_idx_to_instance_idx;
}
this.is_nereids = other.is_nereids;
this.wal_id = other.wal_id;
this.content_length = other.content_length;
if (other.isSetCurrentConnectFe()) {
this.current_connect_fe = new org.apache.doris.thrift.TNetworkAddress(other.current_connect_fe);
}
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.isSetAiResources()) {
java.util.Map<java.lang.String,TAIResource> __this__ai_resources = new java.util.HashMap<java.lang.String,TAIResource>(other.ai_resources.size());
for (java.util.Map.Entry<java.lang.String, TAIResource> other_element : other.ai_resources.entrySet()) {
java.lang.String other_element_key = other_element.getKey();
TAIResource other_element_value = other_element.getValue();
java.lang.String __this__ai_resources_copy_key = other_element_key;
TAIResource __this__ai_resources_copy_value = new TAIResource(other_element_value);
__this__ai_resources.put(__this__ai_resources_copy_key, __this__ai_resources_copy_value);
}
this.ai_resources = __this__ai_resources;
}
this.need_notify_close = other.need_notify_close;
this.is_mow_table = other.is_mow_table;
}
public TPipelineFragmentParams deepCopy() {
return new TPipelineFragmentParams(this);
}
@Override
public void clear() {
this.protocol_version = null;
this.query_id = null;
setFragmentIdIsSet(false);
this.fragment_id = 0;
this.per_exch_num_senders = null;
this.desc_tbl = null;
this.resource_info = null;
this.destinations = null;
setNumSendersIsSet(false);
this.num_senders = 0;
setSendQueryStatisticsWithEveryBatchIsSet(false);
this.send_query_statistics_with_every_batch = false;
this.coord = null;
this.query_globals = null;
this.query_options = null;
this.import_label = null;
this.db_name = null;
setLoadJobIdIsSet(false);
this.load_job_id = 0;
this.load_error_hub_info = null;
setFragmentNumOnHostIsSet(false);
this.fragment_num_on_host = 0;
setBackendIdIsSet(false);
this.backend_id = 0;
this.need_wait_execution_trigger = false;
this.instances_sharing_hash_table = null;
this.is_simplified_param = false;
this.global_dict = null;
this.fragment = null;
this.local_params = null;
this.workload_groups = null;
this.txn_conf = null;
this.table_name = null;
this.file_scan_params = null;
this.group_commit = false;
setLoadStreamPerNodeIsSet(false);
this.load_stream_per_node = 0;
setTotalLoadStreamsIsSet(false);
this.total_load_streams = 0;
setNumLocalSinkIsSet(false);
this.num_local_sink = 0;
setNumBucketsIsSet(false);
this.num_buckets = 0;
this.bucket_seq_to_instance_idx = null;
this.per_node_shared_scans = null;
setParallelInstancesIsSet(false);
this.parallel_instances = 0;
setTotalInstancesIsSet(false);
this.total_instances = 0;
this.shuffle_idx_to_instance_idx = null;
this.is_nereids = true;
setWalIdIsSet(false);
this.wal_id = 0;
setContentLengthIsSet(false);
this.content_length = 0;
this.current_connect_fe = null;
this.topn_filter_source_node_ids = null;
this.ai_resources = null;
setNeedNotifyCloseIsSet(false);
this.need_notify_close = false;
setIsMowTableIsSet(false);
this.is_mow_table = false;
}
/**
*
* @see PaloInternalServiceVersion
*/
@org.apache.thrift.annotation.Nullable
public PaloInternalServiceVersion getProtocolVersion() {
return this.protocol_version;
}
/**
*
* @see PaloInternalServiceVersion
*/
public TPipelineFragmentParams setProtocolVersion(@org.apache.thrift.annotation.Nullable PaloInternalServiceVersion 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 TPipelineFragmentParams 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 getFragmentId() {
return this.fragment_id;
}
public TPipelineFragmentParams 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);
}
public int getPerExchNumSendersSize() {
return (this.per_exch_num_senders == null) ? 0 : this.per_exch_num_senders.size();
}
public void putToPerExchNumSenders(int key, int val) {
if (this.per_exch_num_senders == null) {
this.per_exch_num_senders = new java.util.HashMap<java.lang.Integer,java.lang.Integer>();
}
this.per_exch_num_senders.put(key, val);
}
@org.apache.thrift.annotation.Nullable
public java.util.Map<java.lang.Integer,java.lang.Integer> getPerExchNumSenders() {
return this.per_exch_num_senders;
}
public TPipelineFragmentParams setPerExchNumSenders(@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.Integer,java.lang.Integer> per_exch_num_senders) {
this.per_exch_num_senders = per_exch_num_senders;
return this;
}
public void unsetPerExchNumSenders() {
this.per_exch_num_senders = null;
}
/** Returns true if field per_exch_num_senders is set (has been assigned a value) and false otherwise */
public boolean isSetPerExchNumSenders() {
return this.per_exch_num_senders != null;
}
public void setPerExchNumSendersIsSet(boolean value) {
if (!value) {
this.per_exch_num_senders = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TDescriptorTable getDescTbl() {
return this.desc_tbl;
}
public TPipelineFragmentParams 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;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TResourceInfo getResourceInfo() {
return this.resource_info;
}
public TPipelineFragmentParams 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 getDestinationsSize() {
return (this.destinations == null) ? 0 : this.destinations.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TPlanFragmentDestination> getDestinationsIterator() {
return (this.destinations == null) ? null : this.destinations.iterator();
}
public void addToDestinations(org.apache.doris.thrift.TPlanFragmentDestination elem) {
if (this.destinations == null) {
this.destinations = new java.util.ArrayList<org.apache.doris.thrift.TPlanFragmentDestination>();
}
this.destinations.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TPlanFragmentDestination> getDestinations() {
return this.destinations;
}
public TPipelineFragmentParams setDestinations(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TPlanFragmentDestination> destinations) {
this.destinations = destinations;
return this;
}
public void unsetDestinations() {
this.destinations = null;
}
/** Returns true if field destinations is set (has been assigned a value) and false otherwise */
public boolean isSetDestinations() {
return this.destinations != null;
}
public void setDestinationsIsSet(boolean value) {
if (!value) {
this.destinations = null;
}
}
public int getNumSenders() {
return this.num_senders;
}
public TPipelineFragmentParams setNumSenders(int num_senders) {
this.num_senders = num_senders;
setNumSendersIsSet(true);
return this;
}
public void unsetNumSenders() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __NUM_SENDERS_ISSET_ID);
}
/** Returns true if field num_senders is set (has been assigned a value) and false otherwise */
public boolean isSetNumSenders() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __NUM_SENDERS_ISSET_ID);
}
public void setNumSendersIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __NUM_SENDERS_ISSET_ID, value);
}
public boolean isSendQueryStatisticsWithEveryBatch() {
return this.send_query_statistics_with_every_batch;
}
public TPipelineFragmentParams setSendQueryStatisticsWithEveryBatch(boolean send_query_statistics_with_every_batch) {
this.send_query_statistics_with_every_batch = send_query_statistics_with_every_batch;
setSendQueryStatisticsWithEveryBatchIsSet(true);
return this;
}
public void unsetSendQueryStatisticsWithEveryBatch() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __SEND_QUERY_STATISTICS_WITH_EVERY_BATCH_ISSET_ID);
}
/** Returns true if field send_query_statistics_with_every_batch is set (has been assigned a value) and false otherwise */
public boolean isSetSendQueryStatisticsWithEveryBatch() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __SEND_QUERY_STATISTICS_WITH_EVERY_BATCH_ISSET_ID);
}
public void setSendQueryStatisticsWithEveryBatchIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __SEND_QUERY_STATISTICS_WITH_EVERY_BATCH_ISSET_ID, value);
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TNetworkAddress getCoord() {
return this.coord;
}
public TPipelineFragmentParams 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 TPipelineFragmentParams 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 TQueryOptions getQueryOptions() {
return this.query_options;
}
public TPipelineFragmentParams 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;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getImportLabel() {
return this.import_label;
}
public TPipelineFragmentParams setImportLabel(@org.apache.thrift.annotation.Nullable java.lang.String import_label) {
this.import_label = import_label;
return this;
}
public void unsetImportLabel() {
this.import_label = null;
}
/** Returns true if field import_label is set (has been assigned a value) and false otherwise */
public boolean isSetImportLabel() {
return this.import_label != null;
}
public void setImportLabelIsSet(boolean value) {
if (!value) {
this.import_label = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getDbName() {
return this.db_name;
}
public TPipelineFragmentParams setDbName(@org.apache.thrift.annotation.Nullable java.lang.String db_name) {
this.db_name = db_name;
return this;
}
public void unsetDbName() {
this.db_name = null;
}
/** Returns true if field db_name is set (has been assigned a value) and false otherwise */
public boolean isSetDbName() {
return this.db_name != null;
}
public void setDbNameIsSet(boolean value) {
if (!value) {
this.db_name = null;
}
}
public long getLoadJobId() {
return this.load_job_id;
}
public TPipelineFragmentParams setLoadJobId(long load_job_id) {
this.load_job_id = load_job_id;
setLoadJobIdIsSet(true);
return this;
}
public void unsetLoadJobId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __LOAD_JOB_ID_ISSET_ID);
}
/** Returns true if field load_job_id is set (has been assigned a value) and false otherwise */
public boolean isSetLoadJobId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __LOAD_JOB_ID_ISSET_ID);
}
public void setLoadJobIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __LOAD_JOB_ID_ISSET_ID, value);
}
@org.apache.thrift.annotation.Nullable
public TLoadErrorHubInfo getLoadErrorHubInfo() {
return this.load_error_hub_info;
}
public TPipelineFragmentParams setLoadErrorHubInfo(@org.apache.thrift.annotation.Nullable TLoadErrorHubInfo load_error_hub_info) {
this.load_error_hub_info = load_error_hub_info;
return this;
}
public void unsetLoadErrorHubInfo() {
this.load_error_hub_info = null;
}
/** Returns true if field load_error_hub_info is set (has been assigned a value) and false otherwise */
public boolean isSetLoadErrorHubInfo() {
return this.load_error_hub_info != null;
}
public void setLoadErrorHubInfoIsSet(boolean value) {
if (!value) {
this.load_error_hub_info = null;
}
}
public int getFragmentNumOnHost() {
return this.fragment_num_on_host;
}
public TPipelineFragmentParams 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);
}
public long getBackendId() {
return this.backend_id;
}
public TPipelineFragmentParams 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 boolean isNeedWaitExecutionTrigger() {
return this.need_wait_execution_trigger;
}
public TPipelineFragmentParams setNeedWaitExecutionTrigger(boolean need_wait_execution_trigger) {
this.need_wait_execution_trigger = need_wait_execution_trigger;
setNeedWaitExecutionTriggerIsSet(true);
return this;
}
public void unsetNeedWaitExecutionTrigger() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __NEED_WAIT_EXECUTION_TRIGGER_ISSET_ID);
}
/** Returns true if field need_wait_execution_trigger is set (has been assigned a value) and false otherwise */
public boolean isSetNeedWaitExecutionTrigger() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __NEED_WAIT_EXECUTION_TRIGGER_ISSET_ID);
}
public void setNeedWaitExecutionTriggerIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __NEED_WAIT_EXECUTION_TRIGGER_ISSET_ID, value);
}
public int getInstancesSharingHashTableSize() {
return (this.instances_sharing_hash_table == null) ? 0 : this.instances_sharing_hash_table.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TUniqueId> getInstancesSharingHashTableIterator() {
return (this.instances_sharing_hash_table == null) ? null : this.instances_sharing_hash_table.iterator();
}
public void addToInstancesSharingHashTable(org.apache.doris.thrift.TUniqueId elem) {
if (this.instances_sharing_hash_table == null) {
this.instances_sharing_hash_table = new java.util.ArrayList<org.apache.doris.thrift.TUniqueId>();
}
this.instances_sharing_hash_table.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TUniqueId> getInstancesSharingHashTable() {
return this.instances_sharing_hash_table;
}
public TPipelineFragmentParams setInstancesSharingHashTable(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TUniqueId> instances_sharing_hash_table) {
this.instances_sharing_hash_table = instances_sharing_hash_table;
return this;
}
public void unsetInstancesSharingHashTable() {
this.instances_sharing_hash_table = null;
}
/** Returns true if field instances_sharing_hash_table is set (has been assigned a value) and false otherwise */
public boolean isSetInstancesSharingHashTable() {
return this.instances_sharing_hash_table != null;
}
public void setInstancesSharingHashTableIsSet(boolean value) {
if (!value) {
this.instances_sharing_hash_table = null;
}
}
public boolean isIsSimplifiedParam() {
return this.is_simplified_param;
}
public TPipelineFragmentParams setIsSimplifiedParam(boolean is_simplified_param) {
this.is_simplified_param = is_simplified_param;
setIsSimplifiedParamIsSet(true);
return this;
}
public void unsetIsSimplifiedParam() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __IS_SIMPLIFIED_PARAM_ISSET_ID);
}
/** Returns true if field is_simplified_param is set (has been assigned a value) and false otherwise */
public boolean isSetIsSimplifiedParam() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __IS_SIMPLIFIED_PARAM_ISSET_ID);
}
public void setIsSimplifiedParamIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __IS_SIMPLIFIED_PARAM_ISSET_ID, value);
}
@org.apache.thrift.annotation.Nullable
public TGlobalDict getGlobalDict() {
return this.global_dict;
}
public TPipelineFragmentParams setGlobalDict(@org.apache.thrift.annotation.Nullable TGlobalDict global_dict) {
this.global_dict = global_dict;
return this;
}
public void unsetGlobalDict() {
this.global_dict = null;
}
/** Returns true if field global_dict is set (has been assigned a value) and false otherwise */
public boolean isSetGlobalDict() {
return this.global_dict != null;
}
public void setGlobalDictIsSet(boolean value) {
if (!value) {
this.global_dict = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TPlanFragment getFragment() {
return this.fragment;
}
public TPipelineFragmentParams setFragment(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TPlanFragment fragment) {
this.fragment = fragment;
return this;
}
public void unsetFragment() {
this.fragment = null;
}
/** Returns true if field fragment is set (has been assigned a value) and false otherwise */
public boolean isSetFragment() {
return this.fragment != null;
}
public void setFragmentIsSet(boolean value) {
if (!value) {
this.fragment = null;
}
}
public int getLocalParamsSize() {
return (this.local_params == null) ? 0 : this.local_params.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<TPipelineInstanceParams> getLocalParamsIterator() {
return (this.local_params == null) ? null : this.local_params.iterator();
}
public void addToLocalParams(TPipelineInstanceParams elem) {
if (this.local_params == null) {
this.local_params = new java.util.ArrayList<TPipelineInstanceParams>();
}
this.local_params.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<TPipelineInstanceParams> getLocalParams() {
return this.local_params;
}
public TPipelineFragmentParams setLocalParams(@org.apache.thrift.annotation.Nullable java.util.List<TPipelineInstanceParams> local_params) {
this.local_params = local_params;
return this;
}
public void unsetLocalParams() {
this.local_params = null;
}
/** Returns true if field local_params is set (has been assigned a value) and false otherwise */
public boolean isSetLocalParams() {
return this.local_params != null;
}
public void setLocalParamsIsSet(boolean value) {
if (!value) {
this.local_params = null;
}
}
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 TPipelineFragmentParams 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 TTxnParams getTxnConf() {
return this.txn_conf;
}
public TPipelineFragmentParams setTxnConf(@org.apache.thrift.annotation.Nullable TTxnParams txn_conf) {
this.txn_conf = txn_conf;
return this;
}
public void unsetTxnConf() {
this.txn_conf = null;
}
/** Returns true if field txn_conf is set (has been assigned a value) and false otherwise */
public boolean isSetTxnConf() {
return this.txn_conf != null;
}
public void setTxnConfIsSet(boolean value) {
if (!value) {
this.txn_conf = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getTableName() {
return this.table_name;
}
public TPipelineFragmentParams setTableName(@org.apache.thrift.annotation.Nullable java.lang.String table_name) {
this.table_name = table_name;
return this;
}
public void unsetTableName() {
this.table_name = null;
}
/** Returns true if field table_name is set (has been assigned a value) and false otherwise */
public boolean isSetTableName() {
return this.table_name != null;
}
public void setTableNameIsSet(boolean value) {
if (!value) {
this.table_name = 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 TPipelineFragmentParams 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;
}
}
public boolean isGroupCommit() {
return this.group_commit;
}
public TPipelineFragmentParams setGroupCommit(boolean group_commit) {
this.group_commit = group_commit;
setGroupCommitIsSet(true);
return this;
}
public void unsetGroupCommit() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __GROUP_COMMIT_ISSET_ID);
}
/** Returns true if field group_commit is set (has been assigned a value) and false otherwise */
public boolean isSetGroupCommit() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __GROUP_COMMIT_ISSET_ID);
}
public void setGroupCommitIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __GROUP_COMMIT_ISSET_ID, value);
}
public int getLoadStreamPerNode() {
return this.load_stream_per_node;
}
public TPipelineFragmentParams setLoadStreamPerNode(int load_stream_per_node) {
this.load_stream_per_node = load_stream_per_node;
setLoadStreamPerNodeIsSet(true);
return this;
}
public void unsetLoadStreamPerNode() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __LOAD_STREAM_PER_NODE_ISSET_ID);
}
/** Returns true if field load_stream_per_node is set (has been assigned a value) and false otherwise */
public boolean isSetLoadStreamPerNode() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __LOAD_STREAM_PER_NODE_ISSET_ID);
}
public void setLoadStreamPerNodeIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __LOAD_STREAM_PER_NODE_ISSET_ID, value);
}
public int getTotalLoadStreams() {
return this.total_load_streams;
}
public TPipelineFragmentParams setTotalLoadStreams(int total_load_streams) {
this.total_load_streams = total_load_streams;
setTotalLoadStreamsIsSet(true);
return this;
}
public void unsetTotalLoadStreams() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __TOTAL_LOAD_STREAMS_ISSET_ID);
}
/** Returns true if field total_load_streams is set (has been assigned a value) and false otherwise */
public boolean isSetTotalLoadStreams() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __TOTAL_LOAD_STREAMS_ISSET_ID);
}
public void setTotalLoadStreamsIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __TOTAL_LOAD_STREAMS_ISSET_ID, value);
}
public int getNumLocalSink() {
return this.num_local_sink;
}
public TPipelineFragmentParams setNumLocalSink(int num_local_sink) {
this.num_local_sink = num_local_sink;
setNumLocalSinkIsSet(true);
return this;
}
public void unsetNumLocalSink() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __NUM_LOCAL_SINK_ISSET_ID);
}
/** Returns true if field num_local_sink is set (has been assigned a value) and false otherwise */
public boolean isSetNumLocalSink() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __NUM_LOCAL_SINK_ISSET_ID);
}
public void setNumLocalSinkIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __NUM_LOCAL_SINK_ISSET_ID, value);
}
public int getNumBuckets() {
return this.num_buckets;
}
public TPipelineFragmentParams setNumBuckets(int num_buckets) {
this.num_buckets = num_buckets;
setNumBucketsIsSet(true);
return this;
}
public void unsetNumBuckets() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __NUM_BUCKETS_ISSET_ID);
}
/** Returns true if field num_buckets is set (has been assigned a value) and false otherwise */
public boolean isSetNumBuckets() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __NUM_BUCKETS_ISSET_ID);
}
public void setNumBucketsIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __NUM_BUCKETS_ISSET_ID, value);
}
public int getBucketSeqToInstanceIdxSize() {
return (this.bucket_seq_to_instance_idx == null) ? 0 : this.bucket_seq_to_instance_idx.size();
}
public void putToBucketSeqToInstanceIdx(int key, int val) {
if (this.bucket_seq_to_instance_idx == null) {
this.bucket_seq_to_instance_idx = new java.util.HashMap<java.lang.Integer,java.lang.Integer>();
}
this.bucket_seq_to_instance_idx.put(key, val);
}
@org.apache.thrift.annotation.Nullable
public java.util.Map<java.lang.Integer,java.lang.Integer> getBucketSeqToInstanceIdx() {
return this.bucket_seq_to_instance_idx;
}
public TPipelineFragmentParams setBucketSeqToInstanceIdx(@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.Integer,java.lang.Integer> bucket_seq_to_instance_idx) {
this.bucket_seq_to_instance_idx = bucket_seq_to_instance_idx;
return this;
}
public void unsetBucketSeqToInstanceIdx() {
this.bucket_seq_to_instance_idx = null;
}
/** Returns true if field bucket_seq_to_instance_idx is set (has been assigned a value) and false otherwise */
public boolean isSetBucketSeqToInstanceIdx() {
return this.bucket_seq_to_instance_idx != null;
}
public void setBucketSeqToInstanceIdxIsSet(boolean value) {
if (!value) {
this.bucket_seq_to_instance_idx = null;
}
}
public int getPerNodeSharedScansSize() {
return (this.per_node_shared_scans == null) ? 0 : this.per_node_shared_scans.size();
}
public void putToPerNodeSharedScans(int key, boolean val) {
if (this.per_node_shared_scans == null) {
this.per_node_shared_scans = new java.util.HashMap<java.lang.Integer,java.lang.Boolean>();
}
this.per_node_shared_scans.put(key, val);
}
@org.apache.thrift.annotation.Nullable
public java.util.Map<java.lang.Integer,java.lang.Boolean> getPerNodeSharedScans() {
return this.per_node_shared_scans;
}
public TPipelineFragmentParams setPerNodeSharedScans(@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.Integer,java.lang.Boolean> per_node_shared_scans) {
this.per_node_shared_scans = per_node_shared_scans;
return this;
}
public void unsetPerNodeSharedScans() {
this.per_node_shared_scans = null;
}
/** Returns true if field per_node_shared_scans is set (has been assigned a value) and false otherwise */
public boolean isSetPerNodeSharedScans() {
return this.per_node_shared_scans != null;
}
public void setPerNodeSharedScansIsSet(boolean value) {
if (!value) {
this.per_node_shared_scans = null;
}
}
public int getParallelInstances() {
return this.parallel_instances;
}
public TPipelineFragmentParams setParallelInstances(int parallel_instances) {
this.parallel_instances = parallel_instances;
setParallelInstancesIsSet(true);
return this;
}
public void unsetParallelInstances() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __PARALLEL_INSTANCES_ISSET_ID);
}
/** Returns true if field parallel_instances is set (has been assigned a value) and false otherwise */
public boolean isSetParallelInstances() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __PARALLEL_INSTANCES_ISSET_ID);
}
public void setParallelInstancesIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __PARALLEL_INSTANCES_ISSET_ID, value);
}
public int getTotalInstances() {
return this.total_instances;
}
public TPipelineFragmentParams setTotalInstances(int total_instances) {
this.total_instances = total_instances;
setTotalInstancesIsSet(true);
return this;
}
public void unsetTotalInstances() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __TOTAL_INSTANCES_ISSET_ID);
}
/** Returns true if field total_instances is set (has been assigned a value) and false otherwise */
public boolean isSetTotalInstances() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __TOTAL_INSTANCES_ISSET_ID);
}
public void setTotalInstancesIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __TOTAL_INSTANCES_ISSET_ID, value);
}
public int getShuffleIdxToInstanceIdxSize() {
return (this.shuffle_idx_to_instance_idx == null) ? 0 : this.shuffle_idx_to_instance_idx.size();
}
public void putToShuffleIdxToInstanceIdx(int key, int val) {
if (this.shuffle_idx_to_instance_idx == null) {
this.shuffle_idx_to_instance_idx = new java.util.HashMap<java.lang.Integer,java.lang.Integer>();
}
this.shuffle_idx_to_instance_idx.put(key, val);
}
@org.apache.thrift.annotation.Nullable
public java.util.Map<java.lang.Integer,java.lang.Integer> getShuffleIdxToInstanceIdx() {
return this.shuffle_idx_to_instance_idx;
}
public TPipelineFragmentParams setShuffleIdxToInstanceIdx(@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.Integer,java.lang.Integer> shuffle_idx_to_instance_idx) {
this.shuffle_idx_to_instance_idx = shuffle_idx_to_instance_idx;
return this;
}
public void unsetShuffleIdxToInstanceIdx() {
this.shuffle_idx_to_instance_idx = null;
}
/** Returns true if field shuffle_idx_to_instance_idx is set (has been assigned a value) and false otherwise */
public boolean isSetShuffleIdxToInstanceIdx() {
return this.shuffle_idx_to_instance_idx != null;
}
public void setShuffleIdxToInstanceIdxIsSet(boolean value) {
if (!value) {
this.shuffle_idx_to_instance_idx = null;
}
}
public boolean isIsNereids() {
return this.is_nereids;
}
public TPipelineFragmentParams 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 long getWalId() {
return this.wal_id;
}
public TPipelineFragmentParams setWalId(long wal_id) {
this.wal_id = wal_id;
setWalIdIsSet(true);
return this;
}
public void unsetWalId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __WAL_ID_ISSET_ID);
}
/** Returns true if field wal_id is set (has been assigned a value) and false otherwise */
public boolean isSetWalId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __WAL_ID_ISSET_ID);
}
public void setWalIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __WAL_ID_ISSET_ID, value);
}
public long getContentLength() {
return this.content_length;
}
public TPipelineFragmentParams setContentLength(long content_length) {
this.content_length = content_length;
setContentLengthIsSet(true);
return this;
}
public void unsetContentLength() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __CONTENT_LENGTH_ISSET_ID);
}
/** Returns true if field content_length is set (has been assigned a value) and false otherwise */
public boolean isSetContentLength() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __CONTENT_LENGTH_ISSET_ID);
}
public void setContentLengthIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __CONTENT_LENGTH_ISSET_ID, value);
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TNetworkAddress getCurrentConnectFe() {
return this.current_connect_fe;
}
public TPipelineFragmentParams setCurrentConnectFe(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TNetworkAddress current_connect_fe) {
this.current_connect_fe = current_connect_fe;
return this;
}
public void unsetCurrentConnectFe() {
this.current_connect_fe = null;
}
/** Returns true if field current_connect_fe is set (has been assigned a value) and false otherwise */
public boolean isSetCurrentConnectFe() {
return this.current_connect_fe != null;
}
public void setCurrentConnectFeIsSet(boolean value) {
if (!value) {
this.current_connect_fe = 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 TPipelineFragmentParams 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;
}
}
public int getAiResourcesSize() {
return (this.ai_resources == null) ? 0 : this.ai_resources.size();
}
public void putToAiResources(java.lang.String key, TAIResource val) {
if (this.ai_resources == null) {
this.ai_resources = new java.util.HashMap<java.lang.String,TAIResource>();
}
this.ai_resources.put(key, val);
}
@org.apache.thrift.annotation.Nullable
public java.util.Map<java.lang.String,TAIResource> getAiResources() {
return this.ai_resources;
}
public TPipelineFragmentParams setAiResources(@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,TAIResource> ai_resources) {
this.ai_resources = ai_resources;
return this;
}
public void unsetAiResources() {
this.ai_resources = null;
}
/** Returns true if field ai_resources is set (has been assigned a value) and false otherwise */
public boolean isSetAiResources() {
return this.ai_resources != null;
}
public void setAiResourcesIsSet(boolean value) {
if (!value) {
this.ai_resources = null;
}
}
public boolean isNeedNotifyClose() {
return this.need_notify_close;
}
public TPipelineFragmentParams setNeedNotifyClose(boolean need_notify_close) {
this.need_notify_close = need_notify_close;
setNeedNotifyCloseIsSet(true);
return this;
}
public void unsetNeedNotifyClose() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __NEED_NOTIFY_CLOSE_ISSET_ID);
}
/** Returns true if field need_notify_close is set (has been assigned a value) and false otherwise */
public boolean isSetNeedNotifyClose() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __NEED_NOTIFY_CLOSE_ISSET_ID);
}
public void setNeedNotifyCloseIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __NEED_NOTIFY_CLOSE_ISSET_ID, value);
}
public boolean isIsMowTable() {
return this.is_mow_table;
}
public TPipelineFragmentParams setIsMowTable(boolean is_mow_table) {
this.is_mow_table = is_mow_table;
setIsMowTableIsSet(true);
return this;
}
public void unsetIsMowTable() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __IS_MOW_TABLE_ISSET_ID);
}
/** Returns true if field is_mow_table is set (has been assigned a value) and false otherwise */
public boolean isSetIsMowTable() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __IS_MOW_TABLE_ISSET_ID);
}
public void setIsMowTableIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __IS_MOW_TABLE_ISSET_ID, value);
}
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((PaloInternalServiceVersion)value);
}
break;
case QUERY_ID:
if (value == null) {
unsetQueryId();
} else {
setQueryId((org.apache.doris.thrift.TUniqueId)value);
}
break;
case FRAGMENT_ID:
if (value == null) {
unsetFragmentId();
} else {
setFragmentId((java.lang.Integer)value);
}
break;
case PER_EXCH_NUM_SENDERS:
if (value == null) {
unsetPerExchNumSenders();
} else {
setPerExchNumSenders((java.util.Map<java.lang.Integer,java.lang.Integer>)value);
}
break;
case DESC_TBL:
if (value == null) {
unsetDescTbl();
} else {
setDescTbl((org.apache.doris.thrift.TDescriptorTable)value);
}
break;
case RESOURCE_INFO:
if (value == null) {
unsetResourceInfo();
} else {
setResourceInfo((org.apache.doris.thrift.TResourceInfo)value);
}
break;
case DESTINATIONS:
if (value == null) {
unsetDestinations();
} else {
setDestinations((java.util.List<org.apache.doris.thrift.TPlanFragmentDestination>)value);
}
break;
case NUM_SENDERS:
if (value == null) {
unsetNumSenders();
} else {
setNumSenders((java.lang.Integer)value);
}
break;
case SEND_QUERY_STATISTICS_WITH_EVERY_BATCH:
if (value == null) {
unsetSendQueryStatisticsWithEveryBatch();
} else {
setSendQueryStatisticsWithEveryBatch((java.lang.Boolean)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 QUERY_OPTIONS:
if (value == null) {
unsetQueryOptions();
} else {
setQueryOptions((TQueryOptions)value);
}
break;
case IMPORT_LABEL:
if (value == null) {
unsetImportLabel();
} else {
setImportLabel((java.lang.String)value);
}
break;
case DB_NAME:
if (value == null) {
unsetDbName();
} else {
setDbName((java.lang.String)value);
}
break;
case LOAD_JOB_ID:
if (value == null) {
unsetLoadJobId();
} else {
setLoadJobId((java.lang.Long)value);
}
break;
case LOAD_ERROR_HUB_INFO:
if (value == null) {
unsetLoadErrorHubInfo();
} else {
setLoadErrorHubInfo((TLoadErrorHubInfo)value);
}
break;
case FRAGMENT_NUM_ON_HOST:
if (value == null) {
unsetFragmentNumOnHost();
} else {
setFragmentNumOnHost((java.lang.Integer)value);
}
break;
case BACKEND_ID:
if (value == null) {
unsetBackendId();
} else {
setBackendId((java.lang.Long)value);
}
break;
case NEED_WAIT_EXECUTION_TRIGGER:
if (value == null) {
unsetNeedWaitExecutionTrigger();
} else {
setNeedWaitExecutionTrigger((java.lang.Boolean)value);
}
break;
case INSTANCES_SHARING_HASH_TABLE:
if (value == null) {
unsetInstancesSharingHashTable();
} else {
setInstancesSharingHashTable((java.util.List<org.apache.doris.thrift.TUniqueId>)value);
}
break;
case IS_SIMPLIFIED_PARAM:
if (value == null) {
unsetIsSimplifiedParam();
} else {
setIsSimplifiedParam((java.lang.Boolean)value);
}
break;
case GLOBAL_DICT:
if (value == null) {
unsetGlobalDict();
} else {
setGlobalDict((TGlobalDict)value);
}
break;
case FRAGMENT:
if (value == null) {
unsetFragment();
} else {
setFragment((org.apache.doris.thrift.TPlanFragment)value);
}
break;
case LOCAL_PARAMS:
if (value == null) {
unsetLocalParams();
} else {
setLocalParams((java.util.List<TPipelineInstanceParams>)value);
}
break;
case WORKLOAD_GROUPS:
if (value == null) {
unsetWorkloadGroups();
} else {
setWorkloadGroups((java.util.List<TPipelineWorkloadGroup>)value);
}
break;
case TXN_CONF:
if (value == null) {
unsetTxnConf();
} else {
setTxnConf((TTxnParams)value);
}
break;
case TABLE_NAME:
if (value == null) {
unsetTableName();
} else {
setTableName((java.lang.String)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 GROUP_COMMIT:
if (value == null) {
unsetGroupCommit();
} else {
setGroupCommit((java.lang.Boolean)value);
}
break;
case LOAD_STREAM_PER_NODE:
if (value == null) {
unsetLoadStreamPerNode();
} else {
setLoadStreamPerNode((java.lang.Integer)value);
}
break;
case TOTAL_LOAD_STREAMS:
if (value == null) {
unsetTotalLoadStreams();
} else {
setTotalLoadStreams((java.lang.Integer)value);
}
break;
case NUM_LOCAL_SINK:
if (value == null) {
unsetNumLocalSink();
} else {
setNumLocalSink((java.lang.Integer)value);
}
break;
case NUM_BUCKETS:
if (value == null) {
unsetNumBuckets();
} else {
setNumBuckets((java.lang.Integer)value);
}
break;
case BUCKET_SEQ_TO_INSTANCE_IDX:
if (value == null) {
unsetBucketSeqToInstanceIdx();
} else {
setBucketSeqToInstanceIdx((java.util.Map<java.lang.Integer,java.lang.Integer>)value);
}
break;
case PER_NODE_SHARED_SCANS:
if (value == null) {
unsetPerNodeSharedScans();
} else {
setPerNodeSharedScans((java.util.Map<java.lang.Integer,java.lang.Boolean>)value);
}
break;
case PARALLEL_INSTANCES:
if (value == null) {
unsetParallelInstances();
} else {
setParallelInstances((java.lang.Integer)value);
}
break;
case TOTAL_INSTANCES:
if (value == null) {
unsetTotalInstances();
} else {
setTotalInstances((java.lang.Integer)value);
}
break;
case SHUFFLE_IDX_TO_INSTANCE_IDX:
if (value == null) {
unsetShuffleIdxToInstanceIdx();
} else {
setShuffleIdxToInstanceIdx((java.util.Map<java.lang.Integer,java.lang.Integer>)value);
}
break;
case IS_NEREIDS:
if (value == null) {
unsetIsNereids();
} else {
setIsNereids((java.lang.Boolean)value);
}
break;
case WAL_ID:
if (value == null) {
unsetWalId();
} else {
setWalId((java.lang.Long)value);
}
break;
case CONTENT_LENGTH:
if (value == null) {
unsetContentLength();
} else {
setContentLength((java.lang.Long)value);
}
break;
case CURRENT_CONNECT_FE:
if (value == null) {
unsetCurrentConnectFe();
} else {
setCurrentConnectFe((org.apache.doris.thrift.TNetworkAddress)value);
}
break;
case TOPN_FILTER_SOURCE_NODE_IDS:
if (value == null) {
unsetTopnFilterSourceNodeIds();
} else {
setTopnFilterSourceNodeIds((java.util.List<java.lang.Integer>)value);
}
break;
case AI_RESOURCES:
if (value == null) {
unsetAiResources();
} else {
setAiResources((java.util.Map<java.lang.String,TAIResource>)value);
}
break;
case NEED_NOTIFY_CLOSE:
if (value == null) {
unsetNeedNotifyClose();
} else {
setNeedNotifyClose((java.lang.Boolean)value);
}
break;
case IS_MOW_TABLE:
if (value == null) {
unsetIsMowTable();
} else {
setIsMowTable((java.lang.Boolean)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 FRAGMENT_ID:
return getFragmentId();
case PER_EXCH_NUM_SENDERS:
return getPerExchNumSenders();
case DESC_TBL:
return getDescTbl();
case RESOURCE_INFO:
return getResourceInfo();
case DESTINATIONS:
return getDestinations();
case NUM_SENDERS:
return getNumSenders();
case SEND_QUERY_STATISTICS_WITH_EVERY_BATCH:
return isSendQueryStatisticsWithEveryBatch();
case COORD:
return getCoord();
case QUERY_GLOBALS:
return getQueryGlobals();
case QUERY_OPTIONS:
return getQueryOptions();
case IMPORT_LABEL:
return getImportLabel();
case DB_NAME:
return getDbName();
case LOAD_JOB_ID:
return getLoadJobId();
case LOAD_ERROR_HUB_INFO:
return getLoadErrorHubInfo();
case FRAGMENT_NUM_ON_HOST:
return getFragmentNumOnHost();
case BACKEND_ID:
return getBackendId();
case NEED_WAIT_EXECUTION_TRIGGER:
return isNeedWaitExecutionTrigger();
case INSTANCES_SHARING_HASH_TABLE:
return getInstancesSharingHashTable();
case IS_SIMPLIFIED_PARAM:
return isIsSimplifiedParam();
case GLOBAL_DICT:
return getGlobalDict();
case FRAGMENT:
return getFragment();
case LOCAL_PARAMS:
return getLocalParams();
case WORKLOAD_GROUPS:
return getWorkloadGroups();
case TXN_CONF:
return getTxnConf();
case TABLE_NAME:
return getTableName();
case FILE_SCAN_PARAMS:
return getFileScanParams();
case GROUP_COMMIT:
return isGroupCommit();
case LOAD_STREAM_PER_NODE:
return getLoadStreamPerNode();
case TOTAL_LOAD_STREAMS:
return getTotalLoadStreams();
case NUM_LOCAL_SINK:
return getNumLocalSink();
case NUM_BUCKETS:
return getNumBuckets();
case BUCKET_SEQ_TO_INSTANCE_IDX:
return getBucketSeqToInstanceIdx();
case PER_NODE_SHARED_SCANS:
return getPerNodeSharedScans();
case PARALLEL_INSTANCES:
return getParallelInstances();
case TOTAL_INSTANCES:
return getTotalInstances();
case SHUFFLE_IDX_TO_INSTANCE_IDX:
return getShuffleIdxToInstanceIdx();
case IS_NEREIDS:
return isIsNereids();
case WAL_ID:
return getWalId();
case CONTENT_LENGTH:
return getContentLength();
case CURRENT_CONNECT_FE:
return getCurrentConnectFe();
case TOPN_FILTER_SOURCE_NODE_IDS:
return getTopnFilterSourceNodeIds();
case AI_RESOURCES:
return getAiResources();
case NEED_NOTIFY_CLOSE:
return isNeedNotifyClose();
case IS_MOW_TABLE:
return isIsMowTable();
}
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 FRAGMENT_ID:
return isSetFragmentId();
case PER_EXCH_NUM_SENDERS:
return isSetPerExchNumSenders();
case DESC_TBL:
return isSetDescTbl();
case RESOURCE_INFO:
return isSetResourceInfo();
case DESTINATIONS:
return isSetDestinations();
case NUM_SENDERS:
return isSetNumSenders();
case SEND_QUERY_STATISTICS_WITH_EVERY_BATCH:
return isSetSendQueryStatisticsWithEveryBatch();
case COORD:
return isSetCoord();
case QUERY_GLOBALS:
return isSetQueryGlobals();
case QUERY_OPTIONS:
return isSetQueryOptions();
case IMPORT_LABEL:
return isSetImportLabel();
case DB_NAME:
return isSetDbName();
case LOAD_JOB_ID:
return isSetLoadJobId();
case LOAD_ERROR_HUB_INFO:
return isSetLoadErrorHubInfo();
case FRAGMENT_NUM_ON_HOST:
return isSetFragmentNumOnHost();
case BACKEND_ID:
return isSetBackendId();
case NEED_WAIT_EXECUTION_TRIGGER:
return isSetNeedWaitExecutionTrigger();
case INSTANCES_SHARING_HASH_TABLE:
return isSetInstancesSharingHashTable();
case IS_SIMPLIFIED_PARAM:
return isSetIsSimplifiedParam();
case GLOBAL_DICT:
return isSetGlobalDict();
case FRAGMENT:
return isSetFragment();
case LOCAL_PARAMS:
return isSetLocalParams();
case WORKLOAD_GROUPS:
return isSetWorkloadGroups();
case TXN_CONF:
return isSetTxnConf();
case TABLE_NAME:
return isSetTableName();
case FILE_SCAN_PARAMS:
return isSetFileScanParams();
case GROUP_COMMIT:
return isSetGroupCommit();
case LOAD_STREAM_PER_NODE:
return isSetLoadStreamPerNode();
case TOTAL_LOAD_STREAMS:
return isSetTotalLoadStreams();
case NUM_LOCAL_SINK:
return isSetNumLocalSink();
case NUM_BUCKETS:
return isSetNumBuckets();
case BUCKET_SEQ_TO_INSTANCE_IDX:
return isSetBucketSeqToInstanceIdx();
case PER_NODE_SHARED_SCANS:
return isSetPerNodeSharedScans();
case PARALLEL_INSTANCES:
return isSetParallelInstances();
case TOTAL_INSTANCES:
return isSetTotalInstances();
case SHUFFLE_IDX_TO_INSTANCE_IDX:
return isSetShuffleIdxToInstanceIdx();
case IS_NEREIDS:
return isSetIsNereids();
case WAL_ID:
return isSetWalId();
case CONTENT_LENGTH:
return isSetContentLength();
case CURRENT_CONNECT_FE:
return isSetCurrentConnectFe();
case TOPN_FILTER_SOURCE_NODE_IDS:
return isSetTopnFilterSourceNodeIds();
case AI_RESOURCES:
return isSetAiResources();
case NEED_NOTIFY_CLOSE:
return isSetNeedNotifyClose();
case IS_MOW_TABLE:
return isSetIsMowTable();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof TPipelineFragmentParams)
return this.equals((TPipelineFragmentParams)that);
return false;
}
public boolean equals(TPipelineFragmentParams 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_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_per_exch_num_senders = true && this.isSetPerExchNumSenders();
boolean that_present_per_exch_num_senders = true && that.isSetPerExchNumSenders();
if (this_present_per_exch_num_senders || that_present_per_exch_num_senders) {
if (!(this_present_per_exch_num_senders && that_present_per_exch_num_senders))
return false;
if (!this.per_exch_num_senders.equals(that.per_exch_num_senders))
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_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_destinations = true && this.isSetDestinations();
boolean that_present_destinations = true && that.isSetDestinations();
if (this_present_destinations || that_present_destinations) {
if (!(this_present_destinations && that_present_destinations))
return false;
if (!this.destinations.equals(that.destinations))
return false;
}
boolean this_present_num_senders = true && this.isSetNumSenders();
boolean that_present_num_senders = true && that.isSetNumSenders();
if (this_present_num_senders || that_present_num_senders) {
if (!(this_present_num_senders && that_present_num_senders))
return false;
if (this.num_senders != that.num_senders)
return false;
}
boolean this_present_send_query_statistics_with_every_batch = true && this.isSetSendQueryStatisticsWithEveryBatch();
boolean that_present_send_query_statistics_with_every_batch = true && that.isSetSendQueryStatisticsWithEveryBatch();
if (this_present_send_query_statistics_with_every_batch || that_present_send_query_statistics_with_every_batch) {
if (!(this_present_send_query_statistics_with_every_batch && that_present_send_query_statistics_with_every_batch))
return false;
if (this.send_query_statistics_with_every_batch != that.send_query_statistics_with_every_batch)
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_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_import_label = true && this.isSetImportLabel();
boolean that_present_import_label = true && that.isSetImportLabel();
if (this_present_import_label || that_present_import_label) {
if (!(this_present_import_label && that_present_import_label))
return false;
if (!this.import_label.equals(that.import_label))
return false;
}
boolean this_present_db_name = true && this.isSetDbName();
boolean that_present_db_name = true && that.isSetDbName();
if (this_present_db_name || that_present_db_name) {
if (!(this_present_db_name && that_present_db_name))
return false;
if (!this.db_name.equals(that.db_name))
return false;
}
boolean this_present_load_job_id = true && this.isSetLoadJobId();
boolean that_present_load_job_id = true && that.isSetLoadJobId();
if (this_present_load_job_id || that_present_load_job_id) {
if (!(this_present_load_job_id && that_present_load_job_id))
return false;
if (this.load_job_id != that.load_job_id)
return false;
}
boolean this_present_load_error_hub_info = true && this.isSetLoadErrorHubInfo();
boolean that_present_load_error_hub_info = true && that.isSetLoadErrorHubInfo();
if (this_present_load_error_hub_info || that_present_load_error_hub_info) {
if (!(this_present_load_error_hub_info && that_present_load_error_hub_info))
return false;
if (!this.load_error_hub_info.equals(that.load_error_hub_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_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_need_wait_execution_trigger = true && this.isSetNeedWaitExecutionTrigger();
boolean that_present_need_wait_execution_trigger = true && that.isSetNeedWaitExecutionTrigger();
if (this_present_need_wait_execution_trigger || that_present_need_wait_execution_trigger) {
if (!(this_present_need_wait_execution_trigger && that_present_need_wait_execution_trigger))
return false;
if (this.need_wait_execution_trigger != that.need_wait_execution_trigger)
return false;
}
boolean this_present_instances_sharing_hash_table = true && this.isSetInstancesSharingHashTable();
boolean that_present_instances_sharing_hash_table = true && that.isSetInstancesSharingHashTable();
if (this_present_instances_sharing_hash_table || that_present_instances_sharing_hash_table) {
if (!(this_present_instances_sharing_hash_table && that_present_instances_sharing_hash_table))
return false;
if (!this.instances_sharing_hash_table.equals(that.instances_sharing_hash_table))
return false;
}
boolean this_present_is_simplified_param = true && this.isSetIsSimplifiedParam();
boolean that_present_is_simplified_param = true && that.isSetIsSimplifiedParam();
if (this_present_is_simplified_param || that_present_is_simplified_param) {
if (!(this_present_is_simplified_param && that_present_is_simplified_param))
return false;
if (this.is_simplified_param != that.is_simplified_param)
return false;
}
boolean this_present_global_dict = true && this.isSetGlobalDict();
boolean that_present_global_dict = true && that.isSetGlobalDict();
if (this_present_global_dict || that_present_global_dict) {
if (!(this_present_global_dict && that_present_global_dict))
return false;
if (!this.global_dict.equals(that.global_dict))
return false;
}
boolean this_present_fragment = true && this.isSetFragment();
boolean that_present_fragment = true && that.isSetFragment();
if (this_present_fragment || that_present_fragment) {
if (!(this_present_fragment && that_present_fragment))
return false;
if (!this.fragment.equals(that.fragment))
return false;
}
boolean this_present_local_params = true && this.isSetLocalParams();
boolean that_present_local_params = true && that.isSetLocalParams();
if (this_present_local_params || that_present_local_params) {
if (!(this_present_local_params && that_present_local_params))
return false;
if (!this.local_params.equals(that.local_params))
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_txn_conf = true && this.isSetTxnConf();
boolean that_present_txn_conf = true && that.isSetTxnConf();
if (this_present_txn_conf || that_present_txn_conf) {
if (!(this_present_txn_conf && that_present_txn_conf))
return false;
if (!this.txn_conf.equals(that.txn_conf))
return false;
}
boolean this_present_table_name = true && this.isSetTableName();
boolean that_present_table_name = true && that.isSetTableName();
if (this_present_table_name || that_present_table_name) {
if (!(this_present_table_name && that_present_table_name))
return false;
if (!this.table_name.equals(that.table_name))
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_group_commit = true && this.isSetGroupCommit();
boolean that_present_group_commit = true && that.isSetGroupCommit();
if (this_present_group_commit || that_present_group_commit) {
if (!(this_present_group_commit && that_present_group_commit))
return false;
if (this.group_commit != that.group_commit)
return false;
}
boolean this_present_load_stream_per_node = true && this.isSetLoadStreamPerNode();
boolean that_present_load_stream_per_node = true && that.isSetLoadStreamPerNode();
if (this_present_load_stream_per_node || that_present_load_stream_per_node) {
if (!(this_present_load_stream_per_node && that_present_load_stream_per_node))
return false;
if (this.load_stream_per_node != that.load_stream_per_node)
return false;
}
boolean this_present_total_load_streams = true && this.isSetTotalLoadStreams();
boolean that_present_total_load_streams = true && that.isSetTotalLoadStreams();
if (this_present_total_load_streams || that_present_total_load_streams) {
if (!(this_present_total_load_streams && that_present_total_load_streams))
return false;
if (this.total_load_streams != that.total_load_streams)
return false;
}
boolean this_present_num_local_sink = true && this.isSetNumLocalSink();
boolean that_present_num_local_sink = true && that.isSetNumLocalSink();
if (this_present_num_local_sink || that_present_num_local_sink) {
if (!(this_present_num_local_sink && that_present_num_local_sink))
return false;
if (this.num_local_sink != that.num_local_sink)
return false;
}
boolean this_present_num_buckets = true && this.isSetNumBuckets();
boolean that_present_num_buckets = true && that.isSetNumBuckets();
if (this_present_num_buckets || that_present_num_buckets) {
if (!(this_present_num_buckets && that_present_num_buckets))
return false;
if (this.num_buckets != that.num_buckets)
return false;
}
boolean this_present_bucket_seq_to_instance_idx = true && this.isSetBucketSeqToInstanceIdx();
boolean that_present_bucket_seq_to_instance_idx = true && that.isSetBucketSeqToInstanceIdx();
if (this_present_bucket_seq_to_instance_idx || that_present_bucket_seq_to_instance_idx) {
if (!(this_present_bucket_seq_to_instance_idx && that_present_bucket_seq_to_instance_idx))
return false;
if (!this.bucket_seq_to_instance_idx.equals(that.bucket_seq_to_instance_idx))
return false;
}
boolean this_present_per_node_shared_scans = true && this.isSetPerNodeSharedScans();
boolean that_present_per_node_shared_scans = true && that.isSetPerNodeSharedScans();
if (this_present_per_node_shared_scans || that_present_per_node_shared_scans) {
if (!(this_present_per_node_shared_scans && that_present_per_node_shared_scans))
return false;
if (!this.per_node_shared_scans.equals(that.per_node_shared_scans))
return false;
}
boolean this_present_parallel_instances = true && this.isSetParallelInstances();
boolean that_present_parallel_instances = true && that.isSetParallelInstances();
if (this_present_parallel_instances || that_present_parallel_instances) {
if (!(this_present_parallel_instances && that_present_parallel_instances))
return false;
if (this.parallel_instances != that.parallel_instances)
return false;
}
boolean this_present_total_instances = true && this.isSetTotalInstances();
boolean that_present_total_instances = true && that.isSetTotalInstances();
if (this_present_total_instances || that_present_total_instances) {
if (!(this_present_total_instances && that_present_total_instances))
return false;
if (this.total_instances != that.total_instances)
return false;
}
boolean this_present_shuffle_idx_to_instance_idx = true && this.isSetShuffleIdxToInstanceIdx();
boolean that_present_shuffle_idx_to_instance_idx = true && that.isSetShuffleIdxToInstanceIdx();
if (this_present_shuffle_idx_to_instance_idx || that_present_shuffle_idx_to_instance_idx) {
if (!(this_present_shuffle_idx_to_instance_idx && that_present_shuffle_idx_to_instance_idx))
return false;
if (!this.shuffle_idx_to_instance_idx.equals(that.shuffle_idx_to_instance_idx))
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_wal_id = true && this.isSetWalId();
boolean that_present_wal_id = true && that.isSetWalId();
if (this_present_wal_id || that_present_wal_id) {
if (!(this_present_wal_id && that_present_wal_id))
return false;
if (this.wal_id != that.wal_id)
return false;
}
boolean this_present_content_length = true && this.isSetContentLength();
boolean that_present_content_length = true && that.isSetContentLength();
if (this_present_content_length || that_present_content_length) {
if (!(this_present_content_length && that_present_content_length))
return false;
if (this.content_length != that.content_length)
return false;
}
boolean this_present_current_connect_fe = true && this.isSetCurrentConnectFe();
boolean that_present_current_connect_fe = true && that.isSetCurrentConnectFe();
if (this_present_current_connect_fe || that_present_current_connect_fe) {
if (!(this_present_current_connect_fe && that_present_current_connect_fe))
return false;
if (!this.current_connect_fe.equals(that.current_connect_fe))
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_ai_resources = true && this.isSetAiResources();
boolean that_present_ai_resources = true && that.isSetAiResources();
if (this_present_ai_resources || that_present_ai_resources) {
if (!(this_present_ai_resources && that_present_ai_resources))
return false;
if (!this.ai_resources.equals(that.ai_resources))
return false;
}
boolean this_present_need_notify_close = true && this.isSetNeedNotifyClose();
boolean that_present_need_notify_close = true && that.isSetNeedNotifyClose();
if (this_present_need_notify_close || that_present_need_notify_close) {
if (!(this_present_need_notify_close && that_present_need_notify_close))
return false;
if (this.need_notify_close != that.need_notify_close)
return false;
}
boolean this_present_is_mow_table = true && this.isSetIsMowTable();
boolean that_present_is_mow_table = true && that.isSetIsMowTable();
if (this_present_is_mow_table || that_present_is_mow_table) {
if (!(this_present_is_mow_table && that_present_is_mow_table))
return false;
if (this.is_mow_table != that.is_mow_table)
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 + ((isSetFragmentId()) ? 131071 : 524287);
if (isSetFragmentId())
hashCode = hashCode * 8191 + fragment_id;
hashCode = hashCode * 8191 + ((isSetPerExchNumSenders()) ? 131071 : 524287);
if (isSetPerExchNumSenders())
hashCode = hashCode * 8191 + per_exch_num_senders.hashCode();
hashCode = hashCode * 8191 + ((isSetDescTbl()) ? 131071 : 524287);
if (isSetDescTbl())
hashCode = hashCode * 8191 + desc_tbl.hashCode();
hashCode = hashCode * 8191 + ((isSetResourceInfo()) ? 131071 : 524287);
if (isSetResourceInfo())
hashCode = hashCode * 8191 + resource_info.hashCode();
hashCode = hashCode * 8191 + ((isSetDestinations()) ? 131071 : 524287);
if (isSetDestinations())
hashCode = hashCode * 8191 + destinations.hashCode();
hashCode = hashCode * 8191 + ((isSetNumSenders()) ? 131071 : 524287);
if (isSetNumSenders())
hashCode = hashCode * 8191 + num_senders;
hashCode = hashCode * 8191 + ((isSetSendQueryStatisticsWithEveryBatch()) ? 131071 : 524287);
if (isSetSendQueryStatisticsWithEveryBatch())
hashCode = hashCode * 8191 + ((send_query_statistics_with_every_batch) ? 131071 : 524287);
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 + ((isSetQueryOptions()) ? 131071 : 524287);
if (isSetQueryOptions())
hashCode = hashCode * 8191 + query_options.hashCode();
hashCode = hashCode * 8191 + ((isSetImportLabel()) ? 131071 : 524287);
if (isSetImportLabel())
hashCode = hashCode * 8191 + import_label.hashCode();
hashCode = hashCode * 8191 + ((isSetDbName()) ? 131071 : 524287);
if (isSetDbName())
hashCode = hashCode * 8191 + db_name.hashCode();
hashCode = hashCode * 8191 + ((isSetLoadJobId()) ? 131071 : 524287);
if (isSetLoadJobId())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(load_job_id);
hashCode = hashCode * 8191 + ((isSetLoadErrorHubInfo()) ? 131071 : 524287);
if (isSetLoadErrorHubInfo())
hashCode = hashCode * 8191 + load_error_hub_info.hashCode();
hashCode = hashCode * 8191 + ((isSetFragmentNumOnHost()) ? 131071 : 524287);
if (isSetFragmentNumOnHost())
hashCode = hashCode * 8191 + fragment_num_on_host;
hashCode = hashCode * 8191 + ((isSetBackendId()) ? 131071 : 524287);
if (isSetBackendId())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(backend_id);
hashCode = hashCode * 8191 + ((isSetNeedWaitExecutionTrigger()) ? 131071 : 524287);
if (isSetNeedWaitExecutionTrigger())
hashCode = hashCode * 8191 + ((need_wait_execution_trigger) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetInstancesSharingHashTable()) ? 131071 : 524287);
if (isSetInstancesSharingHashTable())
hashCode = hashCode * 8191 + instances_sharing_hash_table.hashCode();
hashCode = hashCode * 8191 + ((isSetIsSimplifiedParam()) ? 131071 : 524287);
if (isSetIsSimplifiedParam())
hashCode = hashCode * 8191 + ((is_simplified_param) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetGlobalDict()) ? 131071 : 524287);
if (isSetGlobalDict())
hashCode = hashCode * 8191 + global_dict.hashCode();
hashCode = hashCode * 8191 + ((isSetFragment()) ? 131071 : 524287);
if (isSetFragment())
hashCode = hashCode * 8191 + fragment.hashCode();
hashCode = hashCode * 8191 + ((isSetLocalParams()) ? 131071 : 524287);
if (isSetLocalParams())
hashCode = hashCode * 8191 + local_params.hashCode();
hashCode = hashCode * 8191 + ((isSetWorkloadGroups()) ? 131071 : 524287);
if (isSetWorkloadGroups())
hashCode = hashCode * 8191 + workload_groups.hashCode();
hashCode = hashCode * 8191 + ((isSetTxnConf()) ? 131071 : 524287);
if (isSetTxnConf())
hashCode = hashCode * 8191 + txn_conf.hashCode();
hashCode = hashCode * 8191 + ((isSetTableName()) ? 131071 : 524287);
if (isSetTableName())
hashCode = hashCode * 8191 + table_name.hashCode();
hashCode = hashCode * 8191 + ((isSetFileScanParams()) ? 131071 : 524287);
if (isSetFileScanParams())
hashCode = hashCode * 8191 + file_scan_params.hashCode();
hashCode = hashCode * 8191 + ((isSetGroupCommit()) ? 131071 : 524287);
if (isSetGroupCommit())
hashCode = hashCode * 8191 + ((group_commit) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetLoadStreamPerNode()) ? 131071 : 524287);
if (isSetLoadStreamPerNode())
hashCode = hashCode * 8191 + load_stream_per_node;
hashCode = hashCode * 8191 + ((isSetTotalLoadStreams()) ? 131071 : 524287);
if (isSetTotalLoadStreams())
hashCode = hashCode * 8191 + total_load_streams;
hashCode = hashCode * 8191 + ((isSetNumLocalSink()) ? 131071 : 524287);
if (isSetNumLocalSink())
hashCode = hashCode * 8191 + num_local_sink;
hashCode = hashCode * 8191 + ((isSetNumBuckets()) ? 131071 : 524287);
if (isSetNumBuckets())
hashCode = hashCode * 8191 + num_buckets;
hashCode = hashCode * 8191 + ((isSetBucketSeqToInstanceIdx()) ? 131071 : 524287);
if (isSetBucketSeqToInstanceIdx())
hashCode = hashCode * 8191 + bucket_seq_to_instance_idx.hashCode();
hashCode = hashCode * 8191 + ((isSetPerNodeSharedScans()) ? 131071 : 524287);
if (isSetPerNodeSharedScans())
hashCode = hashCode * 8191 + per_node_shared_scans.hashCode();
hashCode = hashCode * 8191 + ((isSetParallelInstances()) ? 131071 : 524287);
if (isSetParallelInstances())
hashCode = hashCode * 8191 + parallel_instances;
hashCode = hashCode * 8191 + ((isSetTotalInstances()) ? 131071 : 524287);
if (isSetTotalInstances())
hashCode = hashCode * 8191 + total_instances;
hashCode = hashCode * 8191 + ((isSetShuffleIdxToInstanceIdx()) ? 131071 : 524287);
if (isSetShuffleIdxToInstanceIdx())
hashCode = hashCode * 8191 + shuffle_idx_to_instance_idx.hashCode();
hashCode = hashCode * 8191 + ((isSetIsNereids()) ? 131071 : 524287);
if (isSetIsNereids())
hashCode = hashCode * 8191 + ((is_nereids) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetWalId()) ? 131071 : 524287);
if (isSetWalId())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(wal_id);
hashCode = hashCode * 8191 + ((isSetContentLength()) ? 131071 : 524287);
if (isSetContentLength())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(content_length);
hashCode = hashCode * 8191 + ((isSetCurrentConnectFe()) ? 131071 : 524287);
if (isSetCurrentConnectFe())
hashCode = hashCode * 8191 + current_connect_fe.hashCode();
hashCode = hashCode * 8191 + ((isSetTopnFilterSourceNodeIds()) ? 131071 : 524287);
if (isSetTopnFilterSourceNodeIds())
hashCode = hashCode * 8191 + topn_filter_source_node_ids.hashCode();
hashCode = hashCode * 8191 + ((isSetAiResources()) ? 131071 : 524287);
if (isSetAiResources())
hashCode = hashCode * 8191 + ai_resources.hashCode();
hashCode = hashCode * 8191 + ((isSetNeedNotifyClose()) ? 131071 : 524287);
if (isSetNeedNotifyClose())
hashCode = hashCode * 8191 + ((need_notify_close) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetIsMowTable()) ? 131071 : 524287);
if (isSetIsMowTable())
hashCode = hashCode * 8191 + ((is_mow_table) ? 131071 : 524287);
return hashCode;
}
@Override
public int compareTo(TPipelineFragmentParams 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(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(isSetPerExchNumSenders(), other.isSetPerExchNumSenders());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPerExchNumSenders()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.per_exch_num_senders, other.per_exch_num_senders);
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(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(isSetDestinations(), other.isSetDestinations());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetDestinations()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.destinations, other.destinations);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetNumSenders(), other.isSetNumSenders());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetNumSenders()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num_senders, other.num_senders);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetSendQueryStatisticsWithEveryBatch(), other.isSetSendQueryStatisticsWithEveryBatch());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetSendQueryStatisticsWithEveryBatch()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.send_query_statistics_with_every_batch, other.send_query_statistics_with_every_batch);
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(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(isSetImportLabel(), other.isSetImportLabel());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetImportLabel()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.import_label, other.import_label);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetDbName(), other.isSetDbName());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetDbName()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.db_name, other.db_name);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetLoadJobId(), other.isSetLoadJobId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetLoadJobId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.load_job_id, other.load_job_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetLoadErrorHubInfo(), other.isSetLoadErrorHubInfo());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetLoadErrorHubInfo()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.load_error_hub_info, other.load_error_hub_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(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(isSetNeedWaitExecutionTrigger(), other.isSetNeedWaitExecutionTrigger());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetNeedWaitExecutionTrigger()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.need_wait_execution_trigger, other.need_wait_execution_trigger);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetInstancesSharingHashTable(), other.isSetInstancesSharingHashTable());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetInstancesSharingHashTable()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.instances_sharing_hash_table, other.instances_sharing_hash_table);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetIsSimplifiedParam(), other.isSetIsSimplifiedParam());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetIsSimplifiedParam()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.is_simplified_param, other.is_simplified_param);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetGlobalDict(), other.isSetGlobalDict());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetGlobalDict()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.global_dict, other.global_dict);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetFragment(), other.isSetFragment());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetFragment()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fragment, other.fragment);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetLocalParams(), other.isSetLocalParams());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetLocalParams()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.local_params, other.local_params);
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(isSetTxnConf(), other.isSetTxnConf());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTxnConf()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.txn_conf, other.txn_conf);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTableName(), other.isSetTableName());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTableName()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.table_name, other.table_name);
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(isSetGroupCommit(), other.isSetGroupCommit());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetGroupCommit()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.group_commit, other.group_commit);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetLoadStreamPerNode(), other.isSetLoadStreamPerNode());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetLoadStreamPerNode()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.load_stream_per_node, other.load_stream_per_node);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTotalLoadStreams(), other.isSetTotalLoadStreams());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTotalLoadStreams()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.total_load_streams, other.total_load_streams);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetNumLocalSink(), other.isSetNumLocalSink());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetNumLocalSink()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num_local_sink, other.num_local_sink);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetNumBuckets(), other.isSetNumBuckets());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetNumBuckets()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num_buckets, other.num_buckets);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetBucketSeqToInstanceIdx(), other.isSetBucketSeqToInstanceIdx());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetBucketSeqToInstanceIdx()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.bucket_seq_to_instance_idx, other.bucket_seq_to_instance_idx);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetPerNodeSharedScans(), other.isSetPerNodeSharedScans());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPerNodeSharedScans()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.per_node_shared_scans, other.per_node_shared_scans);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetParallelInstances(), other.isSetParallelInstances());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetParallelInstances()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.parallel_instances, other.parallel_instances);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTotalInstances(), other.isSetTotalInstances());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTotalInstances()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.total_instances, other.total_instances);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetShuffleIdxToInstanceIdx(), other.isSetShuffleIdxToInstanceIdx());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetShuffleIdxToInstanceIdx()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.shuffle_idx_to_instance_idx, other.shuffle_idx_to_instance_idx);
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(isSetWalId(), other.isSetWalId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetWalId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.wal_id, other.wal_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetContentLength(), other.isSetContentLength());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetContentLength()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.content_length, other.content_length);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetCurrentConnectFe(), other.isSetCurrentConnectFe());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetCurrentConnectFe()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.current_connect_fe, other.current_connect_fe);
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(isSetAiResources(), other.isSetAiResources());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetAiResources()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ai_resources, other.ai_resources);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetNeedNotifyClose(), other.isSetNeedNotifyClose());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetNeedNotifyClose()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.need_notify_close, other.need_notify_close);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetIsMowTable(), other.isSetIsMowTable());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetIsMowTable()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.is_mow_table, other.is_mow_table);
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("TPipelineFragmentParams(");
boolean first = true;
sb.append("protocol_version:");
if (this.protocol_version == null) {
sb.append("null");
} else {
sb.append(this.protocol_version);
}
first = false;
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 (isSetFragmentId()) {
if (!first) sb.append(", ");
sb.append("fragment_id:");
sb.append(this.fragment_id);
first = false;
}
if (!first) sb.append(", ");
sb.append("per_exch_num_senders:");
if (this.per_exch_num_senders == null) {
sb.append("null");
} else {
sb.append(this.per_exch_num_senders);
}
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 (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 (!first) sb.append(", ");
sb.append("destinations:");
if (this.destinations == null) {
sb.append("null");
} else {
sb.append(this.destinations);
}
first = false;
if (isSetNumSenders()) {
if (!first) sb.append(", ");
sb.append("num_senders:");
sb.append(this.num_senders);
first = false;
}
if (isSetSendQueryStatisticsWithEveryBatch()) {
if (!first) sb.append(", ");
sb.append("send_query_statistics_with_every_batch:");
sb.append(this.send_query_statistics_with_every_batch);
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 (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 (isSetImportLabel()) {
if (!first) sb.append(", ");
sb.append("import_label:");
if (this.import_label == null) {
sb.append("null");
} else {
sb.append(this.import_label);
}
first = false;
}
if (isSetDbName()) {
if (!first) sb.append(", ");
sb.append("db_name:");
if (this.db_name == null) {
sb.append("null");
} else {
sb.append(this.db_name);
}
first = false;
}
if (isSetLoadJobId()) {
if (!first) sb.append(", ");
sb.append("load_job_id:");
sb.append(this.load_job_id);
first = false;
}
if (isSetLoadErrorHubInfo()) {
if (!first) sb.append(", ");
sb.append("load_error_hub_info:");
if (this.load_error_hub_info == null) {
sb.append("null");
} else {
sb.append(this.load_error_hub_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 (isSetBackendId()) {
if (!first) sb.append(", ");
sb.append("backend_id:");
sb.append(this.backend_id);
first = false;
}
if (isSetNeedWaitExecutionTrigger()) {
if (!first) sb.append(", ");
sb.append("need_wait_execution_trigger:");
sb.append(this.need_wait_execution_trigger);
first = false;
}
if (isSetInstancesSharingHashTable()) {
if (!first) sb.append(", ");
sb.append("instances_sharing_hash_table:");
if (this.instances_sharing_hash_table == null) {
sb.append("null");
} else {
sb.append(this.instances_sharing_hash_table);
}
first = false;
}
if (isSetIsSimplifiedParam()) {
if (!first) sb.append(", ");
sb.append("is_simplified_param:");
sb.append(this.is_simplified_param);
first = false;
}
if (isSetGlobalDict()) {
if (!first) sb.append(", ");
sb.append("global_dict:");
if (this.global_dict == null) {
sb.append("null");
} else {
sb.append(this.global_dict);
}
first = false;
}
if (isSetFragment()) {
if (!first) sb.append(", ");
sb.append("fragment:");
if (this.fragment == null) {
sb.append("null");
} else {
sb.append(this.fragment);
}
first = false;
}
if (!first) sb.append(", ");
sb.append("local_params:");
if (this.local_params == null) {
sb.append("null");
} else {
sb.append(this.local_params);
}
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 (isSetTxnConf()) {
if (!first) sb.append(", ");
sb.append("txn_conf:");
if (this.txn_conf == null) {
sb.append("null");
} else {
sb.append(this.txn_conf);
}
first = false;
}
if (isSetTableName()) {
if (!first) sb.append(", ");
sb.append("table_name:");
if (this.table_name == null) {
sb.append("null");
} else {
sb.append(this.table_name);
}
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 (isSetGroupCommit()) {
if (!first) sb.append(", ");
sb.append("group_commit:");
sb.append(this.group_commit);
first = false;
}
if (isSetLoadStreamPerNode()) {
if (!first) sb.append(", ");
sb.append("load_stream_per_node:");
sb.append(this.load_stream_per_node);
first = false;
}
if (isSetTotalLoadStreams()) {
if (!first) sb.append(", ");
sb.append("total_load_streams:");
sb.append(this.total_load_streams);
first = false;
}
if (isSetNumLocalSink()) {
if (!first) sb.append(", ");
sb.append("num_local_sink:");
sb.append(this.num_local_sink);
first = false;
}
if (isSetNumBuckets()) {
if (!first) sb.append(", ");
sb.append("num_buckets:");
sb.append(this.num_buckets);
first = false;
}
if (isSetBucketSeqToInstanceIdx()) {
if (!first) sb.append(", ");
sb.append("bucket_seq_to_instance_idx:");
if (this.bucket_seq_to_instance_idx == null) {
sb.append("null");
} else {
sb.append(this.bucket_seq_to_instance_idx);
}
first = false;
}
if (isSetPerNodeSharedScans()) {
if (!first) sb.append(", ");
sb.append("per_node_shared_scans:");
if (this.per_node_shared_scans == null) {
sb.append("null");
} else {
sb.append(this.per_node_shared_scans);
}
first = false;
}
if (isSetParallelInstances()) {
if (!first) sb.append(", ");
sb.append("parallel_instances:");
sb.append(this.parallel_instances);
first = false;
}
if (isSetTotalInstances()) {
if (!first) sb.append(", ");
sb.append("total_instances:");
sb.append(this.total_instances);
first = false;
}
if (isSetShuffleIdxToInstanceIdx()) {
if (!first) sb.append(", ");
sb.append("shuffle_idx_to_instance_idx:");
if (this.shuffle_idx_to_instance_idx == null) {
sb.append("null");
} else {
sb.append(this.shuffle_idx_to_instance_idx);
}
first = false;
}
if (isSetIsNereids()) {
if (!first) sb.append(", ");
sb.append("is_nereids:");
sb.append(this.is_nereids);
first = false;
}
if (isSetWalId()) {
if (!first) sb.append(", ");
sb.append("wal_id:");
sb.append(this.wal_id);
first = false;
}
if (isSetContentLength()) {
if (!first) sb.append(", ");
sb.append("content_length:");
sb.append(this.content_length);
first = false;
}
if (isSetCurrentConnectFe()) {
if (!first) sb.append(", ");
sb.append("current_connect_fe:");
if (this.current_connect_fe == null) {
sb.append("null");
} else {
sb.append(this.current_connect_fe);
}
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 (isSetAiResources()) {
if (!first) sb.append(", ");
sb.append("ai_resources:");
if (this.ai_resources == null) {
sb.append("null");
} else {
sb.append(this.ai_resources);
}
first = false;
}
if (isSetNeedNotifyClose()) {
if (!first) sb.append(", ");
sb.append("need_notify_close:");
sb.append(this.need_notify_close);
first = false;
}
if (isSetIsMowTable()) {
if (!first) sb.append(", ");
sb.append("is_mow_table:");
sb.append(this.is_mow_table);
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());
}
if (query_id == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'query_id' was not present! Struct: " + toString());
}
if (per_exch_num_senders == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'per_exch_num_senders' was not present! Struct: " + toString());
}
// check for sub-struct validity
if (query_id != null) {
query_id.validate();
}
if (desc_tbl != null) {
desc_tbl.validate();
}
if (resource_info != null) {
resource_info.validate();
}
if (coord != null) {
coord.validate();
}
if (query_globals != null) {
query_globals.validate();
}
if (query_options != null) {
query_options.validate();
}
if (load_error_hub_info != null) {
load_error_hub_info.validate();
}
if (global_dict != null) {
global_dict.validate();
}
if (fragment != null) {
fragment.validate();
}
if (txn_conf != null) {
txn_conf.validate();
}
if (current_connect_fe != null) {
current_connect_fe.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 TPipelineFragmentParamsStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TPipelineFragmentParamsStandardScheme getScheme() {
return new TPipelineFragmentParamsStandardScheme();
}
}
private static class TPipelineFragmentParamsStandardScheme extends org.apache.thrift.scheme.StandardScheme<TPipelineFragmentParams> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TPipelineFragmentParams 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.PaloInternalServiceVersion.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: // 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 4: // PER_EXCH_NUM_SENDERS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map200 = iprot.readMapBegin();
struct.per_exch_num_senders = new java.util.HashMap<java.lang.Integer,java.lang.Integer>(2*_map200.size);
int _key201;
int _val202;
for (int _i203 = 0; _i203 < _map200.size; ++_i203)
{
_key201 = iprot.readI32();
_val202 = iprot.readI32();
struct.per_exch_num_senders.put(_key201, _val202);
}
iprot.readMapEnd();
}
struct.setPerExchNumSendersIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // 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 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: // DESTINATIONS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list204 = iprot.readListBegin();
struct.destinations = new java.util.ArrayList<org.apache.doris.thrift.TPlanFragmentDestination>(_list204.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TPlanFragmentDestination _elem205;
for (int _i206 = 0; _i206 < _list204.size; ++_i206)
{
_elem205 = new org.apache.doris.thrift.TPlanFragmentDestination();
_elem205.read(iprot);
struct.destinations.add(_elem205);
}
iprot.readListEnd();
}
struct.setDestinationsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // NUM_SENDERS
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.num_senders = iprot.readI32();
struct.setNumSendersIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // SEND_QUERY_STATISTICS_WITH_EVERY_BATCH
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.send_query_statistics_with_every_batch = iprot.readBool();
struct.setSendQueryStatisticsWithEveryBatchIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 10: // 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 11: // 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 12: // 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 13: // IMPORT_LABEL
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.import_label = iprot.readString();
struct.setImportLabelIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 14: // DB_NAME
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.db_name = iprot.readString();
struct.setDbNameIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 15: // LOAD_JOB_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.load_job_id = iprot.readI64();
struct.setLoadJobIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 16: // LOAD_ERROR_HUB_INFO
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.load_error_hub_info = new TLoadErrorHubInfo();
struct.load_error_hub_info.read(iprot);
struct.setLoadErrorHubInfoIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 17: // 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 18: // 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 19: // NEED_WAIT_EXECUTION_TRIGGER
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.need_wait_execution_trigger = iprot.readBool();
struct.setNeedWaitExecutionTriggerIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 20: // INSTANCES_SHARING_HASH_TABLE
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list207 = iprot.readListBegin();
struct.instances_sharing_hash_table = new java.util.ArrayList<org.apache.doris.thrift.TUniqueId>(_list207.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TUniqueId _elem208;
for (int _i209 = 0; _i209 < _list207.size; ++_i209)
{
_elem208 = new org.apache.doris.thrift.TUniqueId();
_elem208.read(iprot);
struct.instances_sharing_hash_table.add(_elem208);
}
iprot.readListEnd();
}
struct.setInstancesSharingHashTableIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 21: // IS_SIMPLIFIED_PARAM
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.is_simplified_param = iprot.readBool();
struct.setIsSimplifiedParamIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 22: // GLOBAL_DICT
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.global_dict = new TGlobalDict();
struct.global_dict.read(iprot);
struct.setGlobalDictIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 23: // FRAGMENT
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.fragment = new org.apache.doris.thrift.TPlanFragment();
struct.fragment.read(iprot);
struct.setFragmentIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 24: // LOCAL_PARAMS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list210 = iprot.readListBegin();
struct.local_params = new java.util.ArrayList<TPipelineInstanceParams>(_list210.size);
@org.apache.thrift.annotation.Nullable TPipelineInstanceParams _elem211;
for (int _i212 = 0; _i212 < _list210.size; ++_i212)
{
_elem211 = new TPipelineInstanceParams();
_elem211.read(iprot);
struct.local_params.add(_elem211);
}
iprot.readListEnd();
}
struct.setLocalParamsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 26: // WORKLOAD_GROUPS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list213 = iprot.readListBegin();
struct.workload_groups = new java.util.ArrayList<TPipelineWorkloadGroup>(_list213.size);
@org.apache.thrift.annotation.Nullable TPipelineWorkloadGroup _elem214;
for (int _i215 = 0; _i215 < _list213.size; ++_i215)
{
_elem214 = new TPipelineWorkloadGroup();
_elem214.read(iprot);
struct.workload_groups.add(_elem214);
}
iprot.readListEnd();
}
struct.setWorkloadGroupsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 27: // TXN_CONF
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.txn_conf = new TTxnParams();
struct.txn_conf.read(iprot);
struct.setTxnConfIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 28: // TABLE_NAME
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.table_name = iprot.readString();
struct.setTableNameIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 29: // FILE_SCAN_PARAMS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map216 = iprot.readMapBegin();
struct.file_scan_params = new java.util.HashMap<java.lang.Integer,org.apache.doris.thrift.TFileScanRangeParams>(2*_map216.size);
int _key217;
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TFileScanRangeParams _val218;
for (int _i219 = 0; _i219 < _map216.size; ++_i219)
{
_key217 = iprot.readI32();
_val218 = new org.apache.doris.thrift.TFileScanRangeParams();
_val218.read(iprot);
struct.file_scan_params.put(_key217, _val218);
}
iprot.readMapEnd();
}
struct.setFileScanParamsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 30: // GROUP_COMMIT
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.group_commit = iprot.readBool();
struct.setGroupCommitIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 31: // LOAD_STREAM_PER_NODE
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.load_stream_per_node = iprot.readI32();
struct.setLoadStreamPerNodeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 32: // TOTAL_LOAD_STREAMS
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.total_load_streams = iprot.readI32();
struct.setTotalLoadStreamsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 33: // NUM_LOCAL_SINK
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.num_local_sink = iprot.readI32();
struct.setNumLocalSinkIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 34: // NUM_BUCKETS
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.num_buckets = iprot.readI32();
struct.setNumBucketsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 35: // BUCKET_SEQ_TO_INSTANCE_IDX
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map220 = iprot.readMapBegin();
struct.bucket_seq_to_instance_idx = new java.util.HashMap<java.lang.Integer,java.lang.Integer>(2*_map220.size);
int _key221;
int _val222;
for (int _i223 = 0; _i223 < _map220.size; ++_i223)
{
_key221 = iprot.readI32();
_val222 = iprot.readI32();
struct.bucket_seq_to_instance_idx.put(_key221, _val222);
}
iprot.readMapEnd();
}
struct.setBucketSeqToInstanceIdxIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 36: // PER_NODE_SHARED_SCANS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map224 = iprot.readMapBegin();
struct.per_node_shared_scans = new java.util.HashMap<java.lang.Integer,java.lang.Boolean>(2*_map224.size);
int _key225;
boolean _val226;
for (int _i227 = 0; _i227 < _map224.size; ++_i227)
{
_key225 = iprot.readI32();
_val226 = iprot.readBool();
struct.per_node_shared_scans.put(_key225, _val226);
}
iprot.readMapEnd();
}
struct.setPerNodeSharedScansIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 37: // PARALLEL_INSTANCES
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.parallel_instances = iprot.readI32();
struct.setParallelInstancesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 38: // TOTAL_INSTANCES
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.total_instances = iprot.readI32();
struct.setTotalInstancesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 39: // SHUFFLE_IDX_TO_INSTANCE_IDX
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map228 = iprot.readMapBegin();
struct.shuffle_idx_to_instance_idx = new java.util.HashMap<java.lang.Integer,java.lang.Integer>(2*_map228.size);
int _key229;
int _val230;
for (int _i231 = 0; _i231 < _map228.size; ++_i231)
{
_key229 = iprot.readI32();
_val230 = iprot.readI32();
struct.shuffle_idx_to_instance_idx.put(_key229, _val230);
}
iprot.readMapEnd();
}
struct.setShuffleIdxToInstanceIdxIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 40: // 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 41: // WAL_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.wal_id = iprot.readI64();
struct.setWalIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 42: // CONTENT_LENGTH
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.content_length = iprot.readI64();
struct.setContentLengthIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 43: // CURRENT_CONNECT_FE
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.current_connect_fe = new org.apache.doris.thrift.TNetworkAddress();
struct.current_connect_fe.read(iprot);
struct.setCurrentConnectFeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 44: // TOPN_FILTER_SOURCE_NODE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list232 = iprot.readListBegin();
struct.topn_filter_source_node_ids = new java.util.ArrayList<java.lang.Integer>(_list232.size);
int _elem233;
for (int _i234 = 0; _i234 < _list232.size; ++_i234)
{
_elem233 = iprot.readI32();
struct.topn_filter_source_node_ids.add(_elem233);
}
iprot.readListEnd();
}
struct.setTopnFilterSourceNodeIdsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 45: // AI_RESOURCES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map235 = iprot.readMapBegin();
struct.ai_resources = new java.util.HashMap<java.lang.String,TAIResource>(2*_map235.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key236;
@org.apache.thrift.annotation.Nullable TAIResource _val237;
for (int _i238 = 0; _i238 < _map235.size; ++_i238)
{
_key236 = iprot.readString();
_val237 = new TAIResource();
_val237.read(iprot);
struct.ai_resources.put(_key236, _val237);
}
iprot.readMapEnd();
}
struct.setAiResourcesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 46: // NEED_NOTIFY_CLOSE
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.need_notify_close = iprot.readBool();
struct.setNeedNotifyCloseIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 1000: // IS_MOW_TABLE
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.is_mow_table = iprot.readBool();
struct.setIsMowTableIsSet(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, TPipelineFragmentParams 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) {
oprot.writeFieldBegin(QUERY_ID_FIELD_DESC);
struct.query_id.write(oprot);
oprot.writeFieldEnd();
}
if (struct.isSetFragmentId()) {
oprot.writeFieldBegin(FRAGMENT_ID_FIELD_DESC);
oprot.writeI32(struct.fragment_id);
oprot.writeFieldEnd();
}
if (struct.per_exch_num_senders != null) {
oprot.writeFieldBegin(PER_EXCH_NUM_SENDERS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.I32, struct.per_exch_num_senders.size()));
for (java.util.Map.Entry<java.lang.Integer, java.lang.Integer> _iter239 : struct.per_exch_num_senders.entrySet())
{
oprot.writeI32(_iter239.getKey());
oprot.writeI32(_iter239.getValue());
}
oprot.writeMapEnd();
}
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.resource_info != null) {
if (struct.isSetResourceInfo()) {
oprot.writeFieldBegin(RESOURCE_INFO_FIELD_DESC);
struct.resource_info.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.destinations != null) {
oprot.writeFieldBegin(DESTINATIONS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.destinations.size()));
for (org.apache.doris.thrift.TPlanFragmentDestination _iter240 : struct.destinations)
{
_iter240.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
if (struct.isSetNumSenders()) {
oprot.writeFieldBegin(NUM_SENDERS_FIELD_DESC);
oprot.writeI32(struct.num_senders);
oprot.writeFieldEnd();
}
if (struct.isSetSendQueryStatisticsWithEveryBatch()) {
oprot.writeFieldBegin(SEND_QUERY_STATISTICS_WITH_EVERY_BATCH_FIELD_DESC);
oprot.writeBool(struct.send_query_statistics_with_every_batch);
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.query_options != null) {
if (struct.isSetQueryOptions()) {
oprot.writeFieldBegin(QUERY_OPTIONS_FIELD_DESC);
struct.query_options.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.import_label != null) {
if (struct.isSetImportLabel()) {
oprot.writeFieldBegin(IMPORT_LABEL_FIELD_DESC);
oprot.writeString(struct.import_label);
oprot.writeFieldEnd();
}
}
if (struct.db_name != null) {
if (struct.isSetDbName()) {
oprot.writeFieldBegin(DB_NAME_FIELD_DESC);
oprot.writeString(struct.db_name);
oprot.writeFieldEnd();
}
}
if (struct.isSetLoadJobId()) {
oprot.writeFieldBegin(LOAD_JOB_ID_FIELD_DESC);
oprot.writeI64(struct.load_job_id);
oprot.writeFieldEnd();
}
if (struct.load_error_hub_info != null) {
if (struct.isSetLoadErrorHubInfo()) {
oprot.writeFieldBegin(LOAD_ERROR_HUB_INFO_FIELD_DESC);
struct.load_error_hub_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.isSetBackendId()) {
oprot.writeFieldBegin(BACKEND_ID_FIELD_DESC);
oprot.writeI64(struct.backend_id);
oprot.writeFieldEnd();
}
if (struct.isSetNeedWaitExecutionTrigger()) {
oprot.writeFieldBegin(NEED_WAIT_EXECUTION_TRIGGER_FIELD_DESC);
oprot.writeBool(struct.need_wait_execution_trigger);
oprot.writeFieldEnd();
}
if (struct.instances_sharing_hash_table != null) {
if (struct.isSetInstancesSharingHashTable()) {
oprot.writeFieldBegin(INSTANCES_SHARING_HASH_TABLE_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.instances_sharing_hash_table.size()));
for (org.apache.doris.thrift.TUniqueId _iter241 : struct.instances_sharing_hash_table)
{
_iter241.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.isSetIsSimplifiedParam()) {
oprot.writeFieldBegin(IS_SIMPLIFIED_PARAM_FIELD_DESC);
oprot.writeBool(struct.is_simplified_param);
oprot.writeFieldEnd();
}
if (struct.global_dict != null) {
if (struct.isSetGlobalDict()) {
oprot.writeFieldBegin(GLOBAL_DICT_FIELD_DESC);
struct.global_dict.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.fragment != null) {
if (struct.isSetFragment()) {
oprot.writeFieldBegin(FRAGMENT_FIELD_DESC);
struct.fragment.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.local_params != null) {
oprot.writeFieldBegin(LOCAL_PARAMS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.local_params.size()));
for (TPipelineInstanceParams _iter242 : struct.local_params)
{
_iter242.write(oprot);
}
oprot.writeListEnd();
}
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 _iter243 : struct.workload_groups)
{
_iter243.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.txn_conf != null) {
if (struct.isSetTxnConf()) {
oprot.writeFieldBegin(TXN_CONF_FIELD_DESC);
struct.txn_conf.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.table_name != null) {
if (struct.isSetTableName()) {
oprot.writeFieldBegin(TABLE_NAME_FIELD_DESC);
oprot.writeString(struct.table_name);
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> _iter244 : struct.file_scan_params.entrySet())
{
oprot.writeI32(_iter244.getKey());
_iter244.getValue().write(oprot);
}
oprot.writeMapEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.isSetGroupCommit()) {
oprot.writeFieldBegin(GROUP_COMMIT_FIELD_DESC);
oprot.writeBool(struct.group_commit);
oprot.writeFieldEnd();
}
if (struct.isSetLoadStreamPerNode()) {
oprot.writeFieldBegin(LOAD_STREAM_PER_NODE_FIELD_DESC);
oprot.writeI32(struct.load_stream_per_node);
oprot.writeFieldEnd();
}
if (struct.isSetTotalLoadStreams()) {
oprot.writeFieldBegin(TOTAL_LOAD_STREAMS_FIELD_DESC);
oprot.writeI32(struct.total_load_streams);
oprot.writeFieldEnd();
}
if (struct.isSetNumLocalSink()) {
oprot.writeFieldBegin(NUM_LOCAL_SINK_FIELD_DESC);
oprot.writeI32(struct.num_local_sink);
oprot.writeFieldEnd();
}
if (struct.isSetNumBuckets()) {
oprot.writeFieldBegin(NUM_BUCKETS_FIELD_DESC);
oprot.writeI32(struct.num_buckets);
oprot.writeFieldEnd();
}
if (struct.bucket_seq_to_instance_idx != null) {
if (struct.isSetBucketSeqToInstanceIdx()) {
oprot.writeFieldBegin(BUCKET_SEQ_TO_INSTANCE_IDX_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.I32, struct.bucket_seq_to_instance_idx.size()));
for (java.util.Map.Entry<java.lang.Integer, java.lang.Integer> _iter245 : struct.bucket_seq_to_instance_idx.entrySet())
{
oprot.writeI32(_iter245.getKey());
oprot.writeI32(_iter245.getValue());
}
oprot.writeMapEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.per_node_shared_scans != null) {
if (struct.isSetPerNodeSharedScans()) {
oprot.writeFieldBegin(PER_NODE_SHARED_SCANS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.BOOL, struct.per_node_shared_scans.size()));
for (java.util.Map.Entry<java.lang.Integer, java.lang.Boolean> _iter246 : struct.per_node_shared_scans.entrySet())
{
oprot.writeI32(_iter246.getKey());
oprot.writeBool(_iter246.getValue());
}
oprot.writeMapEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.isSetParallelInstances()) {
oprot.writeFieldBegin(PARALLEL_INSTANCES_FIELD_DESC);
oprot.writeI32(struct.parallel_instances);
oprot.writeFieldEnd();
}
if (struct.isSetTotalInstances()) {
oprot.writeFieldBegin(TOTAL_INSTANCES_FIELD_DESC);
oprot.writeI32(struct.total_instances);
oprot.writeFieldEnd();
}
if (struct.shuffle_idx_to_instance_idx != null) {
if (struct.isSetShuffleIdxToInstanceIdx()) {
oprot.writeFieldBegin(SHUFFLE_IDX_TO_INSTANCE_IDX_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.I32, struct.shuffle_idx_to_instance_idx.size()));
for (java.util.Map.Entry<java.lang.Integer, java.lang.Integer> _iter247 : struct.shuffle_idx_to_instance_idx.entrySet())
{
oprot.writeI32(_iter247.getKey());
oprot.writeI32(_iter247.getValue());
}
oprot.writeMapEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.isSetIsNereids()) {
oprot.writeFieldBegin(IS_NEREIDS_FIELD_DESC);
oprot.writeBool(struct.is_nereids);
oprot.writeFieldEnd();
}
if (struct.isSetWalId()) {
oprot.writeFieldBegin(WAL_ID_FIELD_DESC);
oprot.writeI64(struct.wal_id);
oprot.writeFieldEnd();
}
if (struct.isSetContentLength()) {
oprot.writeFieldBegin(CONTENT_LENGTH_FIELD_DESC);
oprot.writeI64(struct.content_length);
oprot.writeFieldEnd();
}
if (struct.current_connect_fe != null) {
if (struct.isSetCurrentConnectFe()) {
oprot.writeFieldBegin(CURRENT_CONNECT_FE_FIELD_DESC);
struct.current_connect_fe.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 _iter248 : struct.topn_filter_source_node_ids)
{
oprot.writeI32(_iter248);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.ai_resources != null) {
if (struct.isSetAiResources()) {
oprot.writeFieldBegin(AI_RESOURCES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.ai_resources.size()));
for (java.util.Map.Entry<java.lang.String, TAIResource> _iter249 : struct.ai_resources.entrySet())
{
oprot.writeString(_iter249.getKey());
_iter249.getValue().write(oprot);
}
oprot.writeMapEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.isSetNeedNotifyClose()) {
oprot.writeFieldBegin(NEED_NOTIFY_CLOSE_FIELD_DESC);
oprot.writeBool(struct.need_notify_close);
oprot.writeFieldEnd();
}
if (struct.isSetIsMowTable()) {
oprot.writeFieldBegin(IS_MOW_TABLE_FIELD_DESC);
oprot.writeBool(struct.is_mow_table);
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class TPipelineFragmentParamsTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TPipelineFragmentParamsTupleScheme getScheme() {
return new TPipelineFragmentParamsTupleScheme();
}
}
private static class TPipelineFragmentParamsTupleScheme extends org.apache.thrift.scheme.TupleScheme<TPipelineFragmentParams> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TPipelineFragmentParams struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
oprot.writeI32(struct.protocol_version.getValue());
struct.query_id.write(oprot);
{
oprot.writeI32(struct.per_exch_num_senders.size());
for (java.util.Map.Entry<java.lang.Integer, java.lang.Integer> _iter250 : struct.per_exch_num_senders.entrySet())
{
oprot.writeI32(_iter250.getKey());
oprot.writeI32(_iter250.getValue());
}
}
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetFragmentId()) {
optionals.set(0);
}
if (struct.isSetDescTbl()) {
optionals.set(1);
}
if (struct.isSetResourceInfo()) {
optionals.set(2);
}
if (struct.isSetDestinations()) {
optionals.set(3);
}
if (struct.isSetNumSenders()) {
optionals.set(4);
}
if (struct.isSetSendQueryStatisticsWithEveryBatch()) {
optionals.set(5);
}
if (struct.isSetCoord()) {
optionals.set(6);
}
if (struct.isSetQueryGlobals()) {
optionals.set(7);
}
if (struct.isSetQueryOptions()) {
optionals.set(8);
}
if (struct.isSetImportLabel()) {
optionals.set(9);
}
if (struct.isSetDbName()) {
optionals.set(10);
}
if (struct.isSetLoadJobId()) {
optionals.set(11);
}
if (struct.isSetLoadErrorHubInfo()) {
optionals.set(12);
}
if (struct.isSetFragmentNumOnHost()) {
optionals.set(13);
}
if (struct.isSetBackendId()) {
optionals.set(14);
}
if (struct.isSetNeedWaitExecutionTrigger()) {
optionals.set(15);
}
if (struct.isSetInstancesSharingHashTable()) {
optionals.set(16);
}
if (struct.isSetIsSimplifiedParam()) {
optionals.set(17);
}
if (struct.isSetGlobalDict()) {
optionals.set(18);
}
if (struct.isSetFragment()) {
optionals.set(19);
}
if (struct.isSetLocalParams()) {
optionals.set(20);
}
if (struct.isSetWorkloadGroups()) {
optionals.set(21);
}
if (struct.isSetTxnConf()) {
optionals.set(22);
}
if (struct.isSetTableName()) {
optionals.set(23);
}
if (struct.isSetFileScanParams()) {
optionals.set(24);
}
if (struct.isSetGroupCommit()) {
optionals.set(25);
}
if (struct.isSetLoadStreamPerNode()) {
optionals.set(26);
}
if (struct.isSetTotalLoadStreams()) {
optionals.set(27);
}
if (struct.isSetNumLocalSink()) {
optionals.set(28);
}
if (struct.isSetNumBuckets()) {
optionals.set(29);
}
if (struct.isSetBucketSeqToInstanceIdx()) {
optionals.set(30);
}
if (struct.isSetPerNodeSharedScans()) {
optionals.set(31);
}
if (struct.isSetParallelInstances()) {
optionals.set(32);
}
if (struct.isSetTotalInstances()) {
optionals.set(33);
}
if (struct.isSetShuffleIdxToInstanceIdx()) {
optionals.set(34);
}
if (struct.isSetIsNereids()) {
optionals.set(35);
}
if (struct.isSetWalId()) {
optionals.set(36);
}
if (struct.isSetContentLength()) {
optionals.set(37);
}
if (struct.isSetCurrentConnectFe()) {
optionals.set(38);
}
if (struct.isSetTopnFilterSourceNodeIds()) {
optionals.set(39);
}
if (struct.isSetAiResources()) {
optionals.set(40);
}
if (struct.isSetNeedNotifyClose()) {
optionals.set(41);
}
if (struct.isSetIsMowTable()) {
optionals.set(42);
}
oprot.writeBitSet(optionals, 43);
if (struct.isSetFragmentId()) {
oprot.writeI32(struct.fragment_id);
}
if (struct.isSetDescTbl()) {
struct.desc_tbl.write(oprot);
}
if (struct.isSetResourceInfo()) {
struct.resource_info.write(oprot);
}
if (struct.isSetDestinations()) {
{
oprot.writeI32(struct.destinations.size());
for (org.apache.doris.thrift.TPlanFragmentDestination _iter251 : struct.destinations)
{
_iter251.write(oprot);
}
}
}
if (struct.isSetNumSenders()) {
oprot.writeI32(struct.num_senders);
}
if (struct.isSetSendQueryStatisticsWithEveryBatch()) {
oprot.writeBool(struct.send_query_statistics_with_every_batch);
}
if (struct.isSetCoord()) {
struct.coord.write(oprot);
}
if (struct.isSetQueryGlobals()) {
struct.query_globals.write(oprot);
}
if (struct.isSetQueryOptions()) {
struct.query_options.write(oprot);
}
if (struct.isSetImportLabel()) {
oprot.writeString(struct.import_label);
}
if (struct.isSetDbName()) {
oprot.writeString(struct.db_name);
}
if (struct.isSetLoadJobId()) {
oprot.writeI64(struct.load_job_id);
}
if (struct.isSetLoadErrorHubInfo()) {
struct.load_error_hub_info.write(oprot);
}
if (struct.isSetFragmentNumOnHost()) {
oprot.writeI32(struct.fragment_num_on_host);
}
if (struct.isSetBackendId()) {
oprot.writeI64(struct.backend_id);
}
if (struct.isSetNeedWaitExecutionTrigger()) {
oprot.writeBool(struct.need_wait_execution_trigger);
}
if (struct.isSetInstancesSharingHashTable()) {
{
oprot.writeI32(struct.instances_sharing_hash_table.size());
for (org.apache.doris.thrift.TUniqueId _iter252 : struct.instances_sharing_hash_table)
{
_iter252.write(oprot);
}
}
}
if (struct.isSetIsSimplifiedParam()) {
oprot.writeBool(struct.is_simplified_param);
}
if (struct.isSetGlobalDict()) {
struct.global_dict.write(oprot);
}
if (struct.isSetFragment()) {
struct.fragment.write(oprot);
}
if (struct.isSetLocalParams()) {
{
oprot.writeI32(struct.local_params.size());
for (TPipelineInstanceParams _iter253 : struct.local_params)
{
_iter253.write(oprot);
}
}
}
if (struct.isSetWorkloadGroups()) {
{
oprot.writeI32(struct.workload_groups.size());
for (TPipelineWorkloadGroup _iter254 : struct.workload_groups)
{
_iter254.write(oprot);
}
}
}
if (struct.isSetTxnConf()) {
struct.txn_conf.write(oprot);
}
if (struct.isSetTableName()) {
oprot.writeString(struct.table_name);
}
if (struct.isSetFileScanParams()) {
{
oprot.writeI32(struct.file_scan_params.size());
for (java.util.Map.Entry<java.lang.Integer, org.apache.doris.thrift.TFileScanRangeParams> _iter255 : struct.file_scan_params.entrySet())
{
oprot.writeI32(_iter255.getKey());
_iter255.getValue().write(oprot);
}
}
}
if (struct.isSetGroupCommit()) {
oprot.writeBool(struct.group_commit);
}
if (struct.isSetLoadStreamPerNode()) {
oprot.writeI32(struct.load_stream_per_node);
}
if (struct.isSetTotalLoadStreams()) {
oprot.writeI32(struct.total_load_streams);
}
if (struct.isSetNumLocalSink()) {
oprot.writeI32(struct.num_local_sink);
}
if (struct.isSetNumBuckets()) {
oprot.writeI32(struct.num_buckets);
}
if (struct.isSetBucketSeqToInstanceIdx()) {
{
oprot.writeI32(struct.bucket_seq_to_instance_idx.size());
for (java.util.Map.Entry<java.lang.Integer, java.lang.Integer> _iter256 : struct.bucket_seq_to_instance_idx.entrySet())
{
oprot.writeI32(_iter256.getKey());
oprot.writeI32(_iter256.getValue());
}
}
}
if (struct.isSetPerNodeSharedScans()) {
{
oprot.writeI32(struct.per_node_shared_scans.size());
for (java.util.Map.Entry<java.lang.Integer, java.lang.Boolean> _iter257 : struct.per_node_shared_scans.entrySet())
{
oprot.writeI32(_iter257.getKey());
oprot.writeBool(_iter257.getValue());
}
}
}
if (struct.isSetParallelInstances()) {
oprot.writeI32(struct.parallel_instances);
}
if (struct.isSetTotalInstances()) {
oprot.writeI32(struct.total_instances);
}
if (struct.isSetShuffleIdxToInstanceIdx()) {
{
oprot.writeI32(struct.shuffle_idx_to_instance_idx.size());
for (java.util.Map.Entry<java.lang.Integer, java.lang.Integer> _iter258 : struct.shuffle_idx_to_instance_idx.entrySet())
{
oprot.writeI32(_iter258.getKey());
oprot.writeI32(_iter258.getValue());
}
}
}
if (struct.isSetIsNereids()) {
oprot.writeBool(struct.is_nereids);
}
if (struct.isSetWalId()) {
oprot.writeI64(struct.wal_id);
}
if (struct.isSetContentLength()) {
oprot.writeI64(struct.content_length);
}
if (struct.isSetCurrentConnectFe()) {
struct.current_connect_fe.write(oprot);
}
if (struct.isSetTopnFilterSourceNodeIds()) {
{
oprot.writeI32(struct.topn_filter_source_node_ids.size());
for (int _iter259 : struct.topn_filter_source_node_ids)
{
oprot.writeI32(_iter259);
}
}
}
if (struct.isSetAiResources()) {
{
oprot.writeI32(struct.ai_resources.size());
for (java.util.Map.Entry<java.lang.String, TAIResource> _iter260 : struct.ai_resources.entrySet())
{
oprot.writeString(_iter260.getKey());
_iter260.getValue().write(oprot);
}
}
}
if (struct.isSetNeedNotifyClose()) {
oprot.writeBool(struct.need_notify_close);
}
if (struct.isSetIsMowTable()) {
oprot.writeBool(struct.is_mow_table);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TPipelineFragmentParams 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.PaloInternalServiceVersion.findByValue(iprot.readI32());
struct.setProtocolVersionIsSet(true);
struct.query_id = new org.apache.doris.thrift.TUniqueId();
struct.query_id.read(iprot);
struct.setQueryIdIsSet(true);
{
org.apache.thrift.protocol.TMap _map261 = iprot.readMapBegin(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.I32);
struct.per_exch_num_senders = new java.util.HashMap<java.lang.Integer,java.lang.Integer>(2*_map261.size);
int _key262;
int _val263;
for (int _i264 = 0; _i264 < _map261.size; ++_i264)
{
_key262 = iprot.readI32();
_val263 = iprot.readI32();
struct.per_exch_num_senders.put(_key262, _val263);
}
}
struct.setPerExchNumSendersIsSet(true);
java.util.BitSet incoming = iprot.readBitSet(43);
if (incoming.get(0)) {
struct.fragment_id = iprot.readI32();
struct.setFragmentIdIsSet(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)) {
struct.resource_info = new org.apache.doris.thrift.TResourceInfo();
struct.resource_info.read(iprot);
struct.setResourceInfoIsSet(true);
}
if (incoming.get(3)) {
{
org.apache.thrift.protocol.TList _list265 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.destinations = new java.util.ArrayList<org.apache.doris.thrift.TPlanFragmentDestination>(_list265.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TPlanFragmentDestination _elem266;
for (int _i267 = 0; _i267 < _list265.size; ++_i267)
{
_elem266 = new org.apache.doris.thrift.TPlanFragmentDestination();
_elem266.read(iprot);
struct.destinations.add(_elem266);
}
}
struct.setDestinationsIsSet(true);
}
if (incoming.get(4)) {
struct.num_senders = iprot.readI32();
struct.setNumSendersIsSet(true);
}
if (incoming.get(5)) {
struct.send_query_statistics_with_every_batch = iprot.readBool();
struct.setSendQueryStatisticsWithEveryBatchIsSet(true);
}
if (incoming.get(6)) {
struct.coord = new org.apache.doris.thrift.TNetworkAddress();
struct.coord.read(iprot);
struct.setCoordIsSet(true);
}
if (incoming.get(7)) {
struct.query_globals = new TQueryGlobals();
struct.query_globals.read(iprot);
struct.setQueryGlobalsIsSet(true);
}
if (incoming.get(8)) {
struct.query_options = new TQueryOptions();
struct.query_options.read(iprot);
struct.setQueryOptionsIsSet(true);
}
if (incoming.get(9)) {
struct.import_label = iprot.readString();
struct.setImportLabelIsSet(true);
}
if (incoming.get(10)) {
struct.db_name = iprot.readString();
struct.setDbNameIsSet(true);
}
if (incoming.get(11)) {
struct.load_job_id = iprot.readI64();
struct.setLoadJobIdIsSet(true);
}
if (incoming.get(12)) {
struct.load_error_hub_info = new TLoadErrorHubInfo();
struct.load_error_hub_info.read(iprot);
struct.setLoadErrorHubInfoIsSet(true);
}
if (incoming.get(13)) {
struct.fragment_num_on_host = iprot.readI32();
struct.setFragmentNumOnHostIsSet(true);
}
if (incoming.get(14)) {
struct.backend_id = iprot.readI64();
struct.setBackendIdIsSet(true);
}
if (incoming.get(15)) {
struct.need_wait_execution_trigger = iprot.readBool();
struct.setNeedWaitExecutionTriggerIsSet(true);
}
if (incoming.get(16)) {
{
org.apache.thrift.protocol.TList _list268 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.instances_sharing_hash_table = new java.util.ArrayList<org.apache.doris.thrift.TUniqueId>(_list268.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TUniqueId _elem269;
for (int _i270 = 0; _i270 < _list268.size; ++_i270)
{
_elem269 = new org.apache.doris.thrift.TUniqueId();
_elem269.read(iprot);
struct.instances_sharing_hash_table.add(_elem269);
}
}
struct.setInstancesSharingHashTableIsSet(true);
}
if (incoming.get(17)) {
struct.is_simplified_param = iprot.readBool();
struct.setIsSimplifiedParamIsSet(true);
}
if (incoming.get(18)) {
struct.global_dict = new TGlobalDict();
struct.global_dict.read(iprot);
struct.setGlobalDictIsSet(true);
}
if (incoming.get(19)) {
struct.fragment = new org.apache.doris.thrift.TPlanFragment();
struct.fragment.read(iprot);
struct.setFragmentIsSet(true);
}
if (incoming.get(20)) {
{
org.apache.thrift.protocol.TList _list271 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.local_params = new java.util.ArrayList<TPipelineInstanceParams>(_list271.size);
@org.apache.thrift.annotation.Nullable TPipelineInstanceParams _elem272;
for (int _i273 = 0; _i273 < _list271.size; ++_i273)
{
_elem272 = new TPipelineInstanceParams();
_elem272.read(iprot);
struct.local_params.add(_elem272);
}
}
struct.setLocalParamsIsSet(true);
}
if (incoming.get(21)) {
{
org.apache.thrift.protocol.TList _list274 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.workload_groups = new java.util.ArrayList<TPipelineWorkloadGroup>(_list274.size);
@org.apache.thrift.annotation.Nullable TPipelineWorkloadGroup _elem275;
for (int _i276 = 0; _i276 < _list274.size; ++_i276)
{
_elem275 = new TPipelineWorkloadGroup();
_elem275.read(iprot);
struct.workload_groups.add(_elem275);
}
}
struct.setWorkloadGroupsIsSet(true);
}
if (incoming.get(22)) {
struct.txn_conf = new TTxnParams();
struct.txn_conf.read(iprot);
struct.setTxnConfIsSet(true);
}
if (incoming.get(23)) {
struct.table_name = iprot.readString();
struct.setTableNameIsSet(true);
}
if (incoming.get(24)) {
{
org.apache.thrift.protocol.TMap _map277 = 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*_map277.size);
int _key278;
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TFileScanRangeParams _val279;
for (int _i280 = 0; _i280 < _map277.size; ++_i280)
{
_key278 = iprot.readI32();
_val279 = new org.apache.doris.thrift.TFileScanRangeParams();
_val279.read(iprot);
struct.file_scan_params.put(_key278, _val279);
}
}
struct.setFileScanParamsIsSet(true);
}
if (incoming.get(25)) {
struct.group_commit = iprot.readBool();
struct.setGroupCommitIsSet(true);
}
if (incoming.get(26)) {
struct.load_stream_per_node = iprot.readI32();
struct.setLoadStreamPerNodeIsSet(true);
}
if (incoming.get(27)) {
struct.total_load_streams = iprot.readI32();
struct.setTotalLoadStreamsIsSet(true);
}
if (incoming.get(28)) {
struct.num_local_sink = iprot.readI32();
struct.setNumLocalSinkIsSet(true);
}
if (incoming.get(29)) {
struct.num_buckets = iprot.readI32();
struct.setNumBucketsIsSet(true);
}
if (incoming.get(30)) {
{
org.apache.thrift.protocol.TMap _map281 = iprot.readMapBegin(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.I32);
struct.bucket_seq_to_instance_idx = new java.util.HashMap<java.lang.Integer,java.lang.Integer>(2*_map281.size);
int _key282;
int _val283;
for (int _i284 = 0; _i284 < _map281.size; ++_i284)
{
_key282 = iprot.readI32();
_val283 = iprot.readI32();
struct.bucket_seq_to_instance_idx.put(_key282, _val283);
}
}
struct.setBucketSeqToInstanceIdxIsSet(true);
}
if (incoming.get(31)) {
{
org.apache.thrift.protocol.TMap _map285 = iprot.readMapBegin(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.BOOL);
struct.per_node_shared_scans = new java.util.HashMap<java.lang.Integer,java.lang.Boolean>(2*_map285.size);
int _key286;
boolean _val287;
for (int _i288 = 0; _i288 < _map285.size; ++_i288)
{
_key286 = iprot.readI32();
_val287 = iprot.readBool();
struct.per_node_shared_scans.put(_key286, _val287);
}
}
struct.setPerNodeSharedScansIsSet(true);
}
if (incoming.get(32)) {
struct.parallel_instances = iprot.readI32();
struct.setParallelInstancesIsSet(true);
}
if (incoming.get(33)) {
struct.total_instances = iprot.readI32();
struct.setTotalInstancesIsSet(true);
}
if (incoming.get(34)) {
{
org.apache.thrift.protocol.TMap _map289 = iprot.readMapBegin(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.I32);
struct.shuffle_idx_to_instance_idx = new java.util.HashMap<java.lang.Integer,java.lang.Integer>(2*_map289.size);
int _key290;
int _val291;
for (int _i292 = 0; _i292 < _map289.size; ++_i292)
{
_key290 = iprot.readI32();
_val291 = iprot.readI32();
struct.shuffle_idx_to_instance_idx.put(_key290, _val291);
}
}
struct.setShuffleIdxToInstanceIdxIsSet(true);
}
if (incoming.get(35)) {
struct.is_nereids = iprot.readBool();
struct.setIsNereidsIsSet(true);
}
if (incoming.get(36)) {
struct.wal_id = iprot.readI64();
struct.setWalIdIsSet(true);
}
if (incoming.get(37)) {
struct.content_length = iprot.readI64();
struct.setContentLengthIsSet(true);
}
if (incoming.get(38)) {
struct.current_connect_fe = new org.apache.doris.thrift.TNetworkAddress();
struct.current_connect_fe.read(iprot);
struct.setCurrentConnectFeIsSet(true);
}
if (incoming.get(39)) {
{
org.apache.thrift.protocol.TList _list293 = iprot.readListBegin(org.apache.thrift.protocol.TType.I32);
struct.topn_filter_source_node_ids = new java.util.ArrayList<java.lang.Integer>(_list293.size);
int _elem294;
for (int _i295 = 0; _i295 < _list293.size; ++_i295)
{
_elem294 = iprot.readI32();
struct.topn_filter_source_node_ids.add(_elem294);
}
}
struct.setTopnFilterSourceNodeIdsIsSet(true);
}
if (incoming.get(40)) {
{
org.apache.thrift.protocol.TMap _map296 = iprot.readMapBegin(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT);
struct.ai_resources = new java.util.HashMap<java.lang.String,TAIResource>(2*_map296.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key297;
@org.apache.thrift.annotation.Nullable TAIResource _val298;
for (int _i299 = 0; _i299 < _map296.size; ++_i299)
{
_key297 = iprot.readString();
_val298 = new TAIResource();
_val298.read(iprot);
struct.ai_resources.put(_key297, _val298);
}
}
struct.setAiResourcesIsSet(true);
}
if (incoming.get(41)) {
struct.need_notify_close = iprot.readBool();
struct.setNeedNotifyCloseIsSet(true);
}
if (incoming.get(42)) {
struct.is_mow_table = iprot.readBool();
struct.setIsMowTableIsSet(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();
}
}