Method CorrInit

be/src/exprs/aggregate-functions-ir.cc:540–549

};

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

static inline void CorrUpdateState(double x, double y, CorrState* state) {
  double deltaX = x - state->xavg;