TAnalyticNode.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 TAnalyticNode implements org.apache.thrift.TBase<TAnalyticNode, TAnalyticNode._Fields>, java.io.Serializable, Cloneable, Comparable<TAnalyticNode> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TAnalyticNode");
private static final org.apache.thrift.protocol.TField PARTITION_EXPRS_FIELD_DESC = new org.apache.thrift.protocol.TField("partition_exprs", org.apache.thrift.protocol.TType.LIST, (short)1);
private static final org.apache.thrift.protocol.TField ORDER_BY_EXPRS_FIELD_DESC = new org.apache.thrift.protocol.TField("order_by_exprs", org.apache.thrift.protocol.TType.LIST, (short)2);
private static final org.apache.thrift.protocol.TField ANALYTIC_FUNCTIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("analytic_functions", org.apache.thrift.protocol.TType.LIST, (short)3);
private static final org.apache.thrift.protocol.TField WINDOW_FIELD_DESC = new org.apache.thrift.protocol.TField("window", org.apache.thrift.protocol.TType.STRUCT, (short)4);
private static final org.apache.thrift.protocol.TField INTERMEDIATE_TUPLE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("intermediate_tuple_id", org.apache.thrift.protocol.TType.I32, (short)5);
private static final org.apache.thrift.protocol.TField OUTPUT_TUPLE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("output_tuple_id", org.apache.thrift.protocol.TType.I32, (short)6);
private static final org.apache.thrift.protocol.TField BUFFERED_TUPLE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("buffered_tuple_id", org.apache.thrift.protocol.TType.I32, (short)7);
private static final org.apache.thrift.protocol.TField PARTITION_BY_EQ_FIELD_DESC = new org.apache.thrift.protocol.TField("partition_by_eq", org.apache.thrift.protocol.TType.STRUCT, (short)8);
private static final org.apache.thrift.protocol.TField ORDER_BY_EQ_FIELD_DESC = new org.apache.thrift.protocol.TField("order_by_eq", org.apache.thrift.protocol.TType.STRUCT, (short)9);
private static final org.apache.thrift.protocol.TField IS_COLOCATE_FIELD_DESC = new org.apache.thrift.protocol.TField("is_colocate", org.apache.thrift.protocol.TType.BOOL, (short)10);
private static final org.apache.thrift.protocol.TField RANGE_BETWEEN_OFFSET_EXPRS_FIELD_DESC = new org.apache.thrift.protocol.TField("range_between_offset_exprs", org.apache.thrift.protocol.TType.LIST, (short)11);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TAnalyticNodeStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TAnalyticNodeTupleSchemeFactory();
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> partition_exprs; // required
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> order_by_exprs; // required
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> analytic_functions; // required
public @org.apache.thrift.annotation.Nullable TAnalyticWindow window; // optional
public int intermediate_tuple_id; // required
public int output_tuple_id; // required
public int buffered_tuple_id; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr partition_by_eq; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr order_by_eq; // optional
public boolean is_colocate; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> range_between_offset_exprs; // 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 {
PARTITION_EXPRS((short)1, "partition_exprs"),
ORDER_BY_EXPRS((short)2, "order_by_exprs"),
ANALYTIC_FUNCTIONS((short)3, "analytic_functions"),
WINDOW((short)4, "window"),
INTERMEDIATE_TUPLE_ID((short)5, "intermediate_tuple_id"),
OUTPUT_TUPLE_ID((short)6, "output_tuple_id"),
BUFFERED_TUPLE_ID((short)7, "buffered_tuple_id"),
PARTITION_BY_EQ((short)8, "partition_by_eq"),
ORDER_BY_EQ((short)9, "order_by_eq"),
IS_COLOCATE((short)10, "is_colocate"),
RANGE_BETWEEN_OFFSET_EXPRS((short)11, "range_between_offset_exprs");
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: // PARTITION_EXPRS
return PARTITION_EXPRS;
case 2: // ORDER_BY_EXPRS
return ORDER_BY_EXPRS;
case 3: // ANALYTIC_FUNCTIONS
return ANALYTIC_FUNCTIONS;
case 4: // WINDOW
return WINDOW;
case 5: // INTERMEDIATE_TUPLE_ID
return INTERMEDIATE_TUPLE_ID;
case 6: // OUTPUT_TUPLE_ID
return OUTPUT_TUPLE_ID;
case 7: // BUFFERED_TUPLE_ID
return BUFFERED_TUPLE_ID;
case 8: // PARTITION_BY_EQ
return PARTITION_BY_EQ;
case 9: // ORDER_BY_EQ
return ORDER_BY_EQ;
case 10: // IS_COLOCATE
return IS_COLOCATE;
case 11: // RANGE_BETWEEN_OFFSET_EXPRS
return RANGE_BETWEEN_OFFSET_EXPRS;
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 __INTERMEDIATE_TUPLE_ID_ISSET_ID = 0;
private static final int __OUTPUT_TUPLE_ID_ISSET_ID = 1;
private static final int __BUFFERED_TUPLE_ID_ISSET_ID = 2;
private static final int __IS_COLOCATE_ISSET_ID = 3;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.WINDOW,_Fields.BUFFERED_TUPLE_ID,_Fields.PARTITION_BY_EQ,_Fields.ORDER_BY_EQ,_Fields.IS_COLOCATE,_Fields.RANGE_BETWEEN_OFFSET_EXPRS};
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.PARTITION_EXPRS, new org.apache.thrift.meta_data.FieldMetaData("partition_exprs", org.apache.thrift.TFieldRequirementType.REQUIRED,
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.TExpr.class))));
tmpMap.put(_Fields.ORDER_BY_EXPRS, new org.apache.thrift.meta_data.FieldMetaData("order_by_exprs", org.apache.thrift.TFieldRequirementType.REQUIRED,
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.TExpr.class))));
tmpMap.put(_Fields.ANALYTIC_FUNCTIONS, new org.apache.thrift.meta_data.FieldMetaData("analytic_functions", org.apache.thrift.TFieldRequirementType.REQUIRED,
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.TExpr.class))));
tmpMap.put(_Fields.WINDOW, new org.apache.thrift.meta_data.FieldMetaData("window", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TAnalyticWindow.class)));
tmpMap.put(_Fields.INTERMEDIATE_TUPLE_ID, new org.apache.thrift.meta_data.FieldMetaData("intermediate_tuple_id", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32 , "TTupleId")));
tmpMap.put(_Fields.OUTPUT_TUPLE_ID, new org.apache.thrift.meta_data.FieldMetaData("output_tuple_id", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32 , "TTupleId")));
tmpMap.put(_Fields.BUFFERED_TUPLE_ID, new org.apache.thrift.meta_data.FieldMetaData("buffered_tuple_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32 , "TTupleId")));
tmpMap.put(_Fields.PARTITION_BY_EQ, new org.apache.thrift.meta_data.FieldMetaData("partition_by_eq", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TExpr.class)));
tmpMap.put(_Fields.ORDER_BY_EQ, new org.apache.thrift.meta_data.FieldMetaData("order_by_eq", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TExpr.class)));
tmpMap.put(_Fields.IS_COLOCATE, new org.apache.thrift.meta_data.FieldMetaData("is_colocate", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.RANGE_BETWEEN_OFFSET_EXPRS, new org.apache.thrift.meta_data.FieldMetaData("range_between_offset_exprs", 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.TExpr.class))));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TAnalyticNode.class, metaDataMap);
}
public TAnalyticNode() {
}
public TAnalyticNode(
java.util.List<org.apache.doris.thrift.TExpr> partition_exprs,
java.util.List<org.apache.doris.thrift.TExpr> order_by_exprs,
java.util.List<org.apache.doris.thrift.TExpr> analytic_functions,
int intermediate_tuple_id,
int output_tuple_id)
{
this();
this.partition_exprs = partition_exprs;
this.order_by_exprs = order_by_exprs;
this.analytic_functions = analytic_functions;
this.intermediate_tuple_id = intermediate_tuple_id;
setIntermediateTupleIdIsSet(true);
this.output_tuple_id = output_tuple_id;
setOutputTupleIdIsSet(true);
}
/**
* Performs a deep copy on <i>other</i>.
*/
public TAnalyticNode(TAnalyticNode other) {
__isset_bitfield = other.__isset_bitfield;
if (other.isSetPartitionExprs()) {
java.util.List<org.apache.doris.thrift.TExpr> __this__partition_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(other.partition_exprs.size());
for (org.apache.doris.thrift.TExpr other_element : other.partition_exprs) {
__this__partition_exprs.add(new org.apache.doris.thrift.TExpr(other_element));
}
this.partition_exprs = __this__partition_exprs;
}
if (other.isSetOrderByExprs()) {
java.util.List<org.apache.doris.thrift.TExpr> __this__order_by_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(other.order_by_exprs.size());
for (org.apache.doris.thrift.TExpr other_element : other.order_by_exprs) {
__this__order_by_exprs.add(new org.apache.doris.thrift.TExpr(other_element));
}
this.order_by_exprs = __this__order_by_exprs;
}
if (other.isSetAnalyticFunctions()) {
java.util.List<org.apache.doris.thrift.TExpr> __this__analytic_functions = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(other.analytic_functions.size());
for (org.apache.doris.thrift.TExpr other_element : other.analytic_functions) {
__this__analytic_functions.add(new org.apache.doris.thrift.TExpr(other_element));
}
this.analytic_functions = __this__analytic_functions;
}
if (other.isSetWindow()) {
this.window = new TAnalyticWindow(other.window);
}
this.intermediate_tuple_id = other.intermediate_tuple_id;
this.output_tuple_id = other.output_tuple_id;
this.buffered_tuple_id = other.buffered_tuple_id;
if (other.isSetPartitionByEq()) {
this.partition_by_eq = new org.apache.doris.thrift.TExpr(other.partition_by_eq);
}
if (other.isSetOrderByEq()) {
this.order_by_eq = new org.apache.doris.thrift.TExpr(other.order_by_eq);
}
this.is_colocate = other.is_colocate;
if (other.isSetRangeBetweenOffsetExprs()) {
java.util.List<org.apache.doris.thrift.TExpr> __this__range_between_offset_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(other.range_between_offset_exprs.size());
for (org.apache.doris.thrift.TExpr other_element : other.range_between_offset_exprs) {
__this__range_between_offset_exprs.add(new org.apache.doris.thrift.TExpr(other_element));
}
this.range_between_offset_exprs = __this__range_between_offset_exprs;
}
}
public TAnalyticNode deepCopy() {
return new TAnalyticNode(this);
}
@Override
public void clear() {
this.partition_exprs = null;
this.order_by_exprs = null;
this.analytic_functions = null;
this.window = null;
setIntermediateTupleIdIsSet(false);
this.intermediate_tuple_id = 0;
setOutputTupleIdIsSet(false);
this.output_tuple_id = 0;
setBufferedTupleIdIsSet(false);
this.buffered_tuple_id = 0;
this.partition_by_eq = null;
this.order_by_eq = null;
setIsColocateIsSet(false);
this.is_colocate = false;
this.range_between_offset_exprs = null;
}
public int getPartitionExprsSize() {
return (this.partition_exprs == null) ? 0 : this.partition_exprs.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TExpr> getPartitionExprsIterator() {
return (this.partition_exprs == null) ? null : this.partition_exprs.iterator();
}
public void addToPartitionExprs(org.apache.doris.thrift.TExpr elem) {
if (this.partition_exprs == null) {
this.partition_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>();
}
this.partition_exprs.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TExpr> getPartitionExprs() {
return this.partition_exprs;
}
public TAnalyticNode setPartitionExprs(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> partition_exprs) {
this.partition_exprs = partition_exprs;
return this;
}
public void unsetPartitionExprs() {
this.partition_exprs = null;
}
/** Returns true if field partition_exprs is set (has been assigned a value) and false otherwise */
public boolean isSetPartitionExprs() {
return this.partition_exprs != null;
}
public void setPartitionExprsIsSet(boolean value) {
if (!value) {
this.partition_exprs = null;
}
}
public int getOrderByExprsSize() {
return (this.order_by_exprs == null) ? 0 : this.order_by_exprs.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TExpr> getOrderByExprsIterator() {
return (this.order_by_exprs == null) ? null : this.order_by_exprs.iterator();
}
public void addToOrderByExprs(org.apache.doris.thrift.TExpr elem) {
if (this.order_by_exprs == null) {
this.order_by_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>();
}
this.order_by_exprs.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TExpr> getOrderByExprs() {
return this.order_by_exprs;
}
public TAnalyticNode setOrderByExprs(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> order_by_exprs) {
this.order_by_exprs = order_by_exprs;
return this;
}
public void unsetOrderByExprs() {
this.order_by_exprs = null;
}
/** Returns true if field order_by_exprs is set (has been assigned a value) and false otherwise */
public boolean isSetOrderByExprs() {
return this.order_by_exprs != null;
}
public void setOrderByExprsIsSet(boolean value) {
if (!value) {
this.order_by_exprs = null;
}
}
public int getAnalyticFunctionsSize() {
return (this.analytic_functions == null) ? 0 : this.analytic_functions.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TExpr> getAnalyticFunctionsIterator() {
return (this.analytic_functions == null) ? null : this.analytic_functions.iterator();
}
public void addToAnalyticFunctions(org.apache.doris.thrift.TExpr elem) {
if (this.analytic_functions == null) {
this.analytic_functions = new java.util.ArrayList<org.apache.doris.thrift.TExpr>();
}
this.analytic_functions.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TExpr> getAnalyticFunctions() {
return this.analytic_functions;
}
public TAnalyticNode setAnalyticFunctions(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> analytic_functions) {
this.analytic_functions = analytic_functions;
return this;
}
public void unsetAnalyticFunctions() {
this.analytic_functions = null;
}
/** Returns true if field analytic_functions is set (has been assigned a value) and false otherwise */
public boolean isSetAnalyticFunctions() {
return this.analytic_functions != null;
}
public void setAnalyticFunctionsIsSet(boolean value) {
if (!value) {
this.analytic_functions = null;
}
}
@org.apache.thrift.annotation.Nullable
public TAnalyticWindow getWindow() {
return this.window;
}
public TAnalyticNode setWindow(@org.apache.thrift.annotation.Nullable TAnalyticWindow window) {
this.window = window;
return this;
}
public void unsetWindow() {
this.window = null;
}
/** Returns true if field window is set (has been assigned a value) and false otherwise */
public boolean isSetWindow() {
return this.window != null;
}
public void setWindowIsSet(boolean value) {
if (!value) {
this.window = null;
}
}
public int getIntermediateTupleId() {
return this.intermediate_tuple_id;
}
public TAnalyticNode setIntermediateTupleId(int intermediate_tuple_id) {
this.intermediate_tuple_id = intermediate_tuple_id;
setIntermediateTupleIdIsSet(true);
return this;
}
public void unsetIntermediateTupleId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __INTERMEDIATE_TUPLE_ID_ISSET_ID);
}
/** Returns true if field intermediate_tuple_id is set (has been assigned a value) and false otherwise */
public boolean isSetIntermediateTupleId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __INTERMEDIATE_TUPLE_ID_ISSET_ID);
}
public void setIntermediateTupleIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __INTERMEDIATE_TUPLE_ID_ISSET_ID, value);
}
public int getOutputTupleId() {
return this.output_tuple_id;
}
public TAnalyticNode setOutputTupleId(int output_tuple_id) {
this.output_tuple_id = output_tuple_id;
setOutputTupleIdIsSet(true);
return this;
}
public void unsetOutputTupleId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __OUTPUT_TUPLE_ID_ISSET_ID);
}
/** Returns true if field output_tuple_id is set (has been assigned a value) and false otherwise */
public boolean isSetOutputTupleId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __OUTPUT_TUPLE_ID_ISSET_ID);
}
public void setOutputTupleIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __OUTPUT_TUPLE_ID_ISSET_ID, value);
}
public int getBufferedTupleId() {
return this.buffered_tuple_id;
}
public TAnalyticNode setBufferedTupleId(int buffered_tuple_id) {
this.buffered_tuple_id = buffered_tuple_id;
setBufferedTupleIdIsSet(true);
return this;
}
public void unsetBufferedTupleId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __BUFFERED_TUPLE_ID_ISSET_ID);
}
/** Returns true if field buffered_tuple_id is set (has been assigned a value) and false otherwise */
public boolean isSetBufferedTupleId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __BUFFERED_TUPLE_ID_ISSET_ID);
}
public void setBufferedTupleIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __BUFFERED_TUPLE_ID_ISSET_ID, value);
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TExpr getPartitionByEq() {
return this.partition_by_eq;
}
public TAnalyticNode setPartitionByEq(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr partition_by_eq) {
this.partition_by_eq = partition_by_eq;
return this;
}
public void unsetPartitionByEq() {
this.partition_by_eq = null;
}
/** Returns true if field partition_by_eq is set (has been assigned a value) and false otherwise */
public boolean isSetPartitionByEq() {
return this.partition_by_eq != null;
}
public void setPartitionByEqIsSet(boolean value) {
if (!value) {
this.partition_by_eq = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TExpr getOrderByEq() {
return this.order_by_eq;
}
public TAnalyticNode setOrderByEq(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr order_by_eq) {
this.order_by_eq = order_by_eq;
return this;
}
public void unsetOrderByEq() {
this.order_by_eq = null;
}
/** Returns true if field order_by_eq is set (has been assigned a value) and false otherwise */
public boolean isSetOrderByEq() {
return this.order_by_eq != null;
}
public void setOrderByEqIsSet(boolean value) {
if (!value) {
this.order_by_eq = null;
}
}
public boolean isIsColocate() {
return this.is_colocate;
}
public TAnalyticNode setIsColocate(boolean is_colocate) {
this.is_colocate = is_colocate;
setIsColocateIsSet(true);
return this;
}
public void unsetIsColocate() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __IS_COLOCATE_ISSET_ID);
}
/** Returns true if field is_colocate is set (has been assigned a value) and false otherwise */
public boolean isSetIsColocate() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __IS_COLOCATE_ISSET_ID);
}
public void setIsColocateIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __IS_COLOCATE_ISSET_ID, value);
}
public int getRangeBetweenOffsetExprsSize() {
return (this.range_between_offset_exprs == null) ? 0 : this.range_between_offset_exprs.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TExpr> getRangeBetweenOffsetExprsIterator() {
return (this.range_between_offset_exprs == null) ? null : this.range_between_offset_exprs.iterator();
}
public void addToRangeBetweenOffsetExprs(org.apache.doris.thrift.TExpr elem) {
if (this.range_between_offset_exprs == null) {
this.range_between_offset_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>();
}
this.range_between_offset_exprs.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TExpr> getRangeBetweenOffsetExprs() {
return this.range_between_offset_exprs;
}
public TAnalyticNode setRangeBetweenOffsetExprs(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> range_between_offset_exprs) {
this.range_between_offset_exprs = range_between_offset_exprs;
return this;
}
public void unsetRangeBetweenOffsetExprs() {
this.range_between_offset_exprs = null;
}
/** Returns true if field range_between_offset_exprs is set (has been assigned a value) and false otherwise */
public boolean isSetRangeBetweenOffsetExprs() {
return this.range_between_offset_exprs != null;
}
public void setRangeBetweenOffsetExprsIsSet(boolean value) {
if (!value) {
this.range_between_offset_exprs = null;
}
}
public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case PARTITION_EXPRS:
if (value == null) {
unsetPartitionExprs();
} else {
setPartitionExprs((java.util.List<org.apache.doris.thrift.TExpr>)value);
}
break;
case ORDER_BY_EXPRS:
if (value == null) {
unsetOrderByExprs();
} else {
setOrderByExprs((java.util.List<org.apache.doris.thrift.TExpr>)value);
}
break;
case ANALYTIC_FUNCTIONS:
if (value == null) {
unsetAnalyticFunctions();
} else {
setAnalyticFunctions((java.util.List<org.apache.doris.thrift.TExpr>)value);
}
break;
case WINDOW:
if (value == null) {
unsetWindow();
} else {
setWindow((TAnalyticWindow)value);
}
break;
case INTERMEDIATE_TUPLE_ID:
if (value == null) {
unsetIntermediateTupleId();
} else {
setIntermediateTupleId((java.lang.Integer)value);
}
break;
case OUTPUT_TUPLE_ID:
if (value == null) {
unsetOutputTupleId();
} else {
setOutputTupleId((java.lang.Integer)value);
}
break;
case BUFFERED_TUPLE_ID:
if (value == null) {
unsetBufferedTupleId();
} else {
setBufferedTupleId((java.lang.Integer)value);
}
break;
case PARTITION_BY_EQ:
if (value == null) {
unsetPartitionByEq();
} else {
setPartitionByEq((org.apache.doris.thrift.TExpr)value);
}
break;
case ORDER_BY_EQ:
if (value == null) {
unsetOrderByEq();
} else {
setOrderByEq((org.apache.doris.thrift.TExpr)value);
}
break;
case IS_COLOCATE:
if (value == null) {
unsetIsColocate();
} else {
setIsColocate((java.lang.Boolean)value);
}
break;
case RANGE_BETWEEN_OFFSET_EXPRS:
if (value == null) {
unsetRangeBetweenOffsetExprs();
} else {
setRangeBetweenOffsetExprs((java.util.List<org.apache.doris.thrift.TExpr>)value);
}
break;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case PARTITION_EXPRS:
return getPartitionExprs();
case ORDER_BY_EXPRS:
return getOrderByExprs();
case ANALYTIC_FUNCTIONS:
return getAnalyticFunctions();
case WINDOW:
return getWindow();
case INTERMEDIATE_TUPLE_ID:
return getIntermediateTupleId();
case OUTPUT_TUPLE_ID:
return getOutputTupleId();
case BUFFERED_TUPLE_ID:
return getBufferedTupleId();
case PARTITION_BY_EQ:
return getPartitionByEq();
case ORDER_BY_EQ:
return getOrderByEq();
case IS_COLOCATE:
return isIsColocate();
case RANGE_BETWEEN_OFFSET_EXPRS:
return getRangeBetweenOffsetExprs();
}
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 PARTITION_EXPRS:
return isSetPartitionExprs();
case ORDER_BY_EXPRS:
return isSetOrderByExprs();
case ANALYTIC_FUNCTIONS:
return isSetAnalyticFunctions();
case WINDOW:
return isSetWindow();
case INTERMEDIATE_TUPLE_ID:
return isSetIntermediateTupleId();
case OUTPUT_TUPLE_ID:
return isSetOutputTupleId();
case BUFFERED_TUPLE_ID:
return isSetBufferedTupleId();
case PARTITION_BY_EQ:
return isSetPartitionByEq();
case ORDER_BY_EQ:
return isSetOrderByEq();
case IS_COLOCATE:
return isSetIsColocate();
case RANGE_BETWEEN_OFFSET_EXPRS:
return isSetRangeBetweenOffsetExprs();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof TAnalyticNode)
return this.equals((TAnalyticNode)that);
return false;
}
public boolean equals(TAnalyticNode that) {
if (that == null)
return false;
if (this == that)
return true;
boolean this_present_partition_exprs = true && this.isSetPartitionExprs();
boolean that_present_partition_exprs = true && that.isSetPartitionExprs();
if (this_present_partition_exprs || that_present_partition_exprs) {
if (!(this_present_partition_exprs && that_present_partition_exprs))
return false;
if (!this.partition_exprs.equals(that.partition_exprs))
return false;
}
boolean this_present_order_by_exprs = true && this.isSetOrderByExprs();
boolean that_present_order_by_exprs = true && that.isSetOrderByExprs();
if (this_present_order_by_exprs || that_present_order_by_exprs) {
if (!(this_present_order_by_exprs && that_present_order_by_exprs))
return false;
if (!this.order_by_exprs.equals(that.order_by_exprs))
return false;
}
boolean this_present_analytic_functions = true && this.isSetAnalyticFunctions();
boolean that_present_analytic_functions = true && that.isSetAnalyticFunctions();
if (this_present_analytic_functions || that_present_analytic_functions) {
if (!(this_present_analytic_functions && that_present_analytic_functions))
return false;
if (!this.analytic_functions.equals(that.analytic_functions))
return false;
}
boolean this_present_window = true && this.isSetWindow();
boolean that_present_window = true && that.isSetWindow();
if (this_present_window || that_present_window) {
if (!(this_present_window && that_present_window))
return false;
if (!this.window.equals(that.window))
return false;
}
boolean this_present_intermediate_tuple_id = true;
boolean that_present_intermediate_tuple_id = true;
if (this_present_intermediate_tuple_id || that_present_intermediate_tuple_id) {
if (!(this_present_intermediate_tuple_id && that_present_intermediate_tuple_id))
return false;
if (this.intermediate_tuple_id != that.intermediate_tuple_id)
return false;
}
boolean this_present_output_tuple_id = true;
boolean that_present_output_tuple_id = true;
if (this_present_output_tuple_id || that_present_output_tuple_id) {
if (!(this_present_output_tuple_id && that_present_output_tuple_id))
return false;
if (this.output_tuple_id != that.output_tuple_id)
return false;
}
boolean this_present_buffered_tuple_id = true && this.isSetBufferedTupleId();
boolean that_present_buffered_tuple_id = true && that.isSetBufferedTupleId();
if (this_present_buffered_tuple_id || that_present_buffered_tuple_id) {
if (!(this_present_buffered_tuple_id && that_present_buffered_tuple_id))
return false;
if (this.buffered_tuple_id != that.buffered_tuple_id)
return false;
}
boolean this_present_partition_by_eq = true && this.isSetPartitionByEq();
boolean that_present_partition_by_eq = true && that.isSetPartitionByEq();
if (this_present_partition_by_eq || that_present_partition_by_eq) {
if (!(this_present_partition_by_eq && that_present_partition_by_eq))
return false;
if (!this.partition_by_eq.equals(that.partition_by_eq))
return false;
}
boolean this_present_order_by_eq = true && this.isSetOrderByEq();
boolean that_present_order_by_eq = true && that.isSetOrderByEq();
if (this_present_order_by_eq || that_present_order_by_eq) {
if (!(this_present_order_by_eq && that_present_order_by_eq))
return false;
if (!this.order_by_eq.equals(that.order_by_eq))
return false;
}
boolean this_present_is_colocate = true && this.isSetIsColocate();
boolean that_present_is_colocate = true && that.isSetIsColocate();
if (this_present_is_colocate || that_present_is_colocate) {
if (!(this_present_is_colocate && that_present_is_colocate))
return false;
if (this.is_colocate != that.is_colocate)
return false;
}
boolean this_present_range_between_offset_exprs = true && this.isSetRangeBetweenOffsetExprs();
boolean that_present_range_between_offset_exprs = true && that.isSetRangeBetweenOffsetExprs();
if (this_present_range_between_offset_exprs || that_present_range_between_offset_exprs) {
if (!(this_present_range_between_offset_exprs && that_present_range_between_offset_exprs))
return false;
if (!this.range_between_offset_exprs.equals(that.range_between_offset_exprs))
return false;
}
return true;
}
@Override
public int hashCode() {
int hashCode = 1;
hashCode = hashCode * 8191 + ((isSetPartitionExprs()) ? 131071 : 524287);
if (isSetPartitionExprs())
hashCode = hashCode * 8191 + partition_exprs.hashCode();
hashCode = hashCode * 8191 + ((isSetOrderByExprs()) ? 131071 : 524287);
if (isSetOrderByExprs())
hashCode = hashCode * 8191 + order_by_exprs.hashCode();
hashCode = hashCode * 8191 + ((isSetAnalyticFunctions()) ? 131071 : 524287);
if (isSetAnalyticFunctions())
hashCode = hashCode * 8191 + analytic_functions.hashCode();
hashCode = hashCode * 8191 + ((isSetWindow()) ? 131071 : 524287);
if (isSetWindow())
hashCode = hashCode * 8191 + window.hashCode();
hashCode = hashCode * 8191 + intermediate_tuple_id;
hashCode = hashCode * 8191 + output_tuple_id;
hashCode = hashCode * 8191 + ((isSetBufferedTupleId()) ? 131071 : 524287);
if (isSetBufferedTupleId())
hashCode = hashCode * 8191 + buffered_tuple_id;
hashCode = hashCode * 8191 + ((isSetPartitionByEq()) ? 131071 : 524287);
if (isSetPartitionByEq())
hashCode = hashCode * 8191 + partition_by_eq.hashCode();
hashCode = hashCode * 8191 + ((isSetOrderByEq()) ? 131071 : 524287);
if (isSetOrderByEq())
hashCode = hashCode * 8191 + order_by_eq.hashCode();
hashCode = hashCode * 8191 + ((isSetIsColocate()) ? 131071 : 524287);
if (isSetIsColocate())
hashCode = hashCode * 8191 + ((is_colocate) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetRangeBetweenOffsetExprs()) ? 131071 : 524287);
if (isSetRangeBetweenOffsetExprs())
hashCode = hashCode * 8191 + range_between_offset_exprs.hashCode();
return hashCode;
}
@Override
public int compareTo(TAnalyticNode other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = java.lang.Boolean.compare(isSetPartitionExprs(), other.isSetPartitionExprs());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPartitionExprs()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partition_exprs, other.partition_exprs);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetOrderByExprs(), other.isSetOrderByExprs());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOrderByExprs()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.order_by_exprs, other.order_by_exprs);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetAnalyticFunctions(), other.isSetAnalyticFunctions());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetAnalyticFunctions()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.analytic_functions, other.analytic_functions);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetWindow(), other.isSetWindow());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetWindow()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.window, other.window);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetIntermediateTupleId(), other.isSetIntermediateTupleId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetIntermediateTupleId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.intermediate_tuple_id, other.intermediate_tuple_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetOutputTupleId(), other.isSetOutputTupleId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOutputTupleId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.output_tuple_id, other.output_tuple_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetBufferedTupleId(), other.isSetBufferedTupleId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetBufferedTupleId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.buffered_tuple_id, other.buffered_tuple_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetPartitionByEq(), other.isSetPartitionByEq());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPartitionByEq()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partition_by_eq, other.partition_by_eq);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetOrderByEq(), other.isSetOrderByEq());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOrderByEq()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.order_by_eq, other.order_by_eq);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetIsColocate(), other.isSetIsColocate());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetIsColocate()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.is_colocate, other.is_colocate);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetRangeBetweenOffsetExprs(), other.isSetRangeBetweenOffsetExprs());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetRangeBetweenOffsetExprs()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.range_between_offset_exprs, other.range_between_offset_exprs);
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("TAnalyticNode(");
boolean first = true;
sb.append("partition_exprs:");
if (this.partition_exprs == null) {
sb.append("null");
} else {
sb.append(this.partition_exprs);
}
first = false;
if (!first) sb.append(", ");
sb.append("order_by_exprs:");
if (this.order_by_exprs == null) {
sb.append("null");
} else {
sb.append(this.order_by_exprs);
}
first = false;
if (!first) sb.append(", ");
sb.append("analytic_functions:");
if (this.analytic_functions == null) {
sb.append("null");
} else {
sb.append(this.analytic_functions);
}
first = false;
if (isSetWindow()) {
if (!first) sb.append(", ");
sb.append("window:");
if (this.window == null) {
sb.append("null");
} else {
sb.append(this.window);
}
first = false;
}
if (!first) sb.append(", ");
sb.append("intermediate_tuple_id:");
sb.append(this.intermediate_tuple_id);
first = false;
if (!first) sb.append(", ");
sb.append("output_tuple_id:");
sb.append(this.output_tuple_id);
first = false;
if (isSetBufferedTupleId()) {
if (!first) sb.append(", ");
sb.append("buffered_tuple_id:");
sb.append(this.buffered_tuple_id);
first = false;
}
if (isSetPartitionByEq()) {
if (!first) sb.append(", ");
sb.append("partition_by_eq:");
if (this.partition_by_eq == null) {
sb.append("null");
} else {
sb.append(this.partition_by_eq);
}
first = false;
}
if (isSetOrderByEq()) {
if (!first) sb.append(", ");
sb.append("order_by_eq:");
if (this.order_by_eq == null) {
sb.append("null");
} else {
sb.append(this.order_by_eq);
}
first = false;
}
if (isSetIsColocate()) {
if (!first) sb.append(", ");
sb.append("is_colocate:");
sb.append(this.is_colocate);
first = false;
}
if (isSetRangeBetweenOffsetExprs()) {
if (!first) sb.append(", ");
sb.append("range_between_offset_exprs:");
if (this.range_between_offset_exprs == null) {
sb.append("null");
} else {
sb.append(this.range_between_offset_exprs);
}
first = false;
}
sb.append(")");
return sb.toString();
}
public void validate() throws org.apache.thrift.TException {
// check for required fields
if (partition_exprs == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'partition_exprs' was not present! Struct: " + toString());
}
if (order_by_exprs == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'order_by_exprs' was not present! Struct: " + toString());
}
if (analytic_functions == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'analytic_functions' was not present! Struct: " + toString());
}
// alas, we cannot check 'intermediate_tuple_id' because it's a primitive and you chose the non-beans generator.
// alas, we cannot check 'output_tuple_id' because it's a primitive and you chose the non-beans generator.
// check for sub-struct validity
if (window != null) {
window.validate();
}
if (partition_by_eq != null) {
partition_by_eq.validate();
}
if (order_by_eq != null) {
order_by_eq.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 TAnalyticNodeStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TAnalyticNodeStandardScheme getScheme() {
return new TAnalyticNodeStandardScheme();
}
}
private static class TAnalyticNodeStandardScheme extends org.apache.thrift.scheme.StandardScheme<TAnalyticNode> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TAnalyticNode 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: // PARTITION_EXPRS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list946 = iprot.readListBegin();
struct.partition_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list946.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem947;
for (int _i948 = 0; _i948 < _list946.size; ++_i948)
{
_elem947 = new org.apache.doris.thrift.TExpr();
_elem947.read(iprot);
struct.partition_exprs.add(_elem947);
}
iprot.readListEnd();
}
struct.setPartitionExprsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // ORDER_BY_EXPRS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list949 = iprot.readListBegin();
struct.order_by_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list949.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem950;
for (int _i951 = 0; _i951 < _list949.size; ++_i951)
{
_elem950 = new org.apache.doris.thrift.TExpr();
_elem950.read(iprot);
struct.order_by_exprs.add(_elem950);
}
iprot.readListEnd();
}
struct.setOrderByExprsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // ANALYTIC_FUNCTIONS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list952 = iprot.readListBegin();
struct.analytic_functions = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list952.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem953;
for (int _i954 = 0; _i954 < _list952.size; ++_i954)
{
_elem953 = new org.apache.doris.thrift.TExpr();
_elem953.read(iprot);
struct.analytic_functions.add(_elem953);
}
iprot.readListEnd();
}
struct.setAnalyticFunctionsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // WINDOW
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.window = new TAnalyticWindow();
struct.window.read(iprot);
struct.setWindowIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // INTERMEDIATE_TUPLE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.intermediate_tuple_id = iprot.readI32();
struct.setIntermediateTupleIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // OUTPUT_TUPLE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.output_tuple_id = iprot.readI32();
struct.setOutputTupleIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // BUFFERED_TUPLE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.buffered_tuple_id = iprot.readI32();
struct.setBufferedTupleIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // PARTITION_BY_EQ
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.partition_by_eq = new org.apache.doris.thrift.TExpr();
struct.partition_by_eq.read(iprot);
struct.setPartitionByEqIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // ORDER_BY_EQ
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.order_by_eq = new org.apache.doris.thrift.TExpr();
struct.order_by_eq.read(iprot);
struct.setOrderByEqIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 10: // IS_COLOCATE
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.is_colocate = iprot.readBool();
struct.setIsColocateIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 11: // RANGE_BETWEEN_OFFSET_EXPRS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list955 = iprot.readListBegin();
struct.range_between_offset_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list955.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem956;
for (int _i957 = 0; _i957 < _list955.size; ++_i957)
{
_elem956 = new org.apache.doris.thrift.TExpr();
_elem956.read(iprot);
struct.range_between_offset_exprs.add(_elem956);
}
iprot.readListEnd();
}
struct.setRangeBetweenOffsetExprsIsSet(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
if (!struct.isSetIntermediateTupleId()) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'intermediate_tuple_id' was not found in serialized data! Struct: " + toString());
}
if (!struct.isSetOutputTupleId()) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'output_tuple_id' was not found in serialized data! Struct: " + toString());
}
struct.validate();
}
public void write(org.apache.thrift.protocol.TProtocol oprot, TAnalyticNode struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.partition_exprs != null) {
oprot.writeFieldBegin(PARTITION_EXPRS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.partition_exprs.size()));
for (org.apache.doris.thrift.TExpr _iter958 : struct.partition_exprs)
{
_iter958.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
if (struct.order_by_exprs != null) {
oprot.writeFieldBegin(ORDER_BY_EXPRS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.order_by_exprs.size()));
for (org.apache.doris.thrift.TExpr _iter959 : struct.order_by_exprs)
{
_iter959.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
if (struct.analytic_functions != null) {
oprot.writeFieldBegin(ANALYTIC_FUNCTIONS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.analytic_functions.size()));
for (org.apache.doris.thrift.TExpr _iter960 : struct.analytic_functions)
{
_iter960.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
if (struct.window != null) {
if (struct.isSetWindow()) {
oprot.writeFieldBegin(WINDOW_FIELD_DESC);
struct.window.write(oprot);
oprot.writeFieldEnd();
}
}
oprot.writeFieldBegin(INTERMEDIATE_TUPLE_ID_FIELD_DESC);
oprot.writeI32(struct.intermediate_tuple_id);
oprot.writeFieldEnd();
oprot.writeFieldBegin(OUTPUT_TUPLE_ID_FIELD_DESC);
oprot.writeI32(struct.output_tuple_id);
oprot.writeFieldEnd();
if (struct.isSetBufferedTupleId()) {
oprot.writeFieldBegin(BUFFERED_TUPLE_ID_FIELD_DESC);
oprot.writeI32(struct.buffered_tuple_id);
oprot.writeFieldEnd();
}
if (struct.partition_by_eq != null) {
if (struct.isSetPartitionByEq()) {
oprot.writeFieldBegin(PARTITION_BY_EQ_FIELD_DESC);
struct.partition_by_eq.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.order_by_eq != null) {
if (struct.isSetOrderByEq()) {
oprot.writeFieldBegin(ORDER_BY_EQ_FIELD_DESC);
struct.order_by_eq.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.isSetIsColocate()) {
oprot.writeFieldBegin(IS_COLOCATE_FIELD_DESC);
oprot.writeBool(struct.is_colocate);
oprot.writeFieldEnd();
}
if (struct.range_between_offset_exprs != null) {
if (struct.isSetRangeBetweenOffsetExprs()) {
oprot.writeFieldBegin(RANGE_BETWEEN_OFFSET_EXPRS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.range_between_offset_exprs.size()));
for (org.apache.doris.thrift.TExpr _iter961 : struct.range_between_offset_exprs)
{
_iter961.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class TAnalyticNodeTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TAnalyticNodeTupleScheme getScheme() {
return new TAnalyticNodeTupleScheme();
}
}
private static class TAnalyticNodeTupleScheme extends org.apache.thrift.scheme.TupleScheme<TAnalyticNode> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TAnalyticNode struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
{
oprot.writeI32(struct.partition_exprs.size());
for (org.apache.doris.thrift.TExpr _iter962 : struct.partition_exprs)
{
_iter962.write(oprot);
}
}
{
oprot.writeI32(struct.order_by_exprs.size());
for (org.apache.doris.thrift.TExpr _iter963 : struct.order_by_exprs)
{
_iter963.write(oprot);
}
}
{
oprot.writeI32(struct.analytic_functions.size());
for (org.apache.doris.thrift.TExpr _iter964 : struct.analytic_functions)
{
_iter964.write(oprot);
}
}
oprot.writeI32(struct.intermediate_tuple_id);
oprot.writeI32(struct.output_tuple_id);
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetWindow()) {
optionals.set(0);
}
if (struct.isSetBufferedTupleId()) {
optionals.set(1);
}
if (struct.isSetPartitionByEq()) {
optionals.set(2);
}
if (struct.isSetOrderByEq()) {
optionals.set(3);
}
if (struct.isSetIsColocate()) {
optionals.set(4);
}
if (struct.isSetRangeBetweenOffsetExprs()) {
optionals.set(5);
}
oprot.writeBitSet(optionals, 6);
if (struct.isSetWindow()) {
struct.window.write(oprot);
}
if (struct.isSetBufferedTupleId()) {
oprot.writeI32(struct.buffered_tuple_id);
}
if (struct.isSetPartitionByEq()) {
struct.partition_by_eq.write(oprot);
}
if (struct.isSetOrderByEq()) {
struct.order_by_eq.write(oprot);
}
if (struct.isSetIsColocate()) {
oprot.writeBool(struct.is_colocate);
}
if (struct.isSetRangeBetweenOffsetExprs()) {
{
oprot.writeI32(struct.range_between_offset_exprs.size());
for (org.apache.doris.thrift.TExpr _iter965 : struct.range_between_offset_exprs)
{
_iter965.write(oprot);
}
}
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TAnalyticNode struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
{
org.apache.thrift.protocol.TList _list966 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.partition_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list966.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem967;
for (int _i968 = 0; _i968 < _list966.size; ++_i968)
{
_elem967 = new org.apache.doris.thrift.TExpr();
_elem967.read(iprot);
struct.partition_exprs.add(_elem967);
}
}
struct.setPartitionExprsIsSet(true);
{
org.apache.thrift.protocol.TList _list969 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.order_by_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list969.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem970;
for (int _i971 = 0; _i971 < _list969.size; ++_i971)
{
_elem970 = new org.apache.doris.thrift.TExpr();
_elem970.read(iprot);
struct.order_by_exprs.add(_elem970);
}
}
struct.setOrderByExprsIsSet(true);
{
org.apache.thrift.protocol.TList _list972 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.analytic_functions = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list972.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem973;
for (int _i974 = 0; _i974 < _list972.size; ++_i974)
{
_elem973 = new org.apache.doris.thrift.TExpr();
_elem973.read(iprot);
struct.analytic_functions.add(_elem973);
}
}
struct.setAnalyticFunctionsIsSet(true);
struct.intermediate_tuple_id = iprot.readI32();
struct.setIntermediateTupleIdIsSet(true);
struct.output_tuple_id = iprot.readI32();
struct.setOutputTupleIdIsSet(true);
java.util.BitSet incoming = iprot.readBitSet(6);
if (incoming.get(0)) {
struct.window = new TAnalyticWindow();
struct.window.read(iprot);
struct.setWindowIsSet(true);
}
if (incoming.get(1)) {
struct.buffered_tuple_id = iprot.readI32();
struct.setBufferedTupleIdIsSet(true);
}
if (incoming.get(2)) {
struct.partition_by_eq = new org.apache.doris.thrift.TExpr();
struct.partition_by_eq.read(iprot);
struct.setPartitionByEqIsSet(true);
}
if (incoming.get(3)) {
struct.order_by_eq = new org.apache.doris.thrift.TExpr();
struct.order_by_eq.read(iprot);
struct.setOrderByEqIsSet(true);
}
if (incoming.get(4)) {
struct.is_colocate = iprot.readBool();
struct.setIsColocateIsSet(true);
}
if (incoming.get(5)) {
{
org.apache.thrift.protocol.TList _list975 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.range_between_offset_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list975.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem976;
for (int _i977 = 0; _i977 < _list975.size; ++_i977)
{
_elem976 = new org.apache.doris.thrift.TExpr();
_elem976.read(iprot);
struct.range_between_offset_exprs.add(_elem976);
}
}
struct.setRangeBetweenOffsetExprsIsSet(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();
}
}