TDataStreamSink.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 TDataStreamSink implements org.apache.thrift.TBase<TDataStreamSink, TDataStreamSink._Fields>, java.io.Serializable, Cloneable, Comparable<TDataStreamSink> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TDataStreamSink");
private static final org.apache.thrift.protocol.TField DEST_NODE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("dest_node_id", org.apache.thrift.protocol.TType.I32, (short)1);
private static final org.apache.thrift.protocol.TField OUTPUT_PARTITION_FIELD_DESC = new org.apache.thrift.protocol.TField("output_partition", org.apache.thrift.protocol.TType.STRUCT, (short)2);
private static final org.apache.thrift.protocol.TField IGNORE_NOT_FOUND_FIELD_DESC = new org.apache.thrift.protocol.TField("ignore_not_found", org.apache.thrift.protocol.TType.BOOL, (short)3);
private static final org.apache.thrift.protocol.TField OUTPUT_EXPRS_FIELD_DESC = new org.apache.thrift.protocol.TField("output_exprs", org.apache.thrift.protocol.TType.LIST, (short)4);
private static final org.apache.thrift.protocol.TField OUTPUT_TUPLE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("output_tuple_id", org.apache.thrift.protocol.TType.I32, (short)5);
private static final org.apache.thrift.protocol.TField CONJUNCTS_FIELD_DESC = new org.apache.thrift.protocol.TField("conjuncts", org.apache.thrift.protocol.TType.LIST, (short)6);
private static final org.apache.thrift.protocol.TField RUNTIME_FILTERS_FIELD_DESC = new org.apache.thrift.protocol.TField("runtime_filters", org.apache.thrift.protocol.TType.LIST, (short)7);
private static final org.apache.thrift.protocol.TField TABLET_SINK_SCHEMA_FIELD_DESC = new org.apache.thrift.protocol.TField("tablet_sink_schema", org.apache.thrift.protocol.TType.STRUCT, (short)8);
private static final org.apache.thrift.protocol.TField TABLET_SINK_PARTITION_FIELD_DESC = new org.apache.thrift.protocol.TField("tablet_sink_partition", org.apache.thrift.protocol.TType.STRUCT, (short)9);
private static final org.apache.thrift.protocol.TField TABLET_SINK_LOCATION_FIELD_DESC = new org.apache.thrift.protocol.TField("tablet_sink_location", org.apache.thrift.protocol.TType.STRUCT, (short)10);
private static final org.apache.thrift.protocol.TField TABLET_SINK_TXN_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("tablet_sink_txn_id", org.apache.thrift.protocol.TType.I64, (short)11);
private static final org.apache.thrift.protocol.TField TABLET_SINK_TUPLE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("tablet_sink_tuple_id", org.apache.thrift.protocol.TType.I32, (short)12);
private static final org.apache.thrift.protocol.TField TABLET_SINK_EXPRS_FIELD_DESC = new org.apache.thrift.protocol.TField("tablet_sink_exprs", org.apache.thrift.protocol.TType.LIST, (short)13);
private static final org.apache.thrift.protocol.TField IS_MERGE_FIELD_DESC = new org.apache.thrift.protocol.TField("is_merge", org.apache.thrift.protocol.TType.BOOL, (short)14);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TDataStreamSinkStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TDataStreamSinkTupleSchemeFactory();
public int dest_node_id; // required
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TDataPartition output_partition; // required
public boolean ignore_not_found; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> output_exprs; // optional
public int output_tuple_id; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> conjuncts; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TRuntimeFilterDesc> runtime_filters; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TOlapTableSchemaParam tablet_sink_schema; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TOlapTablePartitionParam tablet_sink_partition; // optional
public @org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TOlapTableLocationParam tablet_sink_location; // optional
public long tablet_sink_txn_id; // optional
public int tablet_sink_tuple_id; // optional
public @org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> tablet_sink_exprs; // optional
public boolean is_merge; // 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 {
DEST_NODE_ID((short)1, "dest_node_id"),
OUTPUT_PARTITION((short)2, "output_partition"),
IGNORE_NOT_FOUND((short)3, "ignore_not_found"),
OUTPUT_EXPRS((short)4, "output_exprs"),
OUTPUT_TUPLE_ID((short)5, "output_tuple_id"),
CONJUNCTS((short)6, "conjuncts"),
RUNTIME_FILTERS((short)7, "runtime_filters"),
TABLET_SINK_SCHEMA((short)8, "tablet_sink_schema"),
TABLET_SINK_PARTITION((short)9, "tablet_sink_partition"),
TABLET_SINK_LOCATION((short)10, "tablet_sink_location"),
TABLET_SINK_TXN_ID((short)11, "tablet_sink_txn_id"),
TABLET_SINK_TUPLE_ID((short)12, "tablet_sink_tuple_id"),
TABLET_SINK_EXPRS((short)13, "tablet_sink_exprs"),
IS_MERGE((short)14, "is_merge");
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: // DEST_NODE_ID
return DEST_NODE_ID;
case 2: // OUTPUT_PARTITION
return OUTPUT_PARTITION;
case 3: // IGNORE_NOT_FOUND
return IGNORE_NOT_FOUND;
case 4: // OUTPUT_EXPRS
return OUTPUT_EXPRS;
case 5: // OUTPUT_TUPLE_ID
return OUTPUT_TUPLE_ID;
case 6: // CONJUNCTS
return CONJUNCTS;
case 7: // RUNTIME_FILTERS
return RUNTIME_FILTERS;
case 8: // TABLET_SINK_SCHEMA
return TABLET_SINK_SCHEMA;
case 9: // TABLET_SINK_PARTITION
return TABLET_SINK_PARTITION;
case 10: // TABLET_SINK_LOCATION
return TABLET_SINK_LOCATION;
case 11: // TABLET_SINK_TXN_ID
return TABLET_SINK_TXN_ID;
case 12: // TABLET_SINK_TUPLE_ID
return TABLET_SINK_TUPLE_ID;
case 13: // TABLET_SINK_EXPRS
return TABLET_SINK_EXPRS;
case 14: // IS_MERGE
return IS_MERGE;
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 __DEST_NODE_ID_ISSET_ID = 0;
private static final int __IGNORE_NOT_FOUND_ISSET_ID = 1;
private static final int __OUTPUT_TUPLE_ID_ISSET_ID = 2;
private static final int __TABLET_SINK_TXN_ID_ISSET_ID = 3;
private static final int __TABLET_SINK_TUPLE_ID_ISSET_ID = 4;
private static final int __IS_MERGE_ISSET_ID = 5;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.IGNORE_NOT_FOUND,_Fields.OUTPUT_EXPRS,_Fields.OUTPUT_TUPLE_ID,_Fields.CONJUNCTS,_Fields.RUNTIME_FILTERS,_Fields.TABLET_SINK_SCHEMA,_Fields.TABLET_SINK_PARTITION,_Fields.TABLET_SINK_LOCATION,_Fields.TABLET_SINK_TXN_ID,_Fields.TABLET_SINK_TUPLE_ID,_Fields.TABLET_SINK_EXPRS,_Fields.IS_MERGE};
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.DEST_NODE_ID, new org.apache.thrift.meta_data.FieldMetaData("dest_node_id", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32 , "TPlanNodeId")));
tmpMap.put(_Fields.OUTPUT_PARTITION, new org.apache.thrift.meta_data.FieldMetaData("output_partition", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TDataPartition.class)));
tmpMap.put(_Fields.IGNORE_NOT_FOUND, new org.apache.thrift.meta_data.FieldMetaData("ignore_not_found", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
tmpMap.put(_Fields.OUTPUT_EXPRS, new org.apache.thrift.meta_data.FieldMetaData("output_exprs", 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.TExpr.class))));
tmpMap.put(_Fields.OUTPUT_TUPLE_ID, new org.apache.thrift.meta_data.FieldMetaData("output_tuple_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32 , "TTupleId")));
tmpMap.put(_Fields.CONJUNCTS, new org.apache.thrift.meta_data.FieldMetaData("conjuncts", 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.TExpr.class))));
tmpMap.put(_Fields.RUNTIME_FILTERS, new org.apache.thrift.meta_data.FieldMetaData("runtime_filters", 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.TRuntimeFilterDesc.class))));
tmpMap.put(_Fields.TABLET_SINK_SCHEMA, new org.apache.thrift.meta_data.FieldMetaData("tablet_sink_schema", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TOlapTableSchemaParam.class)));
tmpMap.put(_Fields.TABLET_SINK_PARTITION, new org.apache.thrift.meta_data.FieldMetaData("tablet_sink_partition", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TOlapTablePartitionParam.class)));
tmpMap.put(_Fields.TABLET_SINK_LOCATION, new org.apache.thrift.meta_data.FieldMetaData("tablet_sink_location", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.doris.thrift.TOlapTableLocationParam.class)));
tmpMap.put(_Fields.TABLET_SINK_TXN_ID, new org.apache.thrift.meta_data.FieldMetaData("tablet_sink_txn_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.TABLET_SINK_TUPLE_ID, new org.apache.thrift.meta_data.FieldMetaData("tablet_sink_tuple_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32 , "TTupleId")));
tmpMap.put(_Fields.TABLET_SINK_EXPRS, new org.apache.thrift.meta_data.FieldMetaData("tablet_sink_exprs", 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.TExpr.class))));
tmpMap.put(_Fields.IS_MERGE, new org.apache.thrift.meta_data.FieldMetaData("is_merge", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TDataStreamSink.class, metaDataMap);
}
public TDataStreamSink() {
}
public TDataStreamSink(
int dest_node_id,
org.apache.doris.thrift.TDataPartition output_partition)
{
this();
this.dest_node_id = dest_node_id;
setDestNodeIdIsSet(true);
this.output_partition = output_partition;
}
/**
* Performs a deep copy on <i>other</i>.
*/
public TDataStreamSink(TDataStreamSink other) {
__isset_bitfield = other.__isset_bitfield;
this.dest_node_id = other.dest_node_id;
if (other.isSetOutputPartition()) {
this.output_partition = new org.apache.doris.thrift.TDataPartition(other.output_partition);
}
this.ignore_not_found = other.ignore_not_found;
if (other.isSetOutputExprs()) {
java.util.List<org.apache.doris.thrift.TExpr> __this__output_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(other.output_exprs.size());
for (org.apache.doris.thrift.TExpr other_element : other.output_exprs) {
__this__output_exprs.add(new org.apache.doris.thrift.TExpr(other_element));
}
this.output_exprs = __this__output_exprs;
}
this.output_tuple_id = other.output_tuple_id;
if (other.isSetConjuncts()) {
java.util.List<org.apache.doris.thrift.TExpr> __this__conjuncts = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(other.conjuncts.size());
for (org.apache.doris.thrift.TExpr other_element : other.conjuncts) {
__this__conjuncts.add(new org.apache.doris.thrift.TExpr(other_element));
}
this.conjuncts = __this__conjuncts;
}
if (other.isSetRuntimeFilters()) {
java.util.List<org.apache.doris.thrift.TRuntimeFilterDesc> __this__runtime_filters = new java.util.ArrayList<org.apache.doris.thrift.TRuntimeFilterDesc>(other.runtime_filters.size());
for (org.apache.doris.thrift.TRuntimeFilterDesc other_element : other.runtime_filters) {
__this__runtime_filters.add(new org.apache.doris.thrift.TRuntimeFilterDesc(other_element));
}
this.runtime_filters = __this__runtime_filters;
}
if (other.isSetTabletSinkSchema()) {
this.tablet_sink_schema = new org.apache.doris.thrift.TOlapTableSchemaParam(other.tablet_sink_schema);
}
if (other.isSetTabletSinkPartition()) {
this.tablet_sink_partition = new org.apache.doris.thrift.TOlapTablePartitionParam(other.tablet_sink_partition);
}
if (other.isSetTabletSinkLocation()) {
this.tablet_sink_location = new org.apache.doris.thrift.TOlapTableLocationParam(other.tablet_sink_location);
}
this.tablet_sink_txn_id = other.tablet_sink_txn_id;
this.tablet_sink_tuple_id = other.tablet_sink_tuple_id;
if (other.isSetTabletSinkExprs()) {
java.util.List<org.apache.doris.thrift.TExpr> __this__tablet_sink_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(other.tablet_sink_exprs.size());
for (org.apache.doris.thrift.TExpr other_element : other.tablet_sink_exprs) {
__this__tablet_sink_exprs.add(new org.apache.doris.thrift.TExpr(other_element));
}
this.tablet_sink_exprs = __this__tablet_sink_exprs;
}
this.is_merge = other.is_merge;
}
public TDataStreamSink deepCopy() {
return new TDataStreamSink(this);
}
@Override
public void clear() {
setDestNodeIdIsSet(false);
this.dest_node_id = 0;
this.output_partition = null;
setIgnoreNotFoundIsSet(false);
this.ignore_not_found = false;
this.output_exprs = null;
setOutputTupleIdIsSet(false);
this.output_tuple_id = 0;
this.conjuncts = null;
this.runtime_filters = null;
this.tablet_sink_schema = null;
this.tablet_sink_partition = null;
this.tablet_sink_location = null;
setTabletSinkTxnIdIsSet(false);
this.tablet_sink_txn_id = 0;
setTabletSinkTupleIdIsSet(false);
this.tablet_sink_tuple_id = 0;
this.tablet_sink_exprs = null;
setIsMergeIsSet(false);
this.is_merge = false;
}
public int getDestNodeId() {
return this.dest_node_id;
}
public TDataStreamSink setDestNodeId(int dest_node_id) {
this.dest_node_id = dest_node_id;
setDestNodeIdIsSet(true);
return this;
}
public void unsetDestNodeId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __DEST_NODE_ID_ISSET_ID);
}
/** Returns true if field dest_node_id is set (has been assigned a value) and false otherwise */
public boolean isSetDestNodeId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __DEST_NODE_ID_ISSET_ID);
}
public void setDestNodeIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __DEST_NODE_ID_ISSET_ID, value);
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TDataPartition getOutputPartition() {
return this.output_partition;
}
public TDataStreamSink setOutputPartition(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TDataPartition output_partition) {
this.output_partition = output_partition;
return this;
}
public void unsetOutputPartition() {
this.output_partition = null;
}
/** Returns true if field output_partition is set (has been assigned a value) and false otherwise */
public boolean isSetOutputPartition() {
return this.output_partition != null;
}
public void setOutputPartitionIsSet(boolean value) {
if (!value) {
this.output_partition = null;
}
}
public boolean isIgnoreNotFound() {
return this.ignore_not_found;
}
public TDataStreamSink setIgnoreNotFound(boolean ignore_not_found) {
this.ignore_not_found = ignore_not_found;
setIgnoreNotFoundIsSet(true);
return this;
}
public void unsetIgnoreNotFound() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __IGNORE_NOT_FOUND_ISSET_ID);
}
/** Returns true if field ignore_not_found is set (has been assigned a value) and false otherwise */
public boolean isSetIgnoreNotFound() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __IGNORE_NOT_FOUND_ISSET_ID);
}
public void setIgnoreNotFoundIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __IGNORE_NOT_FOUND_ISSET_ID, value);
}
public int getOutputExprsSize() {
return (this.output_exprs == null) ? 0 : this.output_exprs.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TExpr> getOutputExprsIterator() {
return (this.output_exprs == null) ? null : this.output_exprs.iterator();
}
public void addToOutputExprs(org.apache.doris.thrift.TExpr elem) {
if (this.output_exprs == null) {
this.output_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>();
}
this.output_exprs.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TExpr> getOutputExprs() {
return this.output_exprs;
}
public TDataStreamSink setOutputExprs(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> output_exprs) {
this.output_exprs = output_exprs;
return this;
}
public void unsetOutputExprs() {
this.output_exprs = null;
}
/** Returns true if field output_exprs is set (has been assigned a value) and false otherwise */
public boolean isSetOutputExprs() {
return this.output_exprs != null;
}
public void setOutputExprsIsSet(boolean value) {
if (!value) {
this.output_exprs = null;
}
}
public int getOutputTupleId() {
return this.output_tuple_id;
}
public TDataStreamSink setOutputTupleId(int output_tuple_id) {
this.output_tuple_id = output_tuple_id;
setOutputTupleIdIsSet(true);
return this;
}
public void unsetOutputTupleId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __OUTPUT_TUPLE_ID_ISSET_ID);
}
/** Returns true if field output_tuple_id is set (has been assigned a value) and false otherwise */
public boolean isSetOutputTupleId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __OUTPUT_TUPLE_ID_ISSET_ID);
}
public void setOutputTupleIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __OUTPUT_TUPLE_ID_ISSET_ID, value);
}
public int getConjunctsSize() {
return (this.conjuncts == null) ? 0 : this.conjuncts.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TExpr> getConjunctsIterator() {
return (this.conjuncts == null) ? null : this.conjuncts.iterator();
}
public void addToConjuncts(org.apache.doris.thrift.TExpr elem) {
if (this.conjuncts == null) {
this.conjuncts = new java.util.ArrayList<org.apache.doris.thrift.TExpr>();
}
this.conjuncts.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TExpr> getConjuncts() {
return this.conjuncts;
}
public TDataStreamSink setConjuncts(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> conjuncts) {
this.conjuncts = conjuncts;
return this;
}
public void unsetConjuncts() {
this.conjuncts = null;
}
/** Returns true if field conjuncts is set (has been assigned a value) and false otherwise */
public boolean isSetConjuncts() {
return this.conjuncts != null;
}
public void setConjunctsIsSet(boolean value) {
if (!value) {
this.conjuncts = null;
}
}
public int getRuntimeFiltersSize() {
return (this.runtime_filters == null) ? 0 : this.runtime_filters.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TRuntimeFilterDesc> getRuntimeFiltersIterator() {
return (this.runtime_filters == null) ? null : this.runtime_filters.iterator();
}
public void addToRuntimeFilters(org.apache.doris.thrift.TRuntimeFilterDesc elem) {
if (this.runtime_filters == null) {
this.runtime_filters = new java.util.ArrayList<org.apache.doris.thrift.TRuntimeFilterDesc>();
}
this.runtime_filters.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TRuntimeFilterDesc> getRuntimeFilters() {
return this.runtime_filters;
}
public TDataStreamSink setRuntimeFilters(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TRuntimeFilterDesc> runtime_filters) {
this.runtime_filters = runtime_filters;
return this;
}
public void unsetRuntimeFilters() {
this.runtime_filters = null;
}
/** Returns true if field runtime_filters is set (has been assigned a value) and false otherwise */
public boolean isSetRuntimeFilters() {
return this.runtime_filters != null;
}
public void setRuntimeFiltersIsSet(boolean value) {
if (!value) {
this.runtime_filters = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TOlapTableSchemaParam getTabletSinkSchema() {
return this.tablet_sink_schema;
}
public TDataStreamSink setTabletSinkSchema(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TOlapTableSchemaParam tablet_sink_schema) {
this.tablet_sink_schema = tablet_sink_schema;
return this;
}
public void unsetTabletSinkSchema() {
this.tablet_sink_schema = null;
}
/** Returns true if field tablet_sink_schema is set (has been assigned a value) and false otherwise */
public boolean isSetTabletSinkSchema() {
return this.tablet_sink_schema != null;
}
public void setTabletSinkSchemaIsSet(boolean value) {
if (!value) {
this.tablet_sink_schema = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TOlapTablePartitionParam getTabletSinkPartition() {
return this.tablet_sink_partition;
}
public TDataStreamSink setTabletSinkPartition(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TOlapTablePartitionParam tablet_sink_partition) {
this.tablet_sink_partition = tablet_sink_partition;
return this;
}
public void unsetTabletSinkPartition() {
this.tablet_sink_partition = null;
}
/** Returns true if field tablet_sink_partition is set (has been assigned a value) and false otherwise */
public boolean isSetTabletSinkPartition() {
return this.tablet_sink_partition != null;
}
public void setTabletSinkPartitionIsSet(boolean value) {
if (!value) {
this.tablet_sink_partition = null;
}
}
@org.apache.thrift.annotation.Nullable
public org.apache.doris.thrift.TOlapTableLocationParam getTabletSinkLocation() {
return this.tablet_sink_location;
}
public TDataStreamSink setTabletSinkLocation(@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TOlapTableLocationParam tablet_sink_location) {
this.tablet_sink_location = tablet_sink_location;
return this;
}
public void unsetTabletSinkLocation() {
this.tablet_sink_location = null;
}
/** Returns true if field tablet_sink_location is set (has been assigned a value) and false otherwise */
public boolean isSetTabletSinkLocation() {
return this.tablet_sink_location != null;
}
public void setTabletSinkLocationIsSet(boolean value) {
if (!value) {
this.tablet_sink_location = null;
}
}
public long getTabletSinkTxnId() {
return this.tablet_sink_txn_id;
}
public TDataStreamSink setTabletSinkTxnId(long tablet_sink_txn_id) {
this.tablet_sink_txn_id = tablet_sink_txn_id;
setTabletSinkTxnIdIsSet(true);
return this;
}
public void unsetTabletSinkTxnId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __TABLET_SINK_TXN_ID_ISSET_ID);
}
/** Returns true if field tablet_sink_txn_id is set (has been assigned a value) and false otherwise */
public boolean isSetTabletSinkTxnId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __TABLET_SINK_TXN_ID_ISSET_ID);
}
public void setTabletSinkTxnIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __TABLET_SINK_TXN_ID_ISSET_ID, value);
}
public int getTabletSinkTupleId() {
return this.tablet_sink_tuple_id;
}
public TDataStreamSink setTabletSinkTupleId(int tablet_sink_tuple_id) {
this.tablet_sink_tuple_id = tablet_sink_tuple_id;
setTabletSinkTupleIdIsSet(true);
return this;
}
public void unsetTabletSinkTupleId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __TABLET_SINK_TUPLE_ID_ISSET_ID);
}
/** Returns true if field tablet_sink_tuple_id is set (has been assigned a value) and false otherwise */
public boolean isSetTabletSinkTupleId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __TABLET_SINK_TUPLE_ID_ISSET_ID);
}
public void setTabletSinkTupleIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __TABLET_SINK_TUPLE_ID_ISSET_ID, value);
}
public int getTabletSinkExprsSize() {
return (this.tablet_sink_exprs == null) ? 0 : this.tablet_sink_exprs.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.doris.thrift.TExpr> getTabletSinkExprsIterator() {
return (this.tablet_sink_exprs == null) ? null : this.tablet_sink_exprs.iterator();
}
public void addToTabletSinkExprs(org.apache.doris.thrift.TExpr elem) {
if (this.tablet_sink_exprs == null) {
this.tablet_sink_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>();
}
this.tablet_sink_exprs.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.doris.thrift.TExpr> getTabletSinkExprs() {
return this.tablet_sink_exprs;
}
public TDataStreamSink setTabletSinkExprs(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.doris.thrift.TExpr> tablet_sink_exprs) {
this.tablet_sink_exprs = tablet_sink_exprs;
return this;
}
public void unsetTabletSinkExprs() {
this.tablet_sink_exprs = null;
}
/** Returns true if field tablet_sink_exprs is set (has been assigned a value) and false otherwise */
public boolean isSetTabletSinkExprs() {
return this.tablet_sink_exprs != null;
}
public void setTabletSinkExprsIsSet(boolean value) {
if (!value) {
this.tablet_sink_exprs = null;
}
}
public boolean isIsMerge() {
return this.is_merge;
}
public TDataStreamSink setIsMerge(boolean is_merge) {
this.is_merge = is_merge;
setIsMergeIsSet(true);
return this;
}
public void unsetIsMerge() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __IS_MERGE_ISSET_ID);
}
/** Returns true if field is_merge is set (has been assigned a value) and false otherwise */
public boolean isSetIsMerge() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __IS_MERGE_ISSET_ID);
}
public void setIsMergeIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __IS_MERGE_ISSET_ID, value);
}
public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case DEST_NODE_ID:
if (value == null) {
unsetDestNodeId();
} else {
setDestNodeId((java.lang.Integer)value);
}
break;
case OUTPUT_PARTITION:
if (value == null) {
unsetOutputPartition();
} else {
setOutputPartition((org.apache.doris.thrift.TDataPartition)value);
}
break;
case IGNORE_NOT_FOUND:
if (value == null) {
unsetIgnoreNotFound();
} else {
setIgnoreNotFound((java.lang.Boolean)value);
}
break;
case OUTPUT_EXPRS:
if (value == null) {
unsetOutputExprs();
} else {
setOutputExprs((java.util.List<org.apache.doris.thrift.TExpr>)value);
}
break;
case OUTPUT_TUPLE_ID:
if (value == null) {
unsetOutputTupleId();
} else {
setOutputTupleId((java.lang.Integer)value);
}
break;
case CONJUNCTS:
if (value == null) {
unsetConjuncts();
} else {
setConjuncts((java.util.List<org.apache.doris.thrift.TExpr>)value);
}
break;
case RUNTIME_FILTERS:
if (value == null) {
unsetRuntimeFilters();
} else {
setRuntimeFilters((java.util.List<org.apache.doris.thrift.TRuntimeFilterDesc>)value);
}
break;
case TABLET_SINK_SCHEMA:
if (value == null) {
unsetTabletSinkSchema();
} else {
setTabletSinkSchema((org.apache.doris.thrift.TOlapTableSchemaParam)value);
}
break;
case TABLET_SINK_PARTITION:
if (value == null) {
unsetTabletSinkPartition();
} else {
setTabletSinkPartition((org.apache.doris.thrift.TOlapTablePartitionParam)value);
}
break;
case TABLET_SINK_LOCATION:
if (value == null) {
unsetTabletSinkLocation();
} else {
setTabletSinkLocation((org.apache.doris.thrift.TOlapTableLocationParam)value);
}
break;
case TABLET_SINK_TXN_ID:
if (value == null) {
unsetTabletSinkTxnId();
} else {
setTabletSinkTxnId((java.lang.Long)value);
}
break;
case TABLET_SINK_TUPLE_ID:
if (value == null) {
unsetTabletSinkTupleId();
} else {
setTabletSinkTupleId((java.lang.Integer)value);
}
break;
case TABLET_SINK_EXPRS:
if (value == null) {
unsetTabletSinkExprs();
} else {
setTabletSinkExprs((java.util.List<org.apache.doris.thrift.TExpr>)value);
}
break;
case IS_MERGE:
if (value == null) {
unsetIsMerge();
} else {
setIsMerge((java.lang.Boolean)value);
}
break;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case DEST_NODE_ID:
return getDestNodeId();
case OUTPUT_PARTITION:
return getOutputPartition();
case IGNORE_NOT_FOUND:
return isIgnoreNotFound();
case OUTPUT_EXPRS:
return getOutputExprs();
case OUTPUT_TUPLE_ID:
return getOutputTupleId();
case CONJUNCTS:
return getConjuncts();
case RUNTIME_FILTERS:
return getRuntimeFilters();
case TABLET_SINK_SCHEMA:
return getTabletSinkSchema();
case TABLET_SINK_PARTITION:
return getTabletSinkPartition();
case TABLET_SINK_LOCATION:
return getTabletSinkLocation();
case TABLET_SINK_TXN_ID:
return getTabletSinkTxnId();
case TABLET_SINK_TUPLE_ID:
return getTabletSinkTupleId();
case TABLET_SINK_EXPRS:
return getTabletSinkExprs();
case IS_MERGE:
return isIsMerge();
}
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 DEST_NODE_ID:
return isSetDestNodeId();
case OUTPUT_PARTITION:
return isSetOutputPartition();
case IGNORE_NOT_FOUND:
return isSetIgnoreNotFound();
case OUTPUT_EXPRS:
return isSetOutputExprs();
case OUTPUT_TUPLE_ID:
return isSetOutputTupleId();
case CONJUNCTS:
return isSetConjuncts();
case RUNTIME_FILTERS:
return isSetRuntimeFilters();
case TABLET_SINK_SCHEMA:
return isSetTabletSinkSchema();
case TABLET_SINK_PARTITION:
return isSetTabletSinkPartition();
case TABLET_SINK_LOCATION:
return isSetTabletSinkLocation();
case TABLET_SINK_TXN_ID:
return isSetTabletSinkTxnId();
case TABLET_SINK_TUPLE_ID:
return isSetTabletSinkTupleId();
case TABLET_SINK_EXPRS:
return isSetTabletSinkExprs();
case IS_MERGE:
return isSetIsMerge();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof TDataStreamSink)
return this.equals((TDataStreamSink)that);
return false;
}
public boolean equals(TDataStreamSink that) {
if (that == null)
return false;
if (this == that)
return true;
boolean this_present_dest_node_id = true;
boolean that_present_dest_node_id = true;
if (this_present_dest_node_id || that_present_dest_node_id) {
if (!(this_present_dest_node_id && that_present_dest_node_id))
return false;
if (this.dest_node_id != that.dest_node_id)
return false;
}
boolean this_present_output_partition = true && this.isSetOutputPartition();
boolean that_present_output_partition = true && that.isSetOutputPartition();
if (this_present_output_partition || that_present_output_partition) {
if (!(this_present_output_partition && that_present_output_partition))
return false;
if (!this.output_partition.equals(that.output_partition))
return false;
}
boolean this_present_ignore_not_found = true && this.isSetIgnoreNotFound();
boolean that_present_ignore_not_found = true && that.isSetIgnoreNotFound();
if (this_present_ignore_not_found || that_present_ignore_not_found) {
if (!(this_present_ignore_not_found && that_present_ignore_not_found))
return false;
if (this.ignore_not_found != that.ignore_not_found)
return false;
}
boolean this_present_output_exprs = true && this.isSetOutputExprs();
boolean that_present_output_exprs = true && that.isSetOutputExprs();
if (this_present_output_exprs || that_present_output_exprs) {
if (!(this_present_output_exprs && that_present_output_exprs))
return false;
if (!this.output_exprs.equals(that.output_exprs))
return false;
}
boolean this_present_output_tuple_id = true && this.isSetOutputTupleId();
boolean that_present_output_tuple_id = true && that.isSetOutputTupleId();
if (this_present_output_tuple_id || that_present_output_tuple_id) {
if (!(this_present_output_tuple_id && that_present_output_tuple_id))
return false;
if (this.output_tuple_id != that.output_tuple_id)
return false;
}
boolean this_present_conjuncts = true && this.isSetConjuncts();
boolean that_present_conjuncts = true && that.isSetConjuncts();
if (this_present_conjuncts || that_present_conjuncts) {
if (!(this_present_conjuncts && that_present_conjuncts))
return false;
if (!this.conjuncts.equals(that.conjuncts))
return false;
}
boolean this_present_runtime_filters = true && this.isSetRuntimeFilters();
boolean that_present_runtime_filters = true && that.isSetRuntimeFilters();
if (this_present_runtime_filters || that_present_runtime_filters) {
if (!(this_present_runtime_filters && that_present_runtime_filters))
return false;
if (!this.runtime_filters.equals(that.runtime_filters))
return false;
}
boolean this_present_tablet_sink_schema = true && this.isSetTabletSinkSchema();
boolean that_present_tablet_sink_schema = true && that.isSetTabletSinkSchema();
if (this_present_tablet_sink_schema || that_present_tablet_sink_schema) {
if (!(this_present_tablet_sink_schema && that_present_tablet_sink_schema))
return false;
if (!this.tablet_sink_schema.equals(that.tablet_sink_schema))
return false;
}
boolean this_present_tablet_sink_partition = true && this.isSetTabletSinkPartition();
boolean that_present_tablet_sink_partition = true && that.isSetTabletSinkPartition();
if (this_present_tablet_sink_partition || that_present_tablet_sink_partition) {
if (!(this_present_tablet_sink_partition && that_present_tablet_sink_partition))
return false;
if (!this.tablet_sink_partition.equals(that.tablet_sink_partition))
return false;
}
boolean this_present_tablet_sink_location = true && this.isSetTabletSinkLocation();
boolean that_present_tablet_sink_location = true && that.isSetTabletSinkLocation();
if (this_present_tablet_sink_location || that_present_tablet_sink_location) {
if (!(this_present_tablet_sink_location && that_present_tablet_sink_location))
return false;
if (!this.tablet_sink_location.equals(that.tablet_sink_location))
return false;
}
boolean this_present_tablet_sink_txn_id = true && this.isSetTabletSinkTxnId();
boolean that_present_tablet_sink_txn_id = true && that.isSetTabletSinkTxnId();
if (this_present_tablet_sink_txn_id || that_present_tablet_sink_txn_id) {
if (!(this_present_tablet_sink_txn_id && that_present_tablet_sink_txn_id))
return false;
if (this.tablet_sink_txn_id != that.tablet_sink_txn_id)
return false;
}
boolean this_present_tablet_sink_tuple_id = true && this.isSetTabletSinkTupleId();
boolean that_present_tablet_sink_tuple_id = true && that.isSetTabletSinkTupleId();
if (this_present_tablet_sink_tuple_id || that_present_tablet_sink_tuple_id) {
if (!(this_present_tablet_sink_tuple_id && that_present_tablet_sink_tuple_id))
return false;
if (this.tablet_sink_tuple_id != that.tablet_sink_tuple_id)
return false;
}
boolean this_present_tablet_sink_exprs = true && this.isSetTabletSinkExprs();
boolean that_present_tablet_sink_exprs = true && that.isSetTabletSinkExprs();
if (this_present_tablet_sink_exprs || that_present_tablet_sink_exprs) {
if (!(this_present_tablet_sink_exprs && that_present_tablet_sink_exprs))
return false;
if (!this.tablet_sink_exprs.equals(that.tablet_sink_exprs))
return false;
}
boolean this_present_is_merge = true && this.isSetIsMerge();
boolean that_present_is_merge = true && that.isSetIsMerge();
if (this_present_is_merge || that_present_is_merge) {
if (!(this_present_is_merge && that_present_is_merge))
return false;
if (this.is_merge != that.is_merge)
return false;
}
return true;
}
@Override
public int hashCode() {
int hashCode = 1;
hashCode = hashCode * 8191 + dest_node_id;
hashCode = hashCode * 8191 + ((isSetOutputPartition()) ? 131071 : 524287);
if (isSetOutputPartition())
hashCode = hashCode * 8191 + output_partition.hashCode();
hashCode = hashCode * 8191 + ((isSetIgnoreNotFound()) ? 131071 : 524287);
if (isSetIgnoreNotFound())
hashCode = hashCode * 8191 + ((ignore_not_found) ? 131071 : 524287);
hashCode = hashCode * 8191 + ((isSetOutputExprs()) ? 131071 : 524287);
if (isSetOutputExprs())
hashCode = hashCode * 8191 + output_exprs.hashCode();
hashCode = hashCode * 8191 + ((isSetOutputTupleId()) ? 131071 : 524287);
if (isSetOutputTupleId())
hashCode = hashCode * 8191 + output_tuple_id;
hashCode = hashCode * 8191 + ((isSetConjuncts()) ? 131071 : 524287);
if (isSetConjuncts())
hashCode = hashCode * 8191 + conjuncts.hashCode();
hashCode = hashCode * 8191 + ((isSetRuntimeFilters()) ? 131071 : 524287);
if (isSetRuntimeFilters())
hashCode = hashCode * 8191 + runtime_filters.hashCode();
hashCode = hashCode * 8191 + ((isSetTabletSinkSchema()) ? 131071 : 524287);
if (isSetTabletSinkSchema())
hashCode = hashCode * 8191 + tablet_sink_schema.hashCode();
hashCode = hashCode * 8191 + ((isSetTabletSinkPartition()) ? 131071 : 524287);
if (isSetTabletSinkPartition())
hashCode = hashCode * 8191 + tablet_sink_partition.hashCode();
hashCode = hashCode * 8191 + ((isSetTabletSinkLocation()) ? 131071 : 524287);
if (isSetTabletSinkLocation())
hashCode = hashCode * 8191 + tablet_sink_location.hashCode();
hashCode = hashCode * 8191 + ((isSetTabletSinkTxnId()) ? 131071 : 524287);
if (isSetTabletSinkTxnId())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(tablet_sink_txn_id);
hashCode = hashCode * 8191 + ((isSetTabletSinkTupleId()) ? 131071 : 524287);
if (isSetTabletSinkTupleId())
hashCode = hashCode * 8191 + tablet_sink_tuple_id;
hashCode = hashCode * 8191 + ((isSetTabletSinkExprs()) ? 131071 : 524287);
if (isSetTabletSinkExprs())
hashCode = hashCode * 8191 + tablet_sink_exprs.hashCode();
hashCode = hashCode * 8191 + ((isSetIsMerge()) ? 131071 : 524287);
if (isSetIsMerge())
hashCode = hashCode * 8191 + ((is_merge) ? 131071 : 524287);
return hashCode;
}
@Override
public int compareTo(TDataStreamSink other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = java.lang.Boolean.compare(isSetDestNodeId(), other.isSetDestNodeId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetDestNodeId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.dest_node_id, other.dest_node_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetOutputPartition(), other.isSetOutputPartition());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOutputPartition()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.output_partition, other.output_partition);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetIgnoreNotFound(), other.isSetIgnoreNotFound());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetIgnoreNotFound()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ignore_not_found, other.ignore_not_found);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetOutputExprs(), other.isSetOutputExprs());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOutputExprs()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.output_exprs, other.output_exprs);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetOutputTupleId(), other.isSetOutputTupleId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOutputTupleId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.output_tuple_id, other.output_tuple_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetConjuncts(), other.isSetConjuncts());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetConjuncts()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.conjuncts, other.conjuncts);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetRuntimeFilters(), other.isSetRuntimeFilters());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetRuntimeFilters()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.runtime_filters, other.runtime_filters);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTabletSinkSchema(), other.isSetTabletSinkSchema());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTabletSinkSchema()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tablet_sink_schema, other.tablet_sink_schema);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTabletSinkPartition(), other.isSetTabletSinkPartition());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTabletSinkPartition()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tablet_sink_partition, other.tablet_sink_partition);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTabletSinkLocation(), other.isSetTabletSinkLocation());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTabletSinkLocation()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tablet_sink_location, other.tablet_sink_location);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTabletSinkTxnId(), other.isSetTabletSinkTxnId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTabletSinkTxnId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tablet_sink_txn_id, other.tablet_sink_txn_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTabletSinkTupleId(), other.isSetTabletSinkTupleId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTabletSinkTupleId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tablet_sink_tuple_id, other.tablet_sink_tuple_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetTabletSinkExprs(), other.isSetTabletSinkExprs());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTabletSinkExprs()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tablet_sink_exprs, other.tablet_sink_exprs);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetIsMerge(), other.isSetIsMerge());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetIsMerge()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.is_merge, other.is_merge);
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("TDataStreamSink(");
boolean first = true;
sb.append("dest_node_id:");
sb.append(this.dest_node_id);
first = false;
if (!first) sb.append(", ");
sb.append("output_partition:");
if (this.output_partition == null) {
sb.append("null");
} else {
sb.append(this.output_partition);
}
first = false;
if (isSetIgnoreNotFound()) {
if (!first) sb.append(", ");
sb.append("ignore_not_found:");
sb.append(this.ignore_not_found);
first = false;
}
if (isSetOutputExprs()) {
if (!first) sb.append(", ");
sb.append("output_exprs:");
if (this.output_exprs == null) {
sb.append("null");
} else {
sb.append(this.output_exprs);
}
first = false;
}
if (isSetOutputTupleId()) {
if (!first) sb.append(", ");
sb.append("output_tuple_id:");
sb.append(this.output_tuple_id);
first = false;
}
if (isSetConjuncts()) {
if (!first) sb.append(", ");
sb.append("conjuncts:");
if (this.conjuncts == null) {
sb.append("null");
} else {
sb.append(this.conjuncts);
}
first = false;
}
if (isSetRuntimeFilters()) {
if (!first) sb.append(", ");
sb.append("runtime_filters:");
if (this.runtime_filters == null) {
sb.append("null");
} else {
sb.append(this.runtime_filters);
}
first = false;
}
if (isSetTabletSinkSchema()) {
if (!first) sb.append(", ");
sb.append("tablet_sink_schema:");
if (this.tablet_sink_schema == null) {
sb.append("null");
} else {
sb.append(this.tablet_sink_schema);
}
first = false;
}
if (isSetTabletSinkPartition()) {
if (!first) sb.append(", ");
sb.append("tablet_sink_partition:");
if (this.tablet_sink_partition == null) {
sb.append("null");
} else {
sb.append(this.tablet_sink_partition);
}
first = false;
}
if (isSetTabletSinkLocation()) {
if (!first) sb.append(", ");
sb.append("tablet_sink_location:");
if (this.tablet_sink_location == null) {
sb.append("null");
} else {
sb.append(this.tablet_sink_location);
}
first = false;
}
if (isSetTabletSinkTxnId()) {
if (!first) sb.append(", ");
sb.append("tablet_sink_txn_id:");
sb.append(this.tablet_sink_txn_id);
first = false;
}
if (isSetTabletSinkTupleId()) {
if (!first) sb.append(", ");
sb.append("tablet_sink_tuple_id:");
sb.append(this.tablet_sink_tuple_id);
first = false;
}
if (isSetTabletSinkExprs()) {
if (!first) sb.append(", ");
sb.append("tablet_sink_exprs:");
if (this.tablet_sink_exprs == null) {
sb.append("null");
} else {
sb.append(this.tablet_sink_exprs);
}
first = false;
}
if (isSetIsMerge()) {
if (!first) sb.append(", ");
sb.append("is_merge:");
sb.append(this.is_merge);
first = false;
}
sb.append(")");
return sb.toString();
}
public void validate() throws org.apache.thrift.TException {
// check for required fields
// alas, we cannot check 'dest_node_id' because it's a primitive and you chose the non-beans generator.
if (output_partition == null) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'output_partition' was not present! Struct: " + toString());
}
// check for sub-struct validity
if (output_partition != null) {
output_partition.validate();
}
if (tablet_sink_schema != null) {
tablet_sink_schema.validate();
}
if (tablet_sink_partition != null) {
tablet_sink_partition.validate();
}
if (tablet_sink_location != null) {
tablet_sink_location.validate();
}
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private static class TDataStreamSinkStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TDataStreamSinkStandardScheme getScheme() {
return new TDataStreamSinkStandardScheme();
}
}
private static class TDataStreamSinkStandardScheme extends org.apache.thrift.scheme.StandardScheme<TDataStreamSink> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TDataStreamSink 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: // DEST_NODE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.dest_node_id = iprot.readI32();
struct.setDestNodeIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // OUTPUT_PARTITION
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.output_partition = new org.apache.doris.thrift.TDataPartition();
struct.output_partition.read(iprot);
struct.setOutputPartitionIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // IGNORE_NOT_FOUND
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.ignore_not_found = iprot.readBool();
struct.setIgnoreNotFoundIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // OUTPUT_EXPRS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list52 = iprot.readListBegin();
struct.output_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list52.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem53;
for (int _i54 = 0; _i54 < _list52.size; ++_i54)
{
_elem53 = new org.apache.doris.thrift.TExpr();
_elem53.read(iprot);
struct.output_exprs.add(_elem53);
}
iprot.readListEnd();
}
struct.setOutputExprsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // OUTPUT_TUPLE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.output_tuple_id = iprot.readI32();
struct.setOutputTupleIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // CONJUNCTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list55 = iprot.readListBegin();
struct.conjuncts = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list55.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem56;
for (int _i57 = 0; _i57 < _list55.size; ++_i57)
{
_elem56 = new org.apache.doris.thrift.TExpr();
_elem56.read(iprot);
struct.conjuncts.add(_elem56);
}
iprot.readListEnd();
}
struct.setConjunctsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // RUNTIME_FILTERS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list58 = iprot.readListBegin();
struct.runtime_filters = new java.util.ArrayList<org.apache.doris.thrift.TRuntimeFilterDesc>(_list58.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TRuntimeFilterDesc _elem59;
for (int _i60 = 0; _i60 < _list58.size; ++_i60)
{
_elem59 = new org.apache.doris.thrift.TRuntimeFilterDesc();
_elem59.read(iprot);
struct.runtime_filters.add(_elem59);
}
iprot.readListEnd();
}
struct.setRuntimeFiltersIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // TABLET_SINK_SCHEMA
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.tablet_sink_schema = new org.apache.doris.thrift.TOlapTableSchemaParam();
struct.tablet_sink_schema.read(iprot);
struct.setTabletSinkSchemaIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // TABLET_SINK_PARTITION
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.tablet_sink_partition = new org.apache.doris.thrift.TOlapTablePartitionParam();
struct.tablet_sink_partition.read(iprot);
struct.setTabletSinkPartitionIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 10: // TABLET_SINK_LOCATION
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.tablet_sink_location = new org.apache.doris.thrift.TOlapTableLocationParam();
struct.tablet_sink_location.read(iprot);
struct.setTabletSinkLocationIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 11: // TABLET_SINK_TXN_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.tablet_sink_txn_id = iprot.readI64();
struct.setTabletSinkTxnIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 12: // TABLET_SINK_TUPLE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.tablet_sink_tuple_id = iprot.readI32();
struct.setTabletSinkTupleIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 13: // TABLET_SINK_EXPRS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list61 = iprot.readListBegin();
struct.tablet_sink_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list61.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem62;
for (int _i63 = 0; _i63 < _list61.size; ++_i63)
{
_elem62 = new org.apache.doris.thrift.TExpr();
_elem62.read(iprot);
struct.tablet_sink_exprs.add(_elem62);
}
iprot.readListEnd();
}
struct.setTabletSinkExprsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 14: // IS_MERGE
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.is_merge = iprot.readBool();
struct.setIsMergeIsSet(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
if (!struct.isSetDestNodeId()) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'dest_node_id' was not found in serialized data! Struct: " + toString());
}
struct.validate();
}
public void write(org.apache.thrift.protocol.TProtocol oprot, TDataStreamSink struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
oprot.writeFieldBegin(DEST_NODE_ID_FIELD_DESC);
oprot.writeI32(struct.dest_node_id);
oprot.writeFieldEnd();
if (struct.output_partition != null) {
oprot.writeFieldBegin(OUTPUT_PARTITION_FIELD_DESC);
struct.output_partition.write(oprot);
oprot.writeFieldEnd();
}
if (struct.isSetIgnoreNotFound()) {
oprot.writeFieldBegin(IGNORE_NOT_FOUND_FIELD_DESC);
oprot.writeBool(struct.ignore_not_found);
oprot.writeFieldEnd();
}
if (struct.output_exprs != null) {
if (struct.isSetOutputExprs()) {
oprot.writeFieldBegin(OUTPUT_EXPRS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.output_exprs.size()));
for (org.apache.doris.thrift.TExpr _iter64 : struct.output_exprs)
{
_iter64.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.isSetOutputTupleId()) {
oprot.writeFieldBegin(OUTPUT_TUPLE_ID_FIELD_DESC);
oprot.writeI32(struct.output_tuple_id);
oprot.writeFieldEnd();
}
if (struct.conjuncts != null) {
if (struct.isSetConjuncts()) {
oprot.writeFieldBegin(CONJUNCTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.conjuncts.size()));
for (org.apache.doris.thrift.TExpr _iter65 : struct.conjuncts)
{
_iter65.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.runtime_filters != null) {
if (struct.isSetRuntimeFilters()) {
oprot.writeFieldBegin(RUNTIME_FILTERS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.runtime_filters.size()));
for (org.apache.doris.thrift.TRuntimeFilterDesc _iter66 : struct.runtime_filters)
{
_iter66.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.tablet_sink_schema != null) {
if (struct.isSetTabletSinkSchema()) {
oprot.writeFieldBegin(TABLET_SINK_SCHEMA_FIELD_DESC);
struct.tablet_sink_schema.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.tablet_sink_partition != null) {
if (struct.isSetTabletSinkPartition()) {
oprot.writeFieldBegin(TABLET_SINK_PARTITION_FIELD_DESC);
struct.tablet_sink_partition.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.tablet_sink_location != null) {
if (struct.isSetTabletSinkLocation()) {
oprot.writeFieldBegin(TABLET_SINK_LOCATION_FIELD_DESC);
struct.tablet_sink_location.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.isSetTabletSinkTxnId()) {
oprot.writeFieldBegin(TABLET_SINK_TXN_ID_FIELD_DESC);
oprot.writeI64(struct.tablet_sink_txn_id);
oprot.writeFieldEnd();
}
if (struct.isSetTabletSinkTupleId()) {
oprot.writeFieldBegin(TABLET_SINK_TUPLE_ID_FIELD_DESC);
oprot.writeI32(struct.tablet_sink_tuple_id);
oprot.writeFieldEnd();
}
if (struct.tablet_sink_exprs != null) {
if (struct.isSetTabletSinkExprs()) {
oprot.writeFieldBegin(TABLET_SINK_EXPRS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tablet_sink_exprs.size()));
for (org.apache.doris.thrift.TExpr _iter67 : struct.tablet_sink_exprs)
{
_iter67.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.isSetIsMerge()) {
oprot.writeFieldBegin(IS_MERGE_FIELD_DESC);
oprot.writeBool(struct.is_merge);
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class TDataStreamSinkTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TDataStreamSinkTupleScheme getScheme() {
return new TDataStreamSinkTupleScheme();
}
}
private static class TDataStreamSinkTupleScheme extends org.apache.thrift.scheme.TupleScheme<TDataStreamSink> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TDataStreamSink struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
oprot.writeI32(struct.dest_node_id);
struct.output_partition.write(oprot);
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetIgnoreNotFound()) {
optionals.set(0);
}
if (struct.isSetOutputExprs()) {
optionals.set(1);
}
if (struct.isSetOutputTupleId()) {
optionals.set(2);
}
if (struct.isSetConjuncts()) {
optionals.set(3);
}
if (struct.isSetRuntimeFilters()) {
optionals.set(4);
}
if (struct.isSetTabletSinkSchema()) {
optionals.set(5);
}
if (struct.isSetTabletSinkPartition()) {
optionals.set(6);
}
if (struct.isSetTabletSinkLocation()) {
optionals.set(7);
}
if (struct.isSetTabletSinkTxnId()) {
optionals.set(8);
}
if (struct.isSetTabletSinkTupleId()) {
optionals.set(9);
}
if (struct.isSetTabletSinkExprs()) {
optionals.set(10);
}
if (struct.isSetIsMerge()) {
optionals.set(11);
}
oprot.writeBitSet(optionals, 12);
if (struct.isSetIgnoreNotFound()) {
oprot.writeBool(struct.ignore_not_found);
}
if (struct.isSetOutputExprs()) {
{
oprot.writeI32(struct.output_exprs.size());
for (org.apache.doris.thrift.TExpr _iter68 : struct.output_exprs)
{
_iter68.write(oprot);
}
}
}
if (struct.isSetOutputTupleId()) {
oprot.writeI32(struct.output_tuple_id);
}
if (struct.isSetConjuncts()) {
{
oprot.writeI32(struct.conjuncts.size());
for (org.apache.doris.thrift.TExpr _iter69 : struct.conjuncts)
{
_iter69.write(oprot);
}
}
}
if (struct.isSetRuntimeFilters()) {
{
oprot.writeI32(struct.runtime_filters.size());
for (org.apache.doris.thrift.TRuntimeFilterDesc _iter70 : struct.runtime_filters)
{
_iter70.write(oprot);
}
}
}
if (struct.isSetTabletSinkSchema()) {
struct.tablet_sink_schema.write(oprot);
}
if (struct.isSetTabletSinkPartition()) {
struct.tablet_sink_partition.write(oprot);
}
if (struct.isSetTabletSinkLocation()) {
struct.tablet_sink_location.write(oprot);
}
if (struct.isSetTabletSinkTxnId()) {
oprot.writeI64(struct.tablet_sink_txn_id);
}
if (struct.isSetTabletSinkTupleId()) {
oprot.writeI32(struct.tablet_sink_tuple_id);
}
if (struct.isSetTabletSinkExprs()) {
{
oprot.writeI32(struct.tablet_sink_exprs.size());
for (org.apache.doris.thrift.TExpr _iter71 : struct.tablet_sink_exprs)
{
_iter71.write(oprot);
}
}
}
if (struct.isSetIsMerge()) {
oprot.writeBool(struct.is_merge);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TDataStreamSink struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
struct.dest_node_id = iprot.readI32();
struct.setDestNodeIdIsSet(true);
struct.output_partition = new org.apache.doris.thrift.TDataPartition();
struct.output_partition.read(iprot);
struct.setOutputPartitionIsSet(true);
java.util.BitSet incoming = iprot.readBitSet(12);
if (incoming.get(0)) {
struct.ignore_not_found = iprot.readBool();
struct.setIgnoreNotFoundIsSet(true);
}
if (incoming.get(1)) {
{
org.apache.thrift.protocol.TList _list72 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.output_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list72.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem73;
for (int _i74 = 0; _i74 < _list72.size; ++_i74)
{
_elem73 = new org.apache.doris.thrift.TExpr();
_elem73.read(iprot);
struct.output_exprs.add(_elem73);
}
}
struct.setOutputExprsIsSet(true);
}
if (incoming.get(2)) {
struct.output_tuple_id = iprot.readI32();
struct.setOutputTupleIdIsSet(true);
}
if (incoming.get(3)) {
{
org.apache.thrift.protocol.TList _list75 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.conjuncts = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list75.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem76;
for (int _i77 = 0; _i77 < _list75.size; ++_i77)
{
_elem76 = new org.apache.doris.thrift.TExpr();
_elem76.read(iprot);
struct.conjuncts.add(_elem76);
}
}
struct.setConjunctsIsSet(true);
}
if (incoming.get(4)) {
{
org.apache.thrift.protocol.TList _list78 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.runtime_filters = new java.util.ArrayList<org.apache.doris.thrift.TRuntimeFilterDesc>(_list78.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TRuntimeFilterDesc _elem79;
for (int _i80 = 0; _i80 < _list78.size; ++_i80)
{
_elem79 = new org.apache.doris.thrift.TRuntimeFilterDesc();
_elem79.read(iprot);
struct.runtime_filters.add(_elem79);
}
}
struct.setRuntimeFiltersIsSet(true);
}
if (incoming.get(5)) {
struct.tablet_sink_schema = new org.apache.doris.thrift.TOlapTableSchemaParam();
struct.tablet_sink_schema.read(iprot);
struct.setTabletSinkSchemaIsSet(true);
}
if (incoming.get(6)) {
struct.tablet_sink_partition = new org.apache.doris.thrift.TOlapTablePartitionParam();
struct.tablet_sink_partition.read(iprot);
struct.setTabletSinkPartitionIsSet(true);
}
if (incoming.get(7)) {
struct.tablet_sink_location = new org.apache.doris.thrift.TOlapTableLocationParam();
struct.tablet_sink_location.read(iprot);
struct.setTabletSinkLocationIsSet(true);
}
if (incoming.get(8)) {
struct.tablet_sink_txn_id = iprot.readI64();
struct.setTabletSinkTxnIdIsSet(true);
}
if (incoming.get(9)) {
struct.tablet_sink_tuple_id = iprot.readI32();
struct.setTabletSinkTupleIdIsSet(true);
}
if (incoming.get(10)) {
{
org.apache.thrift.protocol.TList _list81 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.tablet_sink_exprs = new java.util.ArrayList<org.apache.doris.thrift.TExpr>(_list81.size);
@org.apache.thrift.annotation.Nullable org.apache.doris.thrift.TExpr _elem82;
for (int _i83 = 0; _i83 < _list81.size; ++_i83)
{
_elem82 = new org.apache.doris.thrift.TExpr();
_elem82.read(iprot);
struct.tablet_sink_exprs.add(_elem82);
}
}
struct.setTabletSinkExprsIsSet(true);
}
if (incoming.get(11)) {
struct.is_merge = iprot.readBool();
struct.setIsMergeIsSet(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();
}
}