code: func (e *HashAggExec) Open(ctx context.Context) error {
  	if err := e.baseExecutor.Open(ctx); err != nil {
  		return err
  	}
  	e.prepared = false
  
  	if e.isUnparallelExec {
  		e.initForUnparallelExec()
  		return nil
  	}
  	e.initForParallelExec(e.ctx)
  	return nil
  }
docs: // Open implements the Executor Open interface.