TSortNode.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 TSortNode implements org.apache.thrift.TBase<TSortNode, TSortNode._Fields>, java.io.Serializable, Cloneable, Comparable<TSortNode> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TSortNode");
private static final org.apache.thrift.protocol.TField SORT_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("sort_info", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final org.apache.thrift.protocol.TField USE_TOP_N_FIELD_DESC = new org.apache.thrift.protocol.TField("use_top_n", org.apache.thrift.protocol.TType.BOOL, (short)2);
private static final org.apache.thrift.protocol.TField OFFSET_FIELD_DESC = new org.apache.thrift.protocol.TField("offset", org.apache.thrift.protocol.TType.I64, (short)3);
private static final org.apache.thrift.protocol.TField IS_DEFAULT_LIMIT_FIELD_DESC = new org.apache.thrift.protocol.TField("is_default_limit", org.apache.thrift.protocol.TType.BOOL, (short)6);
private static final org.apache.thrift.protocol.TField USE_TOPN_OPT_FIELD_DESC = new org.apache.thrift.protocol.TField("use_topn_opt", org.apache.thrift.protocol.TType.BOOL, (short)7);
private static final org.apache.thrift.protocol.TField MERGE_BY_EXCHANGE_FIELD_DESC = new org.apache.thrift.protocol.TField("merge_by_exchange", org.apache.thrift.protocol.TType.BOOL, (short)8);
private static final org.apache.thrift.protocol.TField IS_ANALYTIC_SORT_FIELD_DESC = new org.apache.thrift.protocol.TField("is_analytic_sort", org.apache.thrift.protocol.TType.BOOL, (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 ALGORITHM_FIELD_DESC = new org.apache.thrift.protocol.TField("algorithm", org.apache.thrift.protocol.TType.I32, (short)11);
private static final org.apache.thrift.protocol.TField USE_LOCAL_MERGE_FIELD_DESC = new org.apache.thrift.protocol.TField("use_local_merge", org.apache.thrift.protocol.TType.BOOL, (short)12);
private static final org.apache.thrift.protocol.TField FULL_SORT_MAX_BUFFERED_BYTES_FIELD_DESC = new org.apache.thrift.protocol.TField("full_sort_max_buffered_bytes", org.apache.thrift.protocol.TType.I64, (short)13);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TSortNodeStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TSortNodeTupleSchemeFactory();
public @org.apache.thrift.annotation.Nullable TSortInfo sort_info; // required
public boolean use_top_n; // required
public long offset; // optional
public boolean is_default_limit; // optional
public boolean use_topn_opt; // optional
public boolean merge_by_exchange; // optional
public boolean is_analytic_sort; // optional
public boolean is_colocate; // optional
/**
*
* @see TSortAlgorithm
*/
public @org.apache.thrift.annotation.Nullable TSortAlgorithm algorithm; // optional
public boolean use_local_merge; // optional
public long full_sort_max_buffered_bytes; // 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 {
SORT_INFO((short)1, "sort_info"),
USE_TOP_N((short)2, "use_top_n"),
OFFSET((short)3, "offset"),
IS_DEFAULT_LIMIT((short)6, "is_default_limit"),
USE_TOPN_OPT((short)7, "use_topn_opt"),
MERGE_BY_EXCHANGE((short)8, "merge_by_exchange"),
IS_ANALYTIC_SORT((short)9, "is_analytic_sort"),
IS_COLOCATE((short)10, "is_colocate"),
/**
*
* @see TSortAlgorithm
*/
ALGORITHM((short)11, "algorithm"),
USE_LOCAL_MERGE((short)12, "use_local_merge"),
FULL_SORT_MAX_BUFFERED_BYTES((short)13, "full_sort_max_buffered_bytes");
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: // SORT_INFO
return SORT_INFO;
case 2: // USE_TOP_N
return USE_TOP_N;
case 3: // OFFSET
return OFFSET;
case 6: // IS_DEFAULT_LIMIT
return IS_DEFAULT_LIMIT;
case 7: // USE_TOPN_OPT
return USE_TOPN_OPT;
case 8: // MERGE_BY_EXCHANGE
return MERGE_BY_EXCHANGE;
case 9: // IS_ANALYTIC_SORT
return IS_ANALYTIC_SORT;
case 10: // IS_COLOCATE
return IS_COLOCATE;
case 11: // ALGORITHM
return ALGORITHM;
case 12: // USE_LOCAL_MERGE
return USE_LOCAL_MERGE;
case 13: // FULL_SORT_MAX_BUFFERED_BYTES
return FULL_SORT_MAX_BUFFERED_BYTES;
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 __USE_TOP_N_ISSET_ID = 0;
private static final int __OFFSET_ISSET_ID = 1;
private static final int __IS_DEFAULT_LIMIT_ISSET_ID = 2;
private static final int __USE_TOPN_OPT_ISSET_ID = 3;
private static final int __MERGE_BY_EXCHANGE_ISSET_ID = 4;
private static final int __IS_ANALYTIC_SORT_ISSET_ID = 5;
private static final int __IS_COLOCATE_ISSET_ID = 6;
private static final int __USE_LOCAL_MERGE_ISSET_ID = 7;
private static final int __FULL_SORT_MAX_BUFFERED_BYTES_ISSET_ID = 8;
private short __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.OFFSET,_Fields.IS_DEFAULT_LIMIT,_Fields.USE_TOPN_OPT,_Fields.MERGE_BY_EXCHANGE,_Fields.IS_ANALYTIC_SORT,_Fields.IS_COLOCATE,_Fields.ALGORITHM,_Fields.USE_LOCAL_MERGE,_Fields.FULL_SORT_MAX_BUFFERED_BYTES};
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.SORT_INFO, new org.apache.thrift.meta_data.FieldMetaData("sort_info", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TSortInfo.class)));
tmpMap.put(_Fields.USE_TOP_N, new org.apache.thrift.meta_data.FieldMetaData("use_top_n", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.OFFSET, new org.apache.thrift.meta_data.FieldMetaData("offset", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.IS_DEFAULT_LIMIT, new org.apache.thrift.meta_data.FieldMetaData("is_default_limit", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.USE_TOPN_OPT, new org.apache.thrift.meta_data.FieldMetaData("use_topn_opt", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.MERGE_BY_EXCHANGE, new org.apache.thrift.meta_data.FieldMetaData("merge_by_exchange", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.IS_ANALYTIC_SORT, new org.apache.thrift.meta_data.FieldMetaData("is_analytic_sort", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
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.ALGORITHM, new org.apache.thrift.meta_data.FieldMetaData("algorithm", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, TSortAlgorithm.class)));
tmpMap.put(_Fields.USE_LOCAL_MERGE, new org.apache.thrift.meta_data.FieldMetaData("use_local_merge", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.FULL_SORT_MAX_BUFFERED_BYTES, new org.apache.thrift.meta_data.FieldMetaData("full_sort_max_buffered_bytes", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TSortNode.class, metaDataMap);
}
public TSortNode() {
}
public TSortNode(
TSortInfo sort_info,
boolean use_top_n)
{
this();
this.sort_info = sort_info;
this.use_top_n = use_top_n;
setUseTopNIsSet(true);
}
/**
* Performs a deep copy on <i>other</i>.
*/
public TSortNode(TSortNode other) {
__isset_bitfield = other.__isset_bitfield;
if (other.isSetSortInfo()) {
this.sort_info = new TSortInfo(other.sort_info);
}
this.use_top_n = other.use_top_n;
this.offset = other.offset;
this.is_default_limit = other.is_default_limit;
this.use_topn_opt = other.use_topn_opt;
this.merge_by_exchange = other.merge_by_exchange;
this.is_analytic_sort = other.is_analytic_sort;
this.is_colocate = other.is_colocate;
if (other.isSetAlgorithm()) {
this.algorithm = other.algorithm;
}
this.use_local_merge = other.use_local_merge;
this.full_sort_max_buffered_bytes = other.full_sort_max_buffered_bytes;
}
public TSortNode deepCopy() {
return new TSortNode(this);
}
@Override
public void clear() {
this.sort_info = null;
setUseTopNIsSet(false);
this.use_top_n = false;
setOffsetIsSet(false);
this.offset = 0;
setIsDefaultLimitIsSet(false);
this.is_default_limit = false;
setUseTopnOptIsSet(false);
this.use_topn_opt = false;
setMergeByExchangeIsSet(false);
this.merge_by_exchange = false;
setIsAnalyticSortIsSet(false);
this.is_analytic_sort = false;
setIsColocateIsSet(false);
this.is_colocate = false;
this.algorithm = null;
setUseLocalMergeIsSet(false);
this.use_local_merge = false;
setFullSortMaxBufferedBytesIsSet(false);
this.full_sort_max_buffered_bytes = 0;
}
@org.apache.thrift.annotation.Nullable
public TSortInfo getSortInfo() {
return this.sort_info;
}
public TSortNode setSortInfo(@org.apache.thrift.annotation.Nullable TSortInfo sort_info) {
this.sort_info = sort_info;
return this;
}
public void unsetSortInfo() {
this.sort_info = null;
}
/** Returns true if field sort_info is set (has been assigned a value) and false otherwise */
public boolean isSetSortInfo() {
return this.sort_info != null;
}
public void setSortInfoIsSet(boolean value) {
if (!value) {
this.sort_info = null;
}
}
public boolean isUseTopN() {
return this.use_top_n;
}
public TSortNode setUseTopN(boolean use_top_n) {
this.use_top_n = use_top_n;
setUseTopNIsSet(true);
return this;
}
public void unsetUseTopN() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __USE_TOP_N_ISSET_ID);
}
/** Returns true if field use_top_n is set (has been assigned a value) and false otherwise */
public boolean isSetUseTopN() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __USE_TOP_N_ISSET_ID);
}
public void setUseTopNIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __USE_TOP_N_ISSET_ID, value);
}
public long getOffset() {
return this.offset;
}
public TSortNode setOffset(long offset) {
this.offset = offset;
setOffsetIsSet(true);
return this;
}
public void unsetOffset() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __OFFSET_ISSET_ID);
}
/** Returns true if field offset is set (has been assigned a value) and false otherwise */
public boolean isSetOffset() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __OFFSET_ISSET_ID);
}
public void setOffsetIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __OFFSET_ISSET_ID, value);
}
public boolean isIsDefaultLimit() {
return this.is_default_limit;
}
public TSortNode setIsDefaultLimit(boolean is_default_limit) {
this.is_default_limit = is_default_limit;
setIsDefaultLimitIsSet(true);
return this;
}
public void unsetIsDefaultLimit() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __IS_DEFAULT_LIMIT_ISSET_ID);
}
/** Returns true if field is_default_limit is set (has been assigned a value) and false otherwise */
public boolean isSetIsDefaultLimit() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __IS_DEFAULT_LIMIT_ISSET_ID);
}
public void setIsDefaultLimitIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __IS_DEFAULT_LIMIT_ISSET_ID, value);
}
public boolean isUseTopnOpt() {
return this.use_topn_opt;
}
public TSortNode setUseTopnOpt(boolean use_topn_opt) {
this.use_topn_opt = use_topn_opt;
setUseTopnOptIsSet(true);
return this;
}
public void unsetUseTopnOpt() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __USE_TOPN_OPT_ISSET_ID);
}
/** Returns true if field use_topn_opt is set (has been assigned a value) and false otherwise */
public boolean isSetUseTopnOpt() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __USE_TOPN_OPT_ISSET_ID);
}
public void setUseTopnOptIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __USE_TOPN_OPT_ISSET_ID, value);
}
public boolean isMergeByExchange() {
return this.merge_by_exchange;
}
public TSortNode setMergeByExchange(boolean merge_by_exchange) {
this.merge_by_exchange = merge_by_exchange;
setMergeByExchangeIsSet(true);
return this;
}
public void unsetMergeByExchange() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __MERGE_BY_EXCHANGE_ISSET_ID);
}
/** Returns true if field merge_by_exchange is set (has been assigned a value) and false otherwise */
public boolean isSetMergeByExchange() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __MERGE_BY_EXCHANGE_ISSET_ID);
}
public void setMergeByExchangeIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __MERGE_BY_EXCHANGE_ISSET_ID, value);
}
public boolean isIsAnalyticSort() {
return this.is_analytic_sort;
}
public TSortNode setIsAnalyticSort(boolean is_analytic_sort) {
this.is_analytic_sort = is_analytic_sort;
setIsAnalyticSortIsSet(true);
return this;
}
public void unsetIsAnalyticSort() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __IS_ANALYTIC_SORT_ISSET_ID);
}
/** Returns true if field is_analytic_sort is set (has been assigned a value) and false otherwise */
public boolean isSetIsAnalyticSort() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __IS_ANALYTIC_SORT_ISSET_ID);
}
public void setIsAnalyticSortIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __IS_ANALYTIC_SORT_ISSET_ID, value);
}
public boolean isIsColocate() {
return this.is_colocate;
}
public TSortNode 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);
}
/**
*
* @see TSortAlgorithm
*/
@org.apache.thrift.annotation.Nullable
public TSortAlgorithm getAlgorithm() {
return this.algorithm;
}
/**
*
* @see TSortAlgorithm
*/
public TSortNode setAlgorithm(@org.apache.thrift.annotation.Nullable TSortAlgorithm algorithm) {
this.algorithm = algorithm;
return this;
}
public void unsetAlgorithm() {
this.algorithm = null;
}
/** Returns true if field algorithm is set (has been assigned a value) and false otherwise */
public boolean isSetAlgorithm() {
return this.algorithm != null;
}
public void setAlgorithmIsSet(boolean value) {
if (!value) {
this.algorithm = null;
}
}
public boolean isUseLocalMerge() {
return this.use_local_merge;
}
public TSortNode setUseLocalMerge(boolean use_local_merge) {
this.use_local_merge = use_local_merge;
setUseLocalMergeIsSet(true);
return this;
}
public void unsetUseLocalMerge() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __USE_LOCAL_MERGE_ISSET_ID);
}
/** Returns true if field use_local_merge is set (has been assigned a value) and false otherwise */
public boolean isSetUseLocalMerge() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __USE_LOCAL_MERGE_ISSET_ID);
}
public void setUseLocalMergeIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __USE_LOCAL_MERGE_ISSET_ID, value);
}
public long getFullSortMaxBufferedBytes() {
return this.full_sort_max_buffered_bytes;
}
public TSortNode setFullSortMaxBufferedBytes(long full_sort_max_buffered_bytes) {
this.full_sort_max_buffered_bytes = full_sort_max_buffered_bytes;
setFullSortMaxBufferedBytesIsSet(true);
return this;
}
public void unsetFullSortMaxBufferedBytes() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __FULL_SORT_MAX_BUFFERED_BYTES_ISSET_ID);
}
/** Returns true if field full_sort_max_buffered_bytes is set (has been assigned a value) and false otherwise */
public boolean isSetFullSortMaxBufferedBytes() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __FULL_SORT_MAX_BUFFERED_BYTES_ISSET_ID);
}
public void setFullSortMaxBufferedBytesIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __FULL_SORT_MAX_BUFFERED_BYTES_ISSET_ID, value);
}
public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case SORT_INFO:
if (value == null) {
unsetSortInfo();
} else {
setSortInfo((TSortInfo)value);
}
break;
case USE_TOP_N:
if (value == null) {
unsetUseTopN();
} else {
setUseTopN((java.lang.Boolean)value);
}
break;
case OFFSET:
if (value == null) {
unsetOffset();
} else {
setOffset((java.lang.Long)value);
}
break;
case IS_DEFAULT_LIMIT:
if (value == null) {
unsetIsDefaultLimit();
} else {
setIsDefaultLimit((java.lang.Boolean)value);
}
break;
case USE_TOPN_OPT:
if (value == null) {
unsetUseTopnOpt();
} else {
setUseTopnOpt((java.lang.Boolean)value);
}
break;
case MERGE_BY_EXCHANGE:
if (value == null) {
unsetMergeByExchange();
} else {
setMergeByExchange((java.lang.Boolean)value);
}
break;
case IS_ANALYTIC_SORT:
if (value == null) {
unsetIsAnalyticSort();
} else {
setIsAnalyticSort((java.lang.Boolean)value);
}
break;
case IS_COLOCATE:
if (value == null) {
unsetIsColocate();
} else {
setIsColocate((java.lang.Boolean)value);
}
break;
case ALGORITHM:
if (value == null) {
unsetAlgorithm();
} else {
setAlgorithm((TSortAlgorithm)value);
}
break;
case USE_LOCAL_MERGE:
if (value == null) {
unsetUseLocalMerge();
} else {
setUseLocalMerge((java.lang.Boolean)value);
}
break;
case FULL_SORT_MAX_BUFFERED_BYTES:
if (value == null) {
unsetFullSortMaxBufferedBytes();
} else {
setFullSortMaxBufferedBytes((java.lang.Long)value);
}
break;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case SORT_INFO:
return getSortInfo();
case USE_TOP_N:
return isUseTopN();
case OFFSET:
return getOffset();
case IS_DEFAULT_LIMIT:
return isIsDefaultLimit();
case USE_TOPN_OPT:
return isUseTopnOpt();
case MERGE_BY_EXCHANGE:
return isMergeByExchange();
case IS_ANALYTIC_SORT:
return isIsAnalyticSort();
case IS_COLOCATE:
return isIsColocate();
case ALGORITHM:
return getAlgorithm();
case USE_LOCAL_MERGE:
return isUseLocalMerge();
case FULL_SORT_MAX_BUFFERED_BYTES:
return getFullSortMaxBufferedBytes();
}
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 SORT_INFO:
return isSetSortInfo();
case USE_TOP_N:
return isSetUseTopN();
case OFFSET:
return isSetOffset();
case IS_DEFAULT_LIMIT:
return isSetIsDefaultLimit();
case USE_TOPN_OPT:
return isSetUseTopnOpt();
case MERGE_BY_EXCHANGE:
return isSetMergeByExchange();
case IS_ANALYTIC_SORT:
return isSetIsAnalyticSort();
case IS_COLOCATE:
return isSetIsColocate();
case ALGORITHM:
return isSetAlgorithm();
case USE_LOCAL_MERGE:
return isSetUseLocalMerge();
case FULL_SORT_MAX_BUFFERED_BYTES:
return isSetFullSortMaxBufferedBytes();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof TSortNode)
return this.equals((TSortNode)that);
return false;
}
public boolean equals(TSortNode that) {
if (that == null)
return false;
if (this == that)
return true;
boolean this_present_sort_info = true && this.isSetSortInfo();
boolean that_present_sort_info = true && that.isSetSortInfo();
if (this_present_sort_info || that_present_sort_info) {
if (!(this_present_sort_info && that_present_sort_info))
return false;
if (!this.sort_info.equals(that.sort_info))
return false;
}
boolean this_present_use_top_n = true;
boolean that_present_use_top_n = true;
if (this_present_use_top_n || that_present_use_top_n) {
if (!(this_present_use_top_n && that_present_use_top_n))
return false;
if (this.use_top_n != that.use_top_n)
return false;
}
boolean this_present_offset = true && this.isSetOffset();
boolean that_present_offset = true && that.isSetOffset();
if (this_present_offset || that_present_offset) {
if (!(this_present_offset && that_present_offset))
return false;
if (this.offset != that.offset)
return false;
}
boolean this_present_is_default_limit = true && this.isSetIsDefaultLimit();
boolean that_present_is_default_limit = true && that.isSetIsDefaultLimit();
if (this_present_is_default_limit || that_present_is_default_limit) {
if (!(this_present_is_default_limit && that_present_is_default_limit))
return false;
if (this.is_default_limit != that.is_default_limit)
return false;
}
boolean this_present_use_topn_opt = true && this.isSetUseTopnOpt();
boolean that_present_use_topn_opt = true && that.isSetUseTopnOpt();
if (this_present_use_topn_opt || that_present_use_topn_opt) {
if (!(this_present_use_topn_opt && that_present_use_topn_opt))
return false;
if (this.use_topn_opt != that.use_topn_opt)
return false;
}
boolean this_present_merge_by_exchange = true && this.isSetMergeByExchange();
boolean that_present_merge_by_exchange = true && that.isSetMergeByExchange();
if (this_present_merge_by_exchange || that_present_merge_by_exchange) {
if (!(this_present_merge_by_exchange && that_present_merge_by_exchange))
return false;
if (this.merge_by_exchange != that.merge_by_exchange)
return false;
}
boolean this_present_is_analytic_sort = true && this.isSetIsAnalyticSort();
boolean that_present_is_analytic_sort = true && that.isSetIsAnalyticSort();
if (this_present_is_analytic_sort || that_present_is_analytic_sort) {
if (!(this_present_is_analytic_sort && that_present_is_analytic_sort))
return false;
if (this.is_analytic_sort != that.is_analytic_sort)
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_algorithm = true && this.isSetAlgorithm();
boolean that_present_algorithm = true && that.isSetAlgorithm();
if (this_present_algorithm || that_present_algorithm) {
if (!(this_present_algorithm && that_present_algorithm))
return false;
if (!this.algorithm.equals(that.algorithm))
return false;
}
boolean this_present_use_local_merge = true && this.isSetUseLocalMerge();
boolean that_present_use_local_merge = true && that.isSetUseLocalMerge();
if (this_present_use_local_merge || that_present_use_local_merge) {
if (!(this_present_use_local_merge && that_present_use_local_merge))
return false;
if (this.use_local_merge != that.use_local_merge)
return false;
}
boolean this_present_full_sort_max_buffered_bytes = true && this.isSetFullSortMaxBufferedBytes();
boolean that_present_full_sort_max_buffered_bytes = true && that.isSetFullSortMaxBufferedBytes();
if (this_present_full_sort_max_buffered_bytes || that_present_full_sort_max_buffered_bytes) {
if (!(this_present_full_sort_max_buffered_bytes && that_present_full_sort_max_buffered_bytes))
return false;
if (this.full_sort_max_buffered_bytes != that.full_sort_max_buffered_bytes)
return false;
}
return true;
}
@Override
public int hashCode() {
int hashCode = 1;
hashCode = hashCode * 8191 + ((isSetSortInfo()) ? 131071 : 524287);
if (isSetSortInfo())
hashCode = hashCode * 8191 + sort_info.hashCode();
hashCode = hashCode * 8191 + ((use_top_n) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetOffset()) ? 131071 : 524287);
if (isSetOffset())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(offset);
hashCode = hashCode * 8191 + ((isSetIsDefaultLimit()) ? 131071 : 524287);
if (isSetIsDefaultLimit())
hashCode = hashCode * 8191 + ((is_default_limit) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetUseTopnOpt()) ? 131071 : 524287);
if (isSetUseTopnOpt())
hashCode = hashCode * 8191 + ((use_topn_opt) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetMergeByExchange()) ? 131071 : 524287);
if (isSetMergeByExchange())
hashCode = hashCode * 8191 + ((merge_by_exchange) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetIsAnalyticSort()) ? 131071 : 524287);
if (isSetIsAnalyticSort())
hashCode = hashCode * 8191 + ((is_analytic_sort) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetIsColocate()) ? 131071 : 524287);
if (isSetIsColocate())
hashCode = hashCode * 8191 + ((is_colocate) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetAlgorithm()) ? 131071 : 524287);
if (isSetAlgorithm())
hashCode = hashCode * 8191 + algorithm.getValue();
hashCode = hashCode * 8191 + ((isSetUseLocalMerge()) ? 131071 : 524287);
if (isSetUseLocalMerge())
hashCode = hashCode * 8191 + ((use_local_merge) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetFullSortMaxBufferedBytes()) ? 131071 : 524287);
if (isSetFullSortMaxBufferedBytes())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(full_sort_max_buffered_bytes);
return hashCode;
}
@Override
public int compareTo(TSortNode other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = java.lang.Boolean.compare(isSetSortInfo(), other.isSetSortInfo());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetSortInfo()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sort_info, other.sort_info);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetUseTopN(), other.isSetUseTopN());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetUseTopN()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.use_top_n, other.use_top_n);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetOffset(), other.isSetOffset());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOffset()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.offset, other.offset);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetIsDefaultLimit(), other.isSetIsDefaultLimit());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetIsDefaultLimit()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.is_default_limit, other.is_default_limit);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetUseTopnOpt(), other.isSetUseTopnOpt());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetUseTopnOpt()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.use_topn_opt, other.use_topn_opt);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetMergeByExchange(), other.isSetMergeByExchange());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetMergeByExchange()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.merge_by_exchange, other.merge_by_exchange);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetIsAnalyticSort(), other.isSetIsAnalyticSort());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetIsAnalyticSort()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.is_analytic_sort, other.is_analytic_sort);
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(isSetAlgorithm(), other.isSetAlgorithm());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetAlgorithm()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.algorithm, other.algorithm);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetUseLocalMerge(), other.isSetUseLocalMerge());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetUseLocalMerge()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.use_local_merge, other.use_local_merge);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetFullSortMaxBufferedBytes(), other.isSetFullSortMaxBufferedBytes());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetFullSortMaxBufferedBytes()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.full_sort_max_buffered_bytes, other.full_sort_max_buffered_bytes);
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("TSortNode(");
boolean first = true;
sb.append("sort_info:");
if (this.sort_info == null) {
sb.append("null");
} else {
sb.append(this.sort_info);
}
first = false;
if (!first) sb.append(", ");
sb.append("use_top_n:");
sb.append(this.use_top_n);
first = false;
if (isSetOffset()) {
if (!first) sb.append(", ");
sb.append("offset:");
sb.append(this.offset);
first = false;
}
if (isSetIsDefaultLimit()) {
if (!first) sb.append(", ");
sb.append("is_default_limit:");
sb.append(this.is_default_limit);
first = false;
}
if (isSetUseTopnOpt()) {
if (!first) sb.append(", ");
sb.append("use_topn_opt:");
sb.append(this.use_topn_opt);
first = false;
}
if (isSetMergeByExchange()) {
if (!first) sb.append(", ");
sb.append("merge_by_exchange:");
sb.append(this.merge_by_exchange);
first = false;
}
if (isSetIsAnalyticSort()) {
if (!first) sb.append(", ");
sb.append("is_analytic_sort:");
sb.append(this.is_analytic_sort);
first = false;
}
if (isSetIsColocate()) {
if (!first) sb.append(", ");
sb.append("is_colocate:");
sb.append(this.is_colocate);
first = false;
}
if (isSetAlgorithm()) {
if (!first) sb.append(", ");
sb.append("algorithm:");
if (this.algorithm == null) {
sb.append("null");
} else {
sb.append(this.algorithm);
}
first = false;
}
if (isSetUseLocalMerge()) {
if (!first) sb.append(", ");
sb.append("use_local_merge:");
sb.append(this.use_local_merge);
first = false;
}
if (isSetFullSortMaxBufferedBytes()) {
if (!first) sb.append(", ");
sb.append("full_sort_max_buffered_bytes:");
sb.append(this.full_sort_max_buffered_bytes);
first = false;
}
sb.append(")");
return sb.toString();
}
public void validate() throws org.apache.thrift.TException {
// check for required fields
if (sort_info == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'sort_info' was not present! Struct: " + toString());
}
// alas, we cannot check 'use_top_n' because it's a primitive and you chose the non-beans generator.
// check for sub-struct validity
if (sort_info != null) {
sort_info.validate();
}
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private static class TSortNodeStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TSortNodeStandardScheme getScheme() {
return new TSortNodeStandardScheme();
}
}
private static class TSortNodeStandardScheme extends org.apache.thrift.scheme.StandardScheme<TSortNode> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TSortNode 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: // SORT_INFO
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.sort_info = new TSortInfo();
struct.sort_info.read(iprot);
struct.setSortInfoIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // USE_TOP_N
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.use_top_n = iprot.readBool();
struct.setUseTopNIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // OFFSET
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.offset = iprot.readI64();
struct.setOffsetIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // IS_DEFAULT_LIMIT
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.is_default_limit = iprot.readBool();
struct.setIsDefaultLimitIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // USE_TOPN_OPT
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.use_topn_opt = iprot.readBool();
struct.setUseTopnOptIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // MERGE_BY_EXCHANGE
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.merge_by_exchange = iprot.readBool();
struct.setMergeByExchangeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // IS_ANALYTIC_SORT
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.is_analytic_sort = iprot.readBool();
struct.setIsAnalyticSortIsSet(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: // ALGORITHM
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.algorithm = org.apache.doris.thrift.TSortAlgorithm.findByValue(iprot.readI32());
struct.setAlgorithmIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 12: // USE_LOCAL_MERGE
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.use_local_merge = iprot.readBool();
struct.setUseLocalMergeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 13: // FULL_SORT_MAX_BUFFERED_BYTES
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.full_sort_max_buffered_bytes = iprot.readI64();
struct.setFullSortMaxBufferedBytesIsSet(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.isSetUseTopN()) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'use_top_n' was not found in serialized data! Struct: " + toString());
}
struct.validate();
}
public void write(org.apache.thrift.protocol.TProtocol oprot, TSortNode struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.sort_info != null) {
oprot.writeFieldBegin(SORT_INFO_FIELD_DESC);
struct.sort_info.write(oprot);
oprot.writeFieldEnd();
}
oprot.writeFieldBegin(USE_TOP_N_FIELD_DESC);
oprot.writeBool(struct.use_top_n);
oprot.writeFieldEnd();
if (struct.isSetOffset()) {
oprot.writeFieldBegin(OFFSET_FIELD_DESC);
oprot.writeI64(struct.offset);
oprot.writeFieldEnd();
}
if (struct.isSetIsDefaultLimit()) {
oprot.writeFieldBegin(IS_DEFAULT_LIMIT_FIELD_DESC);
oprot.writeBool(struct.is_default_limit);
oprot.writeFieldEnd();
}
if (struct.isSetUseTopnOpt()) {
oprot.writeFieldBegin(USE_TOPN_OPT_FIELD_DESC);
oprot.writeBool(struct.use_topn_opt);
oprot.writeFieldEnd();
}
if (struct.isSetMergeByExchange()) {
oprot.writeFieldBegin(MERGE_BY_EXCHANGE_FIELD_DESC);
oprot.writeBool(struct.merge_by_exchange);
oprot.writeFieldEnd();
}
if (struct.isSetIsAnalyticSort()) {
oprot.writeFieldBegin(IS_ANALYTIC_SORT_FIELD_DESC);
oprot.writeBool(struct.is_analytic_sort);
oprot.writeFieldEnd();
}
if (struct.isSetIsColocate()) {
oprot.writeFieldBegin(IS_COLOCATE_FIELD_DESC);
oprot.writeBool(struct.is_colocate);
oprot.writeFieldEnd();
}
if (struct.algorithm != null) {
if (struct.isSetAlgorithm()) {
oprot.writeFieldBegin(ALGORITHM_FIELD_DESC);
oprot.writeI32(struct.algorithm.getValue());
oprot.writeFieldEnd();
}
}
if (struct.isSetUseLocalMerge()) {
oprot.writeFieldBegin(USE_LOCAL_MERGE_FIELD_DESC);
oprot.writeBool(struct.use_local_merge);
oprot.writeFieldEnd();
}
if (struct.isSetFullSortMaxBufferedBytes()) {
oprot.writeFieldBegin(FULL_SORT_MAX_BUFFERED_BYTES_FIELD_DESC);
oprot.writeI64(struct.full_sort_max_buffered_bytes);
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class TSortNodeTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TSortNodeTupleScheme getScheme() {
return new TSortNodeTupleScheme();
}
}
private static class TSortNodeTupleScheme extends org.apache.thrift.scheme.TupleScheme<TSortNode> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TSortNode struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
struct.sort_info.write(oprot);
oprot.writeBool(struct.use_top_n);
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetOffset()) {
optionals.set(0);
}
if (struct.isSetIsDefaultLimit()) {
optionals.set(1);
}
if (struct.isSetUseTopnOpt()) {
optionals.set(2);
}
if (struct.isSetMergeByExchange()) {
optionals.set(3);
}
if (struct.isSetIsAnalyticSort()) {
optionals.set(4);
}
if (struct.isSetIsColocate()) {
optionals.set(5);
}
if (struct.isSetAlgorithm()) {
optionals.set(6);
}
if (struct.isSetUseLocalMerge()) {
optionals.set(7);
}
if (struct.isSetFullSortMaxBufferedBytes()) {
optionals.set(8);
}
oprot.writeBitSet(optionals, 9);
if (struct.isSetOffset()) {
oprot.writeI64(struct.offset);
}
if (struct.isSetIsDefaultLimit()) {
oprot.writeBool(struct.is_default_limit);
}
if (struct.isSetUseTopnOpt()) {
oprot.writeBool(struct.use_topn_opt);
}
if (struct.isSetMergeByExchange()) {
oprot.writeBool(struct.merge_by_exchange);
}
if (struct.isSetIsAnalyticSort()) {
oprot.writeBool(struct.is_analytic_sort);
}
if (struct.isSetIsColocate()) {
oprot.writeBool(struct.is_colocate);
}
if (struct.isSetAlgorithm()) {
oprot.writeI32(struct.algorithm.getValue());
}
if (struct.isSetUseLocalMerge()) {
oprot.writeBool(struct.use_local_merge);
}
if (struct.isSetFullSortMaxBufferedBytes()) {
oprot.writeI64(struct.full_sort_max_buffered_bytes);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TSortNode struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
struct.sort_info = new TSortInfo();
struct.sort_info.read(iprot);
struct.setSortInfoIsSet(true);
struct.use_top_n = iprot.readBool();
struct.setUseTopNIsSet(true);
java.util.BitSet incoming = iprot.readBitSet(9);
if (incoming.get(0)) {
struct.offset = iprot.readI64();
struct.setOffsetIsSet(true);
}
if (incoming.get(1)) {
struct.is_default_limit = iprot.readBool();
struct.setIsDefaultLimitIsSet(true);
}
if (incoming.get(2)) {
struct.use_topn_opt = iprot.readBool();
struct.setUseTopnOptIsSet(true);
}
if (incoming.get(3)) {
struct.merge_by_exchange = iprot.readBool();
struct.setMergeByExchangeIsSet(true);
}
if (incoming.get(4)) {
struct.is_analytic_sort = iprot.readBool();
struct.setIsAnalyticSortIsSet(true);
}
if (incoming.get(5)) {
struct.is_colocate = iprot.readBool();
struct.setIsColocateIsSet(true);
}
if (incoming.get(6)) {
struct.algorithm = org.apache.doris.thrift.TSortAlgorithm.findByValue(iprot.readI32());
struct.setAlgorithmIsSet(true);
}
if (incoming.get(7)) {
struct.use_local_merge = iprot.readBool();
struct.setUseLocalMergeIsSet(true);
}
if (incoming.get(8)) {
struct.full_sort_max_buffered_bytes = iprot.readI64();
struct.setFullSortMaxBufferedBytesIsSet(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();
}
}