TPaimonMetadataParams.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 TPaimonMetadataParams implements org.apache.thrift.TBase<TPaimonMetadataParams, TPaimonMetadataParams._Fields>, java.io.Serializable, Cloneable, Comparable<TPaimonMetadataParams> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TPaimonMetadataParams");
private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("db_name", org.apache.thrift.protocol.TType.STRING, (short)1);
private static final org.apache.thrift.protocol.TField TBL_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tbl_name", org.apache.thrift.protocol.TType.STRING, (short)2);
private static final org.apache.thrift.protocol.TField QUERY_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("query_type", org.apache.thrift.protocol.TType.STRING, (short)3);
private static final org.apache.thrift.protocol.TField CTL_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("ctl_id", org.apache.thrift.protocol.TType.I64, (short)4);
private static final org.apache.thrift.protocol.TField DB_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("db_id", org.apache.thrift.protocol.TType.I64, (short)5);
private static final org.apache.thrift.protocol.TField TBL_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("tbl_id", org.apache.thrift.protocol.TType.I64, (short)6);
private static final org.apache.thrift.protocol.TField SERIALIZED_SPLIT_FIELD_DESC = new org.apache.thrift.protocol.TField("serialized_split", org.apache.thrift.protocol.TType.STRING, (short)7);
private static final org.apache.thrift.protocol.TField HADOOP_PROPS_FIELD_DESC = new org.apache.thrift.protocol.TField("hadoop_props", org.apache.thrift.protocol.TType.MAP, (short)8);
private static final org.apache.thrift.protocol.TField PAIMON_PROPS_FIELD_DESC = new org.apache.thrift.protocol.TField("paimon_props", org.apache.thrift.protocol.TType.MAP, (short)9);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TPaimonMetadataParamsStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TPaimonMetadataParamsTupleSchemeFactory();
public @org.apache.thrift.annotation.Nullable java.lang.String db_name; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String tbl_name; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String query_type; // optional
public long ctl_id; // optional
public long db_id; // optional
public long tbl_id; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String serialized_split; // optional
public @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> hadoop_props; // optional
public @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> paimon_props; // 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 {
DB_NAME((short)1, "db_name"),
TBL_NAME((short)2, "tbl_name"),
QUERY_TYPE((short)3, "query_type"),
CTL_ID((short)4, "ctl_id"),
DB_ID((short)5, "db_id"),
TBL_ID((short)6, "tbl_id"),
SERIALIZED_SPLIT((short)7, "serialized_split"),
HADOOP_PROPS((short)8, "hadoop_props"),
PAIMON_PROPS((short)9, "paimon_props");
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: // DB_NAME
return DB_NAME;
case 2: // TBL_NAME
return TBL_NAME;
case 3: // QUERY_TYPE
return QUERY_TYPE;
case 4: // CTL_ID
return CTL_ID;
case 5: // DB_ID
return DB_ID;
case 6: // TBL_ID
return TBL_ID;
case 7: // SERIALIZED_SPLIT
return SERIALIZED_SPLIT;
case 8: // HADOOP_PROPS
return HADOOP_PROPS;
case 9: // PAIMON_PROPS
return PAIMON_PROPS;
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 __CTL_ID_ISSET_ID = 0;
private static final int __DB_ID_ISSET_ID = 1;
private static final int __TBL_ID_ISSET_ID = 2;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.DB_NAME,_Fields.TBL_NAME,_Fields.QUERY_TYPE,_Fields.CTL_ID,_Fields.DB_ID,_Fields.TBL_ID,_Fields.SERIALIZED_SPLIT,_Fields.HADOOP_PROPS,_Fields.PAIMON_PROPS};
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.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("db_name", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.TBL_NAME, new org.apache.thrift.meta_data.FieldMetaData("tbl_name", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.QUERY_TYPE, new org.apache.thrift.meta_data.FieldMetaData("query_type", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.CTL_ID, new org.apache.thrift.meta_data.FieldMetaData("ctl_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.DB_ID, new org.apache.thrift.meta_data.FieldMetaData("db_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.TBL_ID, new org.apache.thrift.meta_data.FieldMetaData("tbl_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.SERIALIZED_SPLIT, new org.apache.thrift.meta_data.FieldMetaData("serialized_split", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.HADOOP_PROPS, new org.apache.thrift.meta_data.FieldMetaData("hadoop_props", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING),
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
tmpMap.put(_Fields.PAIMON_PROPS, new org.apache.thrift.meta_data.FieldMetaData("paimon_props", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING),
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TPaimonMetadataParams.class, metaDataMap);
}
public TPaimonMetadataParams() {
}
/**
* Performs a deep copy on <i>other</i>.
*/
public TPaimonMetadataParams(TPaimonMetadataParams other) {
__isset_bitfield = other.__isset_bitfield;
if (other.isSetDbName()) {
this.db_name = other.db_name;
}
if (other.isSetTblName()) {
this.tbl_name = other.tbl_name;
}
if (other.isSetQueryType()) {
this.query_type = other.query_type;
}
this.ctl_id = other.ctl_id;
this.db_id = other.db_id;
this.tbl_id = other.tbl_id;
if (other.isSetSerializedSplit()) {
this.serialized_split = other.serialized_split;
}
if (other.isSetHadoopProps()) {
java.util.Map<java.lang.String,java.lang.String> __this__hadoop_props = new java.util.HashMap<java.lang.String,java.lang.String>(other.hadoop_props);
this.hadoop_props = __this__hadoop_props;
}
if (other.isSetPaimonProps()) {
java.util.Map<java.lang.String,java.lang.String> __this__paimon_props = new java.util.HashMap<java.lang.String,java.lang.String>(other.paimon_props);
this.paimon_props = __this__paimon_props;
}
}
public TPaimonMetadataParams deepCopy() {
return new TPaimonMetadataParams(this);
}
@Override
public void clear() {
this.db_name = null;
this.tbl_name = null;
this.query_type = null;
setCtlIdIsSet(false);
this.ctl_id = 0;
setDbIdIsSet(false);
this.db_id = 0;
setTblIdIsSet(false);
this.tbl_id = 0;
this.serialized_split = null;
this.hadoop_props = null;
this.paimon_props = null;
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getDbName() {
return this.db_name;
}
public TPaimonMetadataParams setDbName(@org.apache.thrift.annotation.Nullable java.lang.String db_name) {
this.db_name = db_name;
return this;
}
public void unsetDbName() {
this.db_name = null;
}
/** Returns true if field db_name is set (has been assigned a value) and false otherwise */
public boolean isSetDbName() {
return this.db_name != null;
}
public void setDbNameIsSet(boolean value) {
if (!value) {
this.db_name = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getTblName() {
return this.tbl_name;
}
public TPaimonMetadataParams setTblName(@org.apache.thrift.annotation.Nullable java.lang.String tbl_name) {
this.tbl_name = tbl_name;
return this;
}
public void unsetTblName() {
this.tbl_name = null;
}
/** Returns true if field tbl_name is set (has been assigned a value) and false otherwise */
public boolean isSetTblName() {
return this.tbl_name != null;
}
public void setTblNameIsSet(boolean value) {
if (!value) {
this.tbl_name = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getQueryType() {
return this.query_type;
}
public TPaimonMetadataParams setQueryType(@org.apache.thrift.annotation.Nullable java.lang.String query_type) {
this.query_type = query_type;
return this;
}
public void unsetQueryType() {
this.query_type = null;
}
/** Returns true if field query_type is set (has been assigned a value) and false otherwise */
public boolean isSetQueryType() {
return this.query_type != null;
}
public void setQueryTypeIsSet(boolean value) {
if (!value) {
this.query_type = null;
}
}
public long getCtlId() {
return this.ctl_id;
}
public TPaimonMetadataParams setCtlId(long ctl_id) {
this.ctl_id = ctl_id;
setCtlIdIsSet(true);
return this;
}
public void unsetCtlId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __CTL_ID_ISSET_ID);
}
/** Returns true if field ctl_id is set (has been assigned a value) and false otherwise */
public boolean isSetCtlId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __CTL_ID_ISSET_ID);
}
public void setCtlIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __CTL_ID_ISSET_ID, value);
}
public long getDbId() {
return this.db_id;
}
public TPaimonMetadataParams setDbId(long db_id) {
this.db_id = db_id;
setDbIdIsSet(true);
return this;
}
public void unsetDbId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __DB_ID_ISSET_ID);
}
/** Returns true if field db_id is set (has been assigned a value) and false otherwise */
public boolean isSetDbId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __DB_ID_ISSET_ID);
}
public void setDbIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __DB_ID_ISSET_ID, value);
}
public long getTblId() {
return this.tbl_id;
}
public TPaimonMetadataParams setTblId(long tbl_id) {
this.tbl_id = tbl_id;
setTblIdIsSet(true);
return this;
}
public void unsetTblId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __TBL_ID_ISSET_ID);
}
/** Returns true if field tbl_id is set (has been assigned a value) and false otherwise */
public boolean isSetTblId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __TBL_ID_ISSET_ID);
}
public void setTblIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __TBL_ID_ISSET_ID, value);
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getSerializedSplit() {
return this.serialized_split;
}
public TPaimonMetadataParams setSerializedSplit(@org.apache.thrift.annotation.Nullable java.lang.String serialized_split) {
this.serialized_split = serialized_split;
return this;
}
public void unsetSerializedSplit() {
this.serialized_split = null;
}
/** Returns true if field serialized_split is set (has been assigned a value) and false otherwise */
public boolean isSetSerializedSplit() {
return this.serialized_split != null;
}
public void setSerializedSplitIsSet(boolean value) {
if (!value) {
this.serialized_split = null;
}
}
public int getHadoopPropsSize() {
return (this.hadoop_props == null) ? 0 : this.hadoop_props.size();
}
public void putToHadoopProps(java.lang.String key, java.lang.String val) {
if (this.hadoop_props == null) {
this.hadoop_props = new java.util.HashMap<java.lang.String,java.lang.String>();
}
this.hadoop_props.put(key, val);
}
@org.apache.thrift.annotation.Nullable
public java.util.Map<java.lang.String,java.lang.String> getHadoopProps() {
return this.hadoop_props;
}
public TPaimonMetadataParams setHadoopProps(@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> hadoop_props) {
this.hadoop_props = hadoop_props;
return this;
}
public void unsetHadoopProps() {
this.hadoop_props = null;
}
/** Returns true if field hadoop_props is set (has been assigned a value) and false otherwise */
public boolean isSetHadoopProps() {
return this.hadoop_props != null;
}
public void setHadoopPropsIsSet(boolean value) {
if (!value) {
this.hadoop_props = null;
}
}
public int getPaimonPropsSize() {
return (this.paimon_props == null) ? 0 : this.paimon_props.size();
}
public void putToPaimonProps(java.lang.String key, java.lang.String val) {
if (this.paimon_props == null) {
this.paimon_props = new java.util.HashMap<java.lang.String,java.lang.String>();
}
this.paimon_props.put(key, val);
}
@org.apache.thrift.annotation.Nullable
public java.util.Map<java.lang.String,java.lang.String> getPaimonProps() {
return this.paimon_props;
}
public TPaimonMetadataParams setPaimonProps(@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> paimon_props) {
this.paimon_props = paimon_props;
return this;
}
public void unsetPaimonProps() {
this.paimon_props = null;
}
/** Returns true if field paimon_props is set (has been assigned a value) and false otherwise */
public boolean isSetPaimonProps() {
return this.paimon_props != null;
}
public void setPaimonPropsIsSet(boolean value) {
if (!value) {
this.paimon_props = null;
}
}
public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case DB_NAME:
if (value == null) {
unsetDbName();
} else {
setDbName((java.lang.String)value);
}
break;
case TBL_NAME:
if (value == null) {
unsetTblName();
} else {
setTblName((java.lang.String)value);
}
break;
case QUERY_TYPE:
if (value == null) {
unsetQueryType();
} else {
setQueryType((java.lang.String)value);
}
break;
case CTL_ID:
if (value == null) {
unsetCtlId();
} else {
setCtlId((java.lang.Long)value);
}
break;
case DB_ID:
if (value == null) {
unsetDbId();
} else {
setDbId((java.lang.Long)value);
}
break;
case TBL_ID:
if (value == null) {
unsetTblId();
} else {
setTblId((java.lang.Long)value);
}
break;
case SERIALIZED_SPLIT:
if (value == null) {
unsetSerializedSplit();
} else {
setSerializedSplit((java.lang.String)value);
}
break;
case HADOOP_PROPS:
if (value == null) {
unsetHadoopProps();
} else {
setHadoopProps((java.util.Map<java.lang.String,java.lang.String>)value);
}
break;
case PAIMON_PROPS:
if (value == null) {
unsetPaimonProps();
} else {
setPaimonProps((java.util.Map<java.lang.String,java.lang.String>)value);
}
break;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case DB_NAME:
return getDbName();
case TBL_NAME:
return getTblName();
case QUERY_TYPE:
return getQueryType();
case CTL_ID:
return getCtlId();
case DB_ID:
return getDbId();
case TBL_ID:
return getTblId();
case SERIALIZED_SPLIT:
return getSerializedSplit();
case HADOOP_PROPS:
return getHadoopProps();
case PAIMON_PROPS:
return getPaimonProps();
}
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 DB_NAME:
return isSetDbName();
case TBL_NAME:
return isSetTblName();
case QUERY_TYPE:
return isSetQueryType();
case CTL_ID:
return isSetCtlId();
case DB_ID:
return isSetDbId();
case TBL_ID:
return isSetTblId();
case SERIALIZED_SPLIT:
return isSetSerializedSplit();
case HADOOP_PROPS:
return isSetHadoopProps();
case PAIMON_PROPS:
return isSetPaimonProps();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof TPaimonMetadataParams)
return this.equals((TPaimonMetadataParams)that);
return false;
}
public boolean equals(TPaimonMetadataParams that) {
if (that == null)
return false;
if (this == that)
return true;
boolean this_present_db_name = true && this.isSetDbName();
boolean that_present_db_name = true && that.isSetDbName();
if (this_present_db_name || that_present_db_name) {
if (!(this_present_db_name && that_present_db_name))
return false;
if (!this.db_name.equals(that.db_name))
return false;
}
boolean this_present_tbl_name = true && this.isSetTblName();
boolean that_present_tbl_name = true && that.isSetTblName();
if (this_present_tbl_name || that_present_tbl_name) {
if (!(this_present_tbl_name && that_present_tbl_name))
return false;
if (!this.tbl_name.equals(that.tbl_name))
return false;
}
boolean this_present_query_type = true && this.isSetQueryType();
boolean that_present_query_type = true && that.isSetQueryType();
if (this_present_query_type || that_present_query_type) {
if (!(this_present_query_type && that_present_query_type))
return false;
if (!this.query_type.equals(that.query_type))
return false;
}
boolean this_present_ctl_id = true && this.isSetCtlId();
boolean that_present_ctl_id = true && that.isSetCtlId();
if (this_present_ctl_id || that_present_ctl_id) {
if (!(this_present_ctl_id && that_present_ctl_id))
return false;
if (this.ctl_id != that.ctl_id)
return false;
}
boolean this_present_db_id = true && this.isSetDbId();
boolean that_present_db_id = true && that.isSetDbId();
if (this_present_db_id || that_present_db_id) {
if (!(this_present_db_id && that_present_db_id))
return false;
if (this.db_id != that.db_id)
return false;
}
boolean this_present_tbl_id = true && this.isSetTblId();
boolean that_present_tbl_id = true && that.isSetTblId();
if (this_present_tbl_id || that_present_tbl_id) {
if (!(this_present_tbl_id && that_present_tbl_id))
return false;
if (this.tbl_id != that.tbl_id)
return false;
}
boolean this_present_serialized_split = true && this.isSetSerializedSplit();
boolean that_present_serialized_split = true && that.isSetSerializedSplit();
if (this_present_serialized_split || that_present_serialized_split) {
if (!(this_present_serialized_split && that_present_serialized_split))
return false;
if (!this.serialized_split.equals(that.serialized_split))
return false;
}
boolean this_present_hadoop_props = true && this.isSetHadoopProps();
boolean that_present_hadoop_props = true && that.isSetHadoopProps();
if (this_present_hadoop_props || that_present_hadoop_props) {
if (!(this_present_hadoop_props && that_present_hadoop_props))
return false;
if (!this.hadoop_props.equals(that.hadoop_props))
return false;
}
boolean this_present_paimon_props = true && this.isSetPaimonProps();
boolean that_present_paimon_props = true && that.isSetPaimonProps();
if (this_present_paimon_props || that_present_paimon_props) {
if (!(this_present_paimon_props && that_present_paimon_props))
return false;
if (!this.paimon_props.equals(that.paimon_props))
return false;
}
return true;
}
@Override
public int hashCode() {
int hashCode = 1;
hashCode = hashCode * 8191 + ((isSetDbName()) ? 131071 : 524287);
if (isSetDbName())
hashCode = hashCode * 8191 + db_name.hashCode();
hashCode = hashCode * 8191 + ((isSetTblName()) ? 131071 : 524287);
if (isSetTblName())
hashCode = hashCode * 8191 + tbl_name.hashCode();
hashCode = hashCode * 8191 + ((isSetQueryType()) ? 131071 : 524287);
if (isSetQueryType())
hashCode = hashCode * 8191 + query_type.hashCode();
hashCode = hashCode * 8191 + ((isSetCtlId()) ? 131071 : 524287);
if (isSetCtlId())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(ctl_id);
hashCode = hashCode * 8191 + ((isSetDbId()) ? 131071 : 524287);
if (isSetDbId())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(db_id);
hashCode = hashCode * 8191 + ((isSetTblId()) ? 131071 : 524287);
if (isSetTblId())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(tbl_id);
hashCode = hashCode * 8191 + ((isSetSerializedSplit()) ? 131071 : 524287);
if (isSetSerializedSplit())
hashCode = hashCode * 8191 + serialized_split.hashCode();
hashCode = hashCode * 8191 + ((isSetHadoopProps()) ? 131071 : 524287);
if (isSetHadoopProps())
hashCode = hashCode * 8191 + hadoop_props.hashCode();
hashCode = hashCode * 8191 + ((isSetPaimonProps()) ? 131071 : 524287);
if (isSetPaimonProps())
hashCode = hashCode * 8191 + paimon_props.hashCode();
return hashCode;
}
@Override
public int compareTo(TPaimonMetadataParams other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = java.lang.Boolean.compare(isSetDbName(), other.isSetDbName());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetDbName()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.db_name, other.db_name);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTblName(), other.isSetTblName());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTblName()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tbl_name, other.tbl_name);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetQueryType(), other.isSetQueryType());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetQueryType()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.query_type, other.query_type);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetCtlId(), other.isSetCtlId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetCtlId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ctl_id, other.ctl_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetDbId(), other.isSetDbId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetDbId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.db_id, other.db_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTblId(), other.isSetTblId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTblId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tbl_id, other.tbl_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetSerializedSplit(), other.isSetSerializedSplit());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetSerializedSplit()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.serialized_split, other.serialized_split);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetHadoopProps(), other.isSetHadoopProps());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetHadoopProps()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.hadoop_props, other.hadoop_props);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetPaimonProps(), other.isSetPaimonProps());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPaimonProps()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paimon_props, other.paimon_props);
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("TPaimonMetadataParams(");
boolean first = true;
if (isSetDbName()) {
sb.append("db_name:");
if (this.db_name == null) {
sb.append("null");
} else {
sb.append(this.db_name);
}
first = false;
}
if (isSetTblName()) {
if (!first) sb.append(", ");
sb.append("tbl_name:");
if (this.tbl_name == null) {
sb.append("null");
} else {
sb.append(this.tbl_name);
}
first = false;
}
if (isSetQueryType()) {
if (!first) sb.append(", ");
sb.append("query_type:");
if (this.query_type == null) {
sb.append("null");
} else {
sb.append(this.query_type);
}
first = false;
}
if (isSetCtlId()) {
if (!first) sb.append(", ");
sb.append("ctl_id:");
sb.append(this.ctl_id);
first = false;
}
if (isSetDbId()) {
if (!first) sb.append(", ");
sb.append("db_id:");
sb.append(this.db_id);
first = false;
}
if (isSetTblId()) {
if (!first) sb.append(", ");
sb.append("tbl_id:");
sb.append(this.tbl_id);
first = false;
}
if (isSetSerializedSplit()) {
if (!first) sb.append(", ");
sb.append("serialized_split:");
if (this.serialized_split == null) {
sb.append("null");
} else {
sb.append(this.serialized_split);
}
first = false;
}
if (isSetHadoopProps()) {
if (!first) sb.append(", ");
sb.append("hadoop_props:");
if (this.hadoop_props == null) {
sb.append("null");
} else {
sb.append(this.hadoop_props);
}
first = false;
}
if (isSetPaimonProps()) {
if (!first) sb.append(", ");
sb.append("paimon_props:");
if (this.paimon_props == null) {
sb.append("null");
} else {
sb.append(this.paimon_props);
}
first = false;
}
sb.append(")");
return sb.toString();
}
public void validate() throws org.apache.thrift.TException {
// check for required fields
// check for sub-struct validity
}
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 TPaimonMetadataParamsStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TPaimonMetadataParamsStandardScheme getScheme() {
return new TPaimonMetadataParamsStandardScheme();
}
}
private static class TPaimonMetadataParamsStandardScheme extends org.apache.thrift.scheme.StandardScheme<TPaimonMetadataParams> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TPaimonMetadataParams 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: // DB_NAME
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.db_name = iprot.readString();
struct.setDbNameIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // TBL_NAME
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.tbl_name = iprot.readString();
struct.setTblNameIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // QUERY_TYPE
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.query_type = iprot.readString();
struct.setQueryTypeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // CTL_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.ctl_id = iprot.readI64();
struct.setCtlIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // DB_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.db_id = iprot.readI64();
struct.setDbIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // TBL_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.tbl_id = iprot.readI64();
struct.setTblIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // SERIALIZED_SPLIT
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.serialized_split = iprot.readString();
struct.setSerializedSplitIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // HADOOP_PROPS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map352 = iprot.readMapBegin();
struct.hadoop_props = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map352.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key353;
@org.apache.thrift.annotation.Nullable java.lang.String _val354;
for (int _i355 = 0; _i355 < _map352.size; ++_i355)
{
_key353 = iprot.readString();
_val354 = iprot.readString();
struct.hadoop_props.put(_key353, _val354);
}
iprot.readMapEnd();
}
struct.setHadoopPropsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // PAIMON_PROPS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map356 = iprot.readMapBegin();
struct.paimon_props = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map356.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key357;
@org.apache.thrift.annotation.Nullable java.lang.String _val358;
for (int _i359 = 0; _i359 < _map356.size; ++_i359)
{
_key357 = iprot.readString();
_val358 = iprot.readString();
struct.paimon_props.put(_key357, _val358);
}
iprot.readMapEnd();
}
struct.setPaimonPropsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
iprot.readFieldEnd();
}
iprot.readStructEnd();
// check for required fields of primitive type, which can't be checked in the validate method
struct.validate();
}
public void write(org.apache.thrift.protocol.TProtocol oprot, TPaimonMetadataParams struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.db_name != null) {
if (struct.isSetDbName()) {
oprot.writeFieldBegin(DB_NAME_FIELD_DESC);
oprot.writeString(struct.db_name);
oprot.writeFieldEnd();
}
}
if (struct.tbl_name != null) {
if (struct.isSetTblName()) {
oprot.writeFieldBegin(TBL_NAME_FIELD_DESC);
oprot.writeString(struct.tbl_name);
oprot.writeFieldEnd();
}
}
if (struct.query_type != null) {
if (struct.isSetQueryType()) {
oprot.writeFieldBegin(QUERY_TYPE_FIELD_DESC);
oprot.writeString(struct.query_type);
oprot.writeFieldEnd();
}
}
if (struct.isSetCtlId()) {
oprot.writeFieldBegin(CTL_ID_FIELD_DESC);
oprot.writeI64(struct.ctl_id);
oprot.writeFieldEnd();
}
if (struct.isSetDbId()) {
oprot.writeFieldBegin(DB_ID_FIELD_DESC);
oprot.writeI64(struct.db_id);
oprot.writeFieldEnd();
}
if (struct.isSetTblId()) {
oprot.writeFieldBegin(TBL_ID_FIELD_DESC);
oprot.writeI64(struct.tbl_id);
oprot.writeFieldEnd();
}
if (struct.serialized_split != null) {
if (struct.isSetSerializedSplit()) {
oprot.writeFieldBegin(SERIALIZED_SPLIT_FIELD_DESC);
oprot.writeString(struct.serialized_split);
oprot.writeFieldEnd();
}
}
if (struct.hadoop_props != null) {
if (struct.isSetHadoopProps()) {
oprot.writeFieldBegin(HADOOP_PROPS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.hadoop_props.size()));
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter360 : struct.hadoop_props.entrySet())
{
oprot.writeString(_iter360.getKey());
oprot.writeString(_iter360.getValue());
}
oprot.writeMapEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.paimon_props != null) {
if (struct.isSetPaimonProps()) {
oprot.writeFieldBegin(PAIMON_PROPS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.paimon_props.size()));
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter361 : struct.paimon_props.entrySet())
{
oprot.writeString(_iter361.getKey());
oprot.writeString(_iter361.getValue());
}
oprot.writeMapEnd();
}
oprot.writeFieldEnd();
}
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class TPaimonMetadataParamsTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TPaimonMetadataParamsTupleScheme getScheme() {
return new TPaimonMetadataParamsTupleScheme();
}
}
private static class TPaimonMetadataParamsTupleScheme extends org.apache.thrift.scheme.TupleScheme<TPaimonMetadataParams> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TPaimonMetadataParams struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetDbName()) {
optionals.set(0);
}
if (struct.isSetTblName()) {
optionals.set(1);
}
if (struct.isSetQueryType()) {
optionals.set(2);
}
if (struct.isSetCtlId()) {
optionals.set(3);
}
if (struct.isSetDbId()) {
optionals.set(4);
}
if (struct.isSetTblId()) {
optionals.set(5);
}
if (struct.isSetSerializedSplit()) {
optionals.set(6);
}
if (struct.isSetHadoopProps()) {
optionals.set(7);
}
if (struct.isSetPaimonProps()) {
optionals.set(8);
}
oprot.writeBitSet(optionals, 9);
if (struct.isSetDbName()) {
oprot.writeString(struct.db_name);
}
if (struct.isSetTblName()) {
oprot.writeString(struct.tbl_name);
}
if (struct.isSetQueryType()) {
oprot.writeString(struct.query_type);
}
if (struct.isSetCtlId()) {
oprot.writeI64(struct.ctl_id);
}
if (struct.isSetDbId()) {
oprot.writeI64(struct.db_id);
}
if (struct.isSetTblId()) {
oprot.writeI64(struct.tbl_id);
}
if (struct.isSetSerializedSplit()) {
oprot.writeString(struct.serialized_split);
}
if (struct.isSetHadoopProps()) {
{
oprot.writeI32(struct.hadoop_props.size());
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter362 : struct.hadoop_props.entrySet())
{
oprot.writeString(_iter362.getKey());
oprot.writeString(_iter362.getValue());
}
}
}
if (struct.isSetPaimonProps()) {
{
oprot.writeI32(struct.paimon_props.size());
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter363 : struct.paimon_props.entrySet())
{
oprot.writeString(_iter363.getKey());
oprot.writeString(_iter363.getValue());
}
}
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TPaimonMetadataParams struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet incoming = iprot.readBitSet(9);
if (incoming.get(0)) {
struct.db_name = iprot.readString();
struct.setDbNameIsSet(true);
}
if (incoming.get(1)) {
struct.tbl_name = iprot.readString();
struct.setTblNameIsSet(true);
}
if (incoming.get(2)) {
struct.query_type = iprot.readString();
struct.setQueryTypeIsSet(true);
}
if (incoming.get(3)) {
struct.ctl_id = iprot.readI64();
struct.setCtlIdIsSet(true);
}
if (incoming.get(4)) {
struct.db_id = iprot.readI64();
struct.setDbIdIsSet(true);
}
if (incoming.get(5)) {
struct.tbl_id = iprot.readI64();
struct.setTblIdIsSet(true);
}
if (incoming.get(6)) {
struct.serialized_split = iprot.readString();
struct.setSerializedSplitIsSet(true);
}
if (incoming.get(7)) {
{
org.apache.thrift.protocol.TMap _map364 = iprot.readMapBegin(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING);
struct.hadoop_props = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map364.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key365;
@org.apache.thrift.annotation.Nullable java.lang.String _val366;
for (int _i367 = 0; _i367 < _map364.size; ++_i367)
{
_key365 = iprot.readString();
_val366 = iprot.readString();
struct.hadoop_props.put(_key365, _val366);
}
}
struct.setHadoopPropsIsSet(true);
}
if (incoming.get(8)) {
{
org.apache.thrift.protocol.TMap _map368 = iprot.readMapBegin(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING);
struct.paimon_props = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map368.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key369;
@org.apache.thrift.annotation.Nullable java.lang.String _val370;
for (int _i371 = 0; _i371 < _map368.size; ++_i371)
{
_key369 = iprot.readString();
_val370 = iprot.readString();
struct.paimon_props.put(_key369, _val370);
}
}
struct.setPaimonPropsIsSet(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();
}
}