emr

May 10, 2016

Changes in this version

type ListInstancesInput

+ InstanceStates []*string

Apr 26, 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 InstanceGroupConfig

+ func (s *InstanceGroupConfig) Validate() error

type InstanceGroupModifyConfig

+ func (s *InstanceGroupModifyConfig) Validate() error

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 StepConfig

+ func (s *StepConfig) Validate() error

type TerminateJobFlowsInput

+ func (s *TerminateJobFlowsInput) Validate() error

type VolumeSpecification

+ func (s *VolumeSpecification) Validate() error

Apr 21, 2016

Changes in this version

type InstanceGroup

+ ShrinkPolicy *ShrinkPolicy

type InstanceGroupModifyConfig

+ ShrinkPolicy *ShrinkPolicy

+ type InstanceResizePolicy struct

+ InstanceTerminationTimeout *int64

+ InstancesToProtect []*string

+ InstancesToTerminate []*string

+ func (s InstanceResizePolicy) GoString() string

+ func (s InstanceResizePolicy) String() string

+ type ShrinkPolicy struct

+ DecommissionTimeout *int64

+ InstanceResizePolicy *InstanceResizePolicy

+ func (s ShrinkPolicy) GoString() string

+ func (s ShrinkPolicy) String() string

Feb 16, 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

Dec 21, 2015

Changes in this version

type Ec2InstanceAttributes

+ ServiceAccessSecurityGroup *string

type JobFlowInstancesConfig

+ ServiceAccessSecurityGroup *string

Nov 10, 2015

Changes in this version

type EMR

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

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

Oct 29, 2015

Changes in this version

+ const ServiceName

Sep 3, 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

Jul 23, 2015

Changes in this version

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 7, 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