TTableFormatFileDesc.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 TTableFormatFileDesc implements org.apache.thrift.TBase<TTableFormatFileDesc, TTableFormatFileDesc._Fields>, java.io.Serializable, Cloneable, Comparable<TTableFormatFileDesc> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTableFormatFileDesc");
private static final org.apache.thrift.protocol.TField TABLE_FORMAT_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("table_format_type", org.apache.thrift.protocol.TType.STRING, (short)1);
private static final org.apache.thrift.protocol.TField ICEBERG_PARAMS_FIELD_DESC = new org.apache.thrift.protocol.TField("iceberg_params", org.apache.thrift.protocol.TType.STRUCT, (short)2);
private static final org.apache.thrift.protocol.TField HUDI_PARAMS_FIELD_DESC = new org.apache.thrift.protocol.TField("hudi_params", org.apache.thrift.protocol.TType.STRUCT, (short)3);
private static final org.apache.thrift.protocol.TField PAIMON_PARAMS_FIELD_DESC = new org.apache.thrift.protocol.TField("paimon_params", org.apache.thrift.protocol.TType.STRUCT, (short)4);
private static final org.apache.thrift.protocol.TField TRANSACTIONAL_HIVE_PARAMS_FIELD_DESC = new org.apache.thrift.protocol.TField("transactional_hive_params", org.apache.thrift.protocol.TType.STRUCT, (short)5);
private static final org.apache.thrift.protocol.TField MAX_COMPUTE_PARAMS_FIELD_DESC = new org.apache.thrift.protocol.TField("max_compute_params", org.apache.thrift.protocol.TType.STRUCT, (short)6);
private static final org.apache.thrift.protocol.TField TRINO_CONNECTOR_PARAMS_FIELD_DESC = new org.apache.thrift.protocol.TField("trino_connector_params", org.apache.thrift.protocol.TType.STRUCT, (short)7);
private static final org.apache.thrift.protocol.TField LAKESOUL_PARAMS_FIELD_DESC = new org.apache.thrift.protocol.TField("lakesoul_params", org.apache.thrift.protocol.TType.STRUCT, (short)8);
private static final org.apache.thrift.protocol.TField TABLE_LEVEL_ROW_COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("table_level_row_count", org.apache.thrift.protocol.TType.I64, (short)9);
private static final org.apache.thrift.protocol.TField REMOTE_DORIS_PARAMS_FIELD_DESC = new org.apache.thrift.protocol.TField("remote_doris_params", org.apache.thrift.protocol.TType.STRUCT, (short)10);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TTableFormatFileDescStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TTableFormatFileDescTupleSchemeFactory();
public @org.apache.thrift.annotation.Nullable java.lang.String table_format_type; // optional
public @org.apache.thrift.annotation.Nullable TIcebergFileDesc iceberg_params; // optional
public @org.apache.thrift.annotation.Nullable THudiFileDesc hudi_params; // optional
public @org.apache.thrift.annotation.Nullable TPaimonFileDesc paimon_params; // optional
public @org.apache.thrift.annotation.Nullable TTransactionalHiveDesc transactional_hive_params; // optional
public @org.apache.thrift.annotation.Nullable TMaxComputeFileDesc max_compute_params; // optional
public @org.apache.thrift.annotation.Nullable TTrinoConnectorFileDesc trino_connector_params; // optional
public @org.apache.thrift.annotation.Nullable TLakeSoulFileDesc lakesoul_params; // optional
public long table_level_row_count; // optional
public @org.apache.thrift.annotation.Nullable TRemoteDorisFileDesc remote_doris_params; // 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 {
TABLE_FORMAT_TYPE((short)1, "table_format_type"),
ICEBERG_PARAMS((short)2, "iceberg_params"),
HUDI_PARAMS((short)3, "hudi_params"),
PAIMON_PARAMS((short)4, "paimon_params"),
TRANSACTIONAL_HIVE_PARAMS((short)5, "transactional_hive_params"),
MAX_COMPUTE_PARAMS((short)6, "max_compute_params"),
TRINO_CONNECTOR_PARAMS((short)7, "trino_connector_params"),
LAKESOUL_PARAMS((short)8, "lakesoul_params"),
TABLE_LEVEL_ROW_COUNT((short)9, "table_level_row_count"),
REMOTE_DORIS_PARAMS((short)10, "remote_doris_params");
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: // TABLE_FORMAT_TYPE
return TABLE_FORMAT_TYPE;
case 2: // ICEBERG_PARAMS
return ICEBERG_PARAMS;
case 3: // HUDI_PARAMS
return HUDI_PARAMS;
case 4: // PAIMON_PARAMS
return PAIMON_PARAMS;
case 5: // TRANSACTIONAL_HIVE_PARAMS
return TRANSACTIONAL_HIVE_PARAMS;
case 6: // MAX_COMPUTE_PARAMS
return MAX_COMPUTE_PARAMS;
case 7: // TRINO_CONNECTOR_PARAMS
return TRINO_CONNECTOR_PARAMS;
case 8: // LAKESOUL_PARAMS
return LAKESOUL_PARAMS;
case 9: // TABLE_LEVEL_ROW_COUNT
return TABLE_LEVEL_ROW_COUNT;
case 10: // REMOTE_DORIS_PARAMS
return REMOTE_DORIS_PARAMS;
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 __TABLE_LEVEL_ROW_COUNT_ISSET_ID = 0;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.TABLE_FORMAT_TYPE,_Fields.ICEBERG_PARAMS,_Fields.HUDI_PARAMS,_Fields.PAIMON_PARAMS,_Fields.TRANSACTIONAL_HIVE_PARAMS,_Fields.MAX_COMPUTE_PARAMS,_Fields.TRINO_CONNECTOR_PARAMS,_Fields.LAKESOUL_PARAMS,_Fields.TABLE_LEVEL_ROW_COUNT,_Fields.REMOTE_DORIS_PARAMS};
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.TABLE_FORMAT_TYPE, new org.apache.thrift.meta_data.FieldMetaData("table_format_type", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.ICEBERG_PARAMS, new org.apache.thrift.meta_data.FieldMetaData("iceberg_params", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TIcebergFileDesc.class)));
tmpMap.put(_Fields.HUDI_PARAMS, new org.apache.thrift.meta_data.FieldMetaData("hudi_params", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, THudiFileDesc.class)));
tmpMap.put(_Fields.PAIMON_PARAMS, new org.apache.thrift.meta_data.FieldMetaData("paimon_params", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TPaimonFileDesc.class)));
tmpMap.put(_Fields.TRANSACTIONAL_HIVE_PARAMS, new org.apache.thrift.meta_data.FieldMetaData("transactional_hive_params", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TTransactionalHiveDesc.class)));
tmpMap.put(_Fields.MAX_COMPUTE_PARAMS, new org.apache.thrift.meta_data.FieldMetaData("max_compute_params", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TMaxComputeFileDesc.class)));
tmpMap.put(_Fields.TRINO_CONNECTOR_PARAMS, new org.apache.thrift.meta_data.FieldMetaData("trino_connector_params", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TTrinoConnectorFileDesc.class)));
tmpMap.put(_Fields.LAKESOUL_PARAMS, new org.apache.thrift.meta_data.FieldMetaData("lakesoul_params", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TLakeSoulFileDesc.class)));
tmpMap.put(_Fields.TABLE_LEVEL_ROW_COUNT, new org.apache.thrift.meta_data.FieldMetaData("table_level_row_count", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.REMOTE_DORIS_PARAMS, new org.apache.thrift.meta_data.FieldMetaData("remote_doris_params", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TRemoteDorisFileDesc.class)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TTableFormatFileDesc.class, metaDataMap);
}
public TTableFormatFileDesc() {
this.table_level_row_count = -1L;
}
/**
* Performs a deep copy on <i>other</i>.
*/
public TTableFormatFileDesc(TTableFormatFileDesc other) {
__isset_bitfield = other.__isset_bitfield;
if (other.isSetTableFormatType()) {
this.table_format_type = other.table_format_type;
}
if (other.isSetIcebergParams()) {
this.iceberg_params = new TIcebergFileDesc(other.iceberg_params);
}
if (other.isSetHudiParams()) {
this.hudi_params = new THudiFileDesc(other.hudi_params);
}
if (other.isSetPaimonParams()) {
this.paimon_params = new TPaimonFileDesc(other.paimon_params);
}
if (other.isSetTransactionalHiveParams()) {
this.transactional_hive_params = new TTransactionalHiveDesc(other.transactional_hive_params);
}
if (other.isSetMaxComputeParams()) {
this.max_compute_params = new TMaxComputeFileDesc(other.max_compute_params);
}
if (other.isSetTrinoConnectorParams()) {
this.trino_connector_params = new TTrinoConnectorFileDesc(other.trino_connector_params);
}
if (other.isSetLakesoulParams()) {
this.lakesoul_params = new TLakeSoulFileDesc(other.lakesoul_params);
}
this.table_level_row_count = other.table_level_row_count;
if (other.isSetRemoteDorisParams()) {
this.remote_doris_params = new TRemoteDorisFileDesc(other.remote_doris_params);
}
}
public TTableFormatFileDesc deepCopy() {
return new TTableFormatFileDesc(this);
}
@Override
public void clear() {
this.table_format_type = null;
this.iceberg_params = null;
this.hudi_params = null;
this.paimon_params = null;
this.transactional_hive_params = null;
this.max_compute_params = null;
this.trino_connector_params = null;
this.lakesoul_params = null;
this.table_level_row_count = -1L;
this.remote_doris_params = null;
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getTableFormatType() {
return this.table_format_type;
}
public TTableFormatFileDesc setTableFormatType(@org.apache.thrift.annotation.Nullable java.lang.String table_format_type) {
this.table_format_type = table_format_type;
return this;
}
public void unsetTableFormatType() {
this.table_format_type = null;
}
/** Returns true if field table_format_type is set (has been assigned a value) and false otherwise */
public boolean isSetTableFormatType() {
return this.table_format_type != null;
}
public void setTableFormatTypeIsSet(boolean value) {
if (!value) {
this.table_format_type = null;
}
}
@org.apache.thrift.annotation.Nullable
public TIcebergFileDesc getIcebergParams() {
return this.iceberg_params;
}
public TTableFormatFileDesc setIcebergParams(@org.apache.thrift.annotation.Nullable TIcebergFileDesc iceberg_params) {
this.iceberg_params = iceberg_params;
return this;
}
public void unsetIcebergParams() {
this.iceberg_params = null;
}
/** Returns true if field iceberg_params is set (has been assigned a value) and false otherwise */
public boolean isSetIcebergParams() {
return this.iceberg_params != null;
}
public void setIcebergParamsIsSet(boolean value) {
if (!value) {
this.iceberg_params = null;
}
}
@org.apache.thrift.annotation.Nullable
public THudiFileDesc getHudiParams() {
return this.hudi_params;
}
public TTableFormatFileDesc setHudiParams(@org.apache.thrift.annotation.Nullable THudiFileDesc hudi_params) {
this.hudi_params = hudi_params;
return this;
}
public void unsetHudiParams() {
this.hudi_params = null;
}
/** Returns true if field hudi_params is set (has been assigned a value) and false otherwise */
public boolean isSetHudiParams() {
return this.hudi_params != null;
}
public void setHudiParamsIsSet(boolean value) {
if (!value) {
this.hudi_params = null;
}
}
@org.apache.thrift.annotation.Nullable
public TPaimonFileDesc getPaimonParams() {
return this.paimon_params;
}
public TTableFormatFileDesc setPaimonParams(@org.apache.thrift.annotation.Nullable TPaimonFileDesc paimon_params) {
this.paimon_params = paimon_params;
return this;
}
public void unsetPaimonParams() {
this.paimon_params = null;
}
/** Returns true if field paimon_params is set (has been assigned a value) and false otherwise */
public boolean isSetPaimonParams() {
return this.paimon_params != null;
}
public void setPaimonParamsIsSet(boolean value) {
if (!value) {
this.paimon_params = null;
}
}
@org.apache.thrift.annotation.Nullable
public TTransactionalHiveDesc getTransactionalHiveParams() {
return this.transactional_hive_params;
}
public TTableFormatFileDesc setTransactionalHiveParams(@org.apache.thrift.annotation.Nullable TTransactionalHiveDesc transactional_hive_params) {
this.transactional_hive_params = transactional_hive_params;
return this;
}
public void unsetTransactionalHiveParams() {
this.transactional_hive_params = null;
}
/** Returns true if field transactional_hive_params is set (has been assigned a value) and false otherwise */
public boolean isSetTransactionalHiveParams() {
return this.transactional_hive_params != null;
}
public void setTransactionalHiveParamsIsSet(boolean value) {
if (!value) {
this.transactional_hive_params = null;
}
}
@org.apache.thrift.annotation.Nullable
public TMaxComputeFileDesc getMaxComputeParams() {
return this.max_compute_params;
}
public TTableFormatFileDesc setMaxComputeParams(@org.apache.thrift.annotation.Nullable TMaxComputeFileDesc max_compute_params) {
this.max_compute_params = max_compute_params;
return this;
}
public void unsetMaxComputeParams() {
this.max_compute_params = null;
}
/** Returns true if field max_compute_params is set (has been assigned a value) and false otherwise */
public boolean isSetMaxComputeParams() {
return this.max_compute_params != null;
}
public void setMaxComputeParamsIsSet(boolean value) {
if (!value) {
this.max_compute_params = null;
}
}
@org.apache.thrift.annotation.Nullable
public TTrinoConnectorFileDesc getTrinoConnectorParams() {
return this.trino_connector_params;
}
public TTableFormatFileDesc setTrinoConnectorParams(@org.apache.thrift.annotation.Nullable TTrinoConnectorFileDesc trino_connector_params) {
this.trino_connector_params = trino_connector_params;
return this;
}
public void unsetTrinoConnectorParams() {
this.trino_connector_params = null;
}
/** Returns true if field trino_connector_params is set (has been assigned a value) and false otherwise */
public boolean isSetTrinoConnectorParams() {
return this.trino_connector_params != null;
}
public void setTrinoConnectorParamsIsSet(boolean value) {
if (!value) {
this.trino_connector_params = null;
}
}
@org.apache.thrift.annotation.Nullable
public TLakeSoulFileDesc getLakesoulParams() {
return this.lakesoul_params;
}
public TTableFormatFileDesc setLakesoulParams(@org.apache.thrift.annotation.Nullable TLakeSoulFileDesc lakesoul_params) {
this.lakesoul_params = lakesoul_params;
return this;
}
public void unsetLakesoulParams() {
this.lakesoul_params = null;
}
/** Returns true if field lakesoul_params is set (has been assigned a value) and false otherwise */
public boolean isSetLakesoulParams() {
return this.lakesoul_params != null;
}
public void setLakesoulParamsIsSet(boolean value) {
if (!value) {
this.lakesoul_params = null;
}
}
public long getTableLevelRowCount() {
return this.table_level_row_count;
}
public TTableFormatFileDesc setTableLevelRowCount(long table_level_row_count) {
this.table_level_row_count = table_level_row_count;
setTableLevelRowCountIsSet(true);
return this;
}
public void unsetTableLevelRowCount() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __TABLE_LEVEL_ROW_COUNT_ISSET_ID);
}
/** Returns true if field table_level_row_count is set (has been assigned a value) and false otherwise */
public boolean isSetTableLevelRowCount() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __TABLE_LEVEL_ROW_COUNT_ISSET_ID);
}
public void setTableLevelRowCountIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __TABLE_LEVEL_ROW_COUNT_ISSET_ID, value);
}
@org.apache.thrift.annotation.Nullable
public TRemoteDorisFileDesc getRemoteDorisParams() {
return this.remote_doris_params;
}
public TTableFormatFileDesc setRemoteDorisParams(@org.apache.thrift.annotation.Nullable TRemoteDorisFileDesc remote_doris_params) {
this.remote_doris_params = remote_doris_params;
return this;
}
public void unsetRemoteDorisParams() {
this.remote_doris_params = null;
}
/** Returns true if field remote_doris_params is set (has been assigned a value) and false otherwise */
public boolean isSetRemoteDorisParams() {
return this.remote_doris_params != null;
}
public void setRemoteDorisParamsIsSet(boolean value) {
if (!value) {
this.remote_doris_params = null;
}
}
public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case TABLE_FORMAT_TYPE:
if (value == null) {
unsetTableFormatType();
} else {
setTableFormatType((java.lang.String)value);
}
break;
case ICEBERG_PARAMS:
if (value == null) {
unsetIcebergParams();
} else {
setIcebergParams((TIcebergFileDesc)value);
}
break;
case HUDI_PARAMS:
if (value == null) {
unsetHudiParams();
} else {
setHudiParams((THudiFileDesc)value);
}
break;
case PAIMON_PARAMS:
if (value == null) {
unsetPaimonParams();
} else {
setPaimonParams((TPaimonFileDesc)value);
}
break;
case TRANSACTIONAL_HIVE_PARAMS:
if (value == null) {
unsetTransactionalHiveParams();
} else {
setTransactionalHiveParams((TTransactionalHiveDesc)value);
}
break;
case MAX_COMPUTE_PARAMS:
if (value == null) {
unsetMaxComputeParams();
} else {
setMaxComputeParams((TMaxComputeFileDesc)value);
}
break;
case TRINO_CONNECTOR_PARAMS:
if (value == null) {
unsetTrinoConnectorParams();
} else {
setTrinoConnectorParams((TTrinoConnectorFileDesc)value);
}
break;
case LAKESOUL_PARAMS:
if (value == null) {
unsetLakesoulParams();
} else {
setLakesoulParams((TLakeSoulFileDesc)value);
}
break;
case TABLE_LEVEL_ROW_COUNT:
if (value == null) {
unsetTableLevelRowCount();
} else {
setTableLevelRowCount((java.lang.Long)value);
}
break;
case REMOTE_DORIS_PARAMS:
if (value == null) {
unsetRemoteDorisParams();
} else {
setRemoteDorisParams((TRemoteDorisFileDesc)value);
}
break;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case TABLE_FORMAT_TYPE:
return getTableFormatType();
case ICEBERG_PARAMS:
return getIcebergParams();
case HUDI_PARAMS:
return getHudiParams();
case PAIMON_PARAMS:
return getPaimonParams();
case TRANSACTIONAL_HIVE_PARAMS:
return getTransactionalHiveParams();
case MAX_COMPUTE_PARAMS:
return getMaxComputeParams();
case TRINO_CONNECTOR_PARAMS:
return getTrinoConnectorParams();
case LAKESOUL_PARAMS:
return getLakesoulParams();
case TABLE_LEVEL_ROW_COUNT:
return getTableLevelRowCount();
case REMOTE_DORIS_PARAMS:
return getRemoteDorisParams();
}
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 TABLE_FORMAT_TYPE:
return isSetTableFormatType();
case ICEBERG_PARAMS:
return isSetIcebergParams();
case HUDI_PARAMS:
return isSetHudiParams();
case PAIMON_PARAMS:
return isSetPaimonParams();
case TRANSACTIONAL_HIVE_PARAMS:
return isSetTransactionalHiveParams();
case MAX_COMPUTE_PARAMS:
return isSetMaxComputeParams();
case TRINO_CONNECTOR_PARAMS:
return isSetTrinoConnectorParams();
case LAKESOUL_PARAMS:
return isSetLakesoulParams();
case TABLE_LEVEL_ROW_COUNT:
return isSetTableLevelRowCount();
case REMOTE_DORIS_PARAMS:
return isSetRemoteDorisParams();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof TTableFormatFileDesc)
return this.equals((TTableFormatFileDesc)that);
return false;
}
public boolean equals(TTableFormatFileDesc that) {
if (that == null)
return false;
if (this == that)
return true;
boolean this_present_table_format_type = true && this.isSetTableFormatType();
boolean that_present_table_format_type = true && that.isSetTableFormatType();
if (this_present_table_format_type || that_present_table_format_type) {
if (!(this_present_table_format_type && that_present_table_format_type))
return false;
if (!this.table_format_type.equals(that.table_format_type))
return false;
}
boolean this_present_iceberg_params = true && this.isSetIcebergParams();
boolean that_present_iceberg_params = true && that.isSetIcebergParams();
if (this_present_iceberg_params || that_present_iceberg_params) {
if (!(this_present_iceberg_params && that_present_iceberg_params))
return false;
if (!this.iceberg_params.equals(that.iceberg_params))
return false;
}
boolean this_present_hudi_params = true && this.isSetHudiParams();
boolean that_present_hudi_params = true && that.isSetHudiParams();
if (this_present_hudi_params || that_present_hudi_params) {
if (!(this_present_hudi_params && that_present_hudi_params))
return false;
if (!this.hudi_params.equals(that.hudi_params))
return false;
}
boolean this_present_paimon_params = true && this.isSetPaimonParams();
boolean that_present_paimon_params = true && that.isSetPaimonParams();
if (this_present_paimon_params || that_present_paimon_params) {
if (!(this_present_paimon_params && that_present_paimon_params))
return false;
if (!this.paimon_params.equals(that.paimon_params))
return false;
}
boolean this_present_transactional_hive_params = true && this.isSetTransactionalHiveParams();
boolean that_present_transactional_hive_params = true && that.isSetTransactionalHiveParams();
if (this_present_transactional_hive_params || that_present_transactional_hive_params) {
if (!(this_present_transactional_hive_params && that_present_transactional_hive_params))
return false;
if (!this.transactional_hive_params.equals(that.transactional_hive_params))
return false;
}
boolean this_present_max_compute_params = true && this.isSetMaxComputeParams();
boolean that_present_max_compute_params = true && that.isSetMaxComputeParams();
if (this_present_max_compute_params || that_present_max_compute_params) {
if (!(this_present_max_compute_params && that_present_max_compute_params))
return false;
if (!this.max_compute_params.equals(that.max_compute_params))
return false;
}
boolean this_present_trino_connector_params = true && this.isSetTrinoConnectorParams();
boolean that_present_trino_connector_params = true && that.isSetTrinoConnectorParams();
if (this_present_trino_connector_params || that_present_trino_connector_params) {
if (!(this_present_trino_connector_params && that_present_trino_connector_params))
return false;
if (!this.trino_connector_params.equals(that.trino_connector_params))
return false;
}
boolean this_present_lakesoul_params = true && this.isSetLakesoulParams();
boolean that_present_lakesoul_params = true && that.isSetLakesoulParams();
if (this_present_lakesoul_params || that_present_lakesoul_params) {
if (!(this_present_lakesoul_params && that_present_lakesoul_params))
return false;
if (!this.lakesoul_params.equals(that.lakesoul_params))
return false;
}
boolean this_present_table_level_row_count = true && this.isSetTableLevelRowCount();
boolean that_present_table_level_row_count = true && that.isSetTableLevelRowCount();
if (this_present_table_level_row_count || that_present_table_level_row_count) {
if (!(this_present_table_level_row_count && that_present_table_level_row_count))
return false;
if (this.table_level_row_count != that.table_level_row_count)
return false;
}
boolean this_present_remote_doris_params = true && this.isSetRemoteDorisParams();
boolean that_present_remote_doris_params = true && that.isSetRemoteDorisParams();
if (this_present_remote_doris_params || that_present_remote_doris_params) {
if (!(this_present_remote_doris_params && that_present_remote_doris_params))
return false;
if (!this.remote_doris_params.equals(that.remote_doris_params))
return false;
}
return true;
}
@Override
public int hashCode() {
int hashCode = 1;
hashCode = hashCode * 8191 + ((isSetTableFormatType()) ? 131071 : 524287);
if (isSetTableFormatType())
hashCode = hashCode * 8191 + table_format_type.hashCode();
hashCode = hashCode * 8191 + ((isSetIcebergParams()) ? 131071 : 524287);
if (isSetIcebergParams())
hashCode = hashCode * 8191 + iceberg_params.hashCode();
hashCode = hashCode * 8191 + ((isSetHudiParams()) ? 131071 : 524287);
if (isSetHudiParams())
hashCode = hashCode * 8191 + hudi_params.hashCode();
hashCode = hashCode * 8191 + ((isSetPaimonParams()) ? 131071 : 524287);
if (isSetPaimonParams())
hashCode = hashCode * 8191 + paimon_params.hashCode();
hashCode = hashCode * 8191 + ((isSetTransactionalHiveParams()) ? 131071 : 524287);
if (isSetTransactionalHiveParams())
hashCode = hashCode * 8191 + transactional_hive_params.hashCode();
hashCode = hashCode * 8191 + ((isSetMaxComputeParams()) ? 131071 : 524287);
if (isSetMaxComputeParams())
hashCode = hashCode * 8191 + max_compute_params.hashCode();
hashCode = hashCode * 8191 + ((isSetTrinoConnectorParams()) ? 131071 : 524287);
if (isSetTrinoConnectorParams())
hashCode = hashCode * 8191 + trino_connector_params.hashCode();
hashCode = hashCode * 8191 + ((isSetLakesoulParams()) ? 131071 : 524287);
if (isSetLakesoulParams())
hashCode = hashCode * 8191 + lakesoul_params.hashCode();
hashCode = hashCode * 8191 + ((isSetTableLevelRowCount()) ? 131071 : 524287);
if (isSetTableLevelRowCount())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(table_level_row_count);
hashCode = hashCode * 8191 + ((isSetRemoteDorisParams()) ? 131071 : 524287);
if (isSetRemoteDorisParams())
hashCode = hashCode * 8191 + remote_doris_params.hashCode();
return hashCode;
}
@Override
public int compareTo(TTableFormatFileDesc other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = java.lang.Boolean.compare(isSetTableFormatType(), other.isSetTableFormatType());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTableFormatType()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.table_format_type, other.table_format_type);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetIcebergParams(), other.isSetIcebergParams());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetIcebergParams()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.iceberg_params, other.iceberg_params);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetHudiParams(), other.isSetHudiParams());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetHudiParams()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.hudi_params, other.hudi_params);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetPaimonParams(), other.isSetPaimonParams());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPaimonParams()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paimon_params, other.paimon_params);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTransactionalHiveParams(), other.isSetTransactionalHiveParams());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTransactionalHiveParams()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.transactional_hive_params, other.transactional_hive_params);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetMaxComputeParams(), other.isSetMaxComputeParams());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetMaxComputeParams()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.max_compute_params, other.max_compute_params);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTrinoConnectorParams(), other.isSetTrinoConnectorParams());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTrinoConnectorParams()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.trino_connector_params, other.trino_connector_params);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetLakesoulParams(), other.isSetLakesoulParams());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetLakesoulParams()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.lakesoul_params, other.lakesoul_params);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTableLevelRowCount(), other.isSetTableLevelRowCount());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTableLevelRowCount()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.table_level_row_count, other.table_level_row_count);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetRemoteDorisParams(), other.isSetRemoteDorisParams());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetRemoteDorisParams()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.remote_doris_params, other.remote_doris_params);
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("TTableFormatFileDesc(");
boolean first = true;
if (isSetTableFormatType()) {
sb.append("table_format_type:");
if (this.table_format_type == null) {
sb.append("null");
} else {
sb.append(this.table_format_type);
}
first = false;
}
if (isSetIcebergParams()) {
if (!first) sb.append(", ");
sb.append("iceberg_params:");
if (this.iceberg_params == null) {
sb.append("null");
} else {
sb.append(this.iceberg_params);
}
first = false;
}
if (isSetHudiParams()) {
if (!first) sb.append(", ");
sb.append("hudi_params:");
if (this.hudi_params == null) {
sb.append("null");
} else {
sb.append(this.hudi_params);
}
first = false;
}
if (isSetPaimonParams()) {
if (!first) sb.append(", ");
sb.append("paimon_params:");
if (this.paimon_params == null) {
sb.append("null");
} else {
sb.append(this.paimon_params);
}
first = false;
}
if (isSetTransactionalHiveParams()) {
if (!first) sb.append(", ");
sb.append("transactional_hive_params:");
if (this.transactional_hive_params == null) {
sb.append("null");
} else {
sb.append(this.transactional_hive_params);
}
first = false;
}
if (isSetMaxComputeParams()) {
if (!first) sb.append(", ");
sb.append("max_compute_params:");
if (this.max_compute_params == null) {
sb.append("null");
} else {
sb.append(this.max_compute_params);
}
first = false;
}
if (isSetTrinoConnectorParams()) {
if (!first) sb.append(", ");
sb.append("trino_connector_params:");
if (this.trino_connector_params == null) {
sb.append("null");
} else {
sb.append(this.trino_connector_params);
}
first = false;
}
if (isSetLakesoulParams()) {
if (!first) sb.append(", ");
sb.append("lakesoul_params:");
if (this.lakesoul_params == null) {
sb.append("null");
} else {
sb.append(this.lakesoul_params);
}
first = false;
}
if (isSetTableLevelRowCount()) {
if (!first) sb.append(", ");
sb.append("table_level_row_count:");
sb.append(this.table_level_row_count);
first = false;
}
if (isSetRemoteDorisParams()) {
if (!first) sb.append(", ");
sb.append("remote_doris_params:");
if (this.remote_doris_params == null) {
sb.append("null");
} else {
sb.append(this.remote_doris_params);
}
first = false;
}
sb.append(")");
return sb.toString();
}
public void validate() throws org.apache.thrift.TException {
// check for required fields
// check for sub-struct validity
if (iceberg_params != null) {
iceberg_params.validate();
}
if (hudi_params != null) {
hudi_params.validate();
}
if (paimon_params != null) {
paimon_params.validate();
}
if (transactional_hive_params != null) {
transactional_hive_params.validate();
}
if (max_compute_params != null) {
max_compute_params.validate();
}
if (trino_connector_params != null) {
trino_connector_params.validate();
}
if (lakesoul_params != null) {
lakesoul_params.validate();
}
if (remote_doris_params != null) {
remote_doris_params.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 TTableFormatFileDescStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TTableFormatFileDescStandardScheme getScheme() {
return new TTableFormatFileDescStandardScheme();
}
}
private static class TTableFormatFileDescStandardScheme extends org.apache.thrift.scheme.StandardScheme<TTableFormatFileDesc> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TTableFormatFileDesc 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: // TABLE_FORMAT_TYPE
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.table_format_type = iprot.readString();
struct.setTableFormatTypeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // ICEBERG_PARAMS
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.iceberg_params = new TIcebergFileDesc();
struct.iceberg_params.read(iprot);
struct.setIcebergParamsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // HUDI_PARAMS
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.hudi_params = new THudiFileDesc();
struct.hudi_params.read(iprot);
struct.setHudiParamsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // PAIMON_PARAMS
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.paimon_params = new TPaimonFileDesc();
struct.paimon_params.read(iprot);
struct.setPaimonParamsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // TRANSACTIONAL_HIVE_PARAMS
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.transactional_hive_params = new TTransactionalHiveDesc();
struct.transactional_hive_params.read(iprot);
struct.setTransactionalHiveParamsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // MAX_COMPUTE_PARAMS
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.max_compute_params = new TMaxComputeFileDesc();
struct.max_compute_params.read(iprot);
struct.setMaxComputeParamsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // TRINO_CONNECTOR_PARAMS
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.trino_connector_params = new TTrinoConnectorFileDesc();
struct.trino_connector_params.read(iprot);
struct.setTrinoConnectorParamsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // LAKESOUL_PARAMS
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.lakesoul_params = new TLakeSoulFileDesc();
struct.lakesoul_params.read(iprot);
struct.setLakesoulParamsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // TABLE_LEVEL_ROW_COUNT
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.table_level_row_count = iprot.readI64();
struct.setTableLevelRowCountIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 10: // REMOTE_DORIS_PARAMS
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.remote_doris_params = new TRemoteDorisFileDesc();
struct.remote_doris_params.read(iprot);
struct.setRemoteDorisParamsIsSet(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, TTableFormatFileDesc struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.table_format_type != null) {
if (struct.isSetTableFormatType()) {
oprot.writeFieldBegin(TABLE_FORMAT_TYPE_FIELD_DESC);
oprot.writeString(struct.table_format_type);
oprot.writeFieldEnd();
}
}
if (struct.iceberg_params != null) {
if (struct.isSetIcebergParams()) {
oprot.writeFieldBegin(ICEBERG_PARAMS_FIELD_DESC);
struct.iceberg_params.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.hudi_params != null) {
if (struct.isSetHudiParams()) {
oprot.writeFieldBegin(HUDI_PARAMS_FIELD_DESC);
struct.hudi_params.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.paimon_params != null) {
if (struct.isSetPaimonParams()) {
oprot.writeFieldBegin(PAIMON_PARAMS_FIELD_DESC);
struct.paimon_params.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.transactional_hive_params != null) {
if (struct.isSetTransactionalHiveParams()) {
oprot.writeFieldBegin(TRANSACTIONAL_HIVE_PARAMS_FIELD_DESC);
struct.transactional_hive_params.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.max_compute_params != null) {
if (struct.isSetMaxComputeParams()) {
oprot.writeFieldBegin(MAX_COMPUTE_PARAMS_FIELD_DESC);
struct.max_compute_params.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.trino_connector_params != null) {
if (struct.isSetTrinoConnectorParams()) {
oprot.writeFieldBegin(TRINO_CONNECTOR_PARAMS_FIELD_DESC);
struct.trino_connector_params.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.lakesoul_params != null) {
if (struct.isSetLakesoulParams()) {
oprot.writeFieldBegin(LAKESOUL_PARAMS_FIELD_DESC);
struct.lakesoul_params.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.isSetTableLevelRowCount()) {
oprot.writeFieldBegin(TABLE_LEVEL_ROW_COUNT_FIELD_DESC);
oprot.writeI64(struct.table_level_row_count);
oprot.writeFieldEnd();
}
if (struct.remote_doris_params != null) {
if (struct.isSetRemoteDorisParams()) {
oprot.writeFieldBegin(REMOTE_DORIS_PARAMS_FIELD_DESC);
struct.remote_doris_params.write(oprot);
oprot.writeFieldEnd();
}
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class TTableFormatFileDescTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TTableFormatFileDescTupleScheme getScheme() {
return new TTableFormatFileDescTupleScheme();
}
}
private static class TTableFormatFileDescTupleScheme extends org.apache.thrift.scheme.TupleScheme<TTableFormatFileDesc> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TTableFormatFileDesc 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.isSetTableFormatType()) {
optionals.set(0);
}
if (struct.isSetIcebergParams()) {
optionals.set(1);
}
if (struct.isSetHudiParams()) {
optionals.set(2);
}
if (struct.isSetPaimonParams()) {
optionals.set(3);
}
if (struct.isSetTransactionalHiveParams()) {
optionals.set(4);
}
if (struct.isSetMaxComputeParams()) {
optionals.set(5);
}
if (struct.isSetTrinoConnectorParams()) {
optionals.set(6);
}
if (struct.isSetLakesoulParams()) {
optionals.set(7);
}
if (struct.isSetTableLevelRowCount()) {
optionals.set(8);
}
if (struct.isSetRemoteDorisParams()) {
optionals.set(9);
}
oprot.writeBitSet(optionals, 10);
if (struct.isSetTableFormatType()) {
oprot.writeString(struct.table_format_type);
}
if (struct.isSetIcebergParams()) {
struct.iceberg_params.write(oprot);
}
if (struct.isSetHudiParams()) {
struct.hudi_params.write(oprot);
}
if (struct.isSetPaimonParams()) {
struct.paimon_params.write(oprot);
}
if (struct.isSetTransactionalHiveParams()) {
struct.transactional_hive_params.write(oprot);
}
if (struct.isSetMaxComputeParams()) {
struct.max_compute_params.write(oprot);
}
if (struct.isSetTrinoConnectorParams()) {
struct.trino_connector_params.write(oprot);
}
if (struct.isSetLakesoulParams()) {
struct.lakesoul_params.write(oprot);
}
if (struct.isSetTableLevelRowCount()) {
oprot.writeI64(struct.table_level_row_count);
}
if (struct.isSetRemoteDorisParams()) {
struct.remote_doris_params.write(oprot);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TTableFormatFileDesc struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet incoming = iprot.readBitSet(10);
if (incoming.get(0)) {
struct.table_format_type = iprot.readString();
struct.setTableFormatTypeIsSet(true);
}
if (incoming.get(1)) {
struct.iceberg_params = new TIcebergFileDesc();
struct.iceberg_params.read(iprot);
struct.setIcebergParamsIsSet(true);
}
if (incoming.get(2)) {
struct.hudi_params = new THudiFileDesc();
struct.hudi_params.read(iprot);
struct.setHudiParamsIsSet(true);
}
if (incoming.get(3)) {
struct.paimon_params = new TPaimonFileDesc();
struct.paimon_params.read(iprot);
struct.setPaimonParamsIsSet(true);
}
if (incoming.get(4)) {
struct.transactional_hive_params = new TTransactionalHiveDesc();
struct.transactional_hive_params.read(iprot);
struct.setTransactionalHiveParamsIsSet(true);
}
if (incoming.get(5)) {
struct.max_compute_params = new TMaxComputeFileDesc();
struct.max_compute_params.read(iprot);
struct.setMaxComputeParamsIsSet(true);
}
if (incoming.get(6)) {
struct.trino_connector_params = new TTrinoConnectorFileDesc();
struct.trino_connector_params.read(iprot);
struct.setTrinoConnectorParamsIsSet(true);
}
if (incoming.get(7)) {
struct.lakesoul_params = new TLakeSoulFileDesc();
struct.lakesoul_params.read(iprot);
struct.setLakesoulParamsIsSet(true);
}
if (incoming.get(8)) {
struct.table_level_row_count = iprot.readI64();
struct.setTableLevelRowCountIsSet(true);
}
if (incoming.get(9)) {
struct.remote_doris_params = new TRemoteDorisFileDesc();
struct.remote_doris_params.read(iprot);
struct.setRemoteDorisParamsIsSet(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();
}
}