| 200 | } |
| 201 | |
| 202 | void GroupingAggregatorConfig::Codegen(FragmentState* state) { |
| 203 | LlvmCodeGen* codegen = state->codegen(); |
| 204 | DCHECK(codegen != nullptr); |
| 205 | TPrefetchMode::type prefetch_mode = state->query_options().prefetch_mode; |
| 206 | Status status = is_streaming_preagg_ ? |
| 207 | CodegenAddBatchStreamingImpl(codegen, prefetch_mode) : |
| 208 | CodegenAddBatchImpl(codegen, prefetch_mode); |
| 209 | codegen_status_msg_ = FragmentState::GenerateCodegenMsg(status.ok(), status); |
| 210 | } |
| 211 | |
| 212 | Status GroupingAggregator::Open(RuntimeState* state) { |
| 213 | RETURN_IF_ERROR(Aggregator::Open(state)); |