TPlanNodeRuntimeStatsItem.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 TPlanNodeRuntimeStatsItem implements org.apache.thrift.TBase<TPlanNodeRuntimeStatsItem, TPlanNodeRuntimeStatsItem._Fields>, java.io.Serializable, Cloneable, Comparable<TPlanNodeRuntimeStatsItem> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TPlanNodeRuntimeStatsItem");
private static final org.apache.thrift.protocol.TField NODE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("node_id", org.apache.thrift.protocol.TType.I32, (short)1);
private static final org.apache.thrift.protocol.TField INPUT_ROWS_FIELD_DESC = new org.apache.thrift.protocol.TField("input_rows", org.apache.thrift.protocol.TType.I64, (short)2);
private static final org.apache.thrift.protocol.TField OUTPUT_ROWS_FIELD_DESC = new org.apache.thrift.protocol.TField("output_rows", org.apache.thrift.protocol.TType.I64, (short)3);
private static final org.apache.thrift.protocol.TField COMMON_FILTER_ROWS_FIELD_DESC = new org.apache.thrift.protocol.TField("common_filter_rows", org.apache.thrift.protocol.TType.I64, (short)4);
private static final org.apache.thrift.protocol.TField COMMON_FILTER_INPUT_ROWS_FIELD_DESC = new org.apache.thrift.protocol.TField("common_filter_input_rows", org.apache.thrift.protocol.TType.I64, (short)5);
private static final org.apache.thrift.protocol.TField RUNTIME_FILTER_ROWS_FIELD_DESC = new org.apache.thrift.protocol.TField("runtime_filter_rows", org.apache.thrift.protocol.TType.I64, (short)6);
private static final org.apache.thrift.protocol.TField RUNTIME_FILTER_INPUT_ROWS_FIELD_DESC = new org.apache.thrift.protocol.TField("runtime_filter_input_rows", org.apache.thrift.protocol.TType.I64, (short)7);
private static final org.apache.thrift.protocol.TField JOIN_BUILDER_ROWS_FIELD_DESC = new org.apache.thrift.protocol.TField("join_builder_rows", org.apache.thrift.protocol.TType.I64, (short)8);
private static final org.apache.thrift.protocol.TField JOIN_PROBE_ROWS_FIELD_DESC = new org.apache.thrift.protocol.TField("join_probe_rows", org.apache.thrift.protocol.TType.I64, (short)9);
private static final org.apache.thrift.protocol.TField JOIN_BUILDER_SKEW_RATIO_FIELD_DESC = new org.apache.thrift.protocol.TField("join_builder_skew_ratio", org.apache.thrift.protocol.TType.I32, (short)10);
private static final org.apache.thrift.protocol.TField JOIN_PROBER_SKEW_RATIO_FIELD_DESC = new org.apache.thrift.protocol.TField("join_prober_skew_ratio", org.apache.thrift.protocol.TType.I32, (short)11);
private static final org.apache.thrift.protocol.TField INSTANCE_NUM_FIELD_DESC = new org.apache.thrift.protocol.TField("instance_num", org.apache.thrift.protocol.TType.I32, (short)12);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TPlanNodeRuntimeStatsItemStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TPlanNodeRuntimeStatsItemTupleSchemeFactory();
public int node_id; // optional
public long input_rows; // optional
public long output_rows; // optional
public long common_filter_rows; // optional
public long common_filter_input_rows; // optional
public long runtime_filter_rows; // optional
public long runtime_filter_input_rows; // optional
public long join_builder_rows; // optional
public long join_probe_rows; // optional
public int join_builder_skew_ratio; // optional
public int join_prober_skew_ratio; // optional
public int instance_num; // 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 {
NODE_ID((short)1, "node_id"),
INPUT_ROWS((short)2, "input_rows"),
OUTPUT_ROWS((short)3, "output_rows"),
COMMON_FILTER_ROWS((short)4, "common_filter_rows"),
COMMON_FILTER_INPUT_ROWS((short)5, "common_filter_input_rows"),
RUNTIME_FILTER_ROWS((short)6, "runtime_filter_rows"),
RUNTIME_FILTER_INPUT_ROWS((short)7, "runtime_filter_input_rows"),
JOIN_BUILDER_ROWS((short)8, "join_builder_rows"),
JOIN_PROBE_ROWS((short)9, "join_probe_rows"),
JOIN_BUILDER_SKEW_RATIO((short)10, "join_builder_skew_ratio"),
JOIN_PROBER_SKEW_RATIO((short)11, "join_prober_skew_ratio"),
INSTANCE_NUM((short)12, "instance_num");
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: // NODE_ID
return NODE_ID;
case 2: // INPUT_ROWS
return INPUT_ROWS;
case 3: // OUTPUT_ROWS
return OUTPUT_ROWS;
case 4: // COMMON_FILTER_ROWS
return COMMON_FILTER_ROWS;
case 5: // COMMON_FILTER_INPUT_ROWS
return COMMON_FILTER_INPUT_ROWS;
case 6: // RUNTIME_FILTER_ROWS
return RUNTIME_FILTER_ROWS;
case 7: // RUNTIME_FILTER_INPUT_ROWS
return RUNTIME_FILTER_INPUT_ROWS;
case 8: // JOIN_BUILDER_ROWS
return JOIN_BUILDER_ROWS;
case 9: // JOIN_PROBE_ROWS
return JOIN_PROBE_ROWS;
case 10: // JOIN_BUILDER_SKEW_RATIO
return JOIN_BUILDER_SKEW_RATIO;
case 11: // JOIN_PROBER_SKEW_RATIO
return JOIN_PROBER_SKEW_RATIO;
case 12: // INSTANCE_NUM
return INSTANCE_NUM;
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 __NODE_ID_ISSET_ID = 0;
private static final int __INPUT_ROWS_ISSET_ID = 1;
private static final int __OUTPUT_ROWS_ISSET_ID = 2;
private static final int __COMMON_FILTER_ROWS_ISSET_ID = 3;
private static final int __COMMON_FILTER_INPUT_ROWS_ISSET_ID = 4;
private static final int __RUNTIME_FILTER_ROWS_ISSET_ID = 5;
private static final int __RUNTIME_FILTER_INPUT_ROWS_ISSET_ID = 6;
private static final int __JOIN_BUILDER_ROWS_ISSET_ID = 7;
private static final int __JOIN_PROBE_ROWS_ISSET_ID = 8;
private static final int __JOIN_BUILDER_SKEW_RATIO_ISSET_ID = 9;
private static final int __JOIN_PROBER_SKEW_RATIO_ISSET_ID = 10;
private static final int __INSTANCE_NUM_ISSET_ID = 11;
private short __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.NODE_ID,_Fields.INPUT_ROWS,_Fields.OUTPUT_ROWS,_Fields.COMMON_FILTER_ROWS,_Fields.COMMON_FILTER_INPUT_ROWS,_Fields.RUNTIME_FILTER_ROWS,_Fields.RUNTIME_FILTER_INPUT_ROWS,_Fields.JOIN_BUILDER_ROWS,_Fields.JOIN_PROBE_ROWS,_Fields.JOIN_BUILDER_SKEW_RATIO,_Fields.JOIN_PROBER_SKEW_RATIO,_Fields.INSTANCE_NUM};
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.NODE_ID, new org.apache.thrift.meta_data.FieldMetaData("node_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.INPUT_ROWS, new org.apache.thrift.meta_data.FieldMetaData("input_rows", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.OUTPUT_ROWS, new org.apache.thrift.meta_data.FieldMetaData("output_rows", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.COMMON_FILTER_ROWS, new org.apache.thrift.meta_data.FieldMetaData("common_filter_rows", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.COMMON_FILTER_INPUT_ROWS, new org.apache.thrift.meta_data.FieldMetaData("common_filter_input_rows", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.RUNTIME_FILTER_ROWS, new org.apache.thrift.meta_data.FieldMetaData("runtime_filter_rows", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.RUNTIME_FILTER_INPUT_ROWS, new org.apache.thrift.meta_data.FieldMetaData("runtime_filter_input_rows", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.JOIN_BUILDER_ROWS, new org.apache.thrift.meta_data.FieldMetaData("join_builder_rows", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.JOIN_PROBE_ROWS, new org.apache.thrift.meta_data.FieldMetaData("join_probe_rows", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.JOIN_BUILDER_SKEW_RATIO, new org.apache.thrift.meta_data.FieldMetaData("join_builder_skew_ratio", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.JOIN_PROBER_SKEW_RATIO, new org.apache.thrift.meta_data.FieldMetaData("join_prober_skew_ratio", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.INSTANCE_NUM, new org.apache.thrift.meta_data.FieldMetaData("instance_num", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TPlanNodeRuntimeStatsItem.class, metaDataMap);
}
public TPlanNodeRuntimeStatsItem() {
}
/**
* Performs a deep copy on <i>other</i>.
*/
public TPlanNodeRuntimeStatsItem(TPlanNodeRuntimeStatsItem other) {
__isset_bitfield = other.__isset_bitfield;
this.node_id = other.node_id;
this.input_rows = other.input_rows;
this.output_rows = other.output_rows;
this.common_filter_rows = other.common_filter_rows;
this.common_filter_input_rows = other.common_filter_input_rows;
this.runtime_filter_rows = other.runtime_filter_rows;
this.runtime_filter_input_rows = other.runtime_filter_input_rows;
this.join_builder_rows = other.join_builder_rows;
this.join_probe_rows = other.join_probe_rows;
this.join_builder_skew_ratio = other.join_builder_skew_ratio;
this.join_prober_skew_ratio = other.join_prober_skew_ratio;
this.instance_num = other.instance_num;
}
public TPlanNodeRuntimeStatsItem deepCopy() {
return new TPlanNodeRuntimeStatsItem(this);
}
@Override
public void clear() {
setNodeIdIsSet(false);
this.node_id = 0;
setInputRowsIsSet(false);
this.input_rows = 0;
setOutputRowsIsSet(false);
this.output_rows = 0;
setCommonFilterRowsIsSet(false);
this.common_filter_rows = 0;
setCommonFilterInputRowsIsSet(false);
this.common_filter_input_rows = 0;
setRuntimeFilterRowsIsSet(false);
this.runtime_filter_rows = 0;
setRuntimeFilterInputRowsIsSet(false);
this.runtime_filter_input_rows = 0;
setJoinBuilderRowsIsSet(false);
this.join_builder_rows = 0;
setJoinProbeRowsIsSet(false);
this.join_probe_rows = 0;
setJoinBuilderSkewRatioIsSet(false);
this.join_builder_skew_ratio = 0;
setJoinProberSkewRatioIsSet(false);
this.join_prober_skew_ratio = 0;
setInstanceNumIsSet(false);
this.instance_num = 0;
}
public int getNodeId() {
return this.node_id;
}
public TPlanNodeRuntimeStatsItem setNodeId(int node_id) {
this.node_id = node_id;
setNodeIdIsSet(true);
return this;
}
public void unsetNodeId() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __NODE_ID_ISSET_ID);
}
/** Returns true if field node_id is set (has been assigned a value) and false otherwise */
public boolean isSetNodeId() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __NODE_ID_ISSET_ID);
}
public void setNodeIdIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __NODE_ID_ISSET_ID, value);
}
public long getInputRows() {
return this.input_rows;
}
public TPlanNodeRuntimeStatsItem setInputRows(long input_rows) {
this.input_rows = input_rows;
setInputRowsIsSet(true);
return this;
}
public void unsetInputRows() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __INPUT_ROWS_ISSET_ID);
}
/** Returns true if field input_rows is set (has been assigned a value) and false otherwise */
public boolean isSetInputRows() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __INPUT_ROWS_ISSET_ID);
}
public void setInputRowsIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __INPUT_ROWS_ISSET_ID, value);
}
public long getOutputRows() {
return this.output_rows;
}
public TPlanNodeRuntimeStatsItem setOutputRows(long output_rows) {
this.output_rows = output_rows;
setOutputRowsIsSet(true);
return this;
}
public void unsetOutputRows() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __OUTPUT_ROWS_ISSET_ID);
}
/** Returns true if field output_rows is set (has been assigned a value) and false otherwise */
public boolean isSetOutputRows() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __OUTPUT_ROWS_ISSET_ID);
}
public void setOutputRowsIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __OUTPUT_ROWS_ISSET_ID, value);
}
public long getCommonFilterRows() {
return this.common_filter_rows;
}
public TPlanNodeRuntimeStatsItem setCommonFilterRows(long common_filter_rows) {
this.common_filter_rows = common_filter_rows;
setCommonFilterRowsIsSet(true);
return this;
}
public void unsetCommonFilterRows() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __COMMON_FILTER_ROWS_ISSET_ID);
}
/** Returns true if field common_filter_rows is set (has been assigned a value) and false otherwise */
public boolean isSetCommonFilterRows() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __COMMON_FILTER_ROWS_ISSET_ID);
}
public void setCommonFilterRowsIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __COMMON_FILTER_ROWS_ISSET_ID, value);
}
public long getCommonFilterInputRows() {
return this.common_filter_input_rows;
}
public TPlanNodeRuntimeStatsItem setCommonFilterInputRows(long common_filter_input_rows) {
this.common_filter_input_rows = common_filter_input_rows;
setCommonFilterInputRowsIsSet(true);
return this;
}
public void unsetCommonFilterInputRows() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __COMMON_FILTER_INPUT_ROWS_ISSET_ID);
}
/** Returns true if field common_filter_input_rows is set (has been assigned a value) and false otherwise */
public boolean isSetCommonFilterInputRows() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __COMMON_FILTER_INPUT_ROWS_ISSET_ID);
}
public void setCommonFilterInputRowsIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __COMMON_FILTER_INPUT_ROWS_ISSET_ID, value);
}
public long getRuntimeFilterRows() {
return this.runtime_filter_rows;
}
public TPlanNodeRuntimeStatsItem setRuntimeFilterRows(long runtime_filter_rows) {
this.runtime_filter_rows = runtime_filter_rows;
setRuntimeFilterRowsIsSet(true);
return this;
}
public void unsetRuntimeFilterRows() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __RUNTIME_FILTER_ROWS_ISSET_ID);
}
/** Returns true if field runtime_filter_rows is set (has been assigned a value) and false otherwise */
public boolean isSetRuntimeFilterRows() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __RUNTIME_FILTER_ROWS_ISSET_ID);
}
public void setRuntimeFilterRowsIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __RUNTIME_FILTER_ROWS_ISSET_ID, value);
}
public long getRuntimeFilterInputRows() {
return this.runtime_filter_input_rows;
}
public TPlanNodeRuntimeStatsItem setRuntimeFilterInputRows(long runtime_filter_input_rows) {
this.runtime_filter_input_rows = runtime_filter_input_rows;
setRuntimeFilterInputRowsIsSet(true);
return this;
}
public void unsetRuntimeFilterInputRows() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __RUNTIME_FILTER_INPUT_ROWS_ISSET_ID);
}
/** Returns true if field runtime_filter_input_rows is set (has been assigned a value) and false otherwise */
public boolean isSetRuntimeFilterInputRows() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __RUNTIME_FILTER_INPUT_ROWS_ISSET_ID);
}
public void setRuntimeFilterInputRowsIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __RUNTIME_FILTER_INPUT_ROWS_ISSET_ID, value);
}
public long getJoinBuilderRows() {
return this.join_builder_rows;
}
public TPlanNodeRuntimeStatsItem setJoinBuilderRows(long join_builder_rows) {
this.join_builder_rows = join_builder_rows;
setJoinBuilderRowsIsSet(true);
return this;
}
public void unsetJoinBuilderRows() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __JOIN_BUILDER_ROWS_ISSET_ID);
}
/** Returns true if field join_builder_rows is set (has been assigned a value) and false otherwise */
public boolean isSetJoinBuilderRows() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __JOIN_BUILDER_ROWS_ISSET_ID);
}
public void setJoinBuilderRowsIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __JOIN_BUILDER_ROWS_ISSET_ID, value);
}
public long getJoinProbeRows() {
return this.join_probe_rows;
}
public TPlanNodeRuntimeStatsItem setJoinProbeRows(long join_probe_rows) {
this.join_probe_rows = join_probe_rows;
setJoinProbeRowsIsSet(true);
return this;
}
public void unsetJoinProbeRows() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __JOIN_PROBE_ROWS_ISSET_ID);
}
/** Returns true if field join_probe_rows is set (has been assigned a value) and false otherwise */
public boolean isSetJoinProbeRows() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __JOIN_PROBE_ROWS_ISSET_ID);
}
public void setJoinProbeRowsIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __JOIN_PROBE_ROWS_ISSET_ID, value);
}
public int getJoinBuilderSkewRatio() {
return this.join_builder_skew_ratio;
}
public TPlanNodeRuntimeStatsItem setJoinBuilderSkewRatio(int join_builder_skew_ratio) {
this.join_builder_skew_ratio = join_builder_skew_ratio;
setJoinBuilderSkewRatioIsSet(true);
return this;
}
public void unsetJoinBuilderSkewRatio() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __JOIN_BUILDER_SKEW_RATIO_ISSET_ID);
}
/** Returns true if field join_builder_skew_ratio is set (has been assigned a value) and false otherwise */
public boolean isSetJoinBuilderSkewRatio() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __JOIN_BUILDER_SKEW_RATIO_ISSET_ID);
}
public void setJoinBuilderSkewRatioIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __JOIN_BUILDER_SKEW_RATIO_ISSET_ID, value);
}
public int getJoinProberSkewRatio() {
return this.join_prober_skew_ratio;
}
public TPlanNodeRuntimeStatsItem setJoinProberSkewRatio(int join_prober_skew_ratio) {
this.join_prober_skew_ratio = join_prober_skew_ratio;
setJoinProberSkewRatioIsSet(true);
return this;
}
public void unsetJoinProberSkewRatio() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __JOIN_PROBER_SKEW_RATIO_ISSET_ID);
}
/** Returns true if field join_prober_skew_ratio is set (has been assigned a value) and false otherwise */
public boolean isSetJoinProberSkewRatio() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __JOIN_PROBER_SKEW_RATIO_ISSET_ID);
}
public void setJoinProberSkewRatioIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __JOIN_PROBER_SKEW_RATIO_ISSET_ID, value);
}
public int getInstanceNum() {
return this.instance_num;
}
public TPlanNodeRuntimeStatsItem setInstanceNum(int instance_num) {
this.instance_num = instance_num;
setInstanceNumIsSet(true);
return this;
}
public void unsetInstanceNum() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __INSTANCE_NUM_ISSET_ID);
}
/** Returns true if field instance_num is set (has been assigned a value) and false otherwise */
public boolean isSetInstanceNum() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __INSTANCE_NUM_ISSET_ID);
}
public void setInstanceNumIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __INSTANCE_NUM_ISSET_ID, value);
}
public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case NODE_ID:
if (value == null) {
unsetNodeId();
} else {
setNodeId((java.lang.Integer)value);
}
break;
case INPUT_ROWS:
if (value == null) {
unsetInputRows();
} else {
setInputRows((java.lang.Long)value);
}
break;
case OUTPUT_ROWS:
if (value == null) {
unsetOutputRows();
} else {
setOutputRows((java.lang.Long)value);
}
break;
case COMMON_FILTER_ROWS:
if (value == null) {
unsetCommonFilterRows();
} else {
setCommonFilterRows((java.lang.Long)value);
}
break;
case COMMON_FILTER_INPUT_ROWS:
if (value == null) {
unsetCommonFilterInputRows();
} else {
setCommonFilterInputRows((java.lang.Long)value);
}
break;
case RUNTIME_FILTER_ROWS:
if (value == null) {
unsetRuntimeFilterRows();
} else {
setRuntimeFilterRows((java.lang.Long)value);
}
break;
case RUNTIME_FILTER_INPUT_ROWS:
if (value == null) {
unsetRuntimeFilterInputRows();
} else {
setRuntimeFilterInputRows((java.lang.Long)value);
}
break;
case JOIN_BUILDER_ROWS:
if (value == null) {
unsetJoinBuilderRows();
} else {
setJoinBuilderRows((java.lang.Long)value);
}
break;
case JOIN_PROBE_ROWS:
if (value == null) {
unsetJoinProbeRows();
} else {
setJoinProbeRows((java.lang.Long)value);
}
break;
case JOIN_BUILDER_SKEW_RATIO:
if (value == null) {
unsetJoinBuilderSkewRatio();
} else {
setJoinBuilderSkewRatio((java.lang.Integer)value);
}
break;
case JOIN_PROBER_SKEW_RATIO:
if (value == null) {
unsetJoinProberSkewRatio();
} else {
setJoinProberSkewRatio((java.lang.Integer)value);
}
break;
case INSTANCE_NUM:
if (value == null) {
unsetInstanceNum();
} else {
setInstanceNum((java.lang.Integer)value);
}
break;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case NODE_ID:
return getNodeId();
case INPUT_ROWS:
return getInputRows();
case OUTPUT_ROWS:
return getOutputRows();
case COMMON_FILTER_ROWS:
return getCommonFilterRows();
case COMMON_FILTER_INPUT_ROWS:
return getCommonFilterInputRows();
case RUNTIME_FILTER_ROWS:
return getRuntimeFilterRows();
case RUNTIME_FILTER_INPUT_ROWS:
return getRuntimeFilterInputRows();
case JOIN_BUILDER_ROWS:
return getJoinBuilderRows();
case JOIN_PROBE_ROWS:
return getJoinProbeRows();
case JOIN_BUILDER_SKEW_RATIO:
return getJoinBuilderSkewRatio();
case JOIN_PROBER_SKEW_RATIO:
return getJoinProberSkewRatio();
case INSTANCE_NUM:
return getInstanceNum();
}
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 NODE_ID:
return isSetNodeId();
case INPUT_ROWS:
return isSetInputRows();
case OUTPUT_ROWS:
return isSetOutputRows();
case COMMON_FILTER_ROWS:
return isSetCommonFilterRows();
case COMMON_FILTER_INPUT_ROWS:
return isSetCommonFilterInputRows();
case RUNTIME_FILTER_ROWS:
return isSetRuntimeFilterRows();
case RUNTIME_FILTER_INPUT_ROWS:
return isSetRuntimeFilterInputRows();
case JOIN_BUILDER_ROWS:
return isSetJoinBuilderRows();
case JOIN_PROBE_ROWS:
return isSetJoinProbeRows();
case JOIN_BUILDER_SKEW_RATIO:
return isSetJoinBuilderSkewRatio();
case JOIN_PROBER_SKEW_RATIO:
return isSetJoinProberSkewRatio();
case INSTANCE_NUM:
return isSetInstanceNum();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof TPlanNodeRuntimeStatsItem)
return this.equals((TPlanNodeRuntimeStatsItem)that);
return false;
}
public boolean equals(TPlanNodeRuntimeStatsItem that) {
if (that == null)
return false;
if (this == that)
return true;
boolean this_present_node_id = true && this.isSetNodeId();
boolean that_present_node_id = true && that.isSetNodeId();
if (this_present_node_id || that_present_node_id) {
if (!(this_present_node_id && that_present_node_id))
return false;
if (this.node_id != that.node_id)
return false;
}
boolean this_present_input_rows = true && this.isSetInputRows();
boolean that_present_input_rows = true && that.isSetInputRows();
if (this_present_input_rows || that_present_input_rows) {
if (!(this_present_input_rows && that_present_input_rows))
return false;
if (this.input_rows != that.input_rows)
return false;
}
boolean this_present_output_rows = true && this.isSetOutputRows();
boolean that_present_output_rows = true && that.isSetOutputRows();
if (this_present_output_rows || that_present_output_rows) {
if (!(this_present_output_rows && that_present_output_rows))
return false;
if (this.output_rows != that.output_rows)
return false;
}
boolean this_present_common_filter_rows = true && this.isSetCommonFilterRows();
boolean that_present_common_filter_rows = true && that.isSetCommonFilterRows();
if (this_present_common_filter_rows || that_present_common_filter_rows) {
if (!(this_present_common_filter_rows && that_present_common_filter_rows))
return false;
if (this.common_filter_rows != that.common_filter_rows)
return false;
}
boolean this_present_common_filter_input_rows = true && this.isSetCommonFilterInputRows();
boolean that_present_common_filter_input_rows = true && that.isSetCommonFilterInputRows();
if (this_present_common_filter_input_rows || that_present_common_filter_input_rows) {
if (!(this_present_common_filter_input_rows && that_present_common_filter_input_rows))
return false;
if (this.common_filter_input_rows != that.common_filter_input_rows)
return false;
}
boolean this_present_runtime_filter_rows = true && this.isSetRuntimeFilterRows();
boolean that_present_runtime_filter_rows = true && that.isSetRuntimeFilterRows();
if (this_present_runtime_filter_rows || that_present_runtime_filter_rows) {
if (!(this_present_runtime_filter_rows && that_present_runtime_filter_rows))
return false;
if (this.runtime_filter_rows != that.runtime_filter_rows)
return false;
}
boolean this_present_runtime_filter_input_rows = true && this.isSetRuntimeFilterInputRows();
boolean that_present_runtime_filter_input_rows = true && that.isSetRuntimeFilterInputRows();
if (this_present_runtime_filter_input_rows || that_present_runtime_filter_input_rows) {
if (!(this_present_runtime_filter_input_rows && that_present_runtime_filter_input_rows))
return false;
if (this.runtime_filter_input_rows != that.runtime_filter_input_rows)
return false;
}
boolean this_present_join_builder_rows = true && this.isSetJoinBuilderRows();
boolean that_present_join_builder_rows = true && that.isSetJoinBuilderRows();
if (this_present_join_builder_rows || that_present_join_builder_rows) {
if (!(this_present_join_builder_rows && that_present_join_builder_rows))
return false;
if (this.join_builder_rows != that.join_builder_rows)
return false;
}
boolean this_present_join_probe_rows = true && this.isSetJoinProbeRows();
boolean that_present_join_probe_rows = true && that.isSetJoinProbeRows();
if (this_present_join_probe_rows || that_present_join_probe_rows) {
if (!(this_present_join_probe_rows && that_present_join_probe_rows))
return false;
if (this.join_probe_rows != that.join_probe_rows)
return false;
}
boolean this_present_join_builder_skew_ratio = true && this.isSetJoinBuilderSkewRatio();
boolean that_present_join_builder_skew_ratio = true && that.isSetJoinBuilderSkewRatio();
if (this_present_join_builder_skew_ratio || that_present_join_builder_skew_ratio) {
if (!(this_present_join_builder_skew_ratio && that_present_join_builder_skew_ratio))
return false;
if (this.join_builder_skew_ratio != that.join_builder_skew_ratio)
return false;
}
boolean this_present_join_prober_skew_ratio = true && this.isSetJoinProberSkewRatio();
boolean that_present_join_prober_skew_ratio = true && that.isSetJoinProberSkewRatio();
if (this_present_join_prober_skew_ratio || that_present_join_prober_skew_ratio) {
if (!(this_present_join_prober_skew_ratio && that_present_join_prober_skew_ratio))
return false;
if (this.join_prober_skew_ratio != that.join_prober_skew_ratio)
return false;
}
boolean this_present_instance_num = true && this.isSetInstanceNum();
boolean that_present_instance_num = true && that.isSetInstanceNum();
if (this_present_instance_num || that_present_instance_num) {
if (!(this_present_instance_num && that_present_instance_num))
return false;
if (this.instance_num != that.instance_num)
return false;
}
return true;
}
@Override
public int hashCode() {
int hashCode = 1;
hashCode = hashCode * 8191 + ((isSetNodeId()) ? 131071 : 524287);
if (isSetNodeId())
hashCode = hashCode * 8191 + node_id;
hashCode = hashCode * 8191 + ((isSetInputRows()) ? 131071 : 524287);
if (isSetInputRows())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(input_rows);
hashCode = hashCode * 8191 + ((isSetOutputRows()) ? 131071 : 524287);
if (isSetOutputRows())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(output_rows);
hashCode = hashCode * 8191 + ((isSetCommonFilterRows()) ? 131071 : 524287);
if (isSetCommonFilterRows())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(common_filter_rows);
hashCode = hashCode * 8191 + ((isSetCommonFilterInputRows()) ? 131071 : 524287);
if (isSetCommonFilterInputRows())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(common_filter_input_rows);
hashCode = hashCode * 8191 + ((isSetRuntimeFilterRows()) ? 131071 : 524287);
if (isSetRuntimeFilterRows())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(runtime_filter_rows);
hashCode = hashCode * 8191 + ((isSetRuntimeFilterInputRows()) ? 131071 : 524287);
if (isSetRuntimeFilterInputRows())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(runtime_filter_input_rows);
hashCode = hashCode * 8191 + ((isSetJoinBuilderRows()) ? 131071 : 524287);
if (isSetJoinBuilderRows())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(join_builder_rows);
hashCode = hashCode * 8191 + ((isSetJoinProbeRows()) ? 131071 : 524287);
if (isSetJoinProbeRows())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(join_probe_rows);
hashCode = hashCode * 8191 + ((isSetJoinBuilderSkewRatio()) ? 131071 : 524287);
if (isSetJoinBuilderSkewRatio())
hashCode = hashCode * 8191 + join_builder_skew_ratio;
hashCode = hashCode * 8191 + ((isSetJoinProberSkewRatio()) ? 131071 : 524287);
if (isSetJoinProberSkewRatio())
hashCode = hashCode * 8191 + join_prober_skew_ratio;
hashCode = hashCode * 8191 + ((isSetInstanceNum()) ? 131071 : 524287);
if (isSetInstanceNum())
hashCode = hashCode * 8191 + instance_num;
return hashCode;
}
@Override
public int compareTo(TPlanNodeRuntimeStatsItem other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = java.lang.Boolean.compare(isSetNodeId(), other.isSetNodeId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetNodeId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.node_id, other.node_id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetInputRows(), other.isSetInputRows());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetInputRows()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.input_rows, other.input_rows);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetOutputRows(), other.isSetOutputRows());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetOutputRows()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.output_rows, other.output_rows);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetCommonFilterRows(), other.isSetCommonFilterRows());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetCommonFilterRows()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.common_filter_rows, other.common_filter_rows);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetCommonFilterInputRows(), other.isSetCommonFilterInputRows());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetCommonFilterInputRows()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.common_filter_input_rows, other.common_filter_input_rows);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetRuntimeFilterRows(), other.isSetRuntimeFilterRows());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetRuntimeFilterRows()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.runtime_filter_rows, other.runtime_filter_rows);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetRuntimeFilterInputRows(), other.isSetRuntimeFilterInputRows());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetRuntimeFilterInputRows()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.runtime_filter_input_rows, other.runtime_filter_input_rows);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetJoinBuilderRows(), other.isSetJoinBuilderRows());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetJoinBuilderRows()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.join_builder_rows, other.join_builder_rows);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetJoinProbeRows(), other.isSetJoinProbeRows());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetJoinProbeRows()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.join_probe_rows, other.join_probe_rows);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetJoinBuilderSkewRatio(), other.isSetJoinBuilderSkewRatio());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetJoinBuilderSkewRatio()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.join_builder_skew_ratio, other.join_builder_skew_ratio);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetJoinProberSkewRatio(), other.isSetJoinProberSkewRatio());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetJoinProberSkewRatio()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.join_prober_skew_ratio, other.join_prober_skew_ratio);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetInstanceNum(), other.isSetInstanceNum());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetInstanceNum()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.instance_num, other.instance_num);
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("TPlanNodeRuntimeStatsItem(");
boolean first = true;
if (isSetNodeId()) {
sb.append("node_id:");
sb.append(this.node_id);
first = false;
}
if (isSetInputRows()) {
if (!first) sb.append(", ");
sb.append("input_rows:");
sb.append(this.input_rows);
first = false;
}
if (isSetOutputRows()) {
if (!first) sb.append(", ");
sb.append("output_rows:");
sb.append(this.output_rows);
first = false;
}
if (isSetCommonFilterRows()) {
if (!first) sb.append(", ");
sb.append("common_filter_rows:");
sb.append(this.common_filter_rows);
first = false;
}
if (isSetCommonFilterInputRows()) {
if (!first) sb.append(", ");
sb.append("common_filter_input_rows:");
sb.append(this.common_filter_input_rows);
first = false;
}
if (isSetRuntimeFilterRows()) {
if (!first) sb.append(", ");
sb.append("runtime_filter_rows:");
sb.append(this.runtime_filter_rows);
first = false;
}
if (isSetRuntimeFilterInputRows()) {
if (!first) sb.append(", ");
sb.append("runtime_filter_input_rows:");
sb.append(this.runtime_filter_input_rows);
first = false;
}
if (isSetJoinBuilderRows()) {
if (!first) sb.append(", ");
sb.append("join_builder_rows:");
sb.append(this.join_builder_rows);
first = false;
}
if (isSetJoinProbeRows()) {
if (!first) sb.append(", ");
sb.append("join_probe_rows:");
sb.append(this.join_probe_rows);
first = false;
}
if (isSetJoinBuilderSkewRatio()) {
if (!first) sb.append(", ");
sb.append("join_builder_skew_ratio:");
sb.append(this.join_builder_skew_ratio);
first = false;
}
if (isSetJoinProberSkewRatio()) {
if (!first) sb.append(", ");
sb.append("join_prober_skew_ratio:");
sb.append(this.join_prober_skew_ratio);
first = false;
}
if (isSetInstanceNum()) {
if (!first) sb.append(", ");
sb.append("instance_num:");
sb.append(this.instance_num);
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 TPlanNodeRuntimeStatsItemStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TPlanNodeRuntimeStatsItemStandardScheme getScheme() {
return new TPlanNodeRuntimeStatsItemStandardScheme();
}
}
private static class TPlanNodeRuntimeStatsItemStandardScheme extends org.apache.thrift.scheme.StandardScheme<TPlanNodeRuntimeStatsItem> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TPlanNodeRuntimeStatsItem 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: // NODE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.node_id = iprot.readI32();
struct.setNodeIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // INPUT_ROWS
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.input_rows = iprot.readI64();
struct.setInputRowsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // OUTPUT_ROWS
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.output_rows = iprot.readI64();
struct.setOutputRowsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // COMMON_FILTER_ROWS
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.common_filter_rows = iprot.readI64();
struct.setCommonFilterRowsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // COMMON_FILTER_INPUT_ROWS
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.common_filter_input_rows = iprot.readI64();
struct.setCommonFilterInputRowsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // RUNTIME_FILTER_ROWS
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.runtime_filter_rows = iprot.readI64();
struct.setRuntimeFilterRowsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // RUNTIME_FILTER_INPUT_ROWS
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.runtime_filter_input_rows = iprot.readI64();
struct.setRuntimeFilterInputRowsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // JOIN_BUILDER_ROWS
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.join_builder_rows = iprot.readI64();
struct.setJoinBuilderRowsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // JOIN_PROBE_ROWS
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.join_probe_rows = iprot.readI64();
struct.setJoinProbeRowsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 10: // JOIN_BUILDER_SKEW_RATIO
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.join_builder_skew_ratio = iprot.readI32();
struct.setJoinBuilderSkewRatioIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 11: // JOIN_PROBER_SKEW_RATIO
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.join_prober_skew_ratio = iprot.readI32();
struct.setJoinProberSkewRatioIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 12: // INSTANCE_NUM
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.instance_num = iprot.readI32();
struct.setInstanceNumIsSet(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, TPlanNodeRuntimeStatsItem struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.isSetNodeId()) {
oprot.writeFieldBegin(NODE_ID_FIELD_DESC);
oprot.writeI32(struct.node_id);
oprot.writeFieldEnd();
}
if (struct.isSetInputRows()) {
oprot.writeFieldBegin(INPUT_ROWS_FIELD_DESC);
oprot.writeI64(struct.input_rows);
oprot.writeFieldEnd();
}
if (struct.isSetOutputRows()) {
oprot.writeFieldBegin(OUTPUT_ROWS_FIELD_DESC);
oprot.writeI64(struct.output_rows);
oprot.writeFieldEnd();
}
if (struct.isSetCommonFilterRows()) {
oprot.writeFieldBegin(COMMON_FILTER_ROWS_FIELD_DESC);
oprot.writeI64(struct.common_filter_rows);
oprot.writeFieldEnd();
}
if (struct.isSetCommonFilterInputRows()) {
oprot.writeFieldBegin(COMMON_FILTER_INPUT_ROWS_FIELD_DESC);
oprot.writeI64(struct.common_filter_input_rows);
oprot.writeFieldEnd();
}
if (struct.isSetRuntimeFilterRows()) {
oprot.writeFieldBegin(RUNTIME_FILTER_ROWS_FIELD_DESC);
oprot.writeI64(struct.runtime_filter_rows);
oprot.writeFieldEnd();
}
if (struct.isSetRuntimeFilterInputRows()) {
oprot.writeFieldBegin(RUNTIME_FILTER_INPUT_ROWS_FIELD_DESC);
oprot.writeI64(struct.runtime_filter_input_rows);
oprot.writeFieldEnd();
}
if (struct.isSetJoinBuilderRows()) {
oprot.writeFieldBegin(JOIN_BUILDER_ROWS_FIELD_DESC);
oprot.writeI64(struct.join_builder_rows);
oprot.writeFieldEnd();
}
if (struct.isSetJoinProbeRows()) {
oprot.writeFieldBegin(JOIN_PROBE_ROWS_FIELD_DESC);
oprot.writeI64(struct.join_probe_rows);
oprot.writeFieldEnd();
}
if (struct.isSetJoinBuilderSkewRatio()) {
oprot.writeFieldBegin(JOIN_BUILDER_SKEW_RATIO_FIELD_DESC);
oprot.writeI32(struct.join_builder_skew_ratio);
oprot.writeFieldEnd();
}
if (struct.isSetJoinProberSkewRatio()) {
oprot.writeFieldBegin(JOIN_PROBER_SKEW_RATIO_FIELD_DESC);
oprot.writeI32(struct.join_prober_skew_ratio);
oprot.writeFieldEnd();
}
if (struct.isSetInstanceNum()) {
oprot.writeFieldBegin(INSTANCE_NUM_FIELD_DESC);
oprot.writeI32(struct.instance_num);
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class TPlanNodeRuntimeStatsItemTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TPlanNodeRuntimeStatsItemTupleScheme getScheme() {
return new TPlanNodeRuntimeStatsItemTupleScheme();
}
}
private static class TPlanNodeRuntimeStatsItemTupleScheme extends org.apache.thrift.scheme.TupleScheme<TPlanNodeRuntimeStatsItem> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TPlanNodeRuntimeStatsItem 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.isSetNodeId()) {
optionals.set(0);
}
if (struct.isSetInputRows()) {
optionals.set(1);
}
if (struct.isSetOutputRows()) {
optionals.set(2);
}
if (struct.isSetCommonFilterRows()) {
optionals.set(3);
}
if (struct.isSetCommonFilterInputRows()) {
optionals.set(4);
}
if (struct.isSetRuntimeFilterRows()) {
optionals.set(5);
}
if (struct.isSetRuntimeFilterInputRows()) {
optionals.set(6);
}
if (struct.isSetJoinBuilderRows()) {
optionals.set(7);
}
if (struct.isSetJoinProbeRows()) {
optionals.set(8);
}
if (struct.isSetJoinBuilderSkewRatio()) {
optionals.set(9);
}
if (struct.isSetJoinProberSkewRatio()) {
optionals.set(10);
}
if (struct.isSetInstanceNum()) {
optionals.set(11);
}
oprot.writeBitSet(optionals, 12);
if (struct.isSetNodeId()) {
oprot.writeI32(struct.node_id);
}
if (struct.isSetInputRows()) {
oprot.writeI64(struct.input_rows);
}
if (struct.isSetOutputRows()) {
oprot.writeI64(struct.output_rows);
}
if (struct.isSetCommonFilterRows()) {
oprot.writeI64(struct.common_filter_rows);
}
if (struct.isSetCommonFilterInputRows()) {
oprot.writeI64(struct.common_filter_input_rows);
}
if (struct.isSetRuntimeFilterRows()) {
oprot.writeI64(struct.runtime_filter_rows);
}
if (struct.isSetRuntimeFilterInputRows()) {
oprot.writeI64(struct.runtime_filter_input_rows);
}
if (struct.isSetJoinBuilderRows()) {
oprot.writeI64(struct.join_builder_rows);
}
if (struct.isSetJoinProbeRows()) {
oprot.writeI64(struct.join_probe_rows);
}
if (struct.isSetJoinBuilderSkewRatio()) {
oprot.writeI32(struct.join_builder_skew_ratio);
}
if (struct.isSetJoinProberSkewRatio()) {
oprot.writeI32(struct.join_prober_skew_ratio);
}
if (struct.isSetInstanceNum()) {
oprot.writeI32(struct.instance_num);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TPlanNodeRuntimeStatsItem struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet incoming = iprot.readBitSet(12);
if (incoming.get(0)) {
struct.node_id = iprot.readI32();
struct.setNodeIdIsSet(true);
}
if (incoming.get(1)) {
struct.input_rows = iprot.readI64();
struct.setInputRowsIsSet(true);
}
if (incoming.get(2)) {
struct.output_rows = iprot.readI64();
struct.setOutputRowsIsSet(true);
}
if (incoming.get(3)) {
struct.common_filter_rows = iprot.readI64();
struct.setCommonFilterRowsIsSet(true);
}
if (incoming.get(4)) {
struct.common_filter_input_rows = iprot.readI64();
struct.setCommonFilterInputRowsIsSet(true);
}
if (incoming.get(5)) {
struct.runtime_filter_rows = iprot.readI64();
struct.setRuntimeFilterRowsIsSet(true);
}
if (incoming.get(6)) {
struct.runtime_filter_input_rows = iprot.readI64();
struct.setRuntimeFilterInputRowsIsSet(true);
}
if (incoming.get(7)) {
struct.join_builder_rows = iprot.readI64();
struct.setJoinBuilderRowsIsSet(true);
}
if (incoming.get(8)) {
struct.join_probe_rows = iprot.readI64();
struct.setJoinProbeRowsIsSet(true);
}
if (incoming.get(9)) {
struct.join_builder_skew_ratio = iprot.readI32();
struct.setJoinBuilderSkewRatioIsSet(true);
}
if (incoming.get(10)) {
struct.join_prober_skew_ratio = iprot.readI32();
struct.setJoinProberSkewRatioIsSet(true);
}
if (incoming.get(11)) {
struct.instance_num = iprot.readI32();
struct.setInstanceNumIsSet(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();
}
}