| 1071 | } |
| 1072 | |
| 1073 | const uint64_t outputBufferSizeToReserve = |
| 1074 | queryConfig_.preferredOutputBatchBytes() * 1.2; |
| 1075 | { |
| 1076 | memory::ReclaimableSectionGuard guard(nonReclaimableSection_); |
| 1077 | if (pool_.maybeReserve(outputBufferSizeToReserve)) { |
| 1078 | return; |
| 1079 | } |
| 1080 | } |
| 1081 | LOG(WARNING) << "Failed to reserve " |
| 1082 | << succinctBytes(outputBufferSizeToReserve) |
| 1083 | << " for memory pool " << pool_.name() |
| 1084 | << ", usage: " << succinctBytes(pool_.currentBytes()) |
| 1085 | << ", reservation: " << succinctBytes(pool_.reservedBytes()); |
| 1086 | } |
| 1087 | |
| 1088 | RowTypePtr GroupingSet::makeSpillType() const { |
| 1089 | auto rows = table_->rows(); |
| 1090 | auto types = rows->keyTypes(); |
nothing calls this directly
no test coverage detected