// SetCorrelated implements Plan interface.
509873
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()
		}
	}
}
790662
func (s *ListObjectParentsInput) SetConsistencyLevel(v string) *ListObjectParentsInput {
	s.ConsistencyLevel = &v
	return s
}
1373294
func (s *RecognizeCelebritiesOutput) SetOrientationCorrection(v string) *RecognizeCelebritiesOutput {
	s.OrientationCorrection = &v
	return s
}
227110
func (s *PlatformDescription) SetDateCreated(v time.Time) *PlatformDescription {
	s.DateCreated = &v
	return s
}
566959
func (p *Selection) SetCorrelated() {
	p.basePlan.SetCorrelated()
	for _, cond := range p.Conditions {
		p.correlated = p.correlated || cond.IsCorrelated()
	}
}
888809
func (s *SelectInput) SetConsistentRead(v bool) *SelectInput {
	s.ConsistentRead = &v
	return s
}
328522
func (tm *transferManager) SetConcurrency(concurrency int) {
	tm.mu.Lock()
	tm.concurrencyLimit = concurrency
	tm.mu.Unlock()
}
1280291
func (s *ListObjectChildrenInput) SetConsistencyLevel(v string) *ListObjectChildrenInput {
	s.ConsistencyLevel = &v
	return s
}
75180
func (s *ThingConnectivity) SetConnected(v bool) *ThingConnectivity {
	s.Connected = &v
	return s
}
688689
func (s *ApplicationDescription) SetDateCreated(v time.Time) *ApplicationDescription {
	s.DateCreated = &v
	return s
}
799831
func (a *EventCorrelator) Correlate(h *swf.HistoryEvent) {
	a.checkInit()

	if a.nilSafeEq(h.EventType, swf.EventTypeActivityTaskScheduled) {
		a.Activities[a.key(h.EventId)] = &ActivityInfo{
			ActivityId:   *h.ActivityTaskScheduledEventAttributes.ActivityId,
			ActivityType: h.ActivityTaskScheduledEventAttributes.ActivityType,
			Input:        h.ActivityTaskScheduledEventAttributes.Input,
		}
	}

	if a.nilSafeEq(h.EventType, swf.EventTypeSignalExternalWorkflowExecutionInitiated) {
		a.Signals[a.key(h.EventId)] = &SignalInfo{
			SignalName: *h.SignalExternalWorkflowExecutionInitiatedEventAttributes.SignalName,
			WorkflowId: *h.SignalExternalWorkflowExecutionInitiatedEventAttributes.WorkflowId,
			Input:      h.SignalExternalWorkflowExecutionInitiatedEventAttributes.Input,
		}
	}

	if a.nilSafeEq(h.EventType, swf.EventTypeRequestCancelExternalWorkflowExecutionInitiated) {
		a.Cancellations[a.key(h.EventId)] = &CancellationInfo{
			WorkflowId: *h.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes.WorkflowId,
			Control:    h.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes.Control,
		}
	}

	if a.nilSafeEq(h.EventType, swf.EventTypeTimerStarted) {
		a.Timers[a.key(h.EventId)] = &TimerInfo{
			Control:            h.TimerStartedEventAttributes.Control,
			TimerId:            *h.TimerStartedEventAttributes.TimerId,
			StartToFireTimeout: *h.TimerStartedEventAttributes.StartToFireTimeout,
		}
	}

	if a.nilSafeEq(h.EventType, swf.EventTypeStartChildWorkflowExecutionInitiated) {
		a.Children[a.key(h.EventId)] = &ChildInfo{
			WorkflowId:   *h.StartChildWorkflowExecutionInitiatedEventAttributes.WorkflowId,
			WorkflowType: h.StartChildWorkflowExecutionInitiatedEventAttributes.WorkflowType,
			Input:        h.StartChildWorkflowExecutionInitiatedEventAttributes.Input,
		}
	}

}
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,
		}
	}
}
237838
func (s *ListIndexInput) SetConsistencyLevel(v string) *ListIndexInput {
	s.ConsistencyLevel = &v
	return s
}
951624
func (s *QueryStatistics) SetRecordsMatched(v float64) *QueryStatistics {
	s.RecordsMatched = &v
	return s
}
1309389
func (s *Block) SetRelationships(v []*Relationship) *Block {
	s.Relationships = v
	return s
}
1235678
func (s *DescribeAlarmsForMetricInput) SetExtendedStatistic(v string) *DescribeAlarmsForMetricInput {
	s.ExtendedStatistic = &v
	return s
}
282503
func (s *FilterLogEventsInput) SetInterleaved(v bool) *FilterLogEventsInput {
	s.Interleaved = &v
	return s
}