emr

package

Go to main page

Versions in this module

v1

v1.0.6

Dec 17, 2015

v1.0.5

Dec 15, 2015

v1.0.4

Dec 8, 2015

v1.0.3

Dec 4, 2015

v1.0.2

Nov 24, 2015

v1.0.0

Nov 19, 2015

v0

v0.10.4

Nov 12, 2015

v0.10.3

Nov 10, 2015

Changes in this version

type EMR

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

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

v0.10.2

Nov 3, 2015

v0.10.1

Nov 2, 2015

v0.10.0

Oct 29, 2015

Changes in this version

+ const ServiceName

v0.9.17

Oct 26, 2015

v0.9.16

Oct 22, 2015

v0.9.15

Oct 15, 2015

v0.9.14

Oct 8, 2015

v0.9.13

Oct 7, 2015

v0.9.12

Oct 6, 2015

v0.9.11

Oct 1, 2015

v0.9.10

Sep 29, 2015

v0.9.9

Sep 17, 2015

v0.9.8

Sep 16, 2015

v0.9.7

Sep 15, 2015

v0.9.6

Sep 10, 2015

v0.9.5

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

v0.7.4

Aug 12, 2015

v0.7.3

Aug 6, 2015

v0.7.2

Aug 4, 2015

v0.7.1

Jul 30, 2015

v0.7.0

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

v0.6.8

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

v0.6.7

Jul 14, 2015

v0.6.6

Jul 9, 2015

v0.6.5

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

v0.6.4

Jun 24, 2015

v0.6.3

Jun 18, 2015

v0.6.2

Jun 11, 2015

v0.6.1

Jun 4, 2015

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL