Versions in this module Expand all Collapse all v0 v0.6.0 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