| 190 | } |
| 191 | |
| 192 | Status MergeFrom(KernelContext*, KernelState&& src) override { |
| 193 | const auto& other_state = checked_cast<const CountDistinctImpl&>(src); |
| 194 | RETURN_NOT_OK(this->memo_table_->MergeTable(*(other_state.memo_table_))); |
| 195 | this->non_nulls = this->memo_table_->size(); |
| 196 | this->has_nulls = this->has_nulls || other_state.has_nulls; |
| 197 | return Status::OK(); |
| 198 | } |
| 199 | |
| 200 | Status Finalize(KernelContext* ctx, Datum* out) override { |
| 201 | const auto& state = checked_cast<const CountDistinctImpl&>(*ctx->state()); |
nothing calls this directly
no test coverage detected