| 2465 | } |
| 2466 | |
| 2467 | void AggregateFunctions::DsHllUnionUpdate(FunctionContext* ctx, const StringVal& src, |
| 2468 | StringVal* dst) { |
| 2469 | if (src.is_null) return; |
| 2470 | DCHECK(!dst->is_null); |
| 2471 | DCHECK_EQ(dst->len, sizeof(datasketches::hll_union)); |
| 2472 | try { |
| 2473 | reinterpret_cast<datasketches::hll_union*>(dst->ptr) |
| 2474 | ->update(datasketches::hll_sketch::deserialize(src.ptr, src.len)); |
| 2475 | } catch (const std::exception& e) { |
| 2476 | LogSketchDeserializationError(ctx, e); |
| 2477 | } |
| 2478 | } |
| 2479 | |
| 2480 | StringVal AggregateFunctions::DsHllUnionSerialize(FunctionContext* ctx, |
| 2481 | const StringVal& src) { |
nothing calls this directly
no test coverage detected