// SetCorrelated implements Plan interface.
194298
func (p *PhysicalHashJoin) SetCorrelated() {
	p.basePlan.SetCorrelated()
	for _, cond := range p.EqualConditions {
		p.correlated = p.correlated || cond.IsCorrelated()
	}
	for _, cond := range p.LeftConditions {
		p.correlated = p.correlated || cond.IsCorrelated()
	}
	for _, cond := range p.RightConditions {
		p.correlated = p.correlated || cond.IsCorrelated()
	}
	for _, cond := range p.OtherConditions {
		p.correlated = p.correlated || cond.IsCorrelated()
	}
}
56523
func (a *ActivityCorrelator) Correlate(h HistoryEvent) {
	if a.Activities == nil {
		a.Activities = make(map[string]*ActivityInfo)
	}
	if h.EventType == EventTypeActivityTaskScheduled {
		a.Activities[strconv.Itoa(h.EventID)] = &ActivityInfo{
			ActivityID:   h.ActivityTaskScheduledEventAttributes.ActivityID,
			ActivityType: h.ActivityTaskScheduledEventAttributes.ActivityType,
		}
	}
}
229753
func (s *GetFunctionOutput) SetConcurrency(v *PutFunctionConcurrencyOutput) *GetFunctionOutput {
	s.Concurrency = v
	return s
}
252002
func (s *DetectFacesOutput) SetOrientationCorrection(v string) *DetectFacesOutput {
	s.OrientationCorrection = &v
	return s
}
546633
func (v *Activatable) SetRelatedAction(action *Action) {
	deprecated_since(3, 10, 0, "gtk_activatable_set_related_action()")
	C.gtk_activatable_set_related_action(ACTIVATABLE(v), ACTION(action))
}
820332
func (s *Invitation) SetRelationshipStatus(v string) *Invitation {
	s.RelationshipStatus = &v
	return s
}
421543
func (s *MergeMetadata) SetIsMerged(v bool) *MergeMetadata {
	s.IsMerged = &v
	return s
}
511309
func (s *CurrentRevision) SetCreated(v time.Time) *CurrentRevision {
	s.Created = &v
	return s
}
964889
func (builder *RequestBuilder) SetConcurrency(concurrency int) *RequestBuilder {
	builder.Request.Concurrency = concurrency
	return builder
}
68145
func (o querySet) SetCond(cond *Condition) QuerySeter {
	o.cond = cond
	return &o
}
563556
func (s *PutMetricAlarmInput) SetExtendedStatistic(v string) *PutMetricAlarmInput {
	s.ExtendedStatistic = &v
	return s
}
79159
func (c *BackgroundService) SetRecording(shouldRecord bool, service string) (*gcdmessage.ChromeResponse, error) {
	var v BackgroundServiceSetRecordingParams
	v.ShouldRecord = shouldRecord
	v.Service = service
	return c.SetRecordingWithParams(&v)
}
667141
func (s *BatchReadInput) SetConsistencyLevel(v string) *BatchReadInput {
	s.ConsistencyLevel = &v
	return s
}
796466
func (writer *ConsoleWriter) SetColored(colored bool) {
	writer.lock.Lock()
	defer writer.lock.Unlock()

	if colored == writer.colored {
		return
	}

	writer.colored = colored

	initPrefix(colored)
}
1373294
func (s *RecognizeCelebritiesOutput) SetOrientationCorrection(v string) *RecognizeCelebritiesOutput {
	s.OrientationCorrection = &v
	return s
}
1336800
func SetCorrelationID(cid string) RequestFunc {
	return func(ctx context.Context, pub *amqp.Publishing, _ *amqp.Delivery) context.Context {
		pub.CorrelationId = cid
		return ctx
	}
}
1099013
func (p *PhysicalApply) SetCorrelated() {
	corColumns := p.GetChildren()[1].extractCorrelatedCols()
	p.correlated = p.GetChildren()[0].IsCorrelated()
	for _, corCol := range corColumns {
		if idx := p.GetChildren()[0].GetSchema().GetColumnIndex(&corCol.Column); idx == -1 {
			p.correlated = true
			break
		}
	}
}