Method CovarInit

be/src/exprs/aggregate-functions-ir.cc:777–786

};

void AggregateFunctions::CovarInit(FunctionContext* ctx, StringVal* dst) {
  dst->is_null = false;
  dst->len = sizeof(CovarState);
  AllocBuffer(ctx, dst, dst->len);
  if (UNLIKELY(dst->is_null)) {
    DCHECK(!ctx->impl()->state()->GetQueryStatus().ok());
    return;
  }
  *(reinterpret_cast<CovarState*>(dst->ptr)) = {};
}

static inline void CovarUpdateState(double x, double y, CovarState* state) {
  ++state->count;