code: func (p *PhysicalAggregation) SetCorrelated() {
  	p.basePlan.SetCorrelated()
  	for _, item := range p.GroupByItems {
  		p.correlated = p.correlated || item.IsCorrelated()
  	}
  	for _, fun := range p.AggFuncs {
  		for _, arg := range fun.GetArgs() {
  			p.correlated = p.correlated || arg.IsCorrelated()
  		}
  	}
  }
docs: // SetCorrelated implements Plan interface.