TPaimonFileDesc.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 TPaimonFileDesc implements org.apache.thrift.TBase<TPaimonFileDesc, TPaimonFileDesc._Fields>, java.io.Serializable, Cloneable, Comparable<TPaimonFileDesc> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TPaimonFileDesc");
private static final org.apache.thrift.protocol.TField PAIMON_SPLIT_FIELD_DESC = new org.apache.thrift.protocol.TField("paimon_split", org.apache.thrift.protocol.TType.STRING, (short)1);
private static final org.apache.thrift.protocol.TField PAIMON_COLUMN_NAMES_FIELD_DESC = new org.apache.thrift.protocol.TField("paimon_column_names", org.apache.thrift.protocol.TType.STRING, (short)2);
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)3);
private static final org.apache.thrift.protocol.TField TABLE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("table_name", org.apache.thrift.protocol.TType.STRING, (short)4);
private static final org.apache.thrift.protocol.TField PAIMON_PREDICATE_FIELD_DESC = new org.apache.thrift.protocol.TField("paimon_predicate", org.apache.thrift.protocol.TType.STRING, (short)5);
private static final org.apache.thrift.protocol.TField PAIMON_OPTIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("paimon_options", org.apache.thrift.protocol.TType.MAP, (short)6);
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)7);
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)8);
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)9);
private static final org.apache.thrift.protocol.TField LAST_UPDATE_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("last_update_time", org.apache.thrift.protocol.TType.I64, (short)10);
private static final org.apache.thrift.protocol.TField FILE_FORMAT_FIELD_DESC = new org.apache.thrift.protocol.TField("file_format", org.apache.thrift.protocol.TType.STRING, (short)11);
private static final org.apache.thrift.protocol.TField DELETION_FILE_FIELD_DESC = new org.apache.thrift.protocol.TField("deletion_file", org.apache.thrift.protocol.TType.STRUCT, (short)12);
private static final org.apache.thrift.protocol.TField HADOOP_CONF_FIELD_DESC = new org.apache.thrift.protocol.TField("hadoop_conf", org.apache.thrift.protocol.TType.MAP, (short)13);
private static final org.apache.thrift.protocol.TField PAIMON_TABLE_FIELD_DESC = new org.apache.thrift.protocol.TField("paimon_table", org.apache.thrift.protocol.TType.STRING, (short)14);
private static final org.apache.thrift.protocol.TField ROW_COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("row_count", org.apache.thrift.protocol.TType.I64, (short)15);
private static final org.apache.thrift.protocol.TField SCHEMA_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("schema_id", org.apache.thrift.protocol.TType.I64, (short)16);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TPaimonFileDescStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TPaimonFileDescTupleSchemeFactory();
public @org.apache.thrift.annotation.Nullable java.lang.String paimon_split; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String paimon_column_names; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String db_name; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String table_name; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String paimon_predicate; // optional
public @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> paimon_options; // optional
public long ctl_id; // optional
public long db_id; // optional
public long tbl_id; // optional
public long last_update_time; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String file_format; // optional
public @org.apache.thrift.annotation.Nullable TPaimonDeletionFileDesc deletion_file; // optional
public @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> hadoop_conf; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String paimon_table; // optional
public long row_count; // optional
public long schema_id; // 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 {
PAIMON_SPLIT((short)1, "paimon_split"),
PAIMON_COLUMN_NAMES((short)2, "paimon_column_names"),
DB_NAME((short)3, "db_name"),
TABLE_NAME((short)4, "table_name"),
PAIMON_PREDICATE((short)5, "paimon_predicate"),
PAIMON_OPTIONS((short)6, "paimon_options"),
CTL_ID((short)7, "ctl_id"),
DB_ID((short)8, "db_id"),
TBL_ID((short)9, "tbl_id"),
LAST_UPDATE_TIME((short)10, "last_update_time"),
FILE_FORMAT((short)11, "file_format"),
DELETION_FILE((short)12, "deletion_file"),
HADOOP_CONF((short)13, "hadoop_conf"),
PAIMON_TABLE((short)14, "paimon_table"),
ROW_COUNT((short)15, "row_count"),
SCHEMA_ID((short)16, "schema_id");
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: // PAIMON_SPLIT
return PAIMON_SPLIT;
case 2: // PAIMON_COLUMN_NAMES
return PAIMON_COLUMN_NAMES;
case 3: // DB_NAME
return DB_NAME;
case 4: // TABLE_NAME
return TABLE_NAME;
case 5: // PAIMON_PREDICATE
return PAIMON_PREDICATE;
case 6: // PAIMON_OPTIONS
return PAIMON_OPTIONS;
case 7: // CTL_ID
return CTL_ID;
case 8: // DB_ID
return DB_ID;
case 9: // TBL_ID
return TBL_ID;
case 10: // LAST_UPDATE_TIME
return LAST_UPDATE_TIME;
case 11: // FILE_FORMAT
return FILE_FORMAT;
case 12: // DELETION_FILE
return DELETION_FILE;
case 13: // HADOOP_CONF
return HADOOP_CONF;
case 14: // PAIMON_TABLE
return PAIMON_TABLE;
case 15: // ROW_COUNT
return ROW_COUNT;
case 16: // SCHEMA_ID
return SCHEMA_ID;
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 static final int __LAST_UPDATE_TIME_ISSET_ID = 3;
private static final int __ROW_COUNT_ISSET_ID = 4;
private static final int __SCHEMA_ID_ISSET_ID = 5;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.PAIMON_SPLIT,_Fields.PAIMON_COLUMN_NAMES,_Fields.DB_NAME,_Fields.TABLE_NAME,_Fields.PAIMON_PREDICATE,_Fields.PAIMON_OPTIONS,_Fields.CTL_ID,_Fields.DB_ID,_Fields.TBL_ID,_Fields.LAST_UPDATE_TIME,_Fields.FILE_FORMAT,_Fields.DELETION_FILE,_Fields.HADOOP_CONF,_Fields.PAIMON_TABLE,_Fields.ROW_COUNT,_Fields.SCHEMA_ID};
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.PAIMON_SPLIT, new org.apache.thrift.meta_data.FieldMetaData("paimon_split", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.PAIMON_COLUMN_NAMES, new org.apache.thrift.meta_data.FieldMetaData("paimon_column_names", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("db_name", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.TABLE_NAME, new org.apache.thrift.meta_data.FieldMetaData("table_name", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.PAIMON_PREDICATE, new org.apache.thrift.meta_data.FieldMetaData("paimon_predicate", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.PAIMON_OPTIONS, new org.apache.thrift.meta_data.FieldMetaData("paimon_options", 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.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.LAST_UPDATE_TIME, new org.apache.thrift.meta_data.FieldMetaData("last_update_time", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.FILE_FORMAT, new org.apache.thrift.meta_data.FieldMetaData("file_format", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.DELETION_FILE, new org.apache.thrift.meta_data.FieldMetaData("deletion_file", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TPaimonDeletionFileDesc.class)));
tmpMap.put(_Fields.HADOOP_CONF, new org.apache.thrift.meta_data.FieldMetaData("hadoop_conf", 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_TABLE, new org.apache.thrift.meta_data.FieldMetaData("paimon_table", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.ROW_COUNT, new org.apache.thrift.meta_data.FieldMetaData("row_count", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.SCHEMA_ID, new org.apache.thrift.meta_data.FieldMetaData("schema_id", 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(TPaimonFileDesc.class, metaDataMap);
}
public TPaimonFileDesc() {
}
/**
* Performs a deep copy on <i>other</i>.
*/
public TPaimonFileDesc(TPaimonFileDesc other) {
__isset_bitfield = other.__isset_bitfield;
if (other.isSetPaimonSplit()) {
this.paimon_split = other.paimon_split;
}
if (other.isSetPaimonColumnNames()) {
this.paimon_column_names = other.paimon_column_names;
}
if (other.isSetDbName()) {
this.db_name = other.db_name;
}
if (other.isSetTableName()) {
this.table_name = other.table_name;
}
if (other.isSetPaimonPredicate()) {
this.paimon_predicate = other.paimon_predicate;
}
if (other.isSetPaimonOptions()) {
java.util.Map<java.lang.String,java.lang.String> __this__paimon_options = new java.util.HashMap<java.lang.String,java.lang.String>(other.paimon_options);
this.paimon_options = __this__paimon_options;
}
this.ctl_id = other.ctl_id;
this.db_id = other.db_id;
this.tbl_id = other.tbl_id;
this.last_update_time = other.last_update_time;
if (other.isSetFileFormat()) {
this.file_format = other.file_format;
}
if (other.isSetDeletionFile()) {
this.deletion_file = new TPaimonDeletionFileDesc(other.deletion_file);
}
if (other.isSetHadoopConf()) {
java.util.Map<java.lang.String,java.lang.String> __this__hadoop_conf = new java.util.HashMap<java.lang.String,java.lang.String>(other.hadoop_conf);
this.hadoop_conf = __this__hadoop_conf;
}
if (other.isSetPaimonTable()) {
this.paimon_table = other.paimon_table;
}
this.row_count = other.row_count;
this.schema_id = other.schema_id;
}
public TPaimonFileDesc deepCopy() {
return new TPaimonFileDesc(this);
}
@Override
public void clear() {
this.paimon_split = null;
this.paimon_column_names = null;
this.db_name = null;
this.table_name = null;
this.paimon_predicate = null;
this.paimon_options = null;
setCtlIdIsSet(false);
this.ctl_id = 0;
setDbIdIsSet(false);
this.db_id = 0;
setTblIdIsSet(false);
this.tbl_id = 0;
setLastUpdateTimeIsSet(false);
this.last_update_time = 0;
this.file_format = null;
this.deletion_file = null;
this.hadoop_conf = null;
this.paimon_table = null;
setRowCountIsSet(false);
this.row_count = 0;
setSchemaIdIsSet(false);
this.schema_id = 0;
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getPaimonSplit() {
return this.paimon_split;
}
public TPaimonFileDesc setPaimonSplit(@org.apache.thrift.annotation.Nullable java.lang.String paimon_split) {
this.paimon_split = paimon_split;
return this;
}
public void unsetPaimonSplit() {
this.paimon_split = null;
}
/** Returns true if field paimon_split is set (has been assigned a value) and false otherwise */
public boolean isSetPaimonSplit() {
return this.paimon_split != null;
}
public void setPaimonSplitIsSet(boolean value) {
if (!value) {
this.paimon_split = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getPaimonColumnNames() {
return this.paimon_column_names;
}
public TPaimonFileDesc setPaimonColumnNames(@org.apache.thrift.annotation.Nullable java.lang.String paimon_column_names) {
this.paimon_column_names = paimon_column_names;
return this;
}
public void unsetPaimonColumnNames() {
this.paimon_column_names = null;
}
/** Returns true if field paimon_column_names is set (has been assigned a value) and false otherwise */
public boolean isSetPaimonColumnNames() {
return this.paimon_column_names != null;
}
public void setPaimonColumnNamesIsSet(boolean value) {
if (!value) {
this.paimon_column_names = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getDbName() {
return this.db_name;
}
public TPaimonFileDesc 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 getTableName() {
return this.table_name;
}
public TPaimonFileDesc setTableName(@org.apache.thrift.annotation.Nullable java.lang.String table_name) {
this.table_name = table_name;
return this;
}
public void unsetTableName() {
this.table_name = null;
}
/** Returns true if field table_name is set (has been assigned a value) and false otherwise */
public boolean isSetTableName() {
return this.table_name != null;
}
public void setTableNameIsSet(boolean value) {
if (!value) {
this.table_name = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getPaimonPredicate() {
return this.paimon_predicate;
}
public TPaimonFileDesc setPaimonPredicate(@org.apache.thrift.annotation.Nullable java.lang.String paimon_predicate) {
this.paimon_predicate = paimon_predicate;
return this;
}
public void unsetPaimonPredicate() {
this.paimon_predicate = null;
}
/** Returns true if field paimon_predicate is set (has been assigned a value) and false otherwise */
public boolean isSetPaimonPredicate() {
return this.paimon_predicate != null;
}
public void setPaimonPredicateIsSet(boolean value) {
if (!value) {
this.paimon_predicate = null;
}
}
public int getPaimonOptionsSize() {
return (this.paimon_options == null) ? 0 : this.paimon_options.size();
}
public void putToPaimonOptions(java.lang.String key, java.lang.String val) {
if (this.paimon_options == null) {
this.paimon_options = new java.util.HashMap<java.lang.String,java.lang.String>();
}
this.paimon_options.put(key, val);
}
@org.apache.thrift.annotation.Nullable
public java.util.Map<java.lang.String,java.lang.String> getPaimonOptions() {
return this.paimon_options;
}
public TPaimonFileDesc setPaimonOptions(@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> paimon_options) {
this.paimon_options = paimon_options;
return this;
}
public void unsetPaimonOptions() {
this.paimon_options = null;
}
/** Returns true if field paimon_options is set (has been assigned a value) and false otherwise */
public boolean isSetPaimonOptions() {
return this.paimon_options != null;
}
public void setPaimonOptionsIsSet(boolean value) {
if (!value) {
this.paimon_options = null;
}
}
public long getCtlId() {
return this.ctl_id;
}
public TPaimonFileDesc 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 TPaimonFileDesc 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 TPaimonFileDesc 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);
}
public long getLastUpdateTime() {
return this.last_update_time;
}
public TPaimonFileDesc setLastUpdateTime(long last_update_time) {
this.last_update_time = last_update_time;
setLastUpdateTimeIsSet(true);
return this;
}
public void unsetLastUpdateTime() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __LAST_UPDATE_TIME_ISSET_ID);
}
/** Returns true if field last_update_time is set (has been assigned a value) and false otherwise */
public boolean isSetLastUpdateTime() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __LAST_UPDATE_TIME_ISSET_ID);
}
public void setLastUpdateTimeIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __LAST_UPDATE_TIME_ISSET_ID, value);
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getFileFormat() {
return this.file_format;
}
public TPaimonFileDesc setFileFormat(@org.apache.thrift.annotation.Nullable java.lang.String file_format) {
this.file_format = file_format;
return this;
}
public void unsetFileFormat() {
this.file_format = null;
}
/** Returns true if field file_format is set (has been assigned a value) and false otherwise */
public boolean isSetFileFormat() {
return this.file_format != null;
}
public void setFileFormatIsSet(boolean value) {
if (!value) {
this.file_format = null;
}
}
@org.apache.thrift.annotation.Nullable
public TPaimonDeletionFileDesc getDeletionFile() {
return this.deletion_file;
}
public TPaimonFileDesc setDeletionFile(@org.apache.thrift.annotation.Nullable TPaimonDeletionFileDesc deletion_file) {
this.deletion_file = deletion_file;
return this;
}
public void unsetDeletionFile() {
this.deletion_file = null;
}
/** Returns true if field deletion_file is set (has been assigned a value) and false otherwise */
public boolean isSetDeletionFile() {
return this.deletion_file != null;
}
public void setDeletionFileIsSet(boolean value) {
if (!value) {
this.deletion_file = null;
}
}
public int getHadoopConfSize() {
return (this.hadoop_conf == null) ? 0 : this.hadoop_conf.size();
}
public void putToHadoopConf(java.lang.String key, java.lang.String val) {
if (this.hadoop_conf == null) {
this.hadoop_conf = new java.util.HashMap<java.lang.String,java.lang.String>();
}
this.hadoop_conf.put(key, val);
}
@org.apache.thrift.annotation.Nullable
public java.util.Map<java.lang.String,java.lang.String> getHadoopConf() {
return this.hadoop_conf;
}
public TPaimonFileDesc setHadoopConf(@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> hadoop_conf) {
this.hadoop_conf = hadoop_conf;
return this;
}
public void unsetHadoopConf() {
this.hadoop_conf = null;
}
/** Returns true if field hadoop_conf is set (has been assigned a value) and false otherwise */
public boolean isSetHadoopConf() {
return this.hadoop_conf != null;
}
public void setHadoopConfIsSet(boolean value) {
if (!value) {
this.hadoop_conf = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getPaimonTable() {
return this.paimon_table;
}
public TPaimonFileDesc setPaimonTable(@org.apache.thrift.annotation.Nullable java.lang.String paimon_table) {
this.paimon_table = paimon_table;
return this;
}
public void unsetPaimonTable() {
this.paimon_table = null;
}
/** Returns true if field paimon_table is set (has been assigned a value) and false otherwise */
public boolean isSetPaimonTable() {
return this.paimon_table != null;
}
public void setPaimonTableIsSet(boolean value) {
if (!value) {
this.paimon_table = null;
}
}
public long getRowCount() {
return this.row_count;
}
public TPaimonFileDesc setRowCount(long row_count) {
this.row_count = row_count;
setRowCountIsSet(true);
return this;
}
public void unsetRowCount() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __ROW_COUNT_ISSET_ID);
}
/** Returns true if field row_count is set (has been assigned a value) and false otherwise */
public boolean isSetRowCount() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __ROW_COUNT_ISSET_ID);
}
public void setRowCountIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __ROW_COUNT_ISSET_ID, value);
}
public long getSchemaId() {
return this.schema_id;
}
public TPaimonFileDesc setSchemaId(long schema_id) {
this.schema_id = schema_id;
setSchemaIdIsSet(true);
return this;
}
public void unsetSchemaId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __SCHEMA_ID_ISSET_ID);
}
/** Returns true if field schema_id is set (has been assigned a value) and false otherwise */
public boolean isSetSchemaId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __SCHEMA_ID_ISSET_ID);
}
public void setSchemaIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __SCHEMA_ID_ISSET_ID, value);
}
public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case PAIMON_SPLIT:
if (value == null) {
unsetPaimonSplit();
} else {
setPaimonSplit((java.lang.String)value);
}
break;
case PAIMON_COLUMN_NAMES:
if (value == null) {
unsetPaimonColumnNames();
} else {
setPaimonColumnNames((java.lang.String)value);
}
break;
case DB_NAME:
if (value == null) {
unsetDbName();
} else {
setDbName((java.lang.String)value);
}
break;
case TABLE_NAME:
if (value == null) {
unsetTableName();
} else {
setTableName((java.lang.String)value);
}
break;
case PAIMON_PREDICATE:
if (value == null) {
unsetPaimonPredicate();
} else {
setPaimonPredicate((java.lang.String)value);
}
break;
case PAIMON_OPTIONS:
if (value == null) {
unsetPaimonOptions();
} else {
setPaimonOptions((java.util.Map<java.lang.String,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 LAST_UPDATE_TIME:
if (value == null) {
unsetLastUpdateTime();
} else {
setLastUpdateTime((java.lang.Long)value);
}
break;
case FILE_FORMAT:
if (value == null) {
unsetFileFormat();
} else {
setFileFormat((java.lang.String)value);
}
break;
case DELETION_FILE:
if (value == null) {
unsetDeletionFile();
} else {
setDeletionFile((TPaimonDeletionFileDesc)value);
}
break;
case HADOOP_CONF:
if (value == null) {
unsetHadoopConf();
} else {
setHadoopConf((java.util.Map<java.lang.String,java.lang.String>)value);
}
break;
case PAIMON_TABLE:
if (value == null) {
unsetPaimonTable();
} else {
setPaimonTable((java.lang.String)value);
}
break;
case ROW_COUNT:
if (value == null) {
unsetRowCount();
} else {
setRowCount((java.lang.Long)value);
}
break;
case SCHEMA_ID:
if (value == null) {
unsetSchemaId();
} else {
setSchemaId((java.lang.Long)value);
}
break;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case PAIMON_SPLIT:
return getPaimonSplit();
case PAIMON_COLUMN_NAMES:
return getPaimonColumnNames();
case DB_NAME:
return getDbName();
case TABLE_NAME:
return getTableName();
case PAIMON_PREDICATE:
return getPaimonPredicate();
case PAIMON_OPTIONS:
return getPaimonOptions();
case CTL_ID:
return getCtlId();
case DB_ID:
return getDbId();
case TBL_ID:
return getTblId();
case LAST_UPDATE_TIME:
return getLastUpdateTime();
case FILE_FORMAT:
return getFileFormat();
case DELETION_FILE:
return getDeletionFile();
case HADOOP_CONF:
return getHadoopConf();
case PAIMON_TABLE:
return getPaimonTable();
case ROW_COUNT:
return getRowCount();
case SCHEMA_ID:
return getSchemaId();
}
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 PAIMON_SPLIT:
return isSetPaimonSplit();
case PAIMON_COLUMN_NAMES:
return isSetPaimonColumnNames();
case DB_NAME:
return isSetDbName();
case TABLE_NAME:
return isSetTableName();
case PAIMON_PREDICATE:
return isSetPaimonPredicate();
case PAIMON_OPTIONS:
return isSetPaimonOptions();
case CTL_ID:
return isSetCtlId();
case DB_ID:
return isSetDbId();
case TBL_ID:
return isSetTblId();
case LAST_UPDATE_TIME:
return isSetLastUpdateTime();
case FILE_FORMAT:
return isSetFileFormat();
case DELETION_FILE:
return isSetDeletionFile();
case HADOOP_CONF:
return isSetHadoopConf();
case PAIMON_TABLE:
return isSetPaimonTable();
case ROW_COUNT:
return isSetRowCount();
case SCHEMA_ID:
return isSetSchemaId();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof TPaimonFileDesc)
return this.equals((TPaimonFileDesc)that);
return false;
}
public boolean equals(TPaimonFileDesc that) {
if (that == null)
return false;
if (this == that)
return true;
boolean this_present_paimon_split = true && this.isSetPaimonSplit();
boolean that_present_paimon_split = true && that.isSetPaimonSplit();
if (this_present_paimon_split || that_present_paimon_split) {
if (!(this_present_paimon_split && that_present_paimon_split))
return false;
if (!this.paimon_split.equals(that.paimon_split))
return false;
}
boolean this_present_paimon_column_names = true && this.isSetPaimonColumnNames();
boolean that_present_paimon_column_names = true && that.isSetPaimonColumnNames();
if (this_present_paimon_column_names || that_present_paimon_column_names) {
if (!(this_present_paimon_column_names && that_present_paimon_column_names))
return false;
if (!this.paimon_column_names.equals(that.paimon_column_names))
return false;
}
boolean this_present_db_name = true && this.isSetDbName();
boolean that_present_db_name = true && that.isSetDbName();
if (this_present_db_name || that_present_db_name) {
if (!(this_present_db_name && that_present_db_name))
return false;
if (!this.db_name.equals(that.db_name))
return false;
}
boolean this_present_table_name = true && this.isSetTableName();
boolean that_present_table_name = true && that.isSetTableName();
if (this_present_table_name || that_present_table_name) {
if (!(this_present_table_name && that_present_table_name))
return false;
if (!this.table_name.equals(that.table_name))
return false;
}
boolean this_present_paimon_predicate = true && this.isSetPaimonPredicate();
boolean that_present_paimon_predicate = true && that.isSetPaimonPredicate();
if (this_present_paimon_predicate || that_present_paimon_predicate) {
if (!(this_present_paimon_predicate && that_present_paimon_predicate))
return false;
if (!this.paimon_predicate.equals(that.paimon_predicate))
return false;
}
boolean this_present_paimon_options = true && this.isSetPaimonOptions();
boolean that_present_paimon_options = true && that.isSetPaimonOptions();
if (this_present_paimon_options || that_present_paimon_options) {
if (!(this_present_paimon_options && that_present_paimon_options))
return false;
if (!this.paimon_options.equals(that.paimon_options))
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_last_update_time = true && this.isSetLastUpdateTime();
boolean that_present_last_update_time = true && that.isSetLastUpdateTime();
if (this_present_last_update_time || that_present_last_update_time) {
if (!(this_present_last_update_time && that_present_last_update_time))
return false;
if (this.last_update_time != that.last_update_time)
return false;
}
boolean this_present_file_format = true && this.isSetFileFormat();
boolean that_present_file_format = true && that.isSetFileFormat();
if (this_present_file_format || that_present_file_format) {
if (!(this_present_file_format && that_present_file_format))
return false;
if (!this.file_format.equals(that.file_format))
return false;
}
boolean this_present_deletion_file = true && this.isSetDeletionFile();
boolean that_present_deletion_file = true && that.isSetDeletionFile();
if (this_present_deletion_file || that_present_deletion_file) {
if (!(this_present_deletion_file && that_present_deletion_file))
return false;
if (!this.deletion_file.equals(that.deletion_file))
return false;
}
boolean this_present_hadoop_conf = true && this.isSetHadoopConf();
boolean that_present_hadoop_conf = true && that.isSetHadoopConf();
if (this_present_hadoop_conf || that_present_hadoop_conf) {
if (!(this_present_hadoop_conf && that_present_hadoop_conf))
return false;
if (!this.hadoop_conf.equals(that.hadoop_conf))
return false;
}
boolean this_present_paimon_table = true && this.isSetPaimonTable();
boolean that_present_paimon_table = true && that.isSetPaimonTable();
if (this_present_paimon_table || that_present_paimon_table) {
if (!(this_present_paimon_table && that_present_paimon_table))
return false;
if (!this.paimon_table.equals(that.paimon_table))
return false;
}
boolean this_present_row_count = true && this.isSetRowCount();
boolean that_present_row_count = true && that.isSetRowCount();
if (this_present_row_count || that_present_row_count) {
if (!(this_present_row_count && that_present_row_count))
return false;
if (this.row_count != that.row_count)
return false;
}
boolean this_present_schema_id = true && this.isSetSchemaId();
boolean that_present_schema_id = true && that.isSetSchemaId();
if (this_present_schema_id || that_present_schema_id) {
if (!(this_present_schema_id && that_present_schema_id))
return false;
if (this.schema_id != that.schema_id)
return false;
}
return true;
}
@Override
public int hashCode() {
int hashCode = 1;
hashCode = hashCode * 8191 + ((isSetPaimonSplit()) ? 131071 : 524287);
if (isSetPaimonSplit())
hashCode = hashCode * 8191 + paimon_split.hashCode();
hashCode = hashCode * 8191 + ((isSetPaimonColumnNames()) ? 131071 : 524287);
if (isSetPaimonColumnNames())
hashCode = hashCode * 8191 + paimon_column_names.hashCode();
hashCode = hashCode * 8191 + ((isSetDbName()) ? 131071 : 524287);
if (isSetDbName())
hashCode = hashCode * 8191 + db_name.hashCode();
hashCode = hashCode * 8191 + ((isSetTableName()) ? 131071 : 524287);
if (isSetTableName())
hashCode = hashCode * 8191 + table_name.hashCode();
hashCode = hashCode * 8191 + ((isSetPaimonPredicate()) ? 131071 : 524287);
if (isSetPaimonPredicate())
hashCode = hashCode * 8191 + paimon_predicate.hashCode();
hashCode = hashCode * 8191 + ((isSetPaimonOptions()) ? 131071 : 524287);
if (isSetPaimonOptions())
hashCode = hashCode * 8191 + paimon_options.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 + ((isSetLastUpdateTime()) ? 131071 : 524287);
if (isSetLastUpdateTime())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(last_update_time);
hashCode = hashCode * 8191 + ((isSetFileFormat()) ? 131071 : 524287);
if (isSetFileFormat())
hashCode = hashCode * 8191 + file_format.hashCode();
hashCode = hashCode * 8191 + ((isSetDeletionFile()) ? 131071 : 524287);
if (isSetDeletionFile())
hashCode = hashCode * 8191 + deletion_file.hashCode();
hashCode = hashCode * 8191 + ((isSetHadoopConf()) ? 131071 : 524287);
if (isSetHadoopConf())
hashCode = hashCode * 8191 + hadoop_conf.hashCode();
hashCode = hashCode * 8191 + ((isSetPaimonTable()) ? 131071 : 524287);
if (isSetPaimonTable())
hashCode = hashCode * 8191 + paimon_table.hashCode();
hashCode = hashCode * 8191 + ((isSetRowCount()) ? 131071 : 524287);
if (isSetRowCount())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(row_count);
hashCode = hashCode * 8191 + ((isSetSchemaId()) ? 131071 : 524287);
if (isSetSchemaId())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(schema_id);
return hashCode;
}
@Override
public int compareTo(TPaimonFileDesc other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = java.lang.Boolean.compare(isSetPaimonSplit(), other.isSetPaimonSplit());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPaimonSplit()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paimon_split, other.paimon_split);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetPaimonColumnNames(), other.isSetPaimonColumnNames());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPaimonColumnNames()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paimon_column_names, other.paimon_column_names);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetDbName(), other.isSetDbName());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetDbName()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.db_name, other.db_name);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTableName(), other.isSetTableName());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTableName()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.table_name, other.table_name);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetPaimonPredicate(), other.isSetPaimonPredicate());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPaimonPredicate()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paimon_predicate, other.paimon_predicate);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetPaimonOptions(), other.isSetPaimonOptions());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPaimonOptions()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paimon_options, other.paimon_options);
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(isSetLastUpdateTime(), other.isSetLastUpdateTime());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetLastUpdateTime()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.last_update_time, other.last_update_time);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetFileFormat(), other.isSetFileFormat());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetFileFormat()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.file_format, other.file_format);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetDeletionFile(), other.isSetDeletionFile());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetDeletionFile()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.deletion_file, other.deletion_file);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetHadoopConf(), other.isSetHadoopConf());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetHadoopConf()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.hadoop_conf, other.hadoop_conf);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetPaimonTable(), other.isSetPaimonTable());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPaimonTable()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.paimon_table, other.paimon_table);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetRowCount(), other.isSetRowCount());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetRowCount()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.row_count, other.row_count);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetSchemaId(), other.isSetSchemaId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetSchemaId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.schema_id, other.schema_id);
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("TPaimonFileDesc(");
boolean first = true;
if (isSetPaimonSplit()) {
sb.append("paimon_split:");
if (this.paimon_split == null) {
sb.append("null");
} else {
sb.append(this.paimon_split);
}
first = false;
}
if (isSetPaimonColumnNames()) {
if (!first) sb.append(", ");
sb.append("paimon_column_names:");
if (this.paimon_column_names == null) {
sb.append("null");
} else {
sb.append(this.paimon_column_names);
}
first = false;
}
if (isSetDbName()) {
if (!first) sb.append(", ");
sb.append("db_name:");
if (this.db_name == null) {
sb.append("null");
} else {
sb.append(this.db_name);
}
first = false;
}
if (isSetTableName()) {
if (!first) sb.append(", ");
sb.append("table_name:");
if (this.table_name == null) {
sb.append("null");
} else {
sb.append(this.table_name);
}
first = false;
}
if (isSetPaimonPredicate()) {
if (!first) sb.append(", ");
sb.append("paimon_predicate:");
if (this.paimon_predicate == null) {
sb.append("null");
} else {
sb.append(this.paimon_predicate);
}
first = false;
}
if (isSetPaimonOptions()) {
if (!first) sb.append(", ");
sb.append("paimon_options:");
if (this.paimon_options == null) {
sb.append("null");
} else {
sb.append(this.paimon_options);
}
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 (isSetLastUpdateTime()) {
if (!first) sb.append(", ");
sb.append("last_update_time:");
sb.append(this.last_update_time);
first = false;
}
if (isSetFileFormat()) {
if (!first) sb.append(", ");
sb.append("file_format:");
if (this.file_format == null) {
sb.append("null");
} else {
sb.append(this.file_format);
}
first = false;
}
if (isSetDeletionFile()) {
if (!first) sb.append(", ");
sb.append("deletion_file:");
if (this.deletion_file == null) {
sb.append("null");
} else {
sb.append(this.deletion_file);
}
first = false;
}
if (isSetHadoopConf()) {
if (!first) sb.append(", ");
sb.append("hadoop_conf:");
if (this.hadoop_conf == null) {
sb.append("null");
} else {
sb.append(this.hadoop_conf);
}
first = false;
}
if (isSetPaimonTable()) {
if (!first) sb.append(", ");
sb.append("paimon_table:");
if (this.paimon_table == null) {
sb.append("null");
} else {
sb.append(this.paimon_table);
}
first = false;
}
if (isSetRowCount()) {
if (!first) sb.append(", ");
sb.append("row_count:");
sb.append(this.row_count);
first = false;
}
if (isSetSchemaId()) {
if (!first) sb.append(", ");
sb.append("schema_id:");
sb.append(this.schema_id);
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 (deletion_file != null) {
deletion_file.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 TPaimonFileDescStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TPaimonFileDescStandardScheme getScheme() {
return new TPaimonFileDescStandardScheme();
}
}
private static class TPaimonFileDescStandardScheme extends org.apache.thrift.scheme.StandardScheme<TPaimonFileDesc> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TPaimonFileDesc 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: // PAIMON_SPLIT
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.paimon_split = iprot.readString();
struct.setPaimonSplitIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // PAIMON_COLUMN_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.paimon_column_names = iprot.readString();
struct.setPaimonColumnNamesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // 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 4: // TABLE_NAME
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.table_name = iprot.readString();
struct.setTableNameIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // PAIMON_PREDICATE
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.paimon_predicate = iprot.readString();
struct.setPaimonPredicateIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // PAIMON_OPTIONS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map118 = iprot.readMapBegin();
struct.paimon_options = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map118.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key119;
@org.apache.thrift.annotation.Nullable java.lang.String _val120;
for (int _i121 = 0; _i121 < _map118.size; ++_i121)
{
_key119 = iprot.readString();
_val120 = iprot.readString();
struct.paimon_options.put(_key119, _val120);
}
iprot.readMapEnd();
}
struct.setPaimonOptionsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // 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 8: // 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 9: // 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 10: // LAST_UPDATE_TIME
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.last_update_time = iprot.readI64();
struct.setLastUpdateTimeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 11: // FILE_FORMAT
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.file_format = iprot.readString();
struct.setFileFormatIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 12: // DELETION_FILE
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.deletion_file = new TPaimonDeletionFileDesc();
struct.deletion_file.read(iprot);
struct.setDeletionFileIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 13: // HADOOP_CONF
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map122 = iprot.readMapBegin();
struct.hadoop_conf = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map122.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key123;
@org.apache.thrift.annotation.Nullable java.lang.String _val124;
for (int _i125 = 0; _i125 < _map122.size; ++_i125)
{
_key123 = iprot.readString();
_val124 = iprot.readString();
struct.hadoop_conf.put(_key123, _val124);
}
iprot.readMapEnd();
}
struct.setHadoopConfIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 14: // PAIMON_TABLE
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.paimon_table = iprot.readString();
struct.setPaimonTableIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 15: // ROW_COUNT
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.row_count = iprot.readI64();
struct.setRowCountIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 16: // SCHEMA_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.schema_id = iprot.readI64();
struct.setSchemaIdIsSet(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, TPaimonFileDesc struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.paimon_split != null) {
if (struct.isSetPaimonSplit()) {
oprot.writeFieldBegin(PAIMON_SPLIT_FIELD_DESC);
oprot.writeString(struct.paimon_split);
oprot.writeFieldEnd();
}
}
if (struct.paimon_column_names != null) {
if (struct.isSetPaimonColumnNames()) {
oprot.writeFieldBegin(PAIMON_COLUMN_NAMES_FIELD_DESC);
oprot.writeString(struct.paimon_column_names);
oprot.writeFieldEnd();
}
}
if (struct.db_name != null) {
if (struct.isSetDbName()) {
oprot.writeFieldBegin(DB_NAME_FIELD_DESC);
oprot.writeString(struct.db_name);
oprot.writeFieldEnd();
}
}
if (struct.table_name != null) {
if (struct.isSetTableName()) {
oprot.writeFieldBegin(TABLE_NAME_FIELD_DESC);
oprot.writeString(struct.table_name);
oprot.writeFieldEnd();
}
}
if (struct.paimon_predicate != null) {
if (struct.isSetPaimonPredicate()) {
oprot.writeFieldBegin(PAIMON_PREDICATE_FIELD_DESC);
oprot.writeString(struct.paimon_predicate);
oprot.writeFieldEnd();
}
}
if (struct.paimon_options != null) {
if (struct.isSetPaimonOptions()) {
oprot.writeFieldBegin(PAIMON_OPTIONS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.paimon_options.size()));
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter126 : struct.paimon_options.entrySet())
{
oprot.writeString(_iter126.getKey());
oprot.writeString(_iter126.getValue());
}
oprot.writeMapEnd();
}
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.isSetLastUpdateTime()) {
oprot.writeFieldBegin(LAST_UPDATE_TIME_FIELD_DESC);
oprot.writeI64(struct.last_update_time);
oprot.writeFieldEnd();
}
if (struct.file_format != null) {
if (struct.isSetFileFormat()) {
oprot.writeFieldBegin(FILE_FORMAT_FIELD_DESC);
oprot.writeString(struct.file_format);
oprot.writeFieldEnd();
}
}
if (struct.deletion_file != null) {
if (struct.isSetDeletionFile()) {
oprot.writeFieldBegin(DELETION_FILE_FIELD_DESC);
struct.deletion_file.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.hadoop_conf != null) {
if (struct.isSetHadoopConf()) {
oprot.writeFieldBegin(HADOOP_CONF_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.hadoop_conf.size()));
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter127 : struct.hadoop_conf.entrySet())
{
oprot.writeString(_iter127.getKey());
oprot.writeString(_iter127.getValue());
}
oprot.writeMapEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.paimon_table != null) {
if (struct.isSetPaimonTable()) {
oprot.writeFieldBegin(PAIMON_TABLE_FIELD_DESC);
oprot.writeString(struct.paimon_table);
oprot.writeFieldEnd();
}
}
if (struct.isSetRowCount()) {
oprot.writeFieldBegin(ROW_COUNT_FIELD_DESC);
oprot.writeI64(struct.row_count);
oprot.writeFieldEnd();
}
if (struct.isSetSchemaId()) {
oprot.writeFieldBegin(SCHEMA_ID_FIELD_DESC);
oprot.writeI64(struct.schema_id);
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class TPaimonFileDescTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TPaimonFileDescTupleScheme getScheme() {
return new TPaimonFileDescTupleScheme();
}
}
private static class TPaimonFileDescTupleScheme extends org.apache.thrift.scheme.TupleScheme<TPaimonFileDesc> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TPaimonFileDesc 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.isSetPaimonSplit()) {
optionals.set(0);
}
if (struct.isSetPaimonColumnNames()) {
optionals.set(1);
}
if (struct.isSetDbName()) {
optionals.set(2);
}
if (struct.isSetTableName()) {
optionals.set(3);
}
if (struct.isSetPaimonPredicate()) {
optionals.set(4);
}
if (struct.isSetPaimonOptions()) {
optionals.set(5);
}
if (struct.isSetCtlId()) {
optionals.set(6);
}
if (struct.isSetDbId()) {
optionals.set(7);
}
if (struct.isSetTblId()) {
optionals.set(8);
}
if (struct.isSetLastUpdateTime()) {
optionals.set(9);
}
if (struct.isSetFileFormat()) {
optionals.set(10);
}
if (struct.isSetDeletionFile()) {
optionals.set(11);
}
if (struct.isSetHadoopConf()) {
optionals.set(12);
}
if (struct.isSetPaimonTable()) {
optionals.set(13);
}
if (struct.isSetRowCount()) {
optionals.set(14);
}
if (struct.isSetSchemaId()) {
optionals.set(15);
}
oprot.writeBitSet(optionals, 16);
if (struct.isSetPaimonSplit()) {
oprot.writeString(struct.paimon_split);
}
if (struct.isSetPaimonColumnNames()) {
oprot.writeString(struct.paimon_column_names);
}
if (struct.isSetDbName()) {
oprot.writeString(struct.db_name);
}
if (struct.isSetTableName()) {
oprot.writeString(struct.table_name);
}
if (struct.isSetPaimonPredicate()) {
oprot.writeString(struct.paimon_predicate);
}
if (struct.isSetPaimonOptions()) {
{
oprot.writeI32(struct.paimon_options.size());
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter128 : struct.paimon_options.entrySet())
{
oprot.writeString(_iter128.getKey());
oprot.writeString(_iter128.getValue());
}
}
}
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.isSetLastUpdateTime()) {
oprot.writeI64(struct.last_update_time);
}
if (struct.isSetFileFormat()) {
oprot.writeString(struct.file_format);
}
if (struct.isSetDeletionFile()) {
struct.deletion_file.write(oprot);
}
if (struct.isSetHadoopConf()) {
{
oprot.writeI32(struct.hadoop_conf.size());
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter129 : struct.hadoop_conf.entrySet())
{
oprot.writeString(_iter129.getKey());
oprot.writeString(_iter129.getValue());
}
}
}
if (struct.isSetPaimonTable()) {
oprot.writeString(struct.paimon_table);
}
if (struct.isSetRowCount()) {
oprot.writeI64(struct.row_count);
}
if (struct.isSetSchemaId()) {
oprot.writeI64(struct.schema_id);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TPaimonFileDesc struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet incoming = iprot.readBitSet(16);
if (incoming.get(0)) {
struct.paimon_split = iprot.readString();
struct.setPaimonSplitIsSet(true);
}
if (incoming.get(1)) {
struct.paimon_column_names = iprot.readString();
struct.setPaimonColumnNamesIsSet(true);
}
if (incoming.get(2)) {
struct.db_name = iprot.readString();
struct.setDbNameIsSet(true);
}
if (incoming.get(3)) {
struct.table_name = iprot.readString();
struct.setTableNameIsSet(true);
}
if (incoming.get(4)) {
struct.paimon_predicate = iprot.readString();
struct.setPaimonPredicateIsSet(true);
}
if (incoming.get(5)) {
{
org.apache.thrift.protocol.TMap _map130 = iprot.readMapBegin(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING);
struct.paimon_options = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map130.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key131;
@org.apache.thrift.annotation.Nullable java.lang.String _val132;
for (int _i133 = 0; _i133 < _map130.size; ++_i133)
{
_key131 = iprot.readString();
_val132 = iprot.readString();
struct.paimon_options.put(_key131, _val132);
}
}
struct.setPaimonOptionsIsSet(true);
}
if (incoming.get(6)) {
struct.ctl_id = iprot.readI64();
struct.setCtlIdIsSet(true);
}
if (incoming.get(7)) {
struct.db_id = iprot.readI64();
struct.setDbIdIsSet(true);
}
if (incoming.get(8)) {
struct.tbl_id = iprot.readI64();
struct.setTblIdIsSet(true);
}
if (incoming.get(9)) {
struct.last_update_time = iprot.readI64();
struct.setLastUpdateTimeIsSet(true);
}
if (incoming.get(10)) {
struct.file_format = iprot.readString();
struct.setFileFormatIsSet(true);
}
if (incoming.get(11)) {
struct.deletion_file = new TPaimonDeletionFileDesc();
struct.deletion_file.read(iprot);
struct.setDeletionFileIsSet(true);
}
if (incoming.get(12)) {
{
org.apache.thrift.protocol.TMap _map134 = iprot.readMapBegin(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING);
struct.hadoop_conf = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map134.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key135;
@org.apache.thrift.annotation.Nullable java.lang.String _val136;
for (int _i137 = 0; _i137 < _map134.size; ++_i137)
{
_key135 = iprot.readString();
_val136 = iprot.readString();
struct.hadoop_conf.put(_key135, _val136);
}
}
struct.setHadoopConfIsSet(true);
}
if (incoming.get(13)) {
struct.paimon_table = iprot.readString();
struct.setPaimonTableIsSet(true);
}
if (incoming.get(14)) {
struct.row_count = iprot.readI64();
struct.setRowCountIsSet(true);
}
if (incoming.get(15)) {
struct.schema_id = iprot.readI64();
struct.setSchemaIdIsSet(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();
}
}