TLakeSoulFileDesc.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 TLakeSoulFileDesc implements org.apache.thrift.TBase<TLakeSoulFileDesc, TLakeSoulFileDesc._Fields>, java.io.Serializable, Cloneable, Comparable<TLakeSoulFileDesc> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TLakeSoulFileDesc");
private static final org.apache.thrift.protocol.TField FILE_PATHS_FIELD_DESC = new org.apache.thrift.protocol.TField("file_paths", org.apache.thrift.protocol.TType.LIST, (short)1);
private static final org.apache.thrift.protocol.TField PRIMARY_KEYS_FIELD_DESC = new org.apache.thrift.protocol.TField("primary_keys", org.apache.thrift.protocol.TType.LIST, (short)2);
private static final org.apache.thrift.protocol.TField PARTITION_DESCS_FIELD_DESC = new org.apache.thrift.protocol.TField("partition_descs", org.apache.thrift.protocol.TType.LIST, (short)3);
private static final org.apache.thrift.protocol.TField TABLE_SCHEMA_FIELD_DESC = new org.apache.thrift.protocol.TField("table_schema", org.apache.thrift.protocol.TType.STRING, (short)4);
private static final org.apache.thrift.protocol.TField OPTIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("options", org.apache.thrift.protocol.TType.STRING, (short)5);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TLakeSoulFileDescStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TLakeSoulFileDescTupleSchemeFactory();
public @org.apache.thrift.annotation.Nullable java.util.List<java.lang.String> file_paths; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<java.lang.String> primary_keys; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<java.lang.String> partition_descs; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String table_schema; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String options; // 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 {
FILE_PATHS((short)1, "file_paths"),
PRIMARY_KEYS((short)2, "primary_keys"),
PARTITION_DESCS((short)3, "partition_descs"),
TABLE_SCHEMA((short)4, "table_schema"),
OPTIONS((short)5, "options");
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: // FILE_PATHS
return FILE_PATHS;
case 2: // PRIMARY_KEYS
return PRIMARY_KEYS;
case 3: // PARTITION_DESCS
return PARTITION_DESCS;
case 4: // TABLE_SCHEMA
return TABLE_SCHEMA;
case 5: // OPTIONS
return OPTIONS;
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 _Fields optionals[] = {_Fields.FILE_PATHS,_Fields.PRIMARY_KEYS,_Fields.PARTITION_DESCS,_Fields.TABLE_SCHEMA,_Fields.OPTIONS};
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.FILE_PATHS, new org.apache.thrift.meta_data.FieldMetaData("file_paths", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
tmpMap.put(_Fields.PRIMARY_KEYS, new org.apache.thrift.meta_data.FieldMetaData("primary_keys", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
tmpMap.put(_Fields.PARTITION_DESCS, new org.apache.thrift.meta_data.FieldMetaData("partition_descs", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
tmpMap.put(_Fields.TABLE_SCHEMA, new org.apache.thrift.meta_data.FieldMetaData("table_schema", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.OPTIONS, new org.apache.thrift.meta_data.FieldMetaData("options", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TLakeSoulFileDesc.class, metaDataMap);
}
public TLakeSoulFileDesc() {
}
/**
* Performs a deep copy on <i>other</i>.
*/
public TLakeSoulFileDesc(TLakeSoulFileDesc other) {
if (other.isSetFilePaths()) {
java.util.List<java.lang.String> __this__file_paths = new java.util.ArrayList<java.lang.String>(other.file_paths);
this.file_paths = __this__file_paths;
}
if (other.isSetPrimaryKeys()) {
java.util.List<java.lang.String> __this__primary_keys = new java.util.ArrayList<java.lang.String>(other.primary_keys);
this.primary_keys = __this__primary_keys;
}
if (other.isSetPartitionDescs()) {
java.util.List<java.lang.String> __this__partition_descs = new java.util.ArrayList<java.lang.String>(other.partition_descs);
this.partition_descs = __this__partition_descs;
}
if (other.isSetTableSchema()) {
this.table_schema = other.table_schema;
}
if (other.isSetOptions()) {
this.options = other.options;
}
}
public TLakeSoulFileDesc deepCopy() {
return new TLakeSoulFileDesc(this);
}
@Override
public void clear() {
this.file_paths = null;
this.primary_keys = null;
this.partition_descs = null;
this.table_schema = null;
this.options = null;
}
public int getFilePathsSize() {
return (this.file_paths == null) ? 0 : this.file_paths.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<java.lang.String> getFilePathsIterator() {
return (this.file_paths == null) ? null : this.file_paths.iterator();
}
public void addToFilePaths(java.lang.String elem) {
if (this.file_paths == null) {
this.file_paths = new java.util.ArrayList<java.lang.String>();
}
this.file_paths.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<java.lang.String> getFilePaths() {
return this.file_paths;
}
public TLakeSoulFileDesc setFilePaths(@org.apache.thrift.annotation.Nullable java.util.List<java.lang.String> file_paths) {
this.file_paths = file_paths;
return this;
}
public void unsetFilePaths() {
this.file_paths = null;
}
/** Returns true if field file_paths is set (has been assigned a value) and false otherwise */
public boolean isSetFilePaths() {
return this.file_paths != null;
}
public void setFilePathsIsSet(boolean value) {
if (!value) {
this.file_paths = null;
}
}
public int getPrimaryKeysSize() {
return (this.primary_keys == null) ? 0 : this.primary_keys.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<java.lang.String> getPrimaryKeysIterator() {
return (this.primary_keys == null) ? null : this.primary_keys.iterator();
}
public void addToPrimaryKeys(java.lang.String elem) {
if (this.primary_keys == null) {
this.primary_keys = new java.util.ArrayList<java.lang.String>();
}
this.primary_keys.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<java.lang.String> getPrimaryKeys() {
return this.primary_keys;
}
public TLakeSoulFileDesc setPrimaryKeys(@org.apache.thrift.annotation.Nullable java.util.List<java.lang.String> primary_keys) {
this.primary_keys = primary_keys;
return this;
}
public void unsetPrimaryKeys() {
this.primary_keys = null;
}
/** Returns true if field primary_keys is set (has been assigned a value) and false otherwise */
public boolean isSetPrimaryKeys() {
return this.primary_keys != null;
}
public void setPrimaryKeysIsSet(boolean value) {
if (!value) {
this.primary_keys = null;
}
}
public int getPartitionDescsSize() {
return (this.partition_descs == null) ? 0 : this.partition_descs.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<java.lang.String> getPartitionDescsIterator() {
return (this.partition_descs == null) ? null : this.partition_descs.iterator();
}
public void addToPartitionDescs(java.lang.String elem) {
if (this.partition_descs == null) {
this.partition_descs = new java.util.ArrayList<java.lang.String>();
}
this.partition_descs.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<java.lang.String> getPartitionDescs() {
return this.partition_descs;
}
public TLakeSoulFileDesc setPartitionDescs(@org.apache.thrift.annotation.Nullable java.util.List<java.lang.String> partition_descs) {
this.partition_descs = partition_descs;
return this;
}
public void unsetPartitionDescs() {
this.partition_descs = null;
}
/** Returns true if field partition_descs is set (has been assigned a value) and false otherwise */
public boolean isSetPartitionDescs() {
return this.partition_descs != null;
}
public void setPartitionDescsIsSet(boolean value) {
if (!value) {
this.partition_descs = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getTableSchema() {
return this.table_schema;
}
public TLakeSoulFileDesc setTableSchema(@org.apache.thrift.annotation.Nullable java.lang.String table_schema) {
this.table_schema = table_schema;
return this;
}
public void unsetTableSchema() {
this.table_schema = null;
}
/** Returns true if field table_schema is set (has been assigned a value) and false otherwise */
public boolean isSetTableSchema() {
return this.table_schema != null;
}
public void setTableSchemaIsSet(boolean value) {
if (!value) {
this.table_schema = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getOptions() {
return this.options;
}
public TLakeSoulFileDesc setOptions(@org.apache.thrift.annotation.Nullable java.lang.String options) {
this.options = options;
return this;
}
public void unsetOptions() {
this.options = null;
}
/** Returns true if field options is set (has been assigned a value) and false otherwise */
public boolean isSetOptions() {
return this.options != null;
}
public void setOptionsIsSet(boolean value) {
if (!value) {
this.options = null;
}
}
public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case FILE_PATHS:
if (value == null) {
unsetFilePaths();
} else {
setFilePaths((java.util.List<java.lang.String>)value);
}
break;
case PRIMARY_KEYS:
if (value == null) {
unsetPrimaryKeys();
} else {
setPrimaryKeys((java.util.List<java.lang.String>)value);
}
break;
case PARTITION_DESCS:
if (value == null) {
unsetPartitionDescs();
} else {
setPartitionDescs((java.util.List<java.lang.String>)value);
}
break;
case TABLE_SCHEMA:
if (value == null) {
unsetTableSchema();
} else {
setTableSchema((java.lang.String)value);
}
break;
case OPTIONS:
if (value == null) {
unsetOptions();
} else {
setOptions((java.lang.String)value);
}
break;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case FILE_PATHS:
return getFilePaths();
case PRIMARY_KEYS:
return getPrimaryKeys();
case PARTITION_DESCS:
return getPartitionDescs();
case TABLE_SCHEMA:
return getTableSchema();
case OPTIONS:
return getOptions();
}
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 FILE_PATHS:
return isSetFilePaths();
case PRIMARY_KEYS:
return isSetPrimaryKeys();
case PARTITION_DESCS:
return isSetPartitionDescs();
case TABLE_SCHEMA:
return isSetTableSchema();
case OPTIONS:
return isSetOptions();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof TLakeSoulFileDesc)
return this.equals((TLakeSoulFileDesc)that);
return false;
}
public boolean equals(TLakeSoulFileDesc that) {
if (that == null)
return false;
if (this == that)
return true;
boolean this_present_file_paths = true && this.isSetFilePaths();
boolean that_present_file_paths = true && that.isSetFilePaths();
if (this_present_file_paths || that_present_file_paths) {
if (!(this_present_file_paths && that_present_file_paths))
return false;
if (!this.file_paths.equals(that.file_paths))
return false;
}
boolean this_present_primary_keys = true && this.isSetPrimaryKeys();
boolean that_present_primary_keys = true && that.isSetPrimaryKeys();
if (this_present_primary_keys || that_present_primary_keys) {
if (!(this_present_primary_keys && that_present_primary_keys))
return false;
if (!this.primary_keys.equals(that.primary_keys))
return false;
}
boolean this_present_partition_descs = true && this.isSetPartitionDescs();
boolean that_present_partition_descs = true && that.isSetPartitionDescs();
if (this_present_partition_descs || that_present_partition_descs) {
if (!(this_present_partition_descs && that_present_partition_descs))
return false;
if (!this.partition_descs.equals(that.partition_descs))
return false;
}
boolean this_present_table_schema = true && this.isSetTableSchema();
boolean that_present_table_schema = true && that.isSetTableSchema();
if (this_present_table_schema || that_present_table_schema) {
if (!(this_present_table_schema && that_present_table_schema))
return false;
if (!this.table_schema.equals(that.table_schema))
return false;
}
boolean this_present_options = true && this.isSetOptions();
boolean that_present_options = true && that.isSetOptions();
if (this_present_options || that_present_options) {
if (!(this_present_options && that_present_options))
return false;
if (!this.options.equals(that.options))
return false;
}
return true;
}
@Override
public int hashCode() {
int hashCode = 1;
hashCode = hashCode * 8191 + ((isSetFilePaths()) ? 131071 : 524287);
if (isSetFilePaths())
hashCode = hashCode * 8191 + file_paths.hashCode();
hashCode = hashCode * 8191 + ((isSetPrimaryKeys()) ? 131071 : 524287);
if (isSetPrimaryKeys())
hashCode = hashCode * 8191 + primary_keys.hashCode();
hashCode = hashCode * 8191 + ((isSetPartitionDescs()) ? 131071 : 524287);
if (isSetPartitionDescs())
hashCode = hashCode * 8191 + partition_descs.hashCode();
hashCode = hashCode * 8191 + ((isSetTableSchema()) ? 131071 : 524287);
if (isSetTableSchema())
hashCode = hashCode * 8191 + table_schema.hashCode();
hashCode = hashCode * 8191 + ((isSetOptions()) ? 131071 : 524287);
if (isSetOptions())
hashCode = hashCode * 8191 + options.hashCode();
return hashCode;
}
@Override
public int compareTo(TLakeSoulFileDesc other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = java.lang.Boolean.compare(isSetFilePaths(), other.isSetFilePaths());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetFilePaths()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.file_paths, other.file_paths);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetPrimaryKeys(), other.isSetPrimaryKeys());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPrimaryKeys()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.primary_keys, other.primary_keys);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetPartitionDescs(), other.isSetPartitionDescs());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPartitionDescs()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partition_descs, other.partition_descs);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTableSchema(), other.isSetTableSchema());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTableSchema()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.table_schema, other.table_schema);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetOptions(), other.isSetOptions());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOptions()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.options, other.options);
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("TLakeSoulFileDesc(");
boolean first = true;
if (isSetFilePaths()) {
sb.append("file_paths:");
if (this.file_paths == null) {
sb.append("null");
} else {
sb.append(this.file_paths);
}
first = false;
}
if (isSetPrimaryKeys()) {
if (!first) sb.append(", ");
sb.append("primary_keys:");
if (this.primary_keys == null) {
sb.append("null");
} else {
sb.append(this.primary_keys);
}
first = false;
}
if (isSetPartitionDescs()) {
if (!first) sb.append(", ");
sb.append("partition_descs:");
if (this.partition_descs == null) {
sb.append("null");
} else {
sb.append(this.partition_descs);
}
first = false;
}
if (isSetTableSchema()) {
if (!first) sb.append(", ");
sb.append("table_schema:");
if (this.table_schema == null) {
sb.append("null");
} else {
sb.append(this.table_schema);
}
first = false;
}
if (isSetOptions()) {
if (!first) sb.append(", ");
sb.append("options:");
if (this.options == null) {
sb.append("null");
} else {
sb.append(this.options);
}
first = false;
}
sb.append(")");
return sb.toString();
}
public void validate() throws org.apache.thrift.TException {
// check for required fields
// check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException {
try {
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 TLakeSoulFileDescStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TLakeSoulFileDescStandardScheme getScheme() {
return new TLakeSoulFileDescStandardScheme();
}
}
private static class TLakeSoulFileDescStandardScheme extends org.apache.thrift.scheme.StandardScheme<TLakeSoulFileDesc> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TLakeSoulFileDesc 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: // FILE_PATHS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list180 = iprot.readListBegin();
struct.file_paths = new java.util.ArrayList<java.lang.String>(_list180.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem181;
for (int _i182 = 0; _i182 < _list180.size; ++_i182)
{
_elem181 = iprot.readString();
struct.file_paths.add(_elem181);
}
iprot.readListEnd();
}
struct.setFilePathsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // PRIMARY_KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list183 = iprot.readListBegin();
struct.primary_keys = new java.util.ArrayList<java.lang.String>(_list183.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem184;
for (int _i185 = 0; _i185 < _list183.size; ++_i185)
{
_elem184 = iprot.readString();
struct.primary_keys.add(_elem184);
}
iprot.readListEnd();
}
struct.setPrimaryKeysIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // PARTITION_DESCS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list186 = iprot.readListBegin();
struct.partition_descs = new java.util.ArrayList<java.lang.String>(_list186.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem187;
for (int _i188 = 0; _i188 < _list186.size; ++_i188)
{
_elem187 = iprot.readString();
struct.partition_descs.add(_elem187);
}
iprot.readListEnd();
}
struct.setPartitionDescsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // TABLE_SCHEMA
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.table_schema = iprot.readString();
struct.setTableSchemaIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // OPTIONS
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.options = iprot.readString();
struct.setOptionsIsSet(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, TLakeSoulFileDesc struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.file_paths != null) {
if (struct.isSetFilePaths()) {
oprot.writeFieldBegin(FILE_PATHS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.file_paths.size()));
for (java.lang.String _iter189 : struct.file_paths)
{
oprot.writeString(_iter189);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.primary_keys != null) {
if (struct.isSetPrimaryKeys()) {
oprot.writeFieldBegin(PRIMARY_KEYS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.primary_keys.size()));
for (java.lang.String _iter190 : struct.primary_keys)
{
oprot.writeString(_iter190);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.partition_descs != null) {
if (struct.isSetPartitionDescs()) {
oprot.writeFieldBegin(PARTITION_DESCS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partition_descs.size()));
for (java.lang.String _iter191 : struct.partition_descs)
{
oprot.writeString(_iter191);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.table_schema != null) {
if (struct.isSetTableSchema()) {
oprot.writeFieldBegin(TABLE_SCHEMA_FIELD_DESC);
oprot.writeString(struct.table_schema);
oprot.writeFieldEnd();
}
}
if (struct.options != null) {
if (struct.isSetOptions()) {
oprot.writeFieldBegin(OPTIONS_FIELD_DESC);
oprot.writeString(struct.options);
oprot.writeFieldEnd();
}
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class TLakeSoulFileDescTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TLakeSoulFileDescTupleScheme getScheme() {
return new TLakeSoulFileDescTupleScheme();
}
}
private static class TLakeSoulFileDescTupleScheme extends org.apache.thrift.scheme.TupleScheme<TLakeSoulFileDesc> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TLakeSoulFileDesc 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.isSetFilePaths()) {
optionals.set(0);
}
if (struct.isSetPrimaryKeys()) {
optionals.set(1);
}
if (struct.isSetPartitionDescs()) {
optionals.set(2);
}
if (struct.isSetTableSchema()) {
optionals.set(3);
}
if (struct.isSetOptions()) {
optionals.set(4);
}
oprot.writeBitSet(optionals, 5);
if (struct.isSetFilePaths()) {
{
oprot.writeI32(struct.file_paths.size());
for (java.lang.String _iter192 : struct.file_paths)
{
oprot.writeString(_iter192);
}
}
}
if (struct.isSetPrimaryKeys()) {
{
oprot.writeI32(struct.primary_keys.size());
for (java.lang.String _iter193 : struct.primary_keys)
{
oprot.writeString(_iter193);
}
}
}
if (struct.isSetPartitionDescs()) {
{
oprot.writeI32(struct.partition_descs.size());
for (java.lang.String _iter194 : struct.partition_descs)
{
oprot.writeString(_iter194);
}
}
}
if (struct.isSetTableSchema()) {
oprot.writeString(struct.table_schema);
}
if (struct.isSetOptions()) {
oprot.writeString(struct.options);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TLakeSoulFileDesc struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet incoming = iprot.readBitSet(5);
if (incoming.get(0)) {
{
org.apache.thrift.protocol.TList _list195 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRING);
struct.file_paths = new java.util.ArrayList<java.lang.String>(_list195.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem196;
for (int _i197 = 0; _i197 < _list195.size; ++_i197)
{
_elem196 = iprot.readString();
struct.file_paths.add(_elem196);
}
}
struct.setFilePathsIsSet(true);
}
if (incoming.get(1)) {
{
org.apache.thrift.protocol.TList _list198 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRING);
struct.primary_keys = new java.util.ArrayList<java.lang.String>(_list198.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem199;
for (int _i200 = 0; _i200 < _list198.size; ++_i200)
{
_elem199 = iprot.readString();
struct.primary_keys.add(_elem199);
}
}
struct.setPrimaryKeysIsSet(true);
}
if (incoming.get(2)) {
{
org.apache.thrift.protocol.TList _list201 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRING);
struct.partition_descs = new java.util.ArrayList<java.lang.String>(_list201.size);
@org.apache.thrift.annotation.Nullable java.lang.String _elem202;
for (int _i203 = 0; _i203 < _list201.size; ++_i203)
{
_elem202 = iprot.readString();
struct.partition_descs.add(_elem202);
}
}
struct.setPartitionDescsIsSet(true);
}
if (incoming.get(3)) {
struct.table_schema = iprot.readString();
struct.setTableSchemaIsSet(true);
}
if (incoming.get(4)) {
struct.options = iprot.readString();
struct.setOptionsIsSet(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();
}
}