| 194 | } |
| 195 | |
| 196 | void assertFieldsEqual(const SpillConfig& e, const SpillConfig& a) { |
| 197 | EXPECT_EQ(e.fileNamePrefix, a.fileNamePrefix); |
| 198 | EXPECT_EQ(e.maxFileSize, a.maxFileSize); |
| 199 | EXPECT_EQ(e.spillUringEnabled, a.spillUringEnabled); |
| 200 | EXPECT_EQ(e.writeBufferSize, a.writeBufferSize); |
| 201 | EXPECT_EQ(e.minSpillableReservationPct, a.minSpillableReservationPct); |
| 202 | EXPECT_EQ(e.spillableReservationGrowthPct, a.spillableReservationGrowthPct); |
| 203 | EXPECT_EQ(e.startPartitionBit, a.startPartitionBit); |
| 204 | EXPECT_EQ(e.joinPartitionBits, a.joinPartitionBits); |
| 205 | EXPECT_EQ(e.joinRepartitionBits, a.joinRepartitionBits); |
| 206 | EXPECT_EQ(e.maxSpillLevel, a.maxSpillLevel); |
| 207 | EXPECT_EQ(e.maxSpillRunRows, a.maxSpillRunRows); |
| 208 | EXPECT_EQ(e.writerFlushThresholdSize, a.writerFlushThresholdSize); |
| 209 | EXPECT_EQ(e.testSpillPct, a.testSpillPct); |
| 210 | EXPECT_EQ(e.compressionKind, a.compressionKind); |
| 211 | EXPECT_EQ(e.fileCreateConfig, a.fileCreateConfig); |
| 212 | EXPECT_EQ(e.rowBasedSpillMode, a.rowBasedSpillMode); |
| 213 | EXPECT_EQ(e.singlePartitionSerdeKind, a.singlePartitionSerdeKind); |
| 214 | EXPECT_EQ( |
| 215 | e.spillPartitionsAdaptiveThreshold, a.spillPartitionsAdaptiveThreshold); |
| 216 | EXPECT_EQ(e.jitEnabled, a.jitEnabled); |
| 217 | EXPECT_EQ(e.needSetNextEqual, a.needSetNextEqual); |
| 218 | EXPECT_EQ(e.aggBypassHTEqualNum, a.aggBypassHTEqualNum); |
| 219 | } |
| 220 | |
| 221 | } // namespace |
| 222 | |