TTVFTableSink.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 TTVFTableSink implements org.apache.thrift.TBase<TTVFTableSink, TTVFTableSink._Fields>, java.io.Serializable, Cloneable, Comparable<TTVFTableSink> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTVFTableSink");
private static final org.apache.thrift.protocol.TField TVF_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tvf_name", org.apache.thrift.protocol.TType.STRING, (short)1);
private static final org.apache.thrift.protocol.TField FILE_PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("file_path", org.apache.thrift.protocol.TType.STRING, (short)2);
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.I32, (short)3);
private static final org.apache.thrift.protocol.TField FILE_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("file_type", org.apache.thrift.protocol.TType.I32, (short)4);
private static final org.apache.thrift.protocol.TField PROPERTIES_FIELD_DESC = new org.apache.thrift.protocol.TField("properties", org.apache.thrift.protocol.TType.MAP, (short)5);
private static final org.apache.thrift.protocol.TField COLUMNS_FIELD_DESC = new org.apache.thrift.protocol.TField("columns", org.apache.thrift.protocol.TType.LIST, (short)6);
private static final org.apache.thrift.protocol.TField COLUMN_SEPARATOR_FIELD_DESC = new org.apache.thrift.protocol.TField("column_separator", org.apache.thrift.protocol.TType.STRING, (short)7);
private static final org.apache.thrift.protocol.TField LINE_DELIMITER_FIELD_DESC = new org.apache.thrift.protocol.TField("line_delimiter", org.apache.thrift.protocol.TType.STRING, (short)8);
private static final org.apache.thrift.protocol.TField MAX_FILE_SIZE_BYTES_FIELD_DESC = new org.apache.thrift.protocol.TField("max_file_size_bytes", org.apache.thrift.protocol.TType.I64, (short)9);
private static final org.apache.thrift.protocol.TField DELETE_EXISTING_FILES_FIELD_DESC = new org.apache.thrift.protocol.TField("delete_existing_files", org.apache.thrift.protocol.TType.BOOL, (short)10);
private static final org.apache.thrift.protocol.TField HADOOP_CONFIG_FIELD_DESC = new org.apache.thrift.protocol.TField("hadoop_config", org.apache.thrift.protocol.TType.MAP, (short)11);
private static final org.apache.thrift.protocol.TField COMPRESSION_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("compression_type", org.apache.thrift.protocol.TType.I32, (short)12);
private static final org.apache.thrift.protocol.TField BACKEND_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("backend_id", org.apache.thrift.protocol.TType.I64, (short)13);
private static final org.apache.thrift.protocol.TField WRITER_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("writer_type", org.apache.thrift.protocol.TType.I32, (short)14);
private static final org.apache.thrift.protocol.TField WRITER_CLASS_FIELD_DESC = new org.apache.thrift.protocol.TField("writer_class", org.apache.thrift.protocol.TType.STRING, (short)15);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TTVFTableSinkStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TTVFTableSinkTupleSchemeFactory();
public @org.apache.thrift.annotation.Nullable java.lang.String tvf_name; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String file_path; // optional
/**
*
* @see org.apache.doris.thrift.TFileFormatType
*/
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TFileFormatType file_format; // optional
/**
*
* @see org.apache.doris.thrift.TFileType
*/
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TFileType file_type; // optional
public @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> properties; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TColumn> columns; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String column_separator; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String line_delimiter; // optional
public long max_file_size_bytes; // optional
public boolean delete_existing_files; // optional
public @org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> hadoop_config; // optional
/**
*
* @see org.apache.doris.thrift.TFileCompressType
*/
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TFileCompressType compression_type; // optional
public long backend_id; // optional
/**
*
* @see TTVFWriterType
*/
public @org.apache.thrift.annotation.Nullable TTVFWriterType writer_type; // optional
public @org.apache.thrift.annotation.Nullable java.lang.String writer_class; // 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 {
TVF_NAME((short)1, "tvf_name"),
FILE_PATH((short)2, "file_path"),
/**
*
* @see org.apache.doris.thrift.TFileFormatType
*/
FILE_FORMAT((short)3, "file_format"),
/**
*
* @see org.apache.doris.thrift.TFileType
*/
FILE_TYPE((short)4, "file_type"),
PROPERTIES((short)5, "properties"),
COLUMNS((short)6, "columns"),
COLUMN_SEPARATOR((short)7, "column_separator"),
LINE_DELIMITER((short)8, "line_delimiter"),
MAX_FILE_SIZE_BYTES((short)9, "max_file_size_bytes"),
DELETE_EXISTING_FILES((short)10, "delete_existing_files"),
HADOOP_CONFIG((short)11, "hadoop_config"),
/**
*
* @see org.apache.doris.thrift.TFileCompressType
*/
COMPRESSION_TYPE((short)12, "compression_type"),
BACKEND_ID((short)13, "backend_id"),
/**
*
* @see TTVFWriterType
*/
WRITER_TYPE((short)14, "writer_type"),
WRITER_CLASS((short)15, "writer_class");
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: // TVF_NAME
return TVF_NAME;
case 2: // FILE_PATH
return FILE_PATH;
case 3: // FILE_FORMAT
return FILE_FORMAT;
case 4: // FILE_TYPE
return FILE_TYPE;
case 5: // PROPERTIES
return PROPERTIES;
case 6: // COLUMNS
return COLUMNS;
case 7: // COLUMN_SEPARATOR
return COLUMN_SEPARATOR;
case 8: // LINE_DELIMITER
return LINE_DELIMITER;
case 9: // MAX_FILE_SIZE_BYTES
return MAX_FILE_SIZE_BYTES;
case 10: // DELETE_EXISTING_FILES
return DELETE_EXISTING_FILES;
case 11: // HADOOP_CONFIG
return HADOOP_CONFIG;
case 12: // COMPRESSION_TYPE
return COMPRESSION_TYPE;
case 13: // BACKEND_ID
return BACKEND_ID;
case 14: // WRITER_TYPE
return WRITER_TYPE;
case 15: // WRITER_CLASS
return WRITER_CLASS;
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 __MAX_FILE_SIZE_BYTES_ISSET_ID = 0;
private static final int __DELETE_EXISTING_FILES_ISSET_ID = 1;
private static final int __BACKEND_ID_ISSET_ID = 2;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.TVF_NAME,_Fields.FILE_PATH,_Fields.FILE_FORMAT,_Fields.FILE_TYPE,_Fields.PROPERTIES,_Fields.COLUMNS,_Fields.COLUMN_SEPARATOR,_Fields.LINE_DELIMITER,_Fields.MAX_FILE_SIZE_BYTES,_Fields.DELETE_EXISTING_FILES,_Fields.HADOOP_CONFIG,_Fields.COMPRESSION_TYPE,_Fields.BACKEND_ID,_Fields.WRITER_TYPE,_Fields.WRITER_CLASS};
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.TVF_NAME, new org.apache.thrift.meta_data.FieldMetaData("tvf_name", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.FILE_PATH, new org.apache.thrift.meta_data.FieldMetaData("file_path", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
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.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, org.apache.doris.thrift.TFileFormatType.class)));
tmpMap.put(_Fields.FILE_TYPE, new org.apache.thrift.meta_data.FieldMetaData("file_type", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, org.apache.doris.thrift.TFileType.class)));
tmpMap.put(_Fields.PROPERTIES, new org.apache.thrift.meta_data.FieldMetaData("properties", 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.COLUMNS, new org.apache.thrift.meta_data.FieldMetaData("columns", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TColumn.class))));
tmpMap.put(_Fields.COLUMN_SEPARATOR, new org.apache.thrift.meta_data.FieldMetaData("column_separator", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.LINE_DELIMITER, new org.apache.thrift.meta_data.FieldMetaData("line_delimiter", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.MAX_FILE_SIZE_BYTES, new org.apache.thrift.meta_data.FieldMetaData("max_file_size_bytes", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.DELETE_EXISTING_FILES, new org.apache.thrift.meta_data.FieldMetaData("delete_existing_files", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.HADOOP_CONFIG, new org.apache.thrift.meta_data.FieldMetaData("hadoop_config", 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.COMPRESSION_TYPE, new org.apache.thrift.meta_data.FieldMetaData("compression_type", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, org.apache.doris.thrift.TFileCompressType.class)));
tmpMap.put(_Fields.BACKEND_ID, new org.apache.thrift.meta_data.FieldMetaData("backend_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.WRITER_TYPE, new org.apache.thrift.meta_data.FieldMetaData("writer_type", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, TTVFWriterType.class)));
tmpMap.put(_Fields.WRITER_CLASS, new org.apache.thrift.meta_data.FieldMetaData("writer_class", 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(TTVFTableSink.class, metaDataMap);
}
public TTVFTableSink() {
}
/**
* Performs a deep copy on <i>other</i>.
*/
public TTVFTableSink(TTVFTableSink other) {
__isset_bitfield = other.__isset_bitfield;
if (other.isSetTvfName()) {
this.tvf_name = other.tvf_name;
}
if (other.isSetFilePath()) {
this.file_path = other.file_path;
}
if (other.isSetFileFormat()) {
this.file_format = other.file_format;
}
if (other.isSetFileType()) {
this.file_type = other.file_type;
}
if (other.isSetProperties()) {
java.util.Map<java.lang.String,java.lang.String> __this__properties = new java.util.HashMap<java.lang.String,java.lang.String>(other.properties);
this.properties = __this__properties;
}
if (other.isSetColumns()) {
java.util.List<org.apache.doris.thrift.TColumn> __this__columns = new java.util.ArrayList<org.apache.doris.thrift.TColumn>(other.columns.size());
for (org.apache.doris.thrift.TColumn other_element : other.columns) {
__this__columns.add(new org.apache.doris.thrift.TColumn(other_element));
}
this.columns = __this__columns;
}
if (other.isSetColumnSeparator()) {
this.column_separator = other.column_separator;
}
if (other.isSetLineDelimiter()) {
this.line_delimiter = other.line_delimiter;
}
this.max_file_size_bytes = other.max_file_size_bytes;
this.delete_existing_files = other.delete_existing_files;
if (other.isSetHadoopConfig()) {
java.util.Map<java.lang.String,java.lang.String> __this__hadoop_config = new java.util.HashMap<java.lang.String,java.lang.String>(other.hadoop_config);
this.hadoop_config = __this__hadoop_config;
}
if (other.isSetCompressionType()) {
this.compression_type = other.compression_type;
}
this.backend_id = other.backend_id;
if (other.isSetWriterType()) {
this.writer_type = other.writer_type;
}
if (other.isSetWriterClass()) {
this.writer_class = other.writer_class;
}
}
public TTVFTableSink deepCopy() {
return new TTVFTableSink(this);
}
@Override
public void clear() {
this.tvf_name = null;
this.file_path = null;
this.file_format = null;
this.file_type = null;
this.properties = null;
this.columns = null;
this.column_separator = null;
this.line_delimiter = null;
setMaxFileSizeBytesIsSet(false);
this.max_file_size_bytes = 0;
setDeleteExistingFilesIsSet(false);
this.delete_existing_files = false;
this.hadoop_config = null;
this.compression_type = null;
setBackendIdIsSet(false);
this.backend_id = 0;
this.writer_type = null;
this.writer_class = null;
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getTvfName() {
return this.tvf_name;
}
public TTVFTableSink setTvfName(@org.apache.thrift.annotation.Nullable java.lang.String tvf_name) {
this.tvf_name = tvf_name;
return this;
}
public void unsetTvfName() {
this.tvf_name = null;
}
/** Returns true if field tvf_name is set (has been assigned a value) and false otherwise */
public boolean isSetTvfName() {
return this.tvf_name != null;
}
public void setTvfNameIsSet(boolean value) {
if (!value) {
this.tvf_name = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getFilePath() {
return this.file_path;
}
public TTVFTableSink setFilePath(@org.apache.thrift.annotation.Nullable java.lang.String file_path) {
this.file_path = file_path;
return this;
}
public void unsetFilePath() {
this.file_path = null;
}
/** Returns true if field file_path is set (has been assigned a value) and false otherwise */
public boolean isSetFilePath() {
return this.file_path != null;
}
public void setFilePathIsSet(boolean value) {
if (!value) {
this.file_path = null;
}
}
/**
*
* @see org.apache.doris.thrift.TFileFormatType
*/
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TFileFormatType getFileFormat() {
return this.file_format;
}
/**
*
* @see org.apache.doris.thrift.TFileFormatType
*/
public TTVFTableSink setFileFormat(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TFileFormatType 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;
}
}
/**
*
* @see org.apache.doris.thrift.TFileType
*/
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TFileType getFileType() {
return this.file_type;
}
/**
*
* @see org.apache.doris.thrift.TFileType
*/
public TTVFTableSink setFileType(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TFileType file_type) {
this.file_type = file_type;
return this;
}
public void unsetFileType() {
this.file_type = null;
}
/** Returns true if field file_type is set (has been assigned a value) and false otherwise */
public boolean isSetFileType() {
return this.file_type != null;
}
public void setFileTypeIsSet(boolean value) {
if (!value) {
this.file_type = null;
}
}
public int getPropertiesSize() {
return (this.properties == null) ? 0 : this.properties.size();
}
public void putToProperties(java.lang.String key, java.lang.String val) {
if (this.properties == null) {
this.properties = new java.util.HashMap<java.lang.String,java.lang.String>();
}
this.properties.put(key, val);
}
@org.apache.thrift.annotation.Nullable
public java.util.Map<java.lang.String,java.lang.String> getProperties() {
return this.properties;
}
public TTVFTableSink setProperties(@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> properties) {
this.properties = properties;
return this;
}
public void unsetProperties() {
this.properties = null;
}
/** Returns true if field properties is set (has been assigned a value) and false otherwise */
public boolean isSetProperties() {
return this.properties != null;
}
public void setPropertiesIsSet(boolean value) {
if (!value) {
this.properties = null;
}
}
public int getColumnsSize() {
return (this.columns == null) ? 0 : this.columns.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TColumn> getColumnsIterator() {
return (this.columns == null) ? null : this.columns.iterator();
}
public void addToColumns(org.apache.doris.thrift.TColumn elem) {
if (this.columns == null) {
this.columns = new java.util.ArrayList<org.apache.doris.thrift.TColumn>();
}
this.columns.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TColumn> getColumns() {
return this.columns;
}
public TTVFTableSink setColumns(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TColumn> columns) {
this.columns = columns;
return this;
}
public void unsetColumns() {
this.columns = null;
}
/** Returns true if field columns is set (has been assigned a value) and false otherwise */
public boolean isSetColumns() {
return this.columns != null;
}
public void setColumnsIsSet(boolean value) {
if (!value) {
this.columns = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getColumnSeparator() {
return this.column_separator;
}
public TTVFTableSink setColumnSeparator(@org.apache.thrift.annotation.Nullable java.lang.String column_separator) {
this.column_separator = column_separator;
return this;
}
public void unsetColumnSeparator() {
this.column_separator = null;
}
/** Returns true if field column_separator is set (has been assigned a value) and false otherwise */
public boolean isSetColumnSeparator() {
return this.column_separator != null;
}
public void setColumnSeparatorIsSet(boolean value) {
if (!value) {
this.column_separator = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getLineDelimiter() {
return this.line_delimiter;
}
public TTVFTableSink setLineDelimiter(@org.apache.thrift.annotation.Nullable java.lang.String line_delimiter) {
this.line_delimiter = line_delimiter;
return this;
}
public void unsetLineDelimiter() {
this.line_delimiter = null;
}
/** Returns true if field line_delimiter is set (has been assigned a value) and false otherwise */
public boolean isSetLineDelimiter() {
return this.line_delimiter != null;
}
public void setLineDelimiterIsSet(boolean value) {
if (!value) {
this.line_delimiter = null;
}
}
public long getMaxFileSizeBytes() {
return this.max_file_size_bytes;
}
public TTVFTableSink setMaxFileSizeBytes(long max_file_size_bytes) {
this.max_file_size_bytes = max_file_size_bytes;
setMaxFileSizeBytesIsSet(true);
return this;
}
public void unsetMaxFileSizeBytes() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __MAX_FILE_SIZE_BYTES_ISSET_ID);
}
/** Returns true if field max_file_size_bytes is set (has been assigned a value) and false otherwise */
public boolean isSetMaxFileSizeBytes() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __MAX_FILE_SIZE_BYTES_ISSET_ID);
}
public void setMaxFileSizeBytesIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __MAX_FILE_SIZE_BYTES_ISSET_ID, value);
}
public boolean isDeleteExistingFiles() {
return this.delete_existing_files;
}
public TTVFTableSink setDeleteExistingFiles(boolean delete_existing_files) {
this.delete_existing_files = delete_existing_files;
setDeleteExistingFilesIsSet(true);
return this;
}
public void unsetDeleteExistingFiles() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __DELETE_EXISTING_FILES_ISSET_ID);
}
/** Returns true if field delete_existing_files is set (has been assigned a value) and false otherwise */
public boolean isSetDeleteExistingFiles() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __DELETE_EXISTING_FILES_ISSET_ID);
}
public void setDeleteExistingFilesIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __DELETE_EXISTING_FILES_ISSET_ID, value);
}
public int getHadoopConfigSize() {
return (this.hadoop_config == null) ? 0 : this.hadoop_config.size();
}
public void putToHadoopConfig(java.lang.String key, java.lang.String val) {
if (this.hadoop_config == null) {
this.hadoop_config = new java.util.HashMap<java.lang.String,java.lang.String>();
}
this.hadoop_config.put(key, val);
}
@org.apache.thrift.annotation.Nullable
public java.util.Map<java.lang.String,java.lang.String> getHadoopConfig() {
return this.hadoop_config;
}
public TTVFTableSink setHadoopConfig(@org.apache.thrift.annotation.Nullable java.util.Map<java.lang.String,java.lang.String> hadoop_config) {
this.hadoop_config = hadoop_config;
return this;
}
public void unsetHadoopConfig() {
this.hadoop_config = null;
}
/** Returns true if field hadoop_config is set (has been assigned a value) and false otherwise */
public boolean isSetHadoopConfig() {
return this.hadoop_config != null;
}
public void setHadoopConfigIsSet(boolean value) {
if (!value) {
this.hadoop_config = null;
}
}
/**
*
* @see org.apache.doris.thrift.TFileCompressType
*/
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TFileCompressType getCompressionType() {
return this.compression_type;
}
/**
*
* @see org.apache.doris.thrift.TFileCompressType
*/
public TTVFTableSink setCompressionType(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TFileCompressType compression_type) {
this.compression_type = compression_type;
return this;
}
public void unsetCompressionType() {
this.compression_type = null;
}
/** Returns true if field compression_type is set (has been assigned a value) and false otherwise */
public boolean isSetCompressionType() {
return this.compression_type != null;
}
public void setCompressionTypeIsSet(boolean value) {
if (!value) {
this.compression_type = null;
}
}
public long getBackendId() {
return this.backend_id;
}
public TTVFTableSink setBackendId(long backend_id) {
this.backend_id = backend_id;
setBackendIdIsSet(true);
return this;
}
public void unsetBackendId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __BACKEND_ID_ISSET_ID);
}
/** Returns true if field backend_id is set (has been assigned a value) and false otherwise */
public boolean isSetBackendId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __BACKEND_ID_ISSET_ID);
}
public void setBackendIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __BACKEND_ID_ISSET_ID, value);
}
/**
*
* @see TTVFWriterType
*/
@org.apache.thrift.annotation.Nullable
public TTVFWriterType getWriterType() {
return this.writer_type;
}
/**
*
* @see TTVFWriterType
*/
public TTVFTableSink setWriterType(@org.apache.thrift.annotation.Nullable TTVFWriterType writer_type) {
this.writer_type = writer_type;
return this;
}
public void unsetWriterType() {
this.writer_type = null;
}
/** Returns true if field writer_type is set (has been assigned a value) and false otherwise */
public boolean isSetWriterType() {
return this.writer_type != null;
}
public void setWriterTypeIsSet(boolean value) {
if (!value) {
this.writer_type = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getWriterClass() {
return this.writer_class;
}
public TTVFTableSink setWriterClass(@org.apache.thrift.annotation.Nullable java.lang.String writer_class) {
this.writer_class = writer_class;
return this;
}
public void unsetWriterClass() {
this.writer_class = null;
}
/** Returns true if field writer_class is set (has been assigned a value) and false otherwise */
public boolean isSetWriterClass() {
return this.writer_class != null;
}
public void setWriterClassIsSet(boolean value) {
if (!value) {
this.writer_class = null;
}
}
public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case TVF_NAME:
if (value == null) {
unsetTvfName();
} else {
setTvfName((java.lang.String)value);
}
break;
case FILE_PATH:
if (value == null) {
unsetFilePath();
} else {
setFilePath((java.lang.String)value);
}
break;
case FILE_FORMAT:
if (value == null) {
unsetFileFormat();
} else {
setFileFormat((org.apache.doris.thrift.TFileFormatType)value);
}
break;
case FILE_TYPE:
if (value == null) {
unsetFileType();
} else {
setFileType((org.apache.doris.thrift.TFileType)value);
}
break;
case PROPERTIES:
if (value == null) {
unsetProperties();
} else {
setProperties((java.util.Map<java.lang.String,java.lang.String>)value);
}
break;
case COLUMNS:
if (value == null) {
unsetColumns();
} else {
setColumns((java.util.List<org.apache.doris.thrift.TColumn>)value);
}
break;
case COLUMN_SEPARATOR:
if (value == null) {
unsetColumnSeparator();
} else {
setColumnSeparator((java.lang.String)value);
}
break;
case LINE_DELIMITER:
if (value == null) {
unsetLineDelimiter();
} else {
setLineDelimiter((java.lang.String)value);
}
break;
case MAX_FILE_SIZE_BYTES:
if (value == null) {
unsetMaxFileSizeBytes();
} else {
setMaxFileSizeBytes((java.lang.Long)value);
}
break;
case DELETE_EXISTING_FILES:
if (value == null) {
unsetDeleteExistingFiles();
} else {
setDeleteExistingFiles((java.lang.Boolean)value);
}
break;
case HADOOP_CONFIG:
if (value == null) {
unsetHadoopConfig();
} else {
setHadoopConfig((java.util.Map<java.lang.String,java.lang.String>)value);
}
break;
case COMPRESSION_TYPE:
if (value == null) {
unsetCompressionType();
} else {
setCompressionType((org.apache.doris.thrift.TFileCompressType)value);
}
break;
case BACKEND_ID:
if (value == null) {
unsetBackendId();
} else {
setBackendId((java.lang.Long)value);
}
break;
case WRITER_TYPE:
if (value == null) {
unsetWriterType();
} else {
setWriterType((TTVFWriterType)value);
}
break;
case WRITER_CLASS:
if (value == null) {
unsetWriterClass();
} else {
setWriterClass((java.lang.String)value);
}
break;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case TVF_NAME:
return getTvfName();
case FILE_PATH:
return getFilePath();
case FILE_FORMAT:
return getFileFormat();
case FILE_TYPE:
return getFileType();
case PROPERTIES:
return getProperties();
case COLUMNS:
return getColumns();
case COLUMN_SEPARATOR:
return getColumnSeparator();
case LINE_DELIMITER:
return getLineDelimiter();
case MAX_FILE_SIZE_BYTES:
return getMaxFileSizeBytes();
case DELETE_EXISTING_FILES:
return isDeleteExistingFiles();
case HADOOP_CONFIG:
return getHadoopConfig();
case COMPRESSION_TYPE:
return getCompressionType();
case BACKEND_ID:
return getBackendId();
case WRITER_TYPE:
return getWriterType();
case WRITER_CLASS:
return getWriterClass();
}
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 TVF_NAME:
return isSetTvfName();
case FILE_PATH:
return isSetFilePath();
case FILE_FORMAT:
return isSetFileFormat();
case FILE_TYPE:
return isSetFileType();
case PROPERTIES:
return isSetProperties();
case COLUMNS:
return isSetColumns();
case COLUMN_SEPARATOR:
return isSetColumnSeparator();
case LINE_DELIMITER:
return isSetLineDelimiter();
case MAX_FILE_SIZE_BYTES:
return isSetMaxFileSizeBytes();
case DELETE_EXISTING_FILES:
return isSetDeleteExistingFiles();
case HADOOP_CONFIG:
return isSetHadoopConfig();
case COMPRESSION_TYPE:
return isSetCompressionType();
case BACKEND_ID:
return isSetBackendId();
case WRITER_TYPE:
return isSetWriterType();
case WRITER_CLASS:
return isSetWriterClass();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof TTVFTableSink)
return this.equals((TTVFTableSink)that);
return false;
}
public boolean equals(TTVFTableSink that) {
if (that == null)
return false;
if (this == that)
return true;
boolean this_present_tvf_name = true && this.isSetTvfName();
boolean that_present_tvf_name = true && that.isSetTvfName();
if (this_present_tvf_name || that_present_tvf_name) {
if (!(this_present_tvf_name && that_present_tvf_name))
return false;
if (!this.tvf_name.equals(that.tvf_name))
return false;
}
boolean this_present_file_path = true && this.isSetFilePath();
boolean that_present_file_path = true && that.isSetFilePath();
if (this_present_file_path || that_present_file_path) {
if (!(this_present_file_path && that_present_file_path))
return false;
if (!this.file_path.equals(that.file_path))
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_file_type = true && this.isSetFileType();
boolean that_present_file_type = true && that.isSetFileType();
if (this_present_file_type || that_present_file_type) {
if (!(this_present_file_type && that_present_file_type))
return false;
if (!this.file_type.equals(that.file_type))
return false;
}
boolean this_present_properties = true && this.isSetProperties();
boolean that_present_properties = true && that.isSetProperties();
if (this_present_properties || that_present_properties) {
if (!(this_present_properties && that_present_properties))
return false;
if (!this.properties.equals(that.properties))
return false;
}
boolean this_present_columns = true && this.isSetColumns();
boolean that_present_columns = true && that.isSetColumns();
if (this_present_columns || that_present_columns) {
if (!(this_present_columns && that_present_columns))
return false;
if (!this.columns.equals(that.columns))
return false;
}
boolean this_present_column_separator = true && this.isSetColumnSeparator();
boolean that_present_column_separator = true && that.isSetColumnSeparator();
if (this_present_column_separator || that_present_column_separator) {
if (!(this_present_column_separator && that_present_column_separator))
return false;
if (!this.column_separator.equals(that.column_separator))
return false;
}
boolean this_present_line_delimiter = true && this.isSetLineDelimiter();
boolean that_present_line_delimiter = true && that.isSetLineDelimiter();
if (this_present_line_delimiter || that_present_line_delimiter) {
if (!(this_present_line_delimiter && that_present_line_delimiter))
return false;
if (!this.line_delimiter.equals(that.line_delimiter))
return false;
}
boolean this_present_max_file_size_bytes = true && this.isSetMaxFileSizeBytes();
boolean that_present_max_file_size_bytes = true && that.isSetMaxFileSizeBytes();
if (this_present_max_file_size_bytes || that_present_max_file_size_bytes) {
if (!(this_present_max_file_size_bytes && that_present_max_file_size_bytes))
return false;
if (this.max_file_size_bytes != that.max_file_size_bytes)
return false;
}
boolean this_present_delete_existing_files = true && this.isSetDeleteExistingFiles();
boolean that_present_delete_existing_files = true && that.isSetDeleteExistingFiles();
if (this_present_delete_existing_files || that_present_delete_existing_files) {
if (!(this_present_delete_existing_files && that_present_delete_existing_files))
return false;
if (this.delete_existing_files != that.delete_existing_files)
return false;
}
boolean this_present_hadoop_config = true && this.isSetHadoopConfig();
boolean that_present_hadoop_config = true && that.isSetHadoopConfig();
if (this_present_hadoop_config || that_present_hadoop_config) {
if (!(this_present_hadoop_config && that_present_hadoop_config))
return false;
if (!this.hadoop_config.equals(that.hadoop_config))
return false;
}
boolean this_present_compression_type = true && this.isSetCompressionType();
boolean that_present_compression_type = true && that.isSetCompressionType();
if (this_present_compression_type || that_present_compression_type) {
if (!(this_present_compression_type && that_present_compression_type))
return false;
if (!this.compression_type.equals(that.compression_type))
return false;
}
boolean this_present_backend_id = true && this.isSetBackendId();
boolean that_present_backend_id = true && that.isSetBackendId();
if (this_present_backend_id || that_present_backend_id) {
if (!(this_present_backend_id && that_present_backend_id))
return false;
if (this.backend_id != that.backend_id)
return false;
}
boolean this_present_writer_type = true && this.isSetWriterType();
boolean that_present_writer_type = true && that.isSetWriterType();
if (this_present_writer_type || that_present_writer_type) {
if (!(this_present_writer_type && that_present_writer_type))
return false;
if (!this.writer_type.equals(that.writer_type))
return false;
}
boolean this_present_writer_class = true && this.isSetWriterClass();
boolean that_present_writer_class = true && that.isSetWriterClass();
if (this_present_writer_class || that_present_writer_class) {
if (!(this_present_writer_class && that_present_writer_class))
return false;
if (!this.writer_class.equals(that.writer_class))
return false;
}
return true;
}
@Override
public int hashCode() {
int hashCode = 1;
hashCode = hashCode * 8191 + ((isSetTvfName()) ? 131071 : 524287);
if (isSetTvfName())
hashCode = hashCode * 8191 + tvf_name.hashCode();
hashCode = hashCode * 8191 + ((isSetFilePath()) ? 131071 : 524287);
if (isSetFilePath())
hashCode = hashCode * 8191 + file_path.hashCode();
hashCode = hashCode * 8191 + ((isSetFileFormat()) ? 131071 : 524287);
if (isSetFileFormat())
hashCode = hashCode * 8191 + file_format.getValue();
hashCode = hashCode * 8191 + ((isSetFileType()) ? 131071 : 524287);
if (isSetFileType())
hashCode = hashCode * 8191 + file_type.getValue();
hashCode = hashCode * 8191 + ((isSetProperties()) ? 131071 : 524287);
if (isSetProperties())
hashCode = hashCode * 8191 + properties.hashCode();
hashCode = hashCode * 8191 + ((isSetColumns()) ? 131071 : 524287);
if (isSetColumns())
hashCode = hashCode * 8191 + columns.hashCode();
hashCode = hashCode * 8191 + ((isSetColumnSeparator()) ? 131071 : 524287);
if (isSetColumnSeparator())
hashCode = hashCode * 8191 + column_separator.hashCode();
hashCode = hashCode * 8191 + ((isSetLineDelimiter()) ? 131071 : 524287);
if (isSetLineDelimiter())
hashCode = hashCode * 8191 + line_delimiter.hashCode();
hashCode = hashCode * 8191 + ((isSetMaxFileSizeBytes()) ? 131071 : 524287);
if (isSetMaxFileSizeBytes())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(max_file_size_bytes);
hashCode = hashCode * 8191 + ((isSetDeleteExistingFiles()) ? 131071 : 524287);
if (isSetDeleteExistingFiles())
hashCode = hashCode * 8191 + ((delete_existing_files) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetHadoopConfig()) ? 131071 : 524287);
if (isSetHadoopConfig())
hashCode = hashCode * 8191 + hadoop_config.hashCode();
hashCode = hashCode * 8191 + ((isSetCompressionType()) ? 131071 : 524287);
if (isSetCompressionType())
hashCode = hashCode * 8191 + compression_type.getValue();
hashCode = hashCode * 8191 + ((isSetBackendId()) ? 131071 : 524287);
if (isSetBackendId())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(backend_id);
hashCode = hashCode * 8191 + ((isSetWriterType()) ? 131071 : 524287);
if (isSetWriterType())
hashCode = hashCode * 8191 + writer_type.getValue();
hashCode = hashCode * 8191 + ((isSetWriterClass()) ? 131071 : 524287);
if (isSetWriterClass())
hashCode = hashCode * 8191 + writer_class.hashCode();
return hashCode;
}
@Override
public int compareTo(TTVFTableSink other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = java.lang.Boolean.compare(isSetTvfName(), other.isSetTvfName());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTvfName()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tvf_name, other.tvf_name);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetFilePath(), other.isSetFilePath());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetFilePath()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.file_path, other.file_path);
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(isSetFileType(), other.isSetFileType());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetFileType()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.file_type, other.file_type);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetProperties(), other.isSetProperties());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetProperties()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.properties, other.properties);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetColumns(), other.isSetColumns());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetColumns()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.columns, other.columns);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetColumnSeparator(), other.isSetColumnSeparator());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetColumnSeparator()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.column_separator, other.column_separator);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetLineDelimiter(), other.isSetLineDelimiter());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetLineDelimiter()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.line_delimiter, other.line_delimiter);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetMaxFileSizeBytes(), other.isSetMaxFileSizeBytes());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetMaxFileSizeBytes()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.max_file_size_bytes, other.max_file_size_bytes);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetDeleteExistingFiles(), other.isSetDeleteExistingFiles());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetDeleteExistingFiles()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.delete_existing_files, other.delete_existing_files);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetHadoopConfig(), other.isSetHadoopConfig());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetHadoopConfig()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.hadoop_config, other.hadoop_config);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetCompressionType(), other.isSetCompressionType());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetCompressionType()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.compression_type, other.compression_type);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetBackendId(), other.isSetBackendId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetBackendId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.backend_id, other.backend_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetWriterType(), other.isSetWriterType());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetWriterType()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.writer_type, other.writer_type);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetWriterClass(), other.isSetWriterClass());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetWriterClass()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.writer_class, other.writer_class);
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("TTVFTableSink(");
boolean first = true;
if (isSetTvfName()) {
sb.append("tvf_name:");
if (this.tvf_name == null) {
sb.append("null");
} else {
sb.append(this.tvf_name);
}
first = false;
}
if (isSetFilePath()) {
if (!first) sb.append(", ");
sb.append("file_path:");
if (this.file_path == null) {
sb.append("null");
} else {
sb.append(this.file_path);
}
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 (isSetFileType()) {
if (!first) sb.append(", ");
sb.append("file_type:");
if (this.file_type == null) {
sb.append("null");
} else {
sb.append(this.file_type);
}
first = false;
}
if (isSetProperties()) {
if (!first) sb.append(", ");
sb.append("properties:");
if (this.properties == null) {
sb.append("null");
} else {
sb.append(this.properties);
}
first = false;
}
if (isSetColumns()) {
if (!first) sb.append(", ");
sb.append("columns:");
if (this.columns == null) {
sb.append("null");
} else {
sb.append(this.columns);
}
first = false;
}
if (isSetColumnSeparator()) {
if (!first) sb.append(", ");
sb.append("column_separator:");
if (this.column_separator == null) {
sb.append("null");
} else {
sb.append(this.column_separator);
}
first = false;
}
if (isSetLineDelimiter()) {
if (!first) sb.append(", ");
sb.append("line_delimiter:");
if (this.line_delimiter == null) {
sb.append("null");
} else {
sb.append(this.line_delimiter);
}
first = false;
}
if (isSetMaxFileSizeBytes()) {
if (!first) sb.append(", ");
sb.append("max_file_size_bytes:");
sb.append(this.max_file_size_bytes);
first = false;
}
if (isSetDeleteExistingFiles()) {
if (!first) sb.append(", ");
sb.append("delete_existing_files:");
sb.append(this.delete_existing_files);
first = false;
}
if (isSetHadoopConfig()) {
if (!first) sb.append(", ");
sb.append("hadoop_config:");
if (this.hadoop_config == null) {
sb.append("null");
} else {
sb.append(this.hadoop_config);
}
first = false;
}
if (isSetCompressionType()) {
if (!first) sb.append(", ");
sb.append("compression_type:");
if (this.compression_type == null) {
sb.append("null");
} else {
sb.append(this.compression_type);
}
first = false;
}
if (isSetBackendId()) {
if (!first) sb.append(", ");
sb.append("backend_id:");
sb.append(this.backend_id);
first = false;
}
if (isSetWriterType()) {
if (!first) sb.append(", ");
sb.append("writer_type:");
if (this.writer_type == null) {
sb.append("null");
} else {
sb.append(this.writer_type);
}
first = false;
}
if (isSetWriterClass()) {
if (!first) sb.append(", ");
sb.append("writer_class:");
if (this.writer_class == null) {
sb.append("null");
} else {
sb.append(this.writer_class);
}
first = false;
}
sb.append(")");
return sb.toString();
}
public void validate() throws org.apache.thrift.TException {
// check for required fields
// check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private static class TTVFTableSinkStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TTVFTableSinkStandardScheme getScheme() {
return new TTVFTableSinkStandardScheme();
}
}
private static class TTVFTableSinkStandardScheme extends org.apache.thrift.scheme.StandardScheme<TTVFTableSink> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TTVFTableSink 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: // TVF_NAME
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.tvf_name = iprot.readString();
struct.setTvfNameIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // FILE_PATH
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.file_path = iprot.readString();
struct.setFilePathIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // FILE_FORMAT
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.file_format = org.apache.doris.thrift.TFileFormatType.findByValue(iprot.readI32());
struct.setFileFormatIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // FILE_TYPE
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.file_type = org.apache.doris.thrift.TFileType.findByValue(iprot.readI32());
struct.setFileTypeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // PROPERTIES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map458 = iprot.readMapBegin();
struct.properties = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map458.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key459;
@org.apache.thrift.annotation.Nullable java.lang.String _val460;
for (int _i461 = 0; _i461 < _map458.size; ++_i461)
{
_key459 = iprot.readString();
_val460 = iprot.readString();
struct.properties.put(_key459, _val460);
}
iprot.readMapEnd();
}
struct.setPropertiesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // COLUMNS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list462 = iprot.readListBegin();
struct.columns = new java.util.ArrayList<org.apache.doris.thrift.TColumn>(_list462.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TColumn _elem463;
for (int _i464 = 0; _i464 < _list462.size; ++_i464)
{
_elem463 = new org.apache.doris.thrift.TColumn();
_elem463.read(iprot);
struct.columns.add(_elem463);
}
iprot.readListEnd();
}
struct.setColumnsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // COLUMN_SEPARATOR
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.column_separator = iprot.readString();
struct.setColumnSeparatorIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // LINE_DELIMITER
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.line_delimiter = iprot.readString();
struct.setLineDelimiterIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // MAX_FILE_SIZE_BYTES
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.max_file_size_bytes = iprot.readI64();
struct.setMaxFileSizeBytesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 10: // DELETE_EXISTING_FILES
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.delete_existing_files = iprot.readBool();
struct.setDeleteExistingFilesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 11: // HADOOP_CONFIG
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map465 = iprot.readMapBegin();
struct.hadoop_config = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map465.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key466;
@org.apache.thrift.annotation.Nullable java.lang.String _val467;
for (int _i468 = 0; _i468 < _map465.size; ++_i468)
{
_key466 = iprot.readString();
_val467 = iprot.readString();
struct.hadoop_config.put(_key466, _val467);
}
iprot.readMapEnd();
}
struct.setHadoopConfigIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 12: // COMPRESSION_TYPE
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.compression_type = org.apache.doris.thrift.TFileCompressType.findByValue(iprot.readI32());
struct.setCompressionTypeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 13: // BACKEND_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.backend_id = iprot.readI64();
struct.setBackendIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 14: // WRITER_TYPE
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.writer_type = org.apache.doris.thrift.TTVFWriterType.findByValue(iprot.readI32());
struct.setWriterTypeIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 15: // WRITER_CLASS
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.writer_class = iprot.readString();
struct.setWriterClassIsSet(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, TTVFTableSink struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.tvf_name != null) {
if (struct.isSetTvfName()) {
oprot.writeFieldBegin(TVF_NAME_FIELD_DESC);
oprot.writeString(struct.tvf_name);
oprot.writeFieldEnd();
}
}
if (struct.file_path != null) {
if (struct.isSetFilePath()) {
oprot.writeFieldBegin(FILE_PATH_FIELD_DESC);
oprot.writeString(struct.file_path);
oprot.writeFieldEnd();
}
}
if (struct.file_format != null) {
if (struct.isSetFileFormat()) {
oprot.writeFieldBegin(FILE_FORMAT_FIELD_DESC);
oprot.writeI32(struct.file_format.getValue());
oprot.writeFieldEnd();
}
}
if (struct.file_type != null) {
if (struct.isSetFileType()) {
oprot.writeFieldBegin(FILE_TYPE_FIELD_DESC);
oprot.writeI32(struct.file_type.getValue());
oprot.writeFieldEnd();
}
}
if (struct.properties != null) {
if (struct.isSetProperties()) {
oprot.writeFieldBegin(PROPERTIES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.properties.size()));
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter469 : struct.properties.entrySet())
{
oprot.writeString(_iter469.getKey());
oprot.writeString(_iter469.getValue());
}
oprot.writeMapEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.columns != null) {
if (struct.isSetColumns()) {
oprot.writeFieldBegin(COLUMNS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.columns.size()));
for (org.apache.doris.thrift.TColumn _iter470 : struct.columns)
{
_iter470.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.column_separator != null) {
if (struct.isSetColumnSeparator()) {
oprot.writeFieldBegin(COLUMN_SEPARATOR_FIELD_DESC);
oprot.writeString(struct.column_separator);
oprot.writeFieldEnd();
}
}
if (struct.line_delimiter != null) {
if (struct.isSetLineDelimiter()) {
oprot.writeFieldBegin(LINE_DELIMITER_FIELD_DESC);
oprot.writeString(struct.line_delimiter);
oprot.writeFieldEnd();
}
}
if (struct.isSetMaxFileSizeBytes()) {
oprot.writeFieldBegin(MAX_FILE_SIZE_BYTES_FIELD_DESC);
oprot.writeI64(struct.max_file_size_bytes);
oprot.writeFieldEnd();
}
if (struct.isSetDeleteExistingFiles()) {
oprot.writeFieldBegin(DELETE_EXISTING_FILES_FIELD_DESC);
oprot.writeBool(struct.delete_existing_files);
oprot.writeFieldEnd();
}
if (struct.hadoop_config != null) {
if (struct.isSetHadoopConfig()) {
oprot.writeFieldBegin(HADOOP_CONFIG_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.hadoop_config.size()));
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter471 : struct.hadoop_config.entrySet())
{
oprot.writeString(_iter471.getKey());
oprot.writeString(_iter471.getValue());
}
oprot.writeMapEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.compression_type != null) {
if (struct.isSetCompressionType()) {
oprot.writeFieldBegin(COMPRESSION_TYPE_FIELD_DESC);
oprot.writeI32(struct.compression_type.getValue());
oprot.writeFieldEnd();
}
}
if (struct.isSetBackendId()) {
oprot.writeFieldBegin(BACKEND_ID_FIELD_DESC);
oprot.writeI64(struct.backend_id);
oprot.writeFieldEnd();
}
if (struct.writer_type != null) {
if (struct.isSetWriterType()) {
oprot.writeFieldBegin(WRITER_TYPE_FIELD_DESC);
oprot.writeI32(struct.writer_type.getValue());
oprot.writeFieldEnd();
}
}
if (struct.writer_class != null) {
if (struct.isSetWriterClass()) {
oprot.writeFieldBegin(WRITER_CLASS_FIELD_DESC);
oprot.writeString(struct.writer_class);
oprot.writeFieldEnd();
}
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class TTVFTableSinkTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TTVFTableSinkTupleScheme getScheme() {
return new TTVFTableSinkTupleScheme();
}
}
private static class TTVFTableSinkTupleScheme extends org.apache.thrift.scheme.TupleScheme<TTVFTableSink> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TTVFTableSink 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.isSetTvfName()) {
optionals.set(0);
}
if (struct.isSetFilePath()) {
optionals.set(1);
}
if (struct.isSetFileFormat()) {
optionals.set(2);
}
if (struct.isSetFileType()) {
optionals.set(3);
}
if (struct.isSetProperties()) {
optionals.set(4);
}
if (struct.isSetColumns()) {
optionals.set(5);
}
if (struct.isSetColumnSeparator()) {
optionals.set(6);
}
if (struct.isSetLineDelimiter()) {
optionals.set(7);
}
if (struct.isSetMaxFileSizeBytes()) {
optionals.set(8);
}
if (struct.isSetDeleteExistingFiles()) {
optionals.set(9);
}
if (struct.isSetHadoopConfig()) {
optionals.set(10);
}
if (struct.isSetCompressionType()) {
optionals.set(11);
}
if (struct.isSetBackendId()) {
optionals.set(12);
}
if (struct.isSetWriterType()) {
optionals.set(13);
}
if (struct.isSetWriterClass()) {
optionals.set(14);
}
oprot.writeBitSet(optionals, 15);
if (struct.isSetTvfName()) {
oprot.writeString(struct.tvf_name);
}
if (struct.isSetFilePath()) {
oprot.writeString(struct.file_path);
}
if (struct.isSetFileFormat()) {
oprot.writeI32(struct.file_format.getValue());
}
if (struct.isSetFileType()) {
oprot.writeI32(struct.file_type.getValue());
}
if (struct.isSetProperties()) {
{
oprot.writeI32(struct.properties.size());
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter472 : struct.properties.entrySet())
{
oprot.writeString(_iter472.getKey());
oprot.writeString(_iter472.getValue());
}
}
}
if (struct.isSetColumns()) {
{
oprot.writeI32(struct.columns.size());
for (org.apache.doris.thrift.TColumn _iter473 : struct.columns)
{
_iter473.write(oprot);
}
}
}
if (struct.isSetColumnSeparator()) {
oprot.writeString(struct.column_separator);
}
if (struct.isSetLineDelimiter()) {
oprot.writeString(struct.line_delimiter);
}
if (struct.isSetMaxFileSizeBytes()) {
oprot.writeI64(struct.max_file_size_bytes);
}
if (struct.isSetDeleteExistingFiles()) {
oprot.writeBool(struct.delete_existing_files);
}
if (struct.isSetHadoopConfig()) {
{
oprot.writeI32(struct.hadoop_config.size());
for (java.util.Map.Entry<java.lang.String, java.lang.String> _iter474 : struct.hadoop_config.entrySet())
{
oprot.writeString(_iter474.getKey());
oprot.writeString(_iter474.getValue());
}
}
}
if (struct.isSetCompressionType()) {
oprot.writeI32(struct.compression_type.getValue());
}
if (struct.isSetBackendId()) {
oprot.writeI64(struct.backend_id);
}
if (struct.isSetWriterType()) {
oprot.writeI32(struct.writer_type.getValue());
}
if (struct.isSetWriterClass()) {
oprot.writeString(struct.writer_class);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TTVFTableSink struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet incoming = iprot.readBitSet(15);
if (incoming.get(0)) {
struct.tvf_name = iprot.readString();
struct.setTvfNameIsSet(true);
}
if (incoming.get(1)) {
struct.file_path = iprot.readString();
struct.setFilePathIsSet(true);
}
if (incoming.get(2)) {
struct.file_format = org.apache.doris.thrift.TFileFormatType.findByValue(iprot.readI32());
struct.setFileFormatIsSet(true);
}
if (incoming.get(3)) {
struct.file_type = org.apache.doris.thrift.TFileType.findByValue(iprot.readI32());
struct.setFileTypeIsSet(true);
}
if (incoming.get(4)) {
{
org.apache.thrift.protocol.TMap _map475 = iprot.readMapBegin(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING);
struct.properties = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map475.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key476;
@org.apache.thrift.annotation.Nullable java.lang.String _val477;
for (int _i478 = 0; _i478 < _map475.size; ++_i478)
{
_key476 = iprot.readString();
_val477 = iprot.readString();
struct.properties.put(_key476, _val477);
}
}
struct.setPropertiesIsSet(true);
}
if (incoming.get(5)) {
{
org.apache.thrift.protocol.TList _list479 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.columns = new java.util.ArrayList<org.apache.doris.thrift.TColumn>(_list479.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TColumn _elem480;
for (int _i481 = 0; _i481 < _list479.size; ++_i481)
{
_elem480 = new org.apache.doris.thrift.TColumn();
_elem480.read(iprot);
struct.columns.add(_elem480);
}
}
struct.setColumnsIsSet(true);
}
if (incoming.get(6)) {
struct.column_separator = iprot.readString();
struct.setColumnSeparatorIsSet(true);
}
if (incoming.get(7)) {
struct.line_delimiter = iprot.readString();
struct.setLineDelimiterIsSet(true);
}
if (incoming.get(8)) {
struct.max_file_size_bytes = iprot.readI64();
struct.setMaxFileSizeBytesIsSet(true);
}
if (incoming.get(9)) {
struct.delete_existing_files = iprot.readBool();
struct.setDeleteExistingFilesIsSet(true);
}
if (incoming.get(10)) {
{
org.apache.thrift.protocol.TMap _map482 = iprot.readMapBegin(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING);
struct.hadoop_config = new java.util.HashMap<java.lang.String,java.lang.String>(2*_map482.size);
@org.apache.thrift.annotation.Nullable java.lang.String _key483;
@org.apache.thrift.annotation.Nullable java.lang.String _val484;
for (int _i485 = 0; _i485 < _map482.size; ++_i485)
{
_key483 = iprot.readString();
_val484 = iprot.readString();
struct.hadoop_config.put(_key483, _val484);
}
}
struct.setHadoopConfigIsSet(true);
}
if (incoming.get(11)) {
struct.compression_type = org.apache.doris.thrift.TFileCompressType.findByValue(iprot.readI32());
struct.setCompressionTypeIsSet(true);
}
if (incoming.get(12)) {
struct.backend_id = iprot.readI64();
struct.setBackendIdIsSet(true);
}
if (incoming.get(13)) {
struct.writer_type = org.apache.doris.thrift.TTVFWriterType.findByValue(iprot.readI32());
struct.setWriterTypeIsSet(true);
}
if (incoming.get(14)) {
struct.writer_class = iprot.readString();
struct.setWriterClassIsSet(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();
}
}