emr

Jun 4, 2018

Changes in this version

+ const ServiceID

Nov 29, 2017

Changes in this version

type Cluster

+ KerberosAttributes *KerberosAttributes

+ func (s *Cluster) SetKerberosAttributes(v *KerberosAttributes) *Cluster

+ type KerberosAttributes struct

+ ADDomainJoinPassword *string

+ ADDomainJoinUser *string

+ CrossRealmTrustPrincipalPassword *string

+ KdcAdminPassword *string

+ Realm *string

+ func (s *KerberosAttributes) SetADDomainJoinPassword(v string) *KerberosAttributes

+ func (s *KerberosAttributes) SetADDomainJoinUser(v string) *KerberosAttributes

+ func (s *KerberosAttributes) SetCrossRealmTrustPrincipalPassword(v string) *KerberosAttributes

+ func (s *KerberosAttributes) SetKdcAdminPassword(v string) *KerberosAttributes

+ func (s *KerberosAttributes) SetRealm(v string) *KerberosAttributes

+ func (s *KerberosAttributes) Validate() error

+ func (s KerberosAttributes) GoString() string

+ func (s KerberosAttributes) String() string

type RunJobFlowInput

+ KerberosAttributes *KerberosAttributes

+ func (s *RunJobFlowInput) SetKerberosAttributes(v *KerberosAttributes) *RunJobFlowInput

Jul 27, 2017

Changes in this version

+ const ClusterStateChangeReasonCodeInstanceFleetTimeout

+ const RepoUpgradeOnBootNone

+ const RepoUpgradeOnBootSecurity

type Cluster

+ CustomAmiId *string

+ EbsRootVolumeSize *int64

+ RepoUpgradeOnBoot *string

+ func (s *Cluster) SetCustomAmiId(v string) *Cluster

+ func (s *Cluster) SetEbsRootVolumeSize(v int64) *Cluster

+ func (s *Cluster) SetRepoUpgradeOnBoot(v string) *Cluster

type RunJobFlowInput

+ CustomAmiId *string

+ EbsRootVolumeSize *int64

+ RepoUpgradeOnBoot *string

+ func (s *RunJobFlowInput) SetCustomAmiId(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetEbsRootVolumeSize(v int64) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetRepoUpgradeOnBoot(v string) *RunJobFlowInput

Mar 22, 2017

Changes in this version

type EMR

+ func (c *EMR) AddInstanceFleetWithContext(ctx aws.Context, input *AddInstanceFleetInput, opts ...request.Option) (*AddInstanceFleetOutput, error)

+ func (c *EMR) AddInstanceGroupsWithContext(ctx aws.Context, input *AddInstanceGroupsInput, opts ...request.Option) (*AddInstanceGroupsOutput, error)

+ func (c *EMR) AddJobFlowStepsWithContext(ctx aws.Context, input *AddJobFlowStepsInput, opts ...request.Option) (*AddJobFlowStepsOutput, error)

+ func (c *EMR) AddTagsWithContext(ctx aws.Context, input *AddTagsInput, opts ...request.Option) (*AddTagsOutput, error)

+ func (c *EMR) CancelStepsWithContext(ctx aws.Context, input *CancelStepsInput, opts ...request.Option) (*CancelStepsOutput, error)

+ func (c *EMR) CreateSecurityConfigurationWithContext(ctx aws.Context, input *CreateSecurityConfigurationInput, ...) (*CreateSecurityConfigurationOutput, error)

+ func (c *EMR) DeleteSecurityConfigurationWithContext(ctx aws.Context, input *DeleteSecurityConfigurationInput, ...) (*DeleteSecurityConfigurationOutput, error)

+ func (c *EMR) DescribeClusterWithContext(ctx aws.Context, input *DescribeClusterInput, opts ...request.Option) (*DescribeClusterOutput, error)

+ func (c *EMR) DescribeJobFlowsWithContext(ctx aws.Context, input *DescribeJobFlowsInput, opts ...request.Option) (*DescribeJobFlowsOutput, error)

+ func (c *EMR) DescribeSecurityConfigurationWithContext(ctx aws.Context, input *DescribeSecurityConfigurationInput, ...) (*DescribeSecurityConfigurationOutput, error)

+ func (c *EMR) DescribeStepWithContext(ctx aws.Context, input *DescribeStepInput, opts ...request.Option) (*DescribeStepOutput, error)

+ func (c *EMR) ListBootstrapActionsPagesWithContext(ctx aws.Context, input *ListBootstrapActionsInput, ...) error

+ func (c *EMR) ListBootstrapActionsWithContext(ctx aws.Context, input *ListBootstrapActionsInput, opts ...request.Option) (*ListBootstrapActionsOutput, error)

+ func (c *EMR) ListClustersPagesWithContext(ctx aws.Context, input *ListClustersInput, ...) error

+ func (c *EMR) ListClustersWithContext(ctx aws.Context, input *ListClustersInput, opts ...request.Option) (*ListClustersOutput, error)

+ func (c *EMR) ListInstanceFleetsPagesWithContext(ctx aws.Context, input *ListInstanceFleetsInput, ...) error

+ func (c *EMR) ListInstanceFleetsWithContext(ctx aws.Context, input *ListInstanceFleetsInput, opts ...request.Option) (*ListInstanceFleetsOutput, error)

+ func (c *EMR) ListInstanceGroupsPagesWithContext(ctx aws.Context, input *ListInstanceGroupsInput, ...) error

+ func (c *EMR) ListInstanceGroupsWithContext(ctx aws.Context, input *ListInstanceGroupsInput, opts ...request.Option) (*ListInstanceGroupsOutput, error)

+ func (c *EMR) ListInstancesPagesWithContext(ctx aws.Context, input *ListInstancesInput, ...) error

+ func (c *EMR) ListInstancesWithContext(ctx aws.Context, input *ListInstancesInput, opts ...request.Option) (*ListInstancesOutput, error)

+ func (c *EMR) ListSecurityConfigurationsWithContext(ctx aws.Context, input *ListSecurityConfigurationsInput, ...) (*ListSecurityConfigurationsOutput, error)

+ func (c *EMR) ListStepsPagesWithContext(ctx aws.Context, input *ListStepsInput, fn func(*ListStepsOutput, bool) bool, ...) error

+ func (c *EMR) ListStepsWithContext(ctx aws.Context, input *ListStepsInput, opts ...request.Option) (*ListStepsOutput, error)

+ func (c *EMR) ModifyInstanceFleetWithContext(ctx aws.Context, input *ModifyInstanceFleetInput, opts ...request.Option) (*ModifyInstanceFleetOutput, error)

+ func (c *EMR) ModifyInstanceGroupsWithContext(ctx aws.Context, input *ModifyInstanceGroupsInput, opts ...request.Option) (*ModifyInstanceGroupsOutput, error)

+ func (c *EMR) PutAutoScalingPolicyWithContext(ctx aws.Context, input *PutAutoScalingPolicyInput, opts ...request.Option) (*PutAutoScalingPolicyOutput, error)

+ func (c *EMR) RemoveAutoScalingPolicyWithContext(ctx aws.Context, input *RemoveAutoScalingPolicyInput, opts ...request.Option) (*RemoveAutoScalingPolicyOutput, error)

+ func (c *EMR) RemoveTagsWithContext(ctx aws.Context, input *RemoveTagsInput, opts ...request.Option) (*RemoveTagsOutput, error)

+ func (c *EMR) RunJobFlowWithContext(ctx aws.Context, input *RunJobFlowInput, opts ...request.Option) (*RunJobFlowOutput, error)

+ func (c *EMR) SetTerminationProtectionWithContext(ctx aws.Context, input *SetTerminationProtectionInput, opts ...request.Option) (*SetTerminationProtectionOutput, error)

+ func (c *EMR) SetVisibleToAllUsersWithContext(ctx aws.Context, input *SetVisibleToAllUsersInput, opts ...request.Option) (*SetVisibleToAllUsersOutput, error)

+ func (c *EMR) TerminateJobFlowsWithContext(ctx aws.Context, input *TerminateJobFlowsInput, opts ...request.Option) (*TerminateJobFlowsOutput, error)

+ func (c *EMR) WaitUntilClusterRunningWithContext(ctx aws.Context, input *DescribeClusterInput, opts ...request.WaiterOption) error

+ func (c *EMR) WaitUntilClusterTerminatedWithContext(ctx aws.Context, input *DescribeClusterInput, opts ...request.WaiterOption) error

+ func (c *EMR) WaitUntilStepCompleteWithContext(ctx aws.Context, input *DescribeStepInput, opts ...request.WaiterOption) error

Mar 10, 2017

Changes in this version

+ const InstanceCollectionTypeInstanceFleet

+ const InstanceCollectionTypeInstanceGroup

+ const InstanceFleetStateBootstrapping

+ const InstanceFleetStateChangeReasonCodeClusterTerminated

+ const InstanceFleetStateChangeReasonCodeInstanceFailure

+ const InstanceFleetStateChangeReasonCodeInternalError

+ const InstanceFleetStateChangeReasonCodeValidationError

+ const InstanceFleetStateProvisioning

+ const InstanceFleetStateResizing

+ const InstanceFleetStateRunning

+ const InstanceFleetStateSuspended

+ const InstanceFleetStateTerminated

+ const InstanceFleetStateTerminating

+ const InstanceFleetTypeCore

+ const InstanceFleetTypeMaster

+ const InstanceFleetTypeTask

+ const SpotProvisioningTimeoutActionSwitchToOnDemand

+ const SpotProvisioningTimeoutActionTerminateCluster

+ type AddInstanceFleetInput struct

+ ClusterId *string

+ InstanceFleet *InstanceFleetConfig

+ func (s *AddInstanceFleetInput) SetClusterId(v string) *AddInstanceFleetInput

+ func (s *AddInstanceFleetInput) SetInstanceFleet(v *InstanceFleetConfig) *AddInstanceFleetInput

+ func (s *AddInstanceFleetInput) Validate() error

+ func (s AddInstanceFleetInput) GoString() string

+ func (s AddInstanceFleetInput) String() string

+ type AddInstanceFleetOutput struct

+ ClusterId *string

+ InstanceFleetId *string

+ func (s *AddInstanceFleetOutput) SetClusterId(v string) *AddInstanceFleetOutput

+ func (s *AddInstanceFleetOutput) SetInstanceFleetId(v string) *AddInstanceFleetOutput

+ func (s AddInstanceFleetOutput) GoString() string

+ func (s AddInstanceFleetOutput) String() string

type Cluster

+ InstanceCollectionType *string

+ func (s *Cluster) SetInstanceCollectionType(v string) *Cluster

type EMR

+ func (c *EMR) AddInstanceFleet(input *AddInstanceFleetInput) (*AddInstanceFleetOutput, error)

+ func (c *EMR) AddInstanceFleetRequest(input *AddInstanceFleetInput) (req *request.Request, output *AddInstanceFleetOutput)

+ func (c *EMR) ListInstanceFleets(input *ListInstanceFleetsInput) (*ListInstanceFleetsOutput, error)

+ func (c *EMR) ListInstanceFleetsPages(input *ListInstanceFleetsInput, ...) error

+ func (c *EMR) ListInstanceFleetsRequest(input *ListInstanceFleetsInput) (req *request.Request, output *ListInstanceFleetsOutput)

+ func (c *EMR) ModifyInstanceFleet(input *ModifyInstanceFleetInput) (*ModifyInstanceFleetOutput, error)

+ func (c *EMR) ModifyInstanceFleetRequest(input *ModifyInstanceFleetInput) (req *request.Request, output *ModifyInstanceFleetOutput)

+ func (c *EMR) WaitUntilClusterTerminated(input *DescribeClusterInput) error

type Ec2InstanceAttributes

+ RequestedEc2AvailabilityZones []*string

+ RequestedEc2SubnetIds []*string

+ func (s *Ec2InstanceAttributes) SetRequestedEc2AvailabilityZones(v []*string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetRequestedEc2SubnetIds(v []*string) *Ec2InstanceAttributes

type Instance

+ InstanceFleetId *string

+ InstanceType *string

+ Market *string

+ func (s *Instance) SetInstanceFleetId(v string) *Instance

+ func (s *Instance) SetInstanceType(v string) *Instance

+ func (s *Instance) SetMarket(v string) *Instance

+ type InstanceFleet struct

+ Id *string

+ InstanceFleetType *string

+ InstanceTypeSpecifications []*InstanceTypeSpecification

+ LaunchSpecifications *InstanceFleetProvisioningSpecifications

+ Name *string

+ ProvisionedOnDemandCapacity *int64

+ ProvisionedSpotCapacity *int64

+ Status *InstanceFleetStatus

+ TargetOnDemandCapacity *int64

+ TargetSpotCapacity *int64

+ func (s *InstanceFleet) SetId(v string) *InstanceFleet

+ func (s *InstanceFleet) SetInstanceFleetType(v string) *InstanceFleet

+ func (s *InstanceFleet) SetInstanceTypeSpecifications(v []*InstanceTypeSpecification) *InstanceFleet

+ func (s *InstanceFleet) SetLaunchSpecifications(v *InstanceFleetProvisioningSpecifications) *InstanceFleet

+ func (s *InstanceFleet) SetName(v string) *InstanceFleet

+ func (s *InstanceFleet) SetProvisionedOnDemandCapacity(v int64) *InstanceFleet

+ func (s *InstanceFleet) SetProvisionedSpotCapacity(v int64) *InstanceFleet

+ func (s *InstanceFleet) SetStatus(v *InstanceFleetStatus) *InstanceFleet

+ func (s *InstanceFleet) SetTargetOnDemandCapacity(v int64) *InstanceFleet

+ func (s *InstanceFleet) SetTargetSpotCapacity(v int64) *InstanceFleet

+ func (s InstanceFleet) GoString() string

+ func (s InstanceFleet) String() string

+ type InstanceFleetConfig struct

+ InstanceFleetType *string

+ InstanceTypeConfigs []*InstanceTypeConfig

+ LaunchSpecifications *InstanceFleetProvisioningSpecifications

+ Name *string

+ TargetOnDemandCapacity *int64

+ TargetSpotCapacity *int64

+ func (s *InstanceFleetConfig) SetInstanceFleetType(v string) *InstanceFleetConfig

+ func (s *InstanceFleetConfig) SetInstanceTypeConfigs(v []*InstanceTypeConfig) *InstanceFleetConfig

+ func (s *InstanceFleetConfig) SetLaunchSpecifications(v *InstanceFleetProvisioningSpecifications) *InstanceFleetConfig

+ func (s *InstanceFleetConfig) SetName(v string) *InstanceFleetConfig

+ func (s *InstanceFleetConfig) SetTargetOnDemandCapacity(v int64) *InstanceFleetConfig

+ func (s *InstanceFleetConfig) SetTargetSpotCapacity(v int64) *InstanceFleetConfig

+ func (s *InstanceFleetConfig) Validate() error

+ func (s InstanceFleetConfig) GoString() string

+ func (s InstanceFleetConfig) String() string

+ type InstanceFleetModifyConfig struct

+ InstanceFleetId *string

+ TargetOnDemandCapacity *int64

+ TargetSpotCapacity *int64

+ func (s *InstanceFleetModifyConfig) SetInstanceFleetId(v string) *InstanceFleetModifyConfig

+ func (s *InstanceFleetModifyConfig) SetTargetOnDemandCapacity(v int64) *InstanceFleetModifyConfig

+ func (s *InstanceFleetModifyConfig) SetTargetSpotCapacity(v int64) *InstanceFleetModifyConfig

+ func (s *InstanceFleetModifyConfig) Validate() error

+ func (s InstanceFleetModifyConfig) GoString() string

+ func (s InstanceFleetModifyConfig) String() string

+ type InstanceFleetProvisioningSpecifications struct

+ SpotSpecification *SpotProvisioningSpecification

+ func (s *InstanceFleetProvisioningSpecifications) SetSpotSpecification(v *SpotProvisioningSpecification) *InstanceFleetProvisioningSpecifications

+ func (s *InstanceFleetProvisioningSpecifications) Validate() error

+ func (s InstanceFleetProvisioningSpecifications) GoString() string

+ func (s InstanceFleetProvisioningSpecifications) String() string

+ type InstanceFleetStateChangeReason struct

+ Code *string

+ Message *string

+ func (s *InstanceFleetStateChangeReason) SetCode(v string) *InstanceFleetStateChangeReason

+ func (s *InstanceFleetStateChangeReason) SetMessage(v string) *InstanceFleetStateChangeReason

+ func (s InstanceFleetStateChangeReason) GoString() string

+ func (s InstanceFleetStateChangeReason) String() string

+ type InstanceFleetStatus struct

+ State *string

+ StateChangeReason *InstanceFleetStateChangeReason

+ Timeline *InstanceFleetTimeline

+ func (s *InstanceFleetStatus) SetState(v string) *InstanceFleetStatus

+ func (s *InstanceFleetStatus) SetStateChangeReason(v *InstanceFleetStateChangeReason) *InstanceFleetStatus

+ func (s *InstanceFleetStatus) SetTimeline(v *InstanceFleetTimeline) *InstanceFleetStatus

+ func (s InstanceFleetStatus) GoString() string

+ func (s InstanceFleetStatus) String() string

+ type InstanceFleetTimeline struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ ReadyDateTime *time.Time

+ func (s *InstanceFleetTimeline) SetCreationDateTime(v time.Time) *InstanceFleetTimeline

+ func (s *InstanceFleetTimeline) SetEndDateTime(v time.Time) *InstanceFleetTimeline

+ func (s *InstanceFleetTimeline) SetReadyDateTime(v time.Time) *InstanceFleetTimeline

+ func (s InstanceFleetTimeline) GoString() string

+ func (s InstanceFleetTimeline) String() string

+ type InstanceTypeConfig struct

+ BidPrice *string

+ BidPriceAsPercentageOfOnDemandPrice *float64

+ Configurations []*Configuration

+ EbsConfiguration *EbsConfiguration

+ InstanceType *string

+ WeightedCapacity *int64

+ func (s *InstanceTypeConfig) SetBidPrice(v string) *InstanceTypeConfig

+ func (s *InstanceTypeConfig) SetBidPriceAsPercentageOfOnDemandPrice(v float64) *InstanceTypeConfig

+ func (s *InstanceTypeConfig) SetConfigurations(v []*Configuration) *InstanceTypeConfig

+ func (s *InstanceTypeConfig) SetEbsConfiguration(v *EbsConfiguration) *InstanceTypeConfig

+ func (s *InstanceTypeConfig) SetInstanceType(v string) *InstanceTypeConfig

+ func (s *InstanceTypeConfig) SetWeightedCapacity(v int64) *InstanceTypeConfig

+ func (s *InstanceTypeConfig) Validate() error

+ func (s InstanceTypeConfig) GoString() string

+ func (s InstanceTypeConfig) String() string

+ type InstanceTypeSpecification struct

+ BidPrice *string

+ BidPriceAsPercentageOfOnDemandPrice *float64

+ Configurations []*Configuration

+ EbsBlockDevices []*EbsBlockDevice

+ EbsOptimized *bool

+ InstanceType *string

+ WeightedCapacity *int64

+ func (s *InstanceTypeSpecification) SetBidPrice(v string) *InstanceTypeSpecification

+ func (s *InstanceTypeSpecification) SetBidPriceAsPercentageOfOnDemandPrice(v float64) *InstanceTypeSpecification

+ func (s *InstanceTypeSpecification) SetConfigurations(v []*Configuration) *InstanceTypeSpecification

+ func (s *InstanceTypeSpecification) SetEbsBlockDevices(v []*EbsBlockDevice) *InstanceTypeSpecification

+ func (s *InstanceTypeSpecification) SetEbsOptimized(v bool) *InstanceTypeSpecification

+ func (s *InstanceTypeSpecification) SetInstanceType(v string) *InstanceTypeSpecification

+ func (s *InstanceTypeSpecification) SetWeightedCapacity(v int64) *InstanceTypeSpecification

+ func (s InstanceTypeSpecification) GoString() string

+ func (s InstanceTypeSpecification) String() string

type JobFlowInstancesConfig

+ Ec2SubnetIds []*string

+ InstanceFleets []*InstanceFleetConfig

+ func (s *JobFlowInstancesConfig) SetEc2SubnetIds(v []*string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetInstanceFleets(v []*InstanceFleetConfig) *JobFlowInstancesConfig

+ type ListInstanceFleetsInput struct

+ ClusterId *string

+ Marker *string

+ func (s *ListInstanceFleetsInput) SetClusterId(v string) *ListInstanceFleetsInput

+ func (s *ListInstanceFleetsInput) SetMarker(v string) *ListInstanceFleetsInput

+ func (s *ListInstanceFleetsInput) Validate() error

+ func (s ListInstanceFleetsInput) GoString() string

+ func (s ListInstanceFleetsInput) String() string

+ type ListInstanceFleetsOutput struct

+ InstanceFleets []*InstanceFleet

+ Marker *string

+ func (s *ListInstanceFleetsOutput) SetInstanceFleets(v []*InstanceFleet) *ListInstanceFleetsOutput

+ func (s *ListInstanceFleetsOutput) SetMarker(v string) *ListInstanceFleetsOutput

+ func (s ListInstanceFleetsOutput) GoString() string

+ func (s ListInstanceFleetsOutput) String() string

type ListInstancesInput

+ InstanceFleetId *string

+ InstanceFleetType *string

+ func (s *ListInstancesInput) SetInstanceFleetId(v string) *ListInstancesInput

+ func (s *ListInstancesInput) SetInstanceFleetType(v string) *ListInstancesInput

+ type ModifyInstanceFleetInput struct

+ ClusterId *string

+ InstanceFleet *InstanceFleetModifyConfig

+ func (s *ModifyInstanceFleetInput) SetClusterId(v string) *ModifyInstanceFleetInput

+ func (s *ModifyInstanceFleetInput) SetInstanceFleet(v *InstanceFleetModifyConfig) *ModifyInstanceFleetInput

+ func (s *ModifyInstanceFleetInput) Validate() error

+ func (s ModifyInstanceFleetInput) GoString() string

+ func (s ModifyInstanceFleetInput) String() string

+ type ModifyInstanceFleetOutput struct

+ func (s ModifyInstanceFleetOutput) GoString() string

+ func (s ModifyInstanceFleetOutput) String() string

type PlacementType

+ AvailabilityZones []*string

+ func (s *PlacementType) SetAvailabilityZones(v []*string) *PlacementType

+ type SpotProvisioningSpecification struct

+ BlockDurationMinutes *int64

+ TimeoutAction *string

+ TimeoutDurationMinutes *int64

+ func (s *SpotProvisioningSpecification) SetBlockDurationMinutes(v int64) *SpotProvisioningSpecification

+ func (s *SpotProvisioningSpecification) SetTimeoutAction(v string) *SpotProvisioningSpecification

+ func (s *SpotProvisioningSpecification) SetTimeoutDurationMinutes(v int64) *SpotProvisioningSpecification

+ func (s *SpotProvisioningSpecification) Validate() error

+ func (s SpotProvisioningSpecification) GoString() string

+ func (s SpotProvisioningSpecification) String() string

Feb 10, 2017

Changes in this version

+ const ErrCodeInternalServerError

+ const ErrCodeInternalServerException

+ const ErrCodeInvalidRequestException

Dec 19, 2016

Changes in this version

+ const EndpointsID

Nov 18, 2016

Changes in this version

+ const AdjustmentTypeChangeInCapacity

+ const AdjustmentTypeExactCapacity

+ const AdjustmentTypePercentChangeInCapacity

+ const AutoScalingPolicyStateAttached

+ const AutoScalingPolicyStateAttaching

+ const AutoScalingPolicyStateChangeReasonCodeCleanupFailure

+ const AutoScalingPolicyStateChangeReasonCodeProvisionFailure

+ const AutoScalingPolicyStateChangeReasonCodeUserRequest

+ const AutoScalingPolicyStateDetached

+ const AutoScalingPolicyStateDetaching

+ const AutoScalingPolicyStateFailed

+ const AutoScalingPolicyStatePending

+ const CancelStepsRequestStatusFailed

+ const CancelStepsRequestStatusSubmitted

+ const ComparisonOperatorGreaterThan

+ const ComparisonOperatorGreaterThanOrEqual

+ const ComparisonOperatorLessThan

+ const ComparisonOperatorLessThanOrEqual

+ const ScaleDownBehaviorTerminateAtInstanceHour

+ const ScaleDownBehaviorTerminateAtTaskCompletion

+ const StatisticAverage

+ const StatisticMaximum

+ const StatisticMinimum

+ const StatisticSampleCount

+ const StatisticSum

+ const StepStateCancelPending

+ const UnitBits

+ const UnitBitsPerSecond

+ const UnitBytes

+ const UnitBytesPerSecond

+ const UnitCount

+ const UnitCountPerSecond

+ const UnitGigaBits

+ const UnitGigaBitsPerSecond

+ const UnitGigaBytes

+ const UnitGigaBytesPerSecond

+ const UnitKiloBits

+ const UnitKiloBitsPerSecond

+ const UnitKiloBytes

+ const UnitKiloBytesPerSecond

+ const UnitMegaBits

+ const UnitMegaBitsPerSecond

+ const UnitMegaBytes

+ const UnitMegaBytesPerSecond

+ const UnitMicroSeconds

+ const UnitMilliSeconds

+ const UnitNone

+ const UnitPercent

+ const UnitSeconds

+ const UnitTeraBits

+ const UnitTeraBitsPerSecond

+ const UnitTeraBytes

+ const UnitTeraBytesPerSecond

+ type AutoScalingPolicy struct

+ Constraints *ScalingConstraints

+ Rules []*ScalingRule

+ func (s *AutoScalingPolicy) SetConstraints(v *ScalingConstraints) *AutoScalingPolicy

+ func (s *AutoScalingPolicy) SetRules(v []*ScalingRule) *AutoScalingPolicy

+ func (s *AutoScalingPolicy) Validate() error

+ func (s AutoScalingPolicy) GoString() string

+ func (s AutoScalingPolicy) String() string

+ type AutoScalingPolicyDescription struct

+ Constraints *ScalingConstraints

+ Rules []*ScalingRule

+ Status *AutoScalingPolicyStatus

+ func (s *AutoScalingPolicyDescription) SetConstraints(v *ScalingConstraints) *AutoScalingPolicyDescription

+ func (s *AutoScalingPolicyDescription) SetRules(v []*ScalingRule) *AutoScalingPolicyDescription

+ func (s *AutoScalingPolicyDescription) SetStatus(v *AutoScalingPolicyStatus) *AutoScalingPolicyDescription

+ func (s AutoScalingPolicyDescription) GoString() string

+ func (s AutoScalingPolicyDescription) String() string

+ type AutoScalingPolicyStateChangeReason struct

+ Code *string

+ Message *string

+ func (s *AutoScalingPolicyStateChangeReason) SetCode(v string) *AutoScalingPolicyStateChangeReason

+ func (s *AutoScalingPolicyStateChangeReason) SetMessage(v string) *AutoScalingPolicyStateChangeReason

+ func (s AutoScalingPolicyStateChangeReason) GoString() string

+ func (s AutoScalingPolicyStateChangeReason) String() string

+ type AutoScalingPolicyStatus struct

+ State *string

+ StateChangeReason *AutoScalingPolicyStateChangeReason

+ func (s *AutoScalingPolicyStatus) SetState(v string) *AutoScalingPolicyStatus

+ func (s *AutoScalingPolicyStatus) SetStateChangeReason(v *AutoScalingPolicyStateChangeReason) *AutoScalingPolicyStatus

+ func (s AutoScalingPolicyStatus) GoString() string

+ func (s AutoScalingPolicyStatus) String() string

+ type CancelStepsInfo struct

+ Reason *string

+ Status *string

+ StepId *string

+ func (s *CancelStepsInfo) SetReason(v string) *CancelStepsInfo

+ func (s *CancelStepsInfo) SetStatus(v string) *CancelStepsInfo

+ func (s *CancelStepsInfo) SetStepId(v string) *CancelStepsInfo

+ func (s CancelStepsInfo) GoString() string

+ func (s CancelStepsInfo) String() string

+ type CancelStepsInput struct

+ ClusterId *string

+ StepIds []*string

+ func (s *CancelStepsInput) SetClusterId(v string) *CancelStepsInput

+ func (s *CancelStepsInput) SetStepIds(v []*string) *CancelStepsInput

+ func (s CancelStepsInput) GoString() string

+ func (s CancelStepsInput) String() string

+ type CancelStepsOutput struct

+ CancelStepsInfoList []*CancelStepsInfo

+ func (s *CancelStepsOutput) SetCancelStepsInfoList(v []*CancelStepsInfo) *CancelStepsOutput

+ func (s CancelStepsOutput) GoString() string

+ func (s CancelStepsOutput) String() string

+ type CloudWatchAlarmDefinition struct

+ ComparisonOperator *string

+ Dimensions []*MetricDimension

+ EvaluationPeriods *int64

+ MetricName *string

+ Namespace *string

+ Period *int64

+ Statistic *string

+ Threshold *float64

+ Unit *string

+ func (s *CloudWatchAlarmDefinition) SetComparisonOperator(v string) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetDimensions(v []*MetricDimension) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetEvaluationPeriods(v int64) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetMetricName(v string) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetNamespace(v string) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetPeriod(v int64) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetStatistic(v string) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetThreshold(v float64) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) SetUnit(v string) *CloudWatchAlarmDefinition

+ func (s *CloudWatchAlarmDefinition) Validate() error

+ func (s CloudWatchAlarmDefinition) GoString() string

+ func (s CloudWatchAlarmDefinition) String() string

type Cluster

+ AutoScalingRole *string

+ ScaleDownBehavior *string

+ func (s *Cluster) SetAutoScalingRole(v string) *Cluster

+ func (s *Cluster) SetScaleDownBehavior(v string) *Cluster

type EMR

+ func (c *EMR) CancelSteps(input *CancelStepsInput) (*CancelStepsOutput, error)

+ func (c *EMR) CancelStepsRequest(input *CancelStepsInput) (req *request.Request, output *CancelStepsOutput)

+ func (c *EMR) PutAutoScalingPolicy(input *PutAutoScalingPolicyInput) (*PutAutoScalingPolicyOutput, error)

+ func (c *EMR) PutAutoScalingPolicyRequest(input *PutAutoScalingPolicyInput) (req *request.Request, output *PutAutoScalingPolicyOutput)

+ func (c *EMR) RemoveAutoScalingPolicy(input *RemoveAutoScalingPolicyInput) (*RemoveAutoScalingPolicyOutput, error)

+ func (c *EMR) RemoveAutoScalingPolicyRequest(input *RemoveAutoScalingPolicyInput) (req *request.Request, output *RemoveAutoScalingPolicyOutput)

type InstanceGroup

+ AutoScalingPolicy *AutoScalingPolicyDescription

+ func (s *InstanceGroup) SetAutoScalingPolicy(v *AutoScalingPolicyDescription) *InstanceGroup

type InstanceGroupConfig

+ AutoScalingPolicy *AutoScalingPolicy

+ func (s *InstanceGroupConfig) SetAutoScalingPolicy(v *AutoScalingPolicy) *InstanceGroupConfig

type JobFlowDetail

+ AutoScalingRole *string

+ ScaleDownBehavior *string

+ func (s *JobFlowDetail) SetAutoScalingRole(v string) *JobFlowDetail

+ func (s *JobFlowDetail) SetScaleDownBehavior(v string) *JobFlowDetail

+ type MetricDimension struct

+ Key *string

+ Value *string

+ func (s *MetricDimension) SetKey(v string) *MetricDimension

+ func (s *MetricDimension) SetValue(v string) *MetricDimension

+ func (s MetricDimension) GoString() string

+ func (s MetricDimension) String() string

type ModifyInstanceGroupsInput

+ ClusterId *string

+ func (s *ModifyInstanceGroupsInput) SetClusterId(v string) *ModifyInstanceGroupsInput

+ type PutAutoScalingPolicyInput struct

+ AutoScalingPolicy *AutoScalingPolicy

+ ClusterId *string

+ InstanceGroupId *string

+ func (s *PutAutoScalingPolicyInput) SetAutoScalingPolicy(v *AutoScalingPolicy) *PutAutoScalingPolicyInput

+ func (s *PutAutoScalingPolicyInput) SetClusterId(v string) *PutAutoScalingPolicyInput

+ func (s *PutAutoScalingPolicyInput) SetInstanceGroupId(v string) *PutAutoScalingPolicyInput

+ func (s *PutAutoScalingPolicyInput) Validate() error

+ func (s PutAutoScalingPolicyInput) GoString() string

+ func (s PutAutoScalingPolicyInput) String() string

+ type PutAutoScalingPolicyOutput struct

+ AutoScalingPolicy *AutoScalingPolicyDescription

+ ClusterId *string

+ InstanceGroupId *string

+ func (s *PutAutoScalingPolicyOutput) SetAutoScalingPolicy(v *AutoScalingPolicyDescription) *PutAutoScalingPolicyOutput

+ func (s *PutAutoScalingPolicyOutput) SetClusterId(v string) *PutAutoScalingPolicyOutput

+ func (s *PutAutoScalingPolicyOutput) SetInstanceGroupId(v string) *PutAutoScalingPolicyOutput

+ func (s PutAutoScalingPolicyOutput) GoString() string

+ func (s PutAutoScalingPolicyOutput) String() string

+ type RemoveAutoScalingPolicyInput struct

+ ClusterId *string

+ InstanceGroupId *string

+ func (s *RemoveAutoScalingPolicyInput) SetClusterId(v string) *RemoveAutoScalingPolicyInput

+ func (s *RemoveAutoScalingPolicyInput) SetInstanceGroupId(v string) *RemoveAutoScalingPolicyInput

+ func (s *RemoveAutoScalingPolicyInput) Validate() error

+ func (s RemoveAutoScalingPolicyInput) GoString() string

+ func (s RemoveAutoScalingPolicyInput) String() string

+ type RemoveAutoScalingPolicyOutput struct

+ func (s RemoveAutoScalingPolicyOutput) GoString() string

+ func (s RemoveAutoScalingPolicyOutput) String() string

type RunJobFlowInput

+ AutoScalingRole *string

+ ScaleDownBehavior *string

+ func (s *RunJobFlowInput) SetAutoScalingRole(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetScaleDownBehavior(v string) *RunJobFlowInput

+ type ScalingAction struct

+ Market *string

+ SimpleScalingPolicyConfiguration *SimpleScalingPolicyConfiguration

+ func (s *ScalingAction) SetMarket(v string) *ScalingAction

+ func (s *ScalingAction) SetSimpleScalingPolicyConfiguration(v *SimpleScalingPolicyConfiguration) *ScalingAction

+ func (s *ScalingAction) Validate() error

+ func (s ScalingAction) GoString() string

+ func (s ScalingAction) String() string

+ type ScalingConstraints struct

+ MaxCapacity *int64

+ MinCapacity *int64

+ func (s *ScalingConstraints) SetMaxCapacity(v int64) *ScalingConstraints

+ func (s *ScalingConstraints) SetMinCapacity(v int64) *ScalingConstraints

+ func (s *ScalingConstraints) Validate() error

+ func (s ScalingConstraints) GoString() string

+ func (s ScalingConstraints) String() string

+ type ScalingRule struct

+ Action *ScalingAction

+ Description *string

+ Name *string

+ Trigger *ScalingTrigger

+ func (s *ScalingRule) SetAction(v *ScalingAction) *ScalingRule

+ func (s *ScalingRule) SetDescription(v string) *ScalingRule

+ func (s *ScalingRule) SetName(v string) *ScalingRule

+ func (s *ScalingRule) SetTrigger(v *ScalingTrigger) *ScalingRule

+ func (s *ScalingRule) Validate() error

+ func (s ScalingRule) GoString() string

+ func (s ScalingRule) String() string

+ type ScalingTrigger struct

+ CloudWatchAlarmDefinition *CloudWatchAlarmDefinition

+ func (s *ScalingTrigger) SetCloudWatchAlarmDefinition(v *CloudWatchAlarmDefinition) *ScalingTrigger

+ func (s *ScalingTrigger) Validate() error

+ func (s ScalingTrigger) GoString() string

+ func (s ScalingTrigger) String() string

+ type SimpleScalingPolicyConfiguration struct

+ AdjustmentType *string

+ CoolDown *int64

+ ScalingAdjustment *int64

+ func (s *SimpleScalingPolicyConfiguration) SetAdjustmentType(v string) *SimpleScalingPolicyConfiguration

+ func (s *SimpleScalingPolicyConfiguration) SetCoolDown(v int64) *SimpleScalingPolicyConfiguration

+ func (s *SimpleScalingPolicyConfiguration) SetScalingAdjustment(v int64) *SimpleScalingPolicyConfiguration

+ func (s *SimpleScalingPolicyConfiguration) Validate() error

+ func (s SimpleScalingPolicyConfiguration) GoString() string

+ func (s SimpleScalingPolicyConfiguration) String() string

Nov 2, 2016

Changes in this version

type AddInstanceGroupsInput

+ func (s *AddInstanceGroupsInput) SetInstanceGroups(v []*InstanceGroupConfig) *AddInstanceGroupsInput

+ func (s *AddInstanceGroupsInput) SetJobFlowId(v string) *AddInstanceGroupsInput

type AddInstanceGroupsOutput

+ func (s *AddInstanceGroupsOutput) SetInstanceGroupIds(v []*string) *AddInstanceGroupsOutput

+ func (s *AddInstanceGroupsOutput) SetJobFlowId(v string) *AddInstanceGroupsOutput

type AddJobFlowStepsInput

+ func (s *AddJobFlowStepsInput) SetJobFlowId(v string) *AddJobFlowStepsInput

+ func (s *AddJobFlowStepsInput) SetSteps(v []*StepConfig) *AddJobFlowStepsInput

type AddJobFlowStepsOutput

+ func (s *AddJobFlowStepsOutput) SetStepIds(v []*string) *AddJobFlowStepsOutput

type AddTagsInput

+ func (s *AddTagsInput) SetResourceId(v string) *AddTagsInput

+ func (s *AddTagsInput) SetTags(v []*Tag) *AddTagsInput

type Application

+ func (s *Application) SetAdditionalInfo(v map[string]*string) *Application

+ func (s *Application) SetArgs(v []*string) *Application

+ func (s *Application) SetName(v string) *Application

+ func (s *Application) SetVersion(v string) *Application

type BootstrapActionConfig

+ func (s *BootstrapActionConfig) SetName(v string) *BootstrapActionConfig

+ func (s *BootstrapActionConfig) SetScriptBootstrapAction(v *ScriptBootstrapActionConfig) *BootstrapActionConfig

type BootstrapActionDetail

+ func (s *BootstrapActionDetail) SetBootstrapActionConfig(v *BootstrapActionConfig) *BootstrapActionDetail

type Cluster

+ SecurityConfiguration *string

+ func (s *Cluster) SetApplications(v []*Application) *Cluster

+ func (s *Cluster) SetAutoTerminate(v bool) *Cluster

+ func (s *Cluster) SetConfigurations(v []*Configuration) *Cluster

+ func (s *Cluster) SetEc2InstanceAttributes(v *Ec2InstanceAttributes) *Cluster

+ func (s *Cluster) SetId(v string) *Cluster

+ func (s *Cluster) SetLogUri(v string) *Cluster

+ func (s *Cluster) SetMasterPublicDnsName(v string) *Cluster

+ func (s *Cluster) SetName(v string) *Cluster

+ func (s *Cluster) SetNormalizedInstanceHours(v int64) *Cluster

+ func (s *Cluster) SetReleaseLabel(v string) *Cluster

+ func (s *Cluster) SetRequestedAmiVersion(v string) *Cluster

+ func (s *Cluster) SetRunningAmiVersion(v string) *Cluster

+ func (s *Cluster) SetSecurityConfiguration(v string) *Cluster

+ func (s *Cluster) SetServiceRole(v string) *Cluster

+ func (s *Cluster) SetStatus(v *ClusterStatus) *Cluster

+ func (s *Cluster) SetTags(v []*Tag) *Cluster

+ func (s *Cluster) SetTerminationProtected(v bool) *Cluster

+ func (s *Cluster) SetVisibleToAllUsers(v bool) *Cluster

type ClusterStateChangeReason

+ func (s *ClusterStateChangeReason) SetCode(v string) *ClusterStateChangeReason

+ func (s *ClusterStateChangeReason) SetMessage(v string) *ClusterStateChangeReason

type ClusterStatus

+ func (s *ClusterStatus) SetState(v string) *ClusterStatus

+ func (s *ClusterStatus) SetStateChangeReason(v *ClusterStateChangeReason) *ClusterStatus

+ func (s *ClusterStatus) SetTimeline(v *ClusterTimeline) *ClusterStatus

type ClusterSummary

+ func (s *ClusterSummary) SetId(v string) *ClusterSummary

+ func (s *ClusterSummary) SetName(v string) *ClusterSummary

+ func (s *ClusterSummary) SetNormalizedInstanceHours(v int64) *ClusterSummary

+ func (s *ClusterSummary) SetStatus(v *ClusterStatus) *ClusterSummary

type ClusterTimeline

+ func (s *ClusterTimeline) SetCreationDateTime(v time.Time) *ClusterTimeline

+ func (s *ClusterTimeline) SetEndDateTime(v time.Time) *ClusterTimeline

+ func (s *ClusterTimeline) SetReadyDateTime(v time.Time) *ClusterTimeline

type Command

+ func (s *Command) SetArgs(v []*string) *Command

+ func (s *Command) SetName(v string) *Command

+ func (s *Command) SetScriptPath(v string) *Command

type Configuration

+ func (s *Configuration) SetClassification(v string) *Configuration

+ func (s *Configuration) SetConfigurations(v []*Configuration) *Configuration

+ func (s *Configuration) SetProperties(v map[string]*string) *Configuration

+ type CreateSecurityConfigurationInput struct

+ Name *string

+ SecurityConfiguration *string

+ func (s *CreateSecurityConfigurationInput) SetName(v string) *CreateSecurityConfigurationInput

+ func (s *CreateSecurityConfigurationInput) SetSecurityConfiguration(v string) *CreateSecurityConfigurationInput

+ func (s *CreateSecurityConfigurationInput) Validate() error

+ func (s CreateSecurityConfigurationInput) GoString() string

+ func (s CreateSecurityConfigurationInput) String() string

+ type CreateSecurityConfigurationOutput struct

+ CreationDateTime *time.Time

+ Name *string

+ func (s *CreateSecurityConfigurationOutput) SetCreationDateTime(v time.Time) *CreateSecurityConfigurationOutput

+ func (s *CreateSecurityConfigurationOutput) SetName(v string) *CreateSecurityConfigurationOutput

+ func (s CreateSecurityConfigurationOutput) GoString() string

+ func (s CreateSecurityConfigurationOutput) String() string

+ type DeleteSecurityConfigurationInput struct

+ Name *string

+ func (s *DeleteSecurityConfigurationInput) SetName(v string) *DeleteSecurityConfigurationInput

+ func (s *DeleteSecurityConfigurationInput) Validate() error

+ func (s DeleteSecurityConfigurationInput) GoString() string

+ func (s DeleteSecurityConfigurationInput) String() string

+ type DeleteSecurityConfigurationOutput struct

+ func (s DeleteSecurityConfigurationOutput) GoString() string

+ func (s DeleteSecurityConfigurationOutput) String() string

type DescribeClusterInput

+ func (s *DescribeClusterInput) SetClusterId(v string) *DescribeClusterInput

type DescribeClusterOutput

+ func (s *DescribeClusterOutput) SetCluster(v *Cluster) *DescribeClusterOutput

type DescribeJobFlowsInput

+ func (s *DescribeJobFlowsInput) SetCreatedAfter(v time.Time) *DescribeJobFlowsInput

+ func (s *DescribeJobFlowsInput) SetCreatedBefore(v time.Time) *DescribeJobFlowsInput

+ func (s *DescribeJobFlowsInput) SetJobFlowIds(v []*string) *DescribeJobFlowsInput

+ func (s *DescribeJobFlowsInput) SetJobFlowStates(v []*string) *DescribeJobFlowsInput

type DescribeJobFlowsOutput

+ func (s *DescribeJobFlowsOutput) SetJobFlows(v []*JobFlowDetail) *DescribeJobFlowsOutput

+ type DescribeSecurityConfigurationInput struct

+ Name *string

+ func (s *DescribeSecurityConfigurationInput) SetName(v string) *DescribeSecurityConfigurationInput

+ func (s *DescribeSecurityConfigurationInput) Validate() error

+ func (s DescribeSecurityConfigurationInput) GoString() string

+ func (s DescribeSecurityConfigurationInput) String() string

+ type DescribeSecurityConfigurationOutput struct

+ CreationDateTime *time.Time

+ Name *string

+ SecurityConfiguration *string

+ func (s *DescribeSecurityConfigurationOutput) SetCreationDateTime(v time.Time) *DescribeSecurityConfigurationOutput

+ func (s *DescribeSecurityConfigurationOutput) SetName(v string) *DescribeSecurityConfigurationOutput

+ func (s *DescribeSecurityConfigurationOutput) SetSecurityConfiguration(v string) *DescribeSecurityConfigurationOutput

+ func (s DescribeSecurityConfigurationOutput) GoString() string

+ func (s DescribeSecurityConfigurationOutput) String() string

type DescribeStepInput

+ func (s *DescribeStepInput) SetClusterId(v string) *DescribeStepInput

+ func (s *DescribeStepInput) SetStepId(v string) *DescribeStepInput

type DescribeStepOutput

+ func (s *DescribeStepOutput) SetStep(v *Step) *DescribeStepOutput

type EMR

+ func (c *EMR) CreateSecurityConfiguration(input *CreateSecurityConfigurationInput) (*CreateSecurityConfigurationOutput, error)

+ func (c *EMR) CreateSecurityConfigurationRequest(input *CreateSecurityConfigurationInput) (req *request.Request, output *CreateSecurityConfigurationOutput)

+ func (c *EMR) DeleteSecurityConfiguration(input *DeleteSecurityConfigurationInput) (*DeleteSecurityConfigurationOutput, error)

+ func (c *EMR) DeleteSecurityConfigurationRequest(input *DeleteSecurityConfigurationInput) (req *request.Request, output *DeleteSecurityConfigurationOutput)

+ func (c *EMR) DescribeSecurityConfiguration(input *DescribeSecurityConfigurationInput) (*DescribeSecurityConfigurationOutput, error)

+ func (c *EMR) DescribeSecurityConfigurationRequest(input *DescribeSecurityConfigurationInput) (req *request.Request, output *DescribeSecurityConfigurationOutput)

+ func (c *EMR) ListSecurityConfigurations(input *ListSecurityConfigurationsInput) (*ListSecurityConfigurationsOutput, error)

+ func (c *EMR) ListSecurityConfigurationsRequest(input *ListSecurityConfigurationsInput) (req *request.Request, output *ListSecurityConfigurationsOutput)

type EbsBlockDevice

+ func (s *EbsBlockDevice) SetDevice(v string) *EbsBlockDevice

+ func (s *EbsBlockDevice) SetVolumeSpecification(v *VolumeSpecification) *EbsBlockDevice

type EbsBlockDeviceConfig

+ func (s *EbsBlockDeviceConfig) SetVolumeSpecification(v *VolumeSpecification) *EbsBlockDeviceConfig

+ func (s *EbsBlockDeviceConfig) SetVolumesPerInstance(v int64) *EbsBlockDeviceConfig

type EbsConfiguration

+ func (s *EbsConfiguration) SetEbsBlockDeviceConfigs(v []*EbsBlockDeviceConfig) *EbsConfiguration

+ func (s *EbsConfiguration) SetEbsOptimized(v bool) *EbsConfiguration

type EbsVolume

+ func (s *EbsVolume) SetDevice(v string) *EbsVolume

+ func (s *EbsVolume) SetVolumeId(v string) *EbsVolume

type Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetAdditionalMasterSecurityGroups(v []*string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetAdditionalSlaveSecurityGroups(v []*string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetEc2AvailabilityZone(v string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetEc2KeyName(v string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetEc2SubnetId(v string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetEmrManagedMasterSecurityGroup(v string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetEmrManagedSlaveSecurityGroup(v string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetIamInstanceProfile(v string) *Ec2InstanceAttributes

+ func (s *Ec2InstanceAttributes) SetServiceAccessSecurityGroup(v string) *Ec2InstanceAttributes

type FailureDetails

+ func (s *FailureDetails) SetLogFile(v string) *FailureDetails

+ func (s *FailureDetails) SetMessage(v string) *FailureDetails

+ func (s *FailureDetails) SetReason(v string) *FailureDetails

type HadoopJarStepConfig

+ func (s *HadoopJarStepConfig) SetArgs(v []*string) *HadoopJarStepConfig

+ func (s *HadoopJarStepConfig) SetJar(v string) *HadoopJarStepConfig

+ func (s *HadoopJarStepConfig) SetMainClass(v string) *HadoopJarStepConfig

+ func (s *HadoopJarStepConfig) SetProperties(v []*KeyValue) *HadoopJarStepConfig

type HadoopStepConfig

+ func (s *HadoopStepConfig) SetArgs(v []*string) *HadoopStepConfig

+ func (s *HadoopStepConfig) SetJar(v string) *HadoopStepConfig

+ func (s *HadoopStepConfig) SetMainClass(v string) *HadoopStepConfig

+ func (s *HadoopStepConfig) SetProperties(v map[string]*string) *HadoopStepConfig

type Instance

+ func (s *Instance) SetEbsVolumes(v []*EbsVolume) *Instance

+ func (s *Instance) SetEc2InstanceId(v string) *Instance

+ func (s *Instance) SetId(v string) *Instance

+ func (s *Instance) SetInstanceGroupId(v string) *Instance

+ func (s *Instance) SetPrivateDnsName(v string) *Instance

+ func (s *Instance) SetPrivateIpAddress(v string) *Instance

+ func (s *Instance) SetPublicDnsName(v string) *Instance

+ func (s *Instance) SetPublicIpAddress(v string) *Instance

+ func (s *Instance) SetStatus(v *InstanceStatus) *Instance

type InstanceGroup

+ func (s *InstanceGroup) SetBidPrice(v string) *InstanceGroup

+ func (s *InstanceGroup) SetConfigurations(v []*Configuration) *InstanceGroup

+ func (s *InstanceGroup) SetEbsBlockDevices(v []*EbsBlockDevice) *InstanceGroup

+ func (s *InstanceGroup) SetEbsOptimized(v bool) *InstanceGroup

+ func (s *InstanceGroup) SetId(v string) *InstanceGroup

+ func (s *InstanceGroup) SetInstanceGroupType(v string) *InstanceGroup

+ func (s *InstanceGroup) SetInstanceType(v string) *InstanceGroup

+ func (s *InstanceGroup) SetMarket(v string) *InstanceGroup

+ func (s *InstanceGroup) SetName(v string) *InstanceGroup

+ func (s *InstanceGroup) SetRequestedInstanceCount(v int64) *InstanceGroup

+ func (s *InstanceGroup) SetRunningInstanceCount(v int64) *InstanceGroup

+ func (s *InstanceGroup) SetShrinkPolicy(v *ShrinkPolicy) *InstanceGroup

+ func (s *InstanceGroup) SetStatus(v *InstanceGroupStatus) *InstanceGroup

type InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetBidPrice(v string) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetConfigurations(v []*Configuration) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetEbsConfiguration(v *EbsConfiguration) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetInstanceCount(v int64) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetInstanceRole(v string) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetInstanceType(v string) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetMarket(v string) *InstanceGroupConfig

+ func (s *InstanceGroupConfig) SetName(v string) *InstanceGroupConfig

type InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetBidPrice(v string) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetCreationDateTime(v time.Time) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetEndDateTime(v time.Time) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetInstanceGroupId(v string) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetInstanceRequestCount(v int64) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetInstanceRole(v string) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetInstanceRunningCount(v int64) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetInstanceType(v string) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetLastStateChangeReason(v string) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetMarket(v string) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetName(v string) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetReadyDateTime(v time.Time) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetStartDateTime(v time.Time) *InstanceGroupDetail

+ func (s *InstanceGroupDetail) SetState(v string) *InstanceGroupDetail

type InstanceGroupModifyConfig

+ func (s *InstanceGroupModifyConfig) SetEC2InstanceIdsToTerminate(v []*string) *InstanceGroupModifyConfig

+ func (s *InstanceGroupModifyConfig) SetInstanceCount(v int64) *InstanceGroupModifyConfig

+ func (s *InstanceGroupModifyConfig) SetInstanceGroupId(v string) *InstanceGroupModifyConfig

+ func (s *InstanceGroupModifyConfig) SetShrinkPolicy(v *ShrinkPolicy) *InstanceGroupModifyConfig

type InstanceGroupStateChangeReason

+ func (s *InstanceGroupStateChangeReason) SetCode(v string) *InstanceGroupStateChangeReason

+ func (s *InstanceGroupStateChangeReason) SetMessage(v string) *InstanceGroupStateChangeReason

type InstanceGroupStatus

+ func (s *InstanceGroupStatus) SetState(v string) *InstanceGroupStatus

+ func (s *InstanceGroupStatus) SetStateChangeReason(v *InstanceGroupStateChangeReason) *InstanceGroupStatus

+ func (s *InstanceGroupStatus) SetTimeline(v *InstanceGroupTimeline) *InstanceGroupStatus

type InstanceGroupTimeline

+ func (s *InstanceGroupTimeline) SetCreationDateTime(v time.Time) *InstanceGroupTimeline

+ func (s *InstanceGroupTimeline) SetEndDateTime(v time.Time) *InstanceGroupTimeline

+ func (s *InstanceGroupTimeline) SetReadyDateTime(v time.Time) *InstanceGroupTimeline

type InstanceResizePolicy

+ func (s *InstanceResizePolicy) SetInstanceTerminationTimeout(v int64) *InstanceResizePolicy

+ func (s *InstanceResizePolicy) SetInstancesToProtect(v []*string) *InstanceResizePolicy

+ func (s *InstanceResizePolicy) SetInstancesToTerminate(v []*string) *InstanceResizePolicy

type InstanceStateChangeReason

+ func (s *InstanceStateChangeReason) SetCode(v string) *InstanceStateChangeReason

+ func (s *InstanceStateChangeReason) SetMessage(v string) *InstanceStateChangeReason

type InstanceStatus

+ func (s *InstanceStatus) SetState(v string) *InstanceStatus

+ func (s *InstanceStatus) SetStateChangeReason(v *InstanceStateChangeReason) *InstanceStatus

+ func (s *InstanceStatus) SetTimeline(v *InstanceTimeline) *InstanceStatus

type InstanceTimeline

+ func (s *InstanceTimeline) SetCreationDateTime(v time.Time) *InstanceTimeline

+ func (s *InstanceTimeline) SetEndDateTime(v time.Time) *InstanceTimeline

+ func (s *InstanceTimeline) SetReadyDateTime(v time.Time) *InstanceTimeline

type JobFlowDetail

+ func (s *JobFlowDetail) SetAmiVersion(v string) *JobFlowDetail

+ func (s *JobFlowDetail) SetBootstrapActions(v []*BootstrapActionDetail) *JobFlowDetail

+ func (s *JobFlowDetail) SetExecutionStatusDetail(v *JobFlowExecutionStatusDetail) *JobFlowDetail

+ func (s *JobFlowDetail) SetInstances(v *JobFlowInstancesDetail) *JobFlowDetail

+ func (s *JobFlowDetail) SetJobFlowId(v string) *JobFlowDetail

+ func (s *JobFlowDetail) SetJobFlowRole(v string) *JobFlowDetail

+ func (s *JobFlowDetail) SetLogUri(v string) *JobFlowDetail

+ func (s *JobFlowDetail) SetName(v string) *JobFlowDetail

+ func (s *JobFlowDetail) SetServiceRole(v string) *JobFlowDetail

+ func (s *JobFlowDetail) SetSteps(v []*StepDetail) *JobFlowDetail

+ func (s *JobFlowDetail) SetSupportedProducts(v []*string) *JobFlowDetail

+ func (s *JobFlowDetail) SetVisibleToAllUsers(v bool) *JobFlowDetail

type JobFlowExecutionStatusDetail

+ func (s *JobFlowExecutionStatusDetail) SetCreationDateTime(v time.Time) *JobFlowExecutionStatusDetail

+ func (s *JobFlowExecutionStatusDetail) SetEndDateTime(v time.Time) *JobFlowExecutionStatusDetail

+ func (s *JobFlowExecutionStatusDetail) SetLastStateChangeReason(v string) *JobFlowExecutionStatusDetail

+ func (s *JobFlowExecutionStatusDetail) SetReadyDateTime(v time.Time) *JobFlowExecutionStatusDetail

+ func (s *JobFlowExecutionStatusDetail) SetStartDateTime(v time.Time) *JobFlowExecutionStatusDetail

+ func (s *JobFlowExecutionStatusDetail) SetState(v string) *JobFlowExecutionStatusDetail

type JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetAdditionalMasterSecurityGroups(v []*string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetAdditionalSlaveSecurityGroups(v []*string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetEc2KeyName(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetEc2SubnetId(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetEmrManagedMasterSecurityGroup(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetEmrManagedSlaveSecurityGroup(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetHadoopVersion(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetInstanceCount(v int64) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetInstanceGroups(v []*InstanceGroupConfig) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetKeepJobFlowAliveWhenNoSteps(v bool) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetMasterInstanceType(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetPlacement(v *PlacementType) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetServiceAccessSecurityGroup(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetSlaveInstanceType(v string) *JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) SetTerminationProtected(v bool) *JobFlowInstancesConfig

type JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetEc2KeyName(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetEc2SubnetId(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetHadoopVersion(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetInstanceCount(v int64) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetInstanceGroups(v []*InstanceGroupDetail) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetKeepJobFlowAliveWhenNoSteps(v bool) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetMasterInstanceId(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetMasterInstanceType(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetMasterPublicDnsName(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetNormalizedInstanceHours(v int64) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetPlacement(v *PlacementType) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetSlaveInstanceType(v string) *JobFlowInstancesDetail

+ func (s *JobFlowInstancesDetail) SetTerminationProtected(v bool) *JobFlowInstancesDetail

type KeyValue

+ func (s *KeyValue) SetKey(v string) *KeyValue

+ func (s *KeyValue) SetValue(v string) *KeyValue

type ListBootstrapActionsInput

+ func (s *ListBootstrapActionsInput) SetClusterId(v string) *ListBootstrapActionsInput

+ func (s *ListBootstrapActionsInput) SetMarker(v string) *ListBootstrapActionsInput

type ListBootstrapActionsOutput

+ func (s *ListBootstrapActionsOutput) SetBootstrapActions(v []*Command) *ListBootstrapActionsOutput

+ func (s *ListBootstrapActionsOutput) SetMarker(v string) *ListBootstrapActionsOutput

type ListClustersInput

+ func (s *ListClustersInput) SetClusterStates(v []*string) *ListClustersInput

+ func (s *ListClustersInput) SetCreatedAfter(v time.Time) *ListClustersInput

+ func (s *ListClustersInput) SetCreatedBefore(v time.Time) *ListClustersInput

+ func (s *ListClustersInput) SetMarker(v string) *ListClustersInput

type ListClustersOutput

+ func (s *ListClustersOutput) SetClusters(v []*ClusterSummary) *ListClustersOutput

+ func (s *ListClustersOutput) SetMarker(v string) *ListClustersOutput

type ListInstanceGroupsInput

+ func (s *ListInstanceGroupsInput) SetClusterId(v string) *ListInstanceGroupsInput

+ func (s *ListInstanceGroupsInput) SetMarker(v string) *ListInstanceGroupsInput

type ListInstanceGroupsOutput

+ func (s *ListInstanceGroupsOutput) SetInstanceGroups(v []*InstanceGroup) *ListInstanceGroupsOutput

+ func (s *ListInstanceGroupsOutput) SetMarker(v string) *ListInstanceGroupsOutput

type ListInstancesInput

+ func (s *ListInstancesInput) SetClusterId(v string) *ListInstancesInput

+ func (s *ListInstancesInput) SetInstanceGroupId(v string) *ListInstancesInput

+ func (s *ListInstancesInput) SetInstanceGroupTypes(v []*string) *ListInstancesInput

+ func (s *ListInstancesInput) SetInstanceStates(v []*string) *ListInstancesInput

+ func (s *ListInstancesInput) SetMarker(v string) *ListInstancesInput

type ListInstancesOutput

+ func (s *ListInstancesOutput) SetInstances(v []*Instance) *ListInstancesOutput

+ func (s *ListInstancesOutput) SetMarker(v string) *ListInstancesOutput

+ type ListSecurityConfigurationsInput struct

+ Marker *string

+ func (s *ListSecurityConfigurationsInput) SetMarker(v string) *ListSecurityConfigurationsInput

+ func (s ListSecurityConfigurationsInput) GoString() string

+ func (s ListSecurityConfigurationsInput) String() string

+ type ListSecurityConfigurationsOutput struct

+ Marker *string

+ SecurityConfigurations []*SecurityConfigurationSummary

+ func (s *ListSecurityConfigurationsOutput) SetMarker(v string) *ListSecurityConfigurationsOutput

+ func (s *ListSecurityConfigurationsOutput) SetSecurityConfigurations(v []*SecurityConfigurationSummary) *ListSecurityConfigurationsOutput

+ func (s ListSecurityConfigurationsOutput) GoString() string

+ func (s ListSecurityConfigurationsOutput) String() string

type ListStepsInput

+ func (s *ListStepsInput) SetClusterId(v string) *ListStepsInput

+ func (s *ListStepsInput) SetMarker(v string) *ListStepsInput

+ func (s *ListStepsInput) SetStepIds(v []*string) *ListStepsInput

+ func (s *ListStepsInput) SetStepStates(v []*string) *ListStepsInput

type ListStepsOutput

+ func (s *ListStepsOutput) SetMarker(v string) *ListStepsOutput

+ func (s *ListStepsOutput) SetSteps(v []*StepSummary) *ListStepsOutput

type ModifyInstanceGroupsInput

+ func (s *ModifyInstanceGroupsInput) SetInstanceGroups(v []*InstanceGroupModifyConfig) *ModifyInstanceGroupsInput

type PlacementType

+ func (s *PlacementType) SetAvailabilityZone(v string) *PlacementType

type RemoveTagsInput

+ func (s *RemoveTagsInput) SetResourceId(v string) *RemoveTagsInput

+ func (s *RemoveTagsInput) SetTagKeys(v []*string) *RemoveTagsInput

type RunJobFlowInput

+ SecurityConfiguration *string

+ func (s *RunJobFlowInput) SetAdditionalInfo(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetAmiVersion(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetApplications(v []*Application) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetBootstrapActions(v []*BootstrapActionConfig) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetConfigurations(v []*Configuration) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetInstances(v *JobFlowInstancesConfig) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetJobFlowRole(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetLogUri(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetName(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetNewSupportedProducts(v []*SupportedProductConfig) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetReleaseLabel(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetSecurityConfiguration(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetServiceRole(v string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetSteps(v []*StepConfig) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetSupportedProducts(v []*string) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetTags(v []*Tag) *RunJobFlowInput

+ func (s *RunJobFlowInput) SetVisibleToAllUsers(v bool) *RunJobFlowInput

type RunJobFlowOutput

+ func (s *RunJobFlowOutput) SetJobFlowId(v string) *RunJobFlowOutput

type ScriptBootstrapActionConfig

+ func (s *ScriptBootstrapActionConfig) SetArgs(v []*string) *ScriptBootstrapActionConfig

+ func (s *ScriptBootstrapActionConfig) SetPath(v string) *ScriptBootstrapActionConfig

+ type SecurityConfigurationSummary struct

+ CreationDateTime *time.Time

+ Name *string

+ func (s *SecurityConfigurationSummary) SetCreationDateTime(v time.Time) *SecurityConfigurationSummary

+ func (s *SecurityConfigurationSummary) SetName(v string) *SecurityConfigurationSummary

+ func (s SecurityConfigurationSummary) GoString() string

+ func (s SecurityConfigurationSummary) String() string

type SetTerminationProtectionInput

+ func (s *SetTerminationProtectionInput) SetJobFlowIds(v []*string) *SetTerminationProtectionInput

+ func (s *SetTerminationProtectionInput) SetTerminationProtected(v bool) *SetTerminationProtectionInput

type SetVisibleToAllUsersInput

+ func (s *SetVisibleToAllUsersInput) SetJobFlowIds(v []*string) *SetVisibleToAllUsersInput

+ func (s *SetVisibleToAllUsersInput) SetVisibleToAllUsers(v bool) *SetVisibleToAllUsersInput

type ShrinkPolicy

+ func (s *ShrinkPolicy) SetDecommissionTimeout(v int64) *ShrinkPolicy

+ func (s *ShrinkPolicy) SetInstanceResizePolicy(v *InstanceResizePolicy) *ShrinkPolicy

type Step

+ func (s *Step) SetActionOnFailure(v string) *Step

+ func (s *Step) SetConfig(v *HadoopStepConfig) *Step

+ func (s *Step) SetId(v string) *Step

+ func (s *Step) SetName(v string) *Step

+ func (s *Step) SetStatus(v *StepStatus) *Step

type StepConfig

+ func (s *StepConfig) SetActionOnFailure(v string) *StepConfig

+ func (s *StepConfig) SetHadoopJarStep(v *HadoopJarStepConfig) *StepConfig

+ func (s *StepConfig) SetName(v string) *StepConfig

type StepDetail

+ func (s *StepDetail) SetExecutionStatusDetail(v *StepExecutionStatusDetail) *StepDetail

+ func (s *StepDetail) SetStepConfig(v *StepConfig) *StepDetail

type StepExecutionStatusDetail

+ func (s *StepExecutionStatusDetail) SetCreationDateTime(v time.Time) *StepExecutionStatusDetail

+ func (s *StepExecutionStatusDetail) SetEndDateTime(v time.Time) *StepExecutionStatusDetail

+ func (s *StepExecutionStatusDetail) SetLastStateChangeReason(v string) *StepExecutionStatusDetail

+ func (s *StepExecutionStatusDetail) SetStartDateTime(v time.Time) *StepExecutionStatusDetail

+ func (s *StepExecutionStatusDetail) SetState(v string) *StepExecutionStatusDetail

type StepStateChangeReason

+ func (s *StepStateChangeReason) SetCode(v string) *StepStateChangeReason

+ func (s *StepStateChangeReason) SetMessage(v string) *StepStateChangeReason

type StepStatus

+ func (s *StepStatus) SetFailureDetails(v *FailureDetails) *StepStatus

+ func (s *StepStatus) SetState(v string) *StepStatus

+ func (s *StepStatus) SetStateChangeReason(v *StepStateChangeReason) *StepStatus

+ func (s *StepStatus) SetTimeline(v *StepTimeline) *StepStatus

type StepSummary

+ func (s *StepSummary) SetActionOnFailure(v string) *StepSummary

+ func (s *StepSummary) SetConfig(v *HadoopStepConfig) *StepSummary

+ func (s *StepSummary) SetId(v string) *StepSummary

+ func (s *StepSummary) SetName(v string) *StepSummary

+ func (s *StepSummary) SetStatus(v *StepStatus) *StepSummary

type StepTimeline

+ func (s *StepTimeline) SetCreationDateTime(v time.Time) *StepTimeline

+ func (s *StepTimeline) SetEndDateTime(v time.Time) *StepTimeline

+ func (s *StepTimeline) SetStartDateTime(v time.Time) *StepTimeline

type SupportedProductConfig

+ func (s *SupportedProductConfig) SetArgs(v []*string) *SupportedProductConfig

+ func (s *SupportedProductConfig) SetName(v string) *SupportedProductConfig

type Tag

+ func (s *Tag) SetKey(v string) *Tag

+ func (s *Tag) SetValue(v string) *Tag

type TerminateJobFlowsInput

+ func (s *TerminateJobFlowsInput) SetJobFlowIds(v []*string) *TerminateJobFlowsInput

type VolumeSpecification

+ func (s *VolumeSpecification) SetIops(v int64) *VolumeSpecification

+ func (s *VolumeSpecification) SetSizeInGB(v int64) *VolumeSpecification

+ func (s *VolumeSpecification) SetVolumeType(v string) *VolumeSpecification

Aug 2, 2016

Changes in this version

+ type FailureDetails struct

+ LogFile *string

+ Message *string

+ Reason *string

+ func (s FailureDetails) GoString() string

+ func (s FailureDetails) String() string

type StepStatus

+ FailureDetails *FailureDetails

Jun 7, 2016

Changes in this version

type ListInstancesInput

+ InstanceStates []*string

May 5, 2016

Changes in this version

type AddInstanceGroupsInput

+ func (s *AddInstanceGroupsInput) Validate() error

type AddJobFlowStepsInput

+ func (s *AddJobFlowStepsInput) Validate() error

type AddTagsInput

+ func (s *AddTagsInput) Validate() error

type BootstrapActionConfig

+ func (s *BootstrapActionConfig) Validate() error

type DescribeClusterInput

+ func (s *DescribeClusterInput) Validate() error

type DescribeStepInput

+ func (s *DescribeStepInput) Validate() error

type EbsBlockDeviceConfig

+ func (s *EbsBlockDeviceConfig) Validate() error

type EbsConfiguration

+ func (s *EbsConfiguration) Validate() error

type HadoopJarStepConfig

+ func (s *HadoopJarStepConfig) Validate() error

type InstanceGroup

+ ShrinkPolicy *ShrinkPolicy

type InstanceGroupConfig

+ func (s *InstanceGroupConfig) Validate() error

type InstanceGroupModifyConfig

+ ShrinkPolicy *ShrinkPolicy

+ func (s *InstanceGroupModifyConfig) Validate() error

+ type InstanceResizePolicy struct

+ InstanceTerminationTimeout *int64

+ InstancesToProtect []*string

+ InstancesToTerminate []*string

+ func (s InstanceResizePolicy) GoString() string

+ func (s InstanceResizePolicy) String() string

type JobFlowInstancesConfig

+ func (s *JobFlowInstancesConfig) Validate() error

type ListBootstrapActionsInput

+ func (s *ListBootstrapActionsInput) Validate() error

type ListInstanceGroupsInput

+ func (s *ListInstanceGroupsInput) Validate() error

type ListInstancesInput

+ func (s *ListInstancesInput) Validate() error

type ListStepsInput

+ func (s *ListStepsInput) Validate() error

type ModifyInstanceGroupsInput

+ func (s *ModifyInstanceGroupsInput) Validate() error

type PlacementType

+ func (s *PlacementType) Validate() error

type RemoveTagsInput

+ func (s *RemoveTagsInput) Validate() error

type RunJobFlowInput

+ func (s *RunJobFlowInput) Validate() error

type ScriptBootstrapActionConfig

+ func (s *ScriptBootstrapActionConfig) Validate() error

type SetTerminationProtectionInput

+ func (s *SetTerminationProtectionInput) Validate() error

type SetVisibleToAllUsersInput

+ func (s *SetVisibleToAllUsersInput) Validate() error

+ type ShrinkPolicy struct

+ DecommissionTimeout *int64

+ InstanceResizePolicy *InstanceResizePolicy

+ func (s ShrinkPolicy) GoString() string

+ func (s ShrinkPolicy) String() string

type StepConfig

+ func (s *StepConfig) Validate() error

type TerminateJobFlowsInput

+ func (s *TerminateJobFlowsInput) Validate() error

type VolumeSpecification

+ func (s *VolumeSpecification) Validate() error

Apr 6, 2016

Changes in this version

+ type EbsBlockDevice struct

+ Device *string

+ VolumeSpecification *VolumeSpecification

+ func (s EbsBlockDevice) GoString() string

+ func (s EbsBlockDevice) String() string

+ type EbsBlockDeviceConfig struct

+ VolumeSpecification *VolumeSpecification

+ VolumesPerInstance *int64

+ func (s EbsBlockDeviceConfig) GoString() string

+ func (s EbsBlockDeviceConfig) String() string

+ type EbsConfiguration struct

+ EbsBlockDeviceConfigs []*EbsBlockDeviceConfig

+ EbsOptimized *bool

+ func (s EbsConfiguration) GoString() string

+ func (s EbsConfiguration) String() string

+ type EbsVolume struct

+ Device *string

+ VolumeId *string

+ func (s EbsVolume) GoString() string

+ func (s EbsVolume) String() string

type Instance

+ EbsVolumes []*EbsVolume

+ InstanceGroupId *string

type InstanceGroup

+ EbsBlockDevices []*EbsBlockDevice

+ EbsOptimized *bool

type InstanceGroupConfig

+ EbsConfiguration *EbsConfiguration

+ type VolumeSpecification struct

+ Iops *int64

+ SizeInGB *int64

+ VolumeType *string

+ func (s VolumeSpecification) GoString() string

+ func (s VolumeSpecification) String() string

Jan 12, 2016

Changes in this version

type Ec2InstanceAttributes

+ ServiceAccessSecurityGroup *string

type JobFlowInstancesConfig

+ ServiceAccessSecurityGroup *string

Nov 19, 2015

Changes in this version

+ const ServiceName

type EMR

+ func (c *EMR) WaitUntilClusterRunning(input *DescribeClusterInput) error

+ func (c *EMR) WaitUntilStepComplete(input *DescribeStepInput) error

Sep 17, 2015

Changes in this version

type AddInstanceGroupsInput

+ JobFlowId *string

type AddInstanceGroupsOutput

+ InstanceGroupIds []*string

+ JobFlowId *string

type AddJobFlowStepsInput

+ JobFlowId *string

type AddJobFlowStepsOutput

+ StepIds []*string

type AddTagsInput

+ ResourceId *string

type Cluster

+ Ec2InstanceAttributes *Ec2InstanceAttributes

+ Id *string

+ LogUri *string

+ MasterPublicDnsName *string

+ RequestedAmiVersion *string

+ RunningAmiVersion *string

type ClusterSummary

+ Id *string

type DescribeClusterInput

+ ClusterId *string

type DescribeJobFlowsInput

+ JobFlowIds []*string

type DescribeStepInput

+ ClusterId *string

+ StepId *string

+ type Ec2InstanceAttributes struct

+ AdditionalMasterSecurityGroups []*string

+ AdditionalSlaveSecurityGroups []*string

+ Ec2AvailabilityZone *string

+ Ec2KeyName *string

+ Ec2SubnetId *string

+ EmrManagedMasterSecurityGroup *string

+ EmrManagedSlaveSecurityGroup *string

+ IamInstanceProfile *string

+ func (s Ec2InstanceAttributes) GoString() string

+ func (s Ec2InstanceAttributes) String() string

+ type HadoopJarStepConfig struct

+ Args []*string

+ Jar *string

+ MainClass *string

+ Properties []*KeyValue

+ func (s HadoopJarStepConfig) GoString() string

+ func (s HadoopJarStepConfig) String() string

type HadoopStepConfig

+ Jar *string

type Instance

+ Ec2InstanceId *string

+ Id *string

+ PrivateDnsName *string

+ PrivateIpAddress *string

+ PublicDnsName *string

+ PublicIpAddress *string

type InstanceGroup

+ Id *string

type InstanceGroupDetail

+ InstanceGroupId *string

type InstanceGroupModifyConfig

+ EC2InstanceIdsToTerminate []*string

+ InstanceGroupId *string

type JobFlowDetail

+ AmiVersion *string

+ JobFlowId *string

+ LogUri *string

type JobFlowInstancesConfig

+ Ec2KeyName *string

+ Ec2SubnetId *string

+ EmrManagedMasterSecurityGroup *string

+ EmrManagedSlaveSecurityGroup *string

type JobFlowInstancesDetail

+ Ec2KeyName *string

+ Ec2SubnetId *string

+ MasterInstanceId *string

+ MasterPublicDnsName *string

type ListBootstrapActionsInput

+ ClusterId *string

type ListInstanceGroupsInput

+ ClusterId *string

type ListInstancesInput

+ ClusterId *string

+ InstanceGroupId *string

type ListStepsInput

+ ClusterId *string

+ StepIds []*string

type RemoveTagsInput

+ ResourceId *string

type RunJobFlowInput

+ AmiVersion *string

+ LogUri *string

type RunJobFlowOutput

+ JobFlowId *string

type SetTerminationProtectionInput

+ JobFlowIds []*string

type SetVisibleToAllUsersInput

+ JobFlowIds []*string

type Step

+ Id *string

type StepConfig

+ HadoopJarStep *HadoopJarStepConfig

type StepSummary

+ Id *string

type TerminateJobFlowsInput

+ JobFlowIds []*string

Jul 28, 2015

Changes in this version

+ const ActionOnFailureCancelAndWait

+ const ActionOnFailureContinue

+ const ActionOnFailureTerminateCluster

+ const ActionOnFailureTerminateJobFlow

+ const ClusterStateBootstrapping

+ const ClusterStateChangeReasonCodeAllStepsCompleted

+ const ClusterStateChangeReasonCodeBootstrapFailure

+ const ClusterStateChangeReasonCodeInstanceFailure

+ const ClusterStateChangeReasonCodeInternalError

+ const ClusterStateChangeReasonCodeStepFailure

+ const ClusterStateChangeReasonCodeUserRequest

+ const ClusterStateChangeReasonCodeValidationError

+ const ClusterStateRunning

+ const ClusterStateStarting

+ const ClusterStateTerminated

+ const ClusterStateTerminatedWithErrors

+ const ClusterStateTerminating

+ const ClusterStateWaiting

+ const InstanceGroupStateArrested

+ const InstanceGroupStateBootstrapping

+ const InstanceGroupStateChangeReasonCodeClusterTerminated

+ const InstanceGroupStateChangeReasonCodeInstanceFailure

+ const InstanceGroupStateChangeReasonCodeInternalError

+ const InstanceGroupStateChangeReasonCodeValidationError

+ const InstanceGroupStateEnded

+ const InstanceGroupStateProvisioning

+ const InstanceGroupStateResizing

+ const InstanceGroupStateRunning

+ const InstanceGroupStateShuttingDown

+ const InstanceGroupStateSuspended

+ const InstanceGroupStateTerminated

+ const InstanceGroupStateTerminating

+ const InstanceGroupTypeCore

+ const InstanceGroupTypeMaster

+ const InstanceGroupTypeTask

+ const InstanceRoleTypeCore

+ const InstanceRoleTypeMaster

+ const InstanceRoleTypeTask

+ const InstanceStateAwaitingFulfillment

+ const InstanceStateBootstrapping

+ const InstanceStateChangeReasonCodeBootstrapFailure

+ const InstanceStateChangeReasonCodeClusterTerminated

+ const InstanceStateChangeReasonCodeInstanceFailure

+ const InstanceStateChangeReasonCodeInternalError

+ const InstanceStateChangeReasonCodeValidationError

+ const InstanceStateProvisioning

+ const InstanceStateRunning

+ const InstanceStateTerminated

+ const JobFlowExecutionStateBootstrapping

+ const JobFlowExecutionStateCompleted

+ const JobFlowExecutionStateFailed

+ const JobFlowExecutionStateRunning

+ const JobFlowExecutionStateShuttingDown

+ const JobFlowExecutionStateStarting

+ const JobFlowExecutionStateTerminated

+ const JobFlowExecutionStateWaiting

+ const MarketTypeOnDemand

+ const MarketTypeSpot

+ const StepExecutionStateCancelled

+ const StepExecutionStateCompleted

+ const StepExecutionStateContinue

+ const StepExecutionStateFailed

+ const StepExecutionStateInterrupted

+ const StepExecutionStatePending

+ const StepExecutionStateRunning

+ const StepStateCancelled

+ const StepStateChangeReasonCodeNone

+ const StepStateCompleted

+ const StepStateFailed

+ const StepStateInterrupted

+ const StepStatePending

+ const StepStateRunning

type Cluster

+ Configurations []*Configuration

+ ReleaseLabel *string

+ type Configuration struct

+ Classification *string

+ Configurations []*Configuration

+ Properties map[string]*string

+ func (s Configuration) GoString() string

+ func (s Configuration) String() string

type InstanceGroup

+ Configurations []*Configuration

type InstanceGroupConfig

+ Configurations []*Configuration

type RunJobFlowInput

+ Applications []*Application

+ Configurations []*Configuration

+ ReleaseLabel *string

Jul 9, 2015

Changes in this version

type AddInstanceGroupsInput

+ func (s AddInstanceGroupsInput) GoString() string

+ func (s AddInstanceGroupsInput) String() string

type AddInstanceGroupsOutput

+ func (s AddInstanceGroupsOutput) GoString() string

+ func (s AddInstanceGroupsOutput) String() string

type AddJobFlowStepsInput

+ func (s AddJobFlowStepsInput) GoString() string

+ func (s AddJobFlowStepsInput) String() string

type AddJobFlowStepsOutput

+ func (s AddJobFlowStepsOutput) GoString() string

+ func (s AddJobFlowStepsOutput) String() string

type AddTagsInput

+ func (s AddTagsInput) GoString() string

+ func (s AddTagsInput) String() string

type AddTagsOutput

+ func (s AddTagsOutput) GoString() string

+ func (s AddTagsOutput) String() string

type Application

+ func (s Application) GoString() string

+ func (s Application) String() string

type BootstrapActionConfig

+ func (s BootstrapActionConfig) GoString() string

+ func (s BootstrapActionConfig) String() string

type BootstrapActionDetail

+ func (s BootstrapActionDetail) GoString() string

+ func (s BootstrapActionDetail) String() string

type Cluster

+ func (s Cluster) GoString() string

+ func (s Cluster) String() string

type ClusterStateChangeReason

+ func (s ClusterStateChangeReason) GoString() string

+ func (s ClusterStateChangeReason) String() string

type ClusterStatus

+ func (s ClusterStatus) GoString() string

+ func (s ClusterStatus) String() string

type ClusterSummary

+ func (s ClusterSummary) GoString() string

+ func (s ClusterSummary) String() string

type ClusterTimeline

+ func (s ClusterTimeline) GoString() string

+ func (s ClusterTimeline) String() string

type Command

+ func (s Command) GoString() string

+ func (s Command) String() string

type DescribeClusterInput

+ func (s DescribeClusterInput) GoString() string

+ func (s DescribeClusterInput) String() string

type DescribeClusterOutput

+ func (s DescribeClusterOutput) GoString() string

+ func (s DescribeClusterOutput) String() string

type DescribeJobFlowsInput

+ func (s DescribeJobFlowsInput) GoString() string

+ func (s DescribeJobFlowsInput) String() string

type DescribeJobFlowsOutput

+ func (s DescribeJobFlowsOutput) GoString() string

+ func (s DescribeJobFlowsOutput) String() string

type DescribeStepInput

+ func (s DescribeStepInput) GoString() string

+ func (s DescribeStepInput) String() string

type DescribeStepOutput

+ func (s DescribeStepOutput) GoString() string

+ func (s DescribeStepOutput) String() string

type EC2InstanceAttributes

+ func (s EC2InstanceAttributes) GoString() string

+ func (s EC2InstanceAttributes) String() string

type HadoopJARStepConfig

+ func (s HadoopJARStepConfig) GoString() string

+ func (s HadoopJARStepConfig) String() string

type HadoopStepConfig

+ func (s HadoopStepConfig) GoString() string

+ func (s HadoopStepConfig) String() string

type Instance

+ func (s Instance) GoString() string

+ func (s Instance) String() string

type InstanceGroup

+ func (s InstanceGroup) GoString() string

+ func (s InstanceGroup) String() string

type InstanceGroupConfig

+ func (s InstanceGroupConfig) GoString() string

+ func (s InstanceGroupConfig) String() string

type InstanceGroupDetail

+ func (s InstanceGroupDetail) GoString() string

+ func (s InstanceGroupDetail) String() string

type InstanceGroupModifyConfig

+ func (s InstanceGroupModifyConfig) GoString() string

+ func (s InstanceGroupModifyConfig) String() string

type InstanceGroupStateChangeReason

+ func (s InstanceGroupStateChangeReason) GoString() string

+ func (s InstanceGroupStateChangeReason) String() string

type InstanceGroupStatus

+ func (s InstanceGroupStatus) GoString() string

+ func (s InstanceGroupStatus) String() string

type InstanceGroupTimeline

+ func (s InstanceGroupTimeline) GoString() string

+ func (s InstanceGroupTimeline) String() string

type InstanceStateChangeReason

+ func (s InstanceStateChangeReason) GoString() string

+ func (s InstanceStateChangeReason) String() string

type InstanceStatus

+ func (s InstanceStatus) GoString() string

+ func (s InstanceStatus) String() string

type InstanceTimeline

+ func (s InstanceTimeline) GoString() string

+ func (s InstanceTimeline) String() string

type JobFlowDetail

+ func (s JobFlowDetail) GoString() string

+ func (s JobFlowDetail) String() string

type JobFlowExecutionStatusDetail

+ func (s JobFlowExecutionStatusDetail) GoString() string

+ func (s JobFlowExecutionStatusDetail) String() string

type JobFlowInstancesConfig

+ func (s JobFlowInstancesConfig) GoString() string

+ func (s JobFlowInstancesConfig) String() string

type JobFlowInstancesDetail

+ func (s JobFlowInstancesDetail) GoString() string

+ func (s JobFlowInstancesDetail) String() string

type KeyValue

+ func (s KeyValue) GoString() string

+ func (s KeyValue) String() string

type ListBootstrapActionsInput

+ func (s ListBootstrapActionsInput) GoString() string

+ func (s ListBootstrapActionsInput) String() string

type ListBootstrapActionsOutput

+ func (s ListBootstrapActionsOutput) GoString() string

+ func (s ListBootstrapActionsOutput) String() string

type ListClustersInput

+ func (s ListClustersInput) GoString() string

+ func (s ListClustersInput) String() string

type ListClustersOutput

+ func (s ListClustersOutput) GoString() string

+ func (s ListClustersOutput) String() string

type ListInstanceGroupsInput

+ func (s ListInstanceGroupsInput) GoString() string

+ func (s ListInstanceGroupsInput) String() string

type ListInstanceGroupsOutput

+ func (s ListInstanceGroupsOutput) GoString() string

+ func (s ListInstanceGroupsOutput) String() string

type ListInstancesInput

+ func (s ListInstancesInput) GoString() string

+ func (s ListInstancesInput) String() string

type ListInstancesOutput

+ func (s ListInstancesOutput) GoString() string

+ func (s ListInstancesOutput) String() string

type ListStepsInput

+ func (s ListStepsInput) GoString() string

+ func (s ListStepsInput) String() string

type ListStepsOutput

+ func (s ListStepsOutput) GoString() string

+ func (s ListStepsOutput) String() string

type ModifyInstanceGroupsInput

+ func (s ModifyInstanceGroupsInput) GoString() string

+ func (s ModifyInstanceGroupsInput) String() string

type ModifyInstanceGroupsOutput

+ func (s ModifyInstanceGroupsOutput) GoString() string

+ func (s ModifyInstanceGroupsOutput) String() string

type PlacementType

+ func (s PlacementType) GoString() string

+ func (s PlacementType) String() string

type RemoveTagsInput

+ func (s RemoveTagsInput) GoString() string

+ func (s RemoveTagsInput) String() string

type RemoveTagsOutput

+ func (s RemoveTagsOutput) GoString() string

+ func (s RemoveTagsOutput) String() string

type RunJobFlowInput

+ func (s RunJobFlowInput) GoString() string

+ func (s RunJobFlowInput) String() string

type RunJobFlowOutput

+ func (s RunJobFlowOutput) GoString() string

+ func (s RunJobFlowOutput) String() string

type ScriptBootstrapActionConfig

+ func (s ScriptBootstrapActionConfig) GoString() string

+ func (s ScriptBootstrapActionConfig) String() string

type SetTerminationProtectionInput

+ func (s SetTerminationProtectionInput) GoString() string

+ func (s SetTerminationProtectionInput) String() string

type SetTerminationProtectionOutput

+ func (s SetTerminationProtectionOutput) GoString() string

+ func (s SetTerminationProtectionOutput) String() string

type SetVisibleToAllUsersInput

+ func (s SetVisibleToAllUsersInput) GoString() string

+ func (s SetVisibleToAllUsersInput) String() string

type SetVisibleToAllUsersOutput

+ func (s SetVisibleToAllUsersOutput) GoString() string

+ func (s SetVisibleToAllUsersOutput) String() string

type Step

+ func (s Step) GoString() string

+ func (s Step) String() string

type StepConfig

+ func (s StepConfig) GoString() string

+ func (s StepConfig) String() string

type StepDetail

+ func (s StepDetail) GoString() string

+ func (s StepDetail) String() string

type StepExecutionStatusDetail

+ func (s StepExecutionStatusDetail) GoString() string

+ func (s StepExecutionStatusDetail) String() string

type StepStateChangeReason

+ func (s StepStateChangeReason) GoString() string

+ func (s StepStateChangeReason) String() string

type StepStatus

+ func (s StepStatus) GoString() string

+ func (s StepStatus) String() string

type StepSummary

+ func (s StepSummary) GoString() string

+ func (s StepSummary) String() string

type StepTimeline

+ func (s StepTimeline) GoString() string

+ func (s StepTimeline) String() string

type SupportedProductConfig

+ func (s SupportedProductConfig) GoString() string

+ func (s SupportedProductConfig) String() string

type Tag

+ func (s Tag) GoString() string

+ func (s Tag) String() string

type TerminateJobFlowsInput

+ func (s TerminateJobFlowsInput) GoString() string

+ func (s TerminateJobFlowsInput) String() string

type TerminateJobFlowsOutput

+ func (s TerminateJobFlowsOutput) GoString() string

+ func (s TerminateJobFlowsOutput) String() string

Jun 3, 2015

Changes in this version

+ type AddInstanceGroupsInput struct

+ InstanceGroups []*InstanceGroupConfig

+ JobFlowID *string

+ type AddInstanceGroupsOutput struct

+ InstanceGroupIDs []*string

+ JobFlowID *string

+ type AddJobFlowStepsInput struct

+ JobFlowID *string

+ Steps []*StepConfig

+ type AddJobFlowStepsOutput struct

+ StepIDs []*string

+ type AddTagsInput struct

+ ResourceID *string

+ Tags []*Tag

+ type AddTagsOutput struct

+ type Application struct

+ AdditionalInfo map[string]*string

+ Args []*string

+ Name *string

+ Version *string

+ type BootstrapActionConfig struct

+ Name *string

+ ScriptBootstrapAction *ScriptBootstrapActionConfig

+ type BootstrapActionDetail struct

+ BootstrapActionConfig *BootstrapActionConfig

+ type Cluster struct

+ Applications []*Application

+ AutoTerminate *bool

+ EC2InstanceAttributes *EC2InstanceAttributes

+ ID *string

+ LogURI *string

+ MasterPublicDNSName *string

+ Name *string

+ NormalizedInstanceHours *int64

+ RequestedAMIVersion *string

+ RunningAMIVersion *string

+ ServiceRole *string

+ Status *ClusterStatus

+ Tags []*Tag

+ TerminationProtected *bool

+ VisibleToAllUsers *bool

+ type ClusterStateChangeReason struct

+ Code *string

+ Message *string

+ type ClusterStatus struct

+ State *string

+ StateChangeReason *ClusterStateChangeReason

+ Timeline *ClusterTimeline

+ type ClusterSummary struct

+ ID *string

+ Name *string

+ NormalizedInstanceHours *int64

+ Status *ClusterStatus

+ type ClusterTimeline struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ ReadyDateTime *time.Time

+ type Command struct

+ Args []*string

+ Name *string

+ ScriptPath *string

+ type DescribeClusterInput struct

+ ClusterID *string

+ type DescribeClusterOutput struct

+ Cluster *Cluster

+ type DescribeJobFlowsInput struct

+ CreatedAfter *time.Time

+ CreatedBefore *time.Time

+ JobFlowIDs []*string

+ JobFlowStates []*string

+ type DescribeJobFlowsOutput struct

+ JobFlows []*JobFlowDetail

+ type DescribeStepInput struct

+ ClusterID *string

+ StepID *string

+ type DescribeStepOutput struct

+ Step *Step

+ type EC2InstanceAttributes struct

+ AdditionalMasterSecurityGroups []*string

+ AdditionalSlaveSecurityGroups []*string

+ EC2AvailabilityZone *string

+ EC2KeyName *string

+ EC2SubnetID *string

+ EMRManagedMasterSecurityGroup *string

+ EMRManagedSlaveSecurityGroup *string

+ IAMInstanceProfile *string

+ type EMR struct

+ func New(config *aws.Config) *EMR

+ func (c *EMR) AddInstanceGroups(input *AddInstanceGroupsInput) (*AddInstanceGroupsOutput, error)

+ func (c *EMR) AddInstanceGroupsRequest(input *AddInstanceGroupsInput) (req *aws.Request, output *AddInstanceGroupsOutput)

+ func (c *EMR) AddJobFlowSteps(input *AddJobFlowStepsInput) (*AddJobFlowStepsOutput, error)

+ func (c *EMR) AddJobFlowStepsRequest(input *AddJobFlowStepsInput) (req *aws.Request, output *AddJobFlowStepsOutput)

+ func (c *EMR) AddTags(input *AddTagsInput) (*AddTagsOutput, error)

+ func (c *EMR) AddTagsRequest(input *AddTagsInput) (req *aws.Request, output *AddTagsOutput)

+ func (c *EMR) DescribeCluster(input *DescribeClusterInput) (*DescribeClusterOutput, error)

+ func (c *EMR) DescribeClusterRequest(input *DescribeClusterInput) (req *aws.Request, output *DescribeClusterOutput)

+ func (c *EMR) DescribeJobFlows(input *DescribeJobFlowsInput) (*DescribeJobFlowsOutput, error)

+ func (c *EMR) DescribeJobFlowsRequest(input *DescribeJobFlowsInput) (req *aws.Request, output *DescribeJobFlowsOutput)

+ func (c *EMR) DescribeStep(input *DescribeStepInput) (*DescribeStepOutput, error)

+ func (c *EMR) DescribeStepRequest(input *DescribeStepInput) (req *aws.Request, output *DescribeStepOutput)

+ func (c *EMR) ListBootstrapActions(input *ListBootstrapActionsInput) (*ListBootstrapActionsOutput, error)

+ func (c *EMR) ListBootstrapActionsPages(input *ListBootstrapActionsInput, ...) error

+ func (c *EMR) ListBootstrapActionsRequest(input *ListBootstrapActionsInput) (req *aws.Request, output *ListBootstrapActionsOutput)

+ func (c *EMR) ListClusters(input *ListClustersInput) (*ListClustersOutput, error)

+ func (c *EMR) ListClustersPages(input *ListClustersInput, ...) error

+ func (c *EMR) ListClustersRequest(input *ListClustersInput) (req *aws.Request, output *ListClustersOutput)

+ func (c *EMR) ListInstanceGroups(input *ListInstanceGroupsInput) (*ListInstanceGroupsOutput, error)

+ func (c *EMR) ListInstanceGroupsPages(input *ListInstanceGroupsInput, ...) error

+ func (c *EMR) ListInstanceGroupsRequest(input *ListInstanceGroupsInput) (req *aws.Request, output *ListInstanceGroupsOutput)

+ func (c *EMR) ListInstances(input *ListInstancesInput) (*ListInstancesOutput, error)

+ func (c *EMR) ListInstancesPages(input *ListInstancesInput, ...) error

+ func (c *EMR) ListInstancesRequest(input *ListInstancesInput) (req *aws.Request, output *ListInstancesOutput)

+ func (c *EMR) ListSteps(input *ListStepsInput) (*ListStepsOutput, error)

+ func (c *EMR) ListStepsPages(input *ListStepsInput, ...) error

+ func (c *EMR) ListStepsRequest(input *ListStepsInput) (req *aws.Request, output *ListStepsOutput)

+ func (c *EMR) ModifyInstanceGroups(input *ModifyInstanceGroupsInput) (*ModifyInstanceGroupsOutput, error)

+ func (c *EMR) ModifyInstanceGroupsRequest(input *ModifyInstanceGroupsInput) (req *aws.Request, output *ModifyInstanceGroupsOutput)

+ func (c *EMR) RemoveTags(input *RemoveTagsInput) (*RemoveTagsOutput, error)

+ func (c *EMR) RemoveTagsRequest(input *RemoveTagsInput) (req *aws.Request, output *RemoveTagsOutput)

+ func (c *EMR) RunJobFlow(input *RunJobFlowInput) (*RunJobFlowOutput, error)

+ func (c *EMR) RunJobFlowRequest(input *RunJobFlowInput) (req *aws.Request, output *RunJobFlowOutput)

+ func (c *EMR) SetTerminationProtection(input *SetTerminationProtectionInput) (*SetTerminationProtectionOutput, error)

+ func (c *EMR) SetTerminationProtectionRequest(input *SetTerminationProtectionInput) (req *aws.Request, output *SetTerminationProtectionOutput)

+ func (c *EMR) SetVisibleToAllUsers(input *SetVisibleToAllUsersInput) (*SetVisibleToAllUsersOutput, error)

+ func (c *EMR) SetVisibleToAllUsersRequest(input *SetVisibleToAllUsersInput) (req *aws.Request, output *SetVisibleToAllUsersOutput)

+ func (c *EMR) TerminateJobFlows(input *TerminateJobFlowsInput) (*TerminateJobFlowsOutput, error)

+ func (c *EMR) TerminateJobFlowsRequest(input *TerminateJobFlowsInput) (req *aws.Request, output *TerminateJobFlowsOutput)

+ type HadoopJARStepConfig struct

+ Args []*string

+ JAR *string

+ MainClass *string

+ Properties []*KeyValue

+ type HadoopStepConfig struct

+ Args []*string

+ JAR *string

+ MainClass *string

+ Properties map[string]*string

+ type Instance struct

+ EC2InstanceID *string

+ ID *string

+ PrivateDNSName *string

+ PrivateIPAddress *string

+ PublicDNSName *string

+ PublicIPAddress *string

+ Status *InstanceStatus

+ type InstanceGroup struct

+ BidPrice *string

+ ID *string

+ InstanceGroupType *string

+ InstanceType *string

+ Market *string

+ Name *string

+ RequestedInstanceCount *int64

+ RunningInstanceCount *int64

+ Status *InstanceGroupStatus

+ type InstanceGroupConfig struct

+ BidPrice *string

+ InstanceCount *int64

+ InstanceRole *string

+ InstanceType *string

+ Market *string

+ Name *string

+ type InstanceGroupDetail struct

+ BidPrice *string

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ InstanceGroupID *string

+ InstanceRequestCount *int64

+ InstanceRole *string

+ InstanceRunningCount *int64

+ InstanceType *string

+ LastStateChangeReason *string

+ Market *string

+ Name *string

+ ReadyDateTime *time.Time

+ StartDateTime *time.Time

+ State *string

+ type InstanceGroupModifyConfig struct

+ EC2InstanceIDsToTerminate []*string

+ InstanceCount *int64

+ InstanceGroupID *string

+ type InstanceGroupStateChangeReason struct

+ Code *string

+ Message *string

+ type InstanceGroupStatus struct

+ State *string

+ StateChangeReason *InstanceGroupStateChangeReason

+ Timeline *InstanceGroupTimeline

+ type InstanceGroupTimeline struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ ReadyDateTime *time.Time

+ type InstanceStateChangeReason struct

+ Code *string

+ Message *string

+ type InstanceStatus struct

+ State *string

+ StateChangeReason *InstanceStateChangeReason

+ Timeline *InstanceTimeline

+ type InstanceTimeline struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ ReadyDateTime *time.Time

+ type JobFlowDetail struct

+ AMIVersion *string

+ BootstrapActions []*BootstrapActionDetail

+ ExecutionStatusDetail *JobFlowExecutionStatusDetail

+ Instances *JobFlowInstancesDetail

+ JobFlowID *string

+ JobFlowRole *string

+ LogURI *string

+ Name *string

+ ServiceRole *string

+ Steps []*StepDetail

+ SupportedProducts []*string

+ VisibleToAllUsers *bool

+ type JobFlowExecutionStatusDetail struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ LastStateChangeReason *string

+ ReadyDateTime *time.Time

+ StartDateTime *time.Time

+ State *string

+ type JobFlowInstancesConfig struct

+ AdditionalMasterSecurityGroups []*string

+ AdditionalSlaveSecurityGroups []*string

+ EC2KeyName *string

+ EC2SubnetID *string

+ EMRManagedMasterSecurityGroup *string

+ EMRManagedSlaveSecurityGroup *string

+ HadoopVersion *string

+ InstanceCount *int64

+ InstanceGroups []*InstanceGroupConfig

+ KeepJobFlowAliveWhenNoSteps *bool

+ MasterInstanceType *string

+ Placement *PlacementType

+ SlaveInstanceType *string

+ TerminationProtected *bool

+ type JobFlowInstancesDetail struct

+ EC2KeyName *string

+ EC2SubnetID *string

+ HadoopVersion *string

+ InstanceCount *int64

+ InstanceGroups []*InstanceGroupDetail

+ KeepJobFlowAliveWhenNoSteps *bool

+ MasterInstanceID *string

+ MasterInstanceType *string

+ MasterPublicDNSName *string

+ NormalizedInstanceHours *int64

+ Placement *PlacementType

+ SlaveInstanceType *string

+ TerminationProtected *bool

+ type KeyValue struct

+ Key *string

+ Value *string

+ type ListBootstrapActionsInput struct

+ ClusterID *string

+ Marker *string

+ type ListBootstrapActionsOutput struct

+ BootstrapActions []*Command

+ Marker *string

+ type ListClustersInput struct

+ ClusterStates []*string

+ CreatedAfter *time.Time

+ CreatedBefore *time.Time

+ Marker *string

+ type ListClustersOutput struct

+ Clusters []*ClusterSummary

+ Marker *string

+ type ListInstanceGroupsInput struct

+ ClusterID *string

+ Marker *string

+ type ListInstanceGroupsOutput struct

+ InstanceGroups []*InstanceGroup

+ Marker *string

+ type ListInstancesInput struct

+ ClusterID *string

+ InstanceGroupID *string

+ InstanceGroupTypes []*string

+ Marker *string

+ type ListInstancesOutput struct

+ Instances []*Instance

+ Marker *string

+ type ListStepsInput struct

+ ClusterID *string

+ Marker *string

+ StepIDs []*string

+ StepStates []*string

+ type ListStepsOutput struct

+ Marker *string

+ Steps []*StepSummary

+ type ModifyInstanceGroupsInput struct

+ InstanceGroups []*InstanceGroupModifyConfig

+ type ModifyInstanceGroupsOutput struct

+ type PlacementType struct

+ AvailabilityZone *string

+ type RemoveTagsInput struct

+ ResourceID *string

+ TagKeys []*string

+ type RemoveTagsOutput struct

+ type RunJobFlowInput struct

+ AMIVersion *string

+ AdditionalInfo *string

+ BootstrapActions []*BootstrapActionConfig

+ Instances *JobFlowInstancesConfig

+ JobFlowRole *string

+ LogURI *string

+ Name *string

+ NewSupportedProducts []*SupportedProductConfig

+ ServiceRole *string

+ Steps []*StepConfig

+ SupportedProducts []*string

+ Tags []*Tag

+ VisibleToAllUsers *bool

+ type RunJobFlowOutput struct

+ JobFlowID *string

+ type ScriptBootstrapActionConfig struct

+ Args []*string

+ Path *string

+ type SetTerminationProtectionInput struct

+ JobFlowIDs []*string

+ TerminationProtected *bool

+ type SetTerminationProtectionOutput struct

+ type SetVisibleToAllUsersInput struct

+ JobFlowIDs []*string

+ VisibleToAllUsers *bool

+ type SetVisibleToAllUsersOutput struct

+ type Step struct

+ ActionOnFailure *string

+ Config *HadoopStepConfig

+ ID *string

+ Name *string

+ Status *StepStatus

+ type StepConfig struct

+ ActionOnFailure *string

+ HadoopJARStep *HadoopJARStepConfig

+ Name *string

+ type StepDetail struct

+ ExecutionStatusDetail *StepExecutionStatusDetail

+ StepConfig *StepConfig

+ type StepExecutionStatusDetail struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ LastStateChangeReason *string

+ StartDateTime *time.Time

+ State *string

+ type StepStateChangeReason struct

+ Code *string

+ Message *string

+ type StepStatus struct

+ State *string

+ StateChangeReason *StepStateChangeReason

+ Timeline *StepTimeline

+ type StepSummary struct

+ ActionOnFailure *string

+ Config *HadoopStepConfig

+ ID *string

+ Name *string

+ Status *StepStatus

+ type StepTimeline struct

+ CreationDateTime *time.Time

+ EndDateTime *time.Time

+ StartDateTime *time.Time

+ type SupportedProductConfig struct

+ Args []*string

+ Name *string

+ type Tag struct

+ Key *string

+ Value *string

+ type TerminateJobFlowsInput struct

+ JobFlowIDs []*string

+ type TerminateJobFlowsOutput struct