| 97 | std::atomic_bool& marker) |
| 98 | : vector_(std::move(vector)), |
| 99 | loaded_(loaded), |
| 100 | loadedAfterMarker_(loadedAfterMarker), |
| 101 | marker_(marker) {} |
| 102 | |
| 103 | private: |
| 104 | void loadInternal( |
| 105 | RowSet rows, |
| 106 | ValueHook* hook, |
| 107 | vector_size_t resultSize, |
| 108 | VectorPtr* result) override { |
| 109 | BOLT_CHECK(!hook, "RecordingLazyLoader doesn't support ValueHook"); |
| 110 | loaded_ = true; |
| 111 | loadedAfterMarker_ = loadedAfterMarker_ || marker_.load(); |
| 112 | |
| 113 | BOLT_CHECK_EQ(rows.size(), vector_->size()); |
| 114 | *result = BaseVector::copy(*vector_); |
| 115 | } |
| 116 | |
| 117 | const VectorPtr vector_; |
| 118 | std::atomic_bool& loaded_; |
| 119 | std::atomic_bool& loadedAfterMarker_; |
| 120 | std::atomic_bool& marker_; |
| 121 | }; |
| 122 | } // namespace |
| 123 | |
| 124 | class OrderByTest : public OperatorTestBase, public WithGPUParamInterface<> { |
| 125 | protected: |
nothing calls this directly
no test coverage detected