TRemoteDorisFileDesc.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 TRemoteDorisFileDesc implements org.apache.thrift.TBase<TRemoteDorisFileDesc, TRemoteDorisFileDesc._Fields>, java.io.Serializable, Cloneable, Comparable<TRemoteDorisFileDesc> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TRemoteDorisFileDesc");
private static final org.apache.thrift.protocol.TField IP_FIELD_DESC = new org.apache.thrift.protocol.TField("ip", org.apache.thrift.protocol.TType.STRING, (short)1);
private static final org.apache.thrift.protocol.TField ARROW_PORT_FIELD_DESC = new org.apache.thrift.protocol.TField("arrow_port", org.apache.thrift.protocol.TType.STRING, (short)2);
private static final org.apache.thrift.protocol.TField TICKET_FIELD_DESC = new org.apache.thrift.protocol.TField("ticket", org.apache.thrift.protocol.TType.STRING, (short)3);
private static final org.apache.thrift.protocol.TField LOCATION_URI_FIELD_DESC = new org.apache.thrift.protocol.TField("location_uri", org.apache.thrift.protocol.TType.STRING, (short)4);
private static final org.apache.thrift.protocol.TField USER_FIELD_DESC = new org.apache.thrift.protocol.TField("user", org.apache.thrift.protocol.TType.STRING, (short)5);
private static final org.apache.thrift.protocol.TField PASSWORD_FIELD_DESC = new org.apache.thrift.protocol.TField("password", org.apache.thrift.protocol.TType.STRING, (short)6);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TRemoteDorisFileDescStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TRemoteDorisFileDescTupleSchemeFactory();
public @org.apache.thrift.annotation.Nullable java.lang.String ip; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String arrow_port; // optional
public @org.apache.thrift.annotation.Nullable java.nio.ByteBuffer ticket; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String location_uri; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String user; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String password; // 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 {
IP((short)1, "ip"),
ARROW_PORT((short)2, "arrow_port"),
TICKET((short)3, "ticket"),
LOCATION_URI((short)4, "location_uri"),
USER((short)5, "user"),
PASSWORD((short)6, "password");
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: // IP
return IP;
case 2: // ARROW_PORT
return ARROW_PORT;
case 3: // TICKET
return TICKET;
case 4: // LOCATION_URI
return LOCATION_URI;
case 5: // USER
return USER;
case 6: // PASSWORD
return PASSWORD;
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.IP,_Fields.ARROW_PORT,_Fields.TICKET,_Fields.LOCATION_URI,_Fields.USER,_Fields.PASSWORD};
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.IP, new org.apache.thrift.meta_data.FieldMetaData("ip", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.ARROW_PORT, new org.apache.thrift.meta_data.FieldMetaData("arrow_port", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.TICKET, new org.apache.thrift.meta_data.FieldMetaData("ticket", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true)));
tmpMap.put(_Fields.LOCATION_URI, new org.apache.thrift.meta_data.FieldMetaData("location_uri", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.USER, new org.apache.thrift.meta_data.FieldMetaData("user", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.PASSWORD, new org.apache.thrift.meta_data.FieldMetaData("password", 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(TRemoteDorisFileDesc.class, metaDataMap);
}
public TRemoteDorisFileDesc() {
}
/**
* Performs a deep copy on <i>other</i>.
*/
public TRemoteDorisFileDesc(TRemoteDorisFileDesc other) {
if (other.isSetIp()) {
this.ip = other.ip;
}
if (other.isSetArrowPort()) {
this.arrow_port = other.arrow_port;
}
if (other.isSetTicket()) {
this.ticket = org.apache.thrift.TBaseHelper.copyBinary(other.ticket);
}
if (other.isSetLocationUri()) {
this.location_uri = other.location_uri;
}
if (other.isSetUser()) {
this.user = other.user;
}
if (other.isSetPassword()) {
this.password = other.password;
}
}
public TRemoteDorisFileDesc deepCopy() {
return new TRemoteDorisFileDesc(this);
}
@Override
public void clear() {
this.ip = null;
this.arrow_port = null;
this.ticket = null;
this.location_uri = null;
this.user = null;
this.password = null;
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getIp() {
return this.ip;
}
public TRemoteDorisFileDesc setIp(@org.apache.thrift.annotation.Nullable java.lang.String ip) {
this.ip = ip;
return this;
}
public void unsetIp() {
this.ip = null;
}
/** Returns true if field ip is set (has been assigned a value) and false otherwise */
public boolean isSetIp() {
return this.ip != null;
}
public void setIpIsSet(boolean value) {
if (!value) {
this.ip = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getArrowPort() {
return this.arrow_port;
}
public TRemoteDorisFileDesc setArrowPort(@org.apache.thrift.annotation.Nullable java.lang.String arrow_port) {
this.arrow_port = arrow_port;
return this;
}
public void unsetArrowPort() {
this.arrow_port = null;
}
/** Returns true if field arrow_port is set (has been assigned a value) and false otherwise */
public boolean isSetArrowPort() {
return this.arrow_port != null;
}
public void setArrowPortIsSet(boolean value) {
if (!value) {
this.arrow_port = null;
}
}
public byte[] getTicket() {
setTicket(org.apache.thrift.TBaseHelper.rightSize(ticket));
return ticket == null ? null : ticket.array();
}
public java.nio.ByteBuffer bufferForTicket() {
return org.apache.thrift.TBaseHelper.copyBinary(ticket);
}
public TRemoteDorisFileDesc setTicket(byte[] ticket) {
this.ticket = ticket == null ? (java.nio.ByteBuffer)null : java.nio.ByteBuffer.wrap(ticket.clone());
return this;
}
public TRemoteDorisFileDesc setTicket(@org.apache.thrift.annotation.Nullable java.nio.ByteBuffer ticket) {
this.ticket = org.apache.thrift.TBaseHelper.copyBinary(ticket);
return this;
}
public void unsetTicket() {
this.ticket = null;
}
/** Returns true if field ticket is set (has been assigned a value) and false otherwise */
public boolean isSetTicket() {
return this.ticket != null;
}
public void setTicketIsSet(boolean value) {
if (!value) {
this.ticket = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getLocationUri() {
return this.location_uri;
}
public TRemoteDorisFileDesc setLocationUri(@org.apache.thrift.annotation.Nullable java.lang.String location_uri) {
this.location_uri = location_uri;
return this;
}
public void unsetLocationUri() {
this.location_uri = null;
}
/** Returns true if field location_uri is set (has been assigned a value) and false otherwise */
public boolean isSetLocationUri() {
return this.location_uri != null;
}
public void setLocationUriIsSet(boolean value) {
if (!value) {
this.location_uri = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getUser() {
return this.user;
}
public TRemoteDorisFileDesc setUser(@org.apache.thrift.annotation.Nullable java.lang.String user) {
this.user = user;
return this;
}
public void unsetUser() {
this.user = null;
}
/** Returns true if field user is set (has been assigned a value) and false otherwise */
public boolean isSetUser() {
return this.user != null;
}
public void setUserIsSet(boolean value) {
if (!value) {
this.user = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getPassword() {
return this.password;
}
public TRemoteDorisFileDesc setPassword(@org.apache.thrift.annotation.Nullable java.lang.String password) {
this.password = password;
return this;
}
public void unsetPassword() {
this.password = null;
}
/** Returns true if field password is set (has been assigned a value) and false otherwise */
public boolean isSetPassword() {
return this.password != null;
}
public void setPasswordIsSet(boolean value) {
if (!value) {
this.password = null;
}
}
public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case IP:
if (value == null) {
unsetIp();
} else {
setIp((java.lang.String)value);
}
break;
case ARROW_PORT:
if (value == null) {
unsetArrowPort();
} else {
setArrowPort((java.lang.String)value);
}
break;
case TICKET:
if (value == null) {
unsetTicket();
} else {
if (value instanceof byte[]) {
setTicket((byte[])value);
} else {
setTicket((java.nio.ByteBuffer)value);
}
}
break;
case LOCATION_URI:
if (value == null) {
unsetLocationUri();
} else {
setLocationUri((java.lang.String)value);
}
break;
case USER:
if (value == null) {
unsetUser();
} else {
setUser((java.lang.String)value);
}
break;
case PASSWORD:
if (value == null) {
unsetPassword();
} else {
setPassword((java.lang.String)value);
}
break;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case IP:
return getIp();
case ARROW_PORT:
return getArrowPort();
case TICKET:
return getTicket();
case LOCATION_URI:
return getLocationUri();
case USER:
return getUser();
case PASSWORD:
return getPassword();
}
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 IP:
return isSetIp();
case ARROW_PORT:
return isSetArrowPort();
case TICKET:
return isSetTicket();
case LOCATION_URI:
return isSetLocationUri();
case USER:
return isSetUser();
case PASSWORD:
return isSetPassword();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof TRemoteDorisFileDesc)
return this.equals((TRemoteDorisFileDesc)that);
return false;
}
public boolean equals(TRemoteDorisFileDesc that) {
if (that == null)
return false;
if (this == that)
return true;
boolean this_present_ip = true && this.isSetIp();
boolean that_present_ip = true && that.isSetIp();
if (this_present_ip || that_present_ip) {
if (!(this_present_ip && that_present_ip))
return false;
if (!this.ip.equals(that.ip))
return false;
}
boolean this_present_arrow_port = true && this.isSetArrowPort();
boolean that_present_arrow_port = true && that.isSetArrowPort();
if (this_present_arrow_port || that_present_arrow_port) {
if (!(this_present_arrow_port && that_present_arrow_port))
return false;
if (!this.arrow_port.equals(that.arrow_port))
return false;
}
boolean this_present_ticket = true && this.isSetTicket();
boolean that_present_ticket = true && that.isSetTicket();
if (this_present_ticket || that_present_ticket) {
if (!(this_present_ticket && that_present_ticket))
return false;
if (!this.ticket.equals(that.ticket))
return false;
}
boolean this_present_location_uri = true && this.isSetLocationUri();
boolean that_present_location_uri = true && that.isSetLocationUri();
if (this_present_location_uri || that_present_location_uri) {
if (!(this_present_location_uri && that_present_location_uri))
return false;
if (!this.location_uri.equals(that.location_uri))
return false;
}
boolean this_present_user = true && this.isSetUser();
boolean that_present_user = true && that.isSetUser();
if (this_present_user || that_present_user) {
if (!(this_present_user && that_present_user))
return false;
if (!this.user.equals(that.user))
return false;
}
boolean this_present_password = true && this.isSetPassword();
boolean that_present_password = true && that.isSetPassword();
if (this_present_password || that_present_password) {
if (!(this_present_password && that_present_password))
return false;
if (!this.password.equals(that.password))
return false;
}
return true;
}
@Override
public int hashCode() {
int hashCode = 1;
hashCode = hashCode * 8191 + ((isSetIp()) ? 131071 : 524287);
if (isSetIp())
hashCode = hashCode * 8191 + ip.hashCode();
hashCode = hashCode * 8191 + ((isSetArrowPort()) ? 131071 : 524287);
if (isSetArrowPort())
hashCode = hashCode * 8191 + arrow_port.hashCode();
hashCode = hashCode * 8191 + ((isSetTicket()) ? 131071 : 524287);
if (isSetTicket())
hashCode = hashCode * 8191 + ticket.hashCode();
hashCode = hashCode * 8191 + ((isSetLocationUri()) ? 131071 : 524287);
if (isSetLocationUri())
hashCode = hashCode * 8191 + location_uri.hashCode();
hashCode = hashCode * 8191 + ((isSetUser()) ? 131071 : 524287);
if (isSetUser())
hashCode = hashCode * 8191 + user.hashCode();
hashCode = hashCode * 8191 + ((isSetPassword()) ? 131071 : 524287);
if (isSetPassword())
hashCode = hashCode * 8191 + password.hashCode();
return hashCode;
}
@Override
public int compareTo(TRemoteDorisFileDesc other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = java.lang.Boolean.compare(isSetIp(), other.isSetIp());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetIp()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ip, other.ip);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetArrowPort(), other.isSetArrowPort());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetArrowPort()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.arrow_port, other.arrow_port);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTicket(), other.isSetTicket());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTicket()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ticket, other.ticket);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetLocationUri(), other.isSetLocationUri());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetLocationUri()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.location_uri, other.location_uri);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetUser(), other.isSetUser());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetUser()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.user, other.user);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetPassword(), other.isSetPassword());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPassword()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.password, other.password);
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("TRemoteDorisFileDesc(");
boolean first = true;
if (isSetIp()) {
sb.append("ip:");
if (this.ip == null) {
sb.append("null");
} else {
sb.append(this.ip);
}
first = false;
}
if (isSetArrowPort()) {
if (!first) sb.append(", ");
sb.append("arrow_port:");
if (this.arrow_port == null) {
sb.append("null");
} else {
sb.append(this.arrow_port);
}
first = false;
}
if (isSetTicket()) {
if (!first) sb.append(", ");
sb.append("ticket:");
if (this.ticket == null) {
sb.append("null");
} else {
org.apache.thrift.TBaseHelper.toString(this.ticket, sb);
}
first = false;
}
if (isSetLocationUri()) {
if (!first) sb.append(", ");
sb.append("location_uri:");
if (this.location_uri == null) {
sb.append("null");
} else {
sb.append(this.location_uri);
}
first = false;
}
if (isSetUser()) {
if (!first) sb.append(", ");
sb.append("user:");
if (this.user == null) {
sb.append("null");
} else {
sb.append(this.user);
}
first = false;
}
if (isSetPassword()) {
if (!first) sb.append(", ");
sb.append("password:");
if (this.password == null) {
sb.append("null");
} else {
sb.append(this.password);
}
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 TRemoteDorisFileDescStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TRemoteDorisFileDescStandardScheme getScheme() {
return new TRemoteDorisFileDescStandardScheme();
}
}
private static class TRemoteDorisFileDescStandardScheme extends org.apache.thrift.scheme.StandardScheme<TRemoteDorisFileDesc> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TRemoteDorisFileDesc 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: // IP
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.ip = iprot.readString();
struct.setIpIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // ARROW_PORT
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.arrow_port = iprot.readString();
struct.setArrowPortIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // TICKET
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.ticket = iprot.readBinary();
struct.setTicketIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // LOCATION_URI
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.location_uri = iprot.readString();
struct.setLocationUriIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // USER
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.user = iprot.readString();
struct.setUserIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // PASSWORD
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.password = iprot.readString();
struct.setPasswordIsSet(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, TRemoteDorisFileDesc struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.ip != null) {
if (struct.isSetIp()) {
oprot.writeFieldBegin(IP_FIELD_DESC);
oprot.writeString(struct.ip);
oprot.writeFieldEnd();
}
}
if (struct.arrow_port != null) {
if (struct.isSetArrowPort()) {
oprot.writeFieldBegin(ARROW_PORT_FIELD_DESC);
oprot.writeString(struct.arrow_port);
oprot.writeFieldEnd();
}
}
if (struct.ticket != null) {
if (struct.isSetTicket()) {
oprot.writeFieldBegin(TICKET_FIELD_DESC);
oprot.writeBinary(struct.ticket);
oprot.writeFieldEnd();
}
}
if (struct.location_uri != null) {
if (struct.isSetLocationUri()) {
oprot.writeFieldBegin(LOCATION_URI_FIELD_DESC);
oprot.writeString(struct.location_uri);
oprot.writeFieldEnd();
}
}
if (struct.user != null) {
if (struct.isSetUser()) {
oprot.writeFieldBegin(USER_FIELD_DESC);
oprot.writeString(struct.user);
oprot.writeFieldEnd();
}
}
if (struct.password != null) {
if (struct.isSetPassword()) {
oprot.writeFieldBegin(PASSWORD_FIELD_DESC);
oprot.writeString(struct.password);
oprot.writeFieldEnd();
}
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class TRemoteDorisFileDescTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TRemoteDorisFileDescTupleScheme getScheme() {
return new TRemoteDorisFileDescTupleScheme();
}
}
private static class TRemoteDorisFileDescTupleScheme extends org.apache.thrift.scheme.TupleScheme<TRemoteDorisFileDesc> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TRemoteDorisFileDesc 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.isSetIp()) {
optionals.set(0);
}
if (struct.isSetArrowPort()) {
optionals.set(1);
}
if (struct.isSetTicket()) {
optionals.set(2);
}
if (struct.isSetLocationUri()) {
optionals.set(3);
}
if (struct.isSetUser()) {
optionals.set(4);
}
if (struct.isSetPassword()) {
optionals.set(5);
}
oprot.writeBitSet(optionals, 6);
if (struct.isSetIp()) {
oprot.writeString(struct.ip);
}
if (struct.isSetArrowPort()) {
oprot.writeString(struct.arrow_port);
}
if (struct.isSetTicket()) {
oprot.writeBinary(struct.ticket);
}
if (struct.isSetLocationUri()) {
oprot.writeString(struct.location_uri);
}
if (struct.isSetUser()) {
oprot.writeString(struct.user);
}
if (struct.isSetPassword()) {
oprot.writeString(struct.password);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TRemoteDorisFileDesc struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet incoming = iprot.readBitSet(6);
if (incoming.get(0)) {
struct.ip = iprot.readString();
struct.setIpIsSet(true);
}
if (incoming.get(1)) {
struct.arrow_port = iprot.readString();
struct.setArrowPortIsSet(true);
}
if (incoming.get(2)) {
struct.ticket = iprot.readBinary();
struct.setTicketIsSet(true);
}
if (incoming.get(3)) {
struct.location_uri = iprot.readString();
struct.setLocationUriIsSet(true);
}
if (incoming.get(4)) {
struct.user = iprot.readString();
struct.setUserIsSet(true);
}
if (incoming.get(5)) {
struct.password = iprot.readString();
struct.setPasswordIsSet(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();
}
}