...
AWS SDK for Go API Reference
import "github.com/aws/aws-sdk-go/service/emrserverless"
Overview
Constants

Overview ▾

Package emrserverless provides the client and types for making API requests to EMR Serverless.

Amazon EMR Serverless is a new deployment option for Amazon EMR. EMR Serverless provides a serverless runtime environment that simplifies running analytics applications using the latest open source frameworks such as Apache Spark and Apache Hive. With EMR Serverless, you don’t have to configure, optimize, secure, or operate clusters to run applications with these frameworks.

The API reference to Amazon EMR Serverless is emr-serverless. The emr-serverless prefix is used in the following scenarios:

See https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13 for more information on this service.

See emrserverless package documentation for more information. https://docs.aws.amazon.com/sdk-for-go/api/service/emrserverless/

Using the Client

To contact EMR Serverless with the SDK use the New function to create a new service client. With that client you can make API requests to the service. These clients are safe to use concurrently.

See the SDK's documentation for more information on how to use the SDK. https://docs.aws.amazon.com/sdk-for-go/api/

See aws.Config documentation for more information on configuring SDK clients. https://docs.aws.amazon.com/sdk-for-go/api/aws/#Config

See the EMR Serverless client EMRServerless for more information on creating client for this service. https://docs.aws.amazon.com/sdk-for-go/api/service/emrserverless/#New

The stub package, emrserverlessiface, can be used to provide alternative implementations of service clients, such as mocking the client for testing.

Types ▾

type EMRServerless
func New(p client.ConfigProvider, cfgs ...*aws.Config) *EMRServerless
func (c *EMRServerless) CancelJobRun(input *CancelJobRunInput) (*CancelJobRunOutput, error)
func (c *EMRServerless) CancelJobRunRequest(input *CancelJobRunInput) (req *request.Request, output *CancelJobRunOutput)
func (c *EMRServerless) CancelJobRunWithContext(ctx aws.Context, input *CancelJobRunInput, opts ...request.Option) (*CancelJobRunOutput, error)
func (c *EMRServerless) CreateApplication(input *CreateApplicationInput) (*CreateApplicationOutput, error)
func (c *EMRServerless) CreateApplicationRequest(input *CreateApplicationInput) (req *request.Request, output *CreateApplicationOutput)
func (c *EMRServerless) CreateApplicationWithContext(ctx aws.Context, input *CreateApplicationInput, opts ...request.Option) (*CreateApplicationOutput, error)
func (c *EMRServerless) DeleteApplication(input *DeleteApplicationInput) (*DeleteApplicationOutput, error)
func (c *EMRServerless) DeleteApplicationRequest(input *DeleteApplicationInput) (req *request.Request, output *DeleteApplicationOutput)
func (c *EMRServerless) DeleteApplicationWithContext(ctx aws.Context, input *DeleteApplicationInput, opts ...request.Option) (*DeleteApplicationOutput, error)
func (c *EMRServerless) GetApplication(input *GetApplicationInput) (*GetApplicationOutput, error)
func (c *EMRServerless) GetApplicationRequest(input *GetApplicationInput) (req *request.Request, output *GetApplicationOutput)
func (c *EMRServerless) GetApplicationWithContext(ctx aws.Context, input *GetApplicationInput, opts ...request.Option) (*GetApplicationOutput, error)
func (c *EMRServerless) GetDashboardForJobRun(input *GetDashboardForJobRunInput) (*GetDashboardForJobRunOutput, error)
func (c *EMRServerless) GetDashboardForJobRunRequest(input *GetDashboardForJobRunInput) (req *request.Request, output *GetDashboardForJobRunOutput)
func (c *EMRServerless) GetDashboardForJobRunWithContext(ctx aws.Context, input *GetDashboardForJobRunInput, opts ...request.Option) (*GetDashboardForJobRunOutput, error)
func (c *EMRServerless) GetJobRun(input *GetJobRunInput) (*GetJobRunOutput, error)
func (c *EMRServerless) GetJobRunRequest(input *GetJobRunInput) (req *request.Request, output *GetJobRunOutput)
func (c *EMRServerless) GetJobRunWithContext(ctx aws.Context, input *GetJobRunInput, opts ...request.Option) (*GetJobRunOutput, error)
func (c *EMRServerless) ListApplications(input *ListApplicationsInput) (*ListApplicationsOutput, error)
func (c *EMRServerless) ListApplicationsPages(input *ListApplicationsInput, fn func(*ListApplicationsOutput, bool) bool) error
func (c *EMRServerless) ListApplicationsPagesWithContext(ctx aws.Context, input *ListApplicationsInput, fn func(*ListApplicationsOutput, bool) bool, opts ...request.Option) error
func (c *EMRServerless) ListApplicationsRequest(input *ListApplicationsInput) (req *request.Request, output *ListApplicationsOutput)
func (c *EMRServerless) ListApplicationsWithContext(ctx aws.Context, input *ListApplicationsInput, opts ...request.Option) (*ListApplicationsOutput, error)
func (c *EMRServerless) ListJobRuns(input *ListJobRunsInput) (*ListJobRunsOutput, error)
func (c *EMRServerless) ListJobRunsPages(input *ListJobRunsInput, fn func(*ListJobRunsOutput, bool) bool) error
func (c *EMRServerless) ListJobRunsPagesWithContext(ctx aws.Context, input *ListJobRunsInput, fn func(*ListJobRunsOutput, bool) bool, opts ...request.Option) error
func (c *EMRServerless) ListJobRunsRequest(input *ListJobRunsInput) (req *request.Request, output *ListJobRunsOutput)
func (c *EMRServerless) ListJobRunsWithContext(ctx aws.Context, input *ListJobRunsInput, opts ...request.Option) (*ListJobRunsOutput, error)
func (c *EMRServerless) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)
func (c *EMRServerless) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)
func (c *EMRServerless) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)
func (c *EMRServerless) StartApplication(input *StartApplicationInput) (*StartApplicationOutput, error)
func (c *EMRServerless) StartApplicationRequest(input *StartApplicationInput) (req *request.Request, output *StartApplicationOutput)
func (c *EMRServerless) StartApplicationWithContext(ctx aws.Context, input *StartApplicationInput, opts ...request.Option) (*StartApplicationOutput, error)
func (c *EMRServerless) StartJobRun(input *StartJobRunInput) (*StartJobRunOutput, error)
func (c *EMRServerless) StartJobRunRequest(input *StartJobRunInput) (req *request.Request, output *StartJobRunOutput)
func (c *EMRServerless) StartJobRunWithContext(ctx aws.Context, input *StartJobRunInput, opts ...request.Option) (*StartJobRunOutput, error)
func (c *EMRServerless) StopApplication(input *StopApplicationInput) (*StopApplicationOutput, error)
func (c *EMRServerless) StopApplicationRequest(input *StopApplicationInput) (req *request.Request, output *StopApplicationOutput)
func (c *EMRServerless) StopApplicationWithContext(ctx aws.Context, input *StopApplicationInput, opts ...request.Option) (*StopApplicationOutput, error)
func (c *EMRServerless) TagResource(input *TagResourceInput) (*TagResourceOutput, error)
func (c *EMRServerless) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)
func (c *EMRServerless) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)
func (c *EMRServerless) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)
func (c *EMRServerless) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)
func (c *EMRServerless) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)
func (c *EMRServerless) UpdateApplication(input *UpdateApplicationInput) (*UpdateApplicationOutput, error)
func (c *EMRServerless) UpdateApplicationRequest(input *UpdateApplicationInput) (req *request.Request, output *UpdateApplicationOutput)
func (c *EMRServerless) UpdateApplicationWithContext(ctx aws.Context, input *UpdateApplicationInput, opts ...request.Option) (*UpdateApplicationOutput, error)
func ApplicationState_Values() []string
func Architecture_Values() []string
func JobRunState_Values() []string
type Application
type ApplicationSummary
type AutoStartConfig
type AutoStopConfig
type CancelJobRunInput
type CancelJobRunOutput
type Configuration
type ConfigurationOverrides
type ConflictException
type CreateApplicationInput
type CreateApplicationOutput
type DeleteApplicationInput
type DeleteApplicationOutput
type GetApplicationInput
type GetApplicationOutput
type GetDashboardForJobRunInput
type GetDashboardForJobRunOutput
type GetJobRunInput
type GetJobRunOutput
type Hive
type InitialCapacityConfig
type InternalServerException
type JobDriver
type JobRun
type JobRunSummary
type ListApplicationsInput
type ListApplicationsOutput
type ListJobRunsInput
type ListJobRunsOutput
type ListTagsForResourceInput
type ListTagsForResourceOutput
type ManagedPersistenceMonitoringConfiguration
type MaximumAllowedResources
type MonitoringConfiguration
type NetworkConfiguration
type ResourceNotFoundException
type S3MonitoringConfiguration
type ServiceQuotaExceededException
type SparkSubmit
type StartApplicationInput
type StartApplicationOutput
type StartJobRunInput
type StartJobRunOutput
type StopApplicationInput
type StopApplicationOutput
type TagResourceInput
type TagResourceOutput
type TotalResourceUtilization
type UntagResourceInput
type UntagResourceOutput
type UpdateApplicationInput
type UpdateApplicationOutput
type ValidationException
type WorkerResourceConfig

Constants ▾

const (
    // ApplicationStateCreating is a ApplicationState enum value
    ApplicationStateCreating = "CREATING"

    // ApplicationStateCreated is a ApplicationState enum value
    ApplicationStateCreated = "CREATED"

    // ApplicationStateStarting is a ApplicationState enum value
    ApplicationStateStarting = "STARTING"

    // ApplicationStateStarted is a ApplicationState enum value
    ApplicationStateStarted = "STARTED"

    // ApplicationStateStopping is a ApplicationState enum value
    ApplicationStateStopping = "STOPPING"

    // ApplicationStateStopped is a ApplicationState enum value
    ApplicationStateStopped = "STOPPED"

    // ApplicationStateTerminated is a ApplicationState enum value
    ApplicationStateTerminated = "TERMINATED"
)
const (
    // ArchitectureArm64 is a Architecture enum value
    ArchitectureArm64 = "ARM64"

    // ArchitectureX8664 is a Architecture enum value
    ArchitectureX8664 = "X86_64"
)
const (
    // JobRunStateSubmitted is a JobRunState enum value
    JobRunStateSubmitted = "SUBMITTED"

    // JobRunStatePending is a JobRunState enum value
    JobRunStatePending = "PENDING"

    // JobRunStateScheduled is a JobRunState enum value
    JobRunStateScheduled = "SCHEDULED"

    // JobRunStateRunning is a JobRunState enum value
    JobRunStateRunning = "RUNNING"

    // JobRunStateSuccess is a JobRunState enum value
    JobRunStateSuccess = "SUCCESS"

    // JobRunStateFailed is a JobRunState enum value
    JobRunStateFailed = "FAILED"

    // JobRunStateCancelling is a JobRunState enum value
    JobRunStateCancelling = "CANCELLING"

    // JobRunStateCancelled is a JobRunState enum value
    JobRunStateCancelled = "CANCELLED"
)
const (

    // ErrCodeConflictException for service response error code
    // "ConflictException".
    //
    // The request could not be processed because of conflict in the current state
    // of the resource.
    ErrCodeConflictException = "ConflictException"

    // ErrCodeInternalServerException for service response error code
    // "InternalServerException".
    //
    // Request processing failed because of an error or failure with the service.
    ErrCodeInternalServerException = "InternalServerException"

    // ErrCodeResourceNotFoundException for service response error code
    // "ResourceNotFoundException".
    //
    // The specified resource was not found.
    ErrCodeResourceNotFoundException = "ResourceNotFoundException"

    // ErrCodeServiceQuotaExceededException for service response error code
    // "ServiceQuotaExceededException".
    //
    // The maximum number of resources per account has been reached.
    ErrCodeServiceQuotaExceededException = "ServiceQuotaExceededException"

    // ErrCodeValidationException for service response error code
    // "ValidationException".
    //
    // The input fails to satisfy the constraints specified by an AWS service.
    ErrCodeValidationException = "ValidationException"
)
const (
    ServiceName = "EMR Serverless" // Name of service.
    EndpointsID = "emr-serverless" // ID to lookup a service endpoint with.
    ServiceID   = "EMR Serverless" // ServiceID is a unique identifier of a specific service.
)

Service information constants

func ApplicationState_Values

func ApplicationState_Values() []string

ApplicationState_Values returns all elements of the ApplicationState enum

func Architecture_Values

func Architecture_Values() []string

Architecture_Values returns all elements of the Architecture enum

func JobRunState_Values

func JobRunState_Values() []string

JobRunState_Values returns all elements of the JobRunState enum

type Application

type Application struct {

    // The ID of the application.
    //
    // ApplicationId is a required field
    ApplicationId *string `locationName:"applicationId" min:"1" type:"string" required:"true"`

    // The CPU architecture of an application.
    Architecture *string `locationName:"architecture" type:"string" enum:"Architecture"`

    // The ARN of the application.
    //
    // Arn is a required field
    Arn *string `locationName:"arn" min:"60" type:"string" required:"true"`

    // The configuration for an application to automatically start on job submission.
    AutoStartConfiguration *AutoStartConfig `locationName:"autoStartConfiguration" type:"structure"`

    // The configuration for an application to automatically stop after a certain
    // amount of time being idle.
    AutoStopConfiguration *AutoStopConfig `locationName:"autoStopConfiguration" type:"structure"`

    // The date and time when the application run was created.
    //
    // CreatedAt is a required field
    CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" required:"true"`

    // The initial capacity of the application.
    InitialCapacity map[string]*InitialCapacityConfig `locationName:"initialCapacity" type:"map"`

    // The maximum capacity of the application. This is cumulative across all workers
    // at any given point in time during the lifespan of the application is created.
    // No new resources will be created once any one of the defined limits is hit.
    MaximumCapacity *MaximumAllowedResources `locationName:"maximumCapacity" type:"structure"`

    // The name of the application.
    Name *string `locationName:"name" min:"1" type:"string"`

    // The network configuration for customer VPC connectivity for the application.
    NetworkConfiguration *NetworkConfiguration `locationName:"networkConfiguration" type:"structure"`

    // The EMR release version associated with the application.
    //
    // ReleaseLabel is a required field
    ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string" required:"true"`

    // The state of the application.
    //
    // State is a required field
    State *string `locationName:"state" type:"string" required:"true" enum:"ApplicationState"`

    // The state details of the application.
    StateDetails *string `locationName:"stateDetails" min:"1" type:"string"`

    // The tags assigned to the application.
    Tags map[string]*string `locationName:"tags" type:"map"`

    // The type of application, such as Spark or Hive.
    //
    // Type is a required field
    Type *string `locationName:"type" min:"1" type:"string" required:"true"`

    // The date and time when the application run was last updated.
    //
    // UpdatedAt is a required field
    UpdatedAt *time.Time `locationName:"updatedAt" type:"timestamp" required:"true"`
    // contains filtered or unexported fields
}

Information about an application. EMR Serverless uses applications to run jobs.

func (Application) GoString

func (s Application) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*Application) SetApplicationId

func (s *Application) SetApplicationId(v string) *Application

SetApplicationId sets the ApplicationId field's value.

func (*Application) SetArchitecture

func (s *Application) SetArchitecture(v string) *Application

SetArchitecture sets the Architecture field's value.

func (*Application) SetArn

func (s *Application) SetArn(v string) *Application

SetArn sets the Arn field's value.

func (*Application) SetAutoStartConfiguration

func (s *Application) SetAutoStartConfiguration(v *AutoStartConfig) *Application

SetAutoStartConfiguration sets the AutoStartConfiguration field's value.

func (*Application) SetAutoStopConfiguration

func (s *Application) SetAutoStopConfiguration(v *AutoStopConfig) *Application

SetAutoStopConfiguration sets the AutoStopConfiguration field's value.

func (*Application) SetCreatedAt

func (s *Application) SetCreatedAt(v time.Time) *Application

SetCreatedAt sets the CreatedAt field's value.

func (*Application) SetInitialCapacity

func (s *Application) SetInitialCapacity(v map[string]*InitialCapacityConfig) *Application

SetInitialCapacity sets the InitialCapacity field's value.

func (*Application) SetMaximumCapacity

func (s *Application) SetMaximumCapacity(v *MaximumAllowedResources) *Application

SetMaximumCapacity sets the MaximumCapacity field's value.

func (*Application) SetName

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

SetName sets the Name field's value.

func (*Application) SetNetworkConfiguration

func (s *Application) SetNetworkConfiguration(v *NetworkConfiguration) *Application

SetNetworkConfiguration sets the NetworkConfiguration field's value.

func (*Application) SetReleaseLabel

func (s *Application) SetReleaseLabel(v string) *Application

SetReleaseLabel sets the ReleaseLabel field's value.

func (*Application) SetState

func (s *Application) SetState(v string) *Application

SetState sets the State field's value.

func (*Application) SetStateDetails

func (s *Application) SetStateDetails(v string) *Application

SetStateDetails sets the StateDetails field's value.

func (*Application) SetTags

func (s *Application) SetTags(v map[string]*string) *Application

SetTags sets the Tags field's value.

func (*Application) SetType

func (s *Application) SetType(v string) *Application

SetType sets the Type field's value.

func (*Application) SetUpdatedAt

func (s *Application) SetUpdatedAt(v time.Time) *Application

SetUpdatedAt sets the UpdatedAt field's value.

func (Application) String

func (s Application) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ApplicationSummary

type ApplicationSummary struct {

    // The CPU architecture of an application.
    Architecture *string `locationName:"architecture" type:"string" enum:"Architecture"`

    // The ARN of the application.
    //
    // Arn is a required field
    Arn *string `locationName:"arn" min:"60" type:"string" required:"true"`

    // The date and time when the application was created.
    //
    // CreatedAt is a required field
    CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" required:"true"`

    // The ID of the application.
    //
    // Id is a required field
    Id *string `locationName:"id" min:"1" type:"string" required:"true"`

    // The name of the application.
    Name *string `locationName:"name" min:"1" type:"string"`

    // The EMR release version associated with the application.
    //
    // ReleaseLabel is a required field
    ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string" required:"true"`

    // The state of the application.
    //
    // State is a required field
    State *string `locationName:"state" type:"string" required:"true" enum:"ApplicationState"`

    // The state details of the application.
    StateDetails *string `locationName:"stateDetails" min:"1" type:"string"`

    // The type of application, such as Spark or Hive.
    //
    // Type is a required field
    Type *string `locationName:"type" min:"1" type:"string" required:"true"`

    // The date and time when the application was last updated.
    //
    // UpdatedAt is a required field
    UpdatedAt *time.Time `locationName:"updatedAt" type:"timestamp" required:"true"`
    // contains filtered or unexported fields
}

The summary of attributes associated with an application.

func (ApplicationSummary) GoString

func (s ApplicationSummary) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ApplicationSummary) SetArchitecture

func (s *ApplicationSummary) SetArchitecture(v string) *ApplicationSummary

SetArchitecture sets the Architecture field's value.

func (*ApplicationSummary) SetArn

func (s *ApplicationSummary) SetArn(v string) *ApplicationSummary

SetArn sets the Arn field's value.

func (*ApplicationSummary) SetCreatedAt

func (s *ApplicationSummary) SetCreatedAt(v time.Time) *ApplicationSummary

SetCreatedAt sets the CreatedAt field's value.

func (*ApplicationSummary) SetId

func (s *ApplicationSummary) SetId(v string) *ApplicationSummary

SetId sets the Id field's value.

func (*ApplicationSummary) SetName

func (s *ApplicationSummary) SetName(v string) *ApplicationSummary

SetName sets the Name field's value.

func (*ApplicationSummary) SetReleaseLabel

func (s *ApplicationSummary) SetReleaseLabel(v string) *ApplicationSummary

SetReleaseLabel sets the ReleaseLabel field's value.

func (*ApplicationSummary) SetState

func (s *ApplicationSummary) SetState(v string) *ApplicationSummary

SetState sets the State field's value.

func (*ApplicationSummary) SetStateDetails

func (s *ApplicationSummary) SetStateDetails(v string) *ApplicationSummary

SetStateDetails sets the StateDetails field's value.

func (*ApplicationSummary) SetType

func (s *ApplicationSummary) SetType(v string) *ApplicationSummary

SetType sets the Type field's value.

func (*ApplicationSummary) SetUpdatedAt

func (s *ApplicationSummary) SetUpdatedAt(v time.Time) *ApplicationSummary

SetUpdatedAt sets the UpdatedAt field's value.

func (ApplicationSummary) String

func (s ApplicationSummary) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type AutoStartConfig

type AutoStartConfig struct {

    // Enables the application to automatically start on job submission. Defaults
    // to true.
    Enabled *bool `locationName:"enabled" type:"boolean"`
    // contains filtered or unexported fields
}

The configuration for an application to automatically start on job submission.

func (AutoStartConfig) GoString

func (s AutoStartConfig) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*AutoStartConfig) SetEnabled

func (s *AutoStartConfig) SetEnabled(v bool) *AutoStartConfig

SetEnabled sets the Enabled field's value.

func (AutoStartConfig) String

func (s AutoStartConfig) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type AutoStopConfig

type AutoStopConfig struct {

    // Enables the application to automatically stop after a certain amount of time
    // being idle. Defaults to true.
    Enabled *bool `locationName:"enabled" type:"boolean"`

    // The amount of idle time in minutes after which your application will automatically
    // stop. Defaults to 15 minutes.
    IdleTimeoutMinutes *int64 `locationName:"idleTimeoutMinutes" min:"1" type:"integer"`
    // contains filtered or unexported fields
}

The configuration for an application to automatically stop after a certain amount of time being idle.

func (AutoStopConfig) GoString

func (s AutoStopConfig) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*AutoStopConfig) SetEnabled

func (s *AutoStopConfig) SetEnabled(v bool) *AutoStopConfig

SetEnabled sets the Enabled field's value.

func (*AutoStopConfig) SetIdleTimeoutMinutes

func (s *AutoStopConfig) SetIdleTimeoutMinutes(v int64) *AutoStopConfig

SetIdleTimeoutMinutes sets the IdleTimeoutMinutes field's value.

func (AutoStopConfig) String

func (s AutoStopConfig) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*AutoStopConfig) Validate

func (s *AutoStopConfig) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CancelJobRunInput

type CancelJobRunInput struct {

    // The ID of the application on which the job run will be canceled.
    //
    // ApplicationId is a required field
    ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"`

    // The ID of the job run to cancel.
    //
    // JobRunId is a required field
    JobRunId *string `location:"uri" locationName:"jobRunId" min:"1" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (CancelJobRunInput) GoString

func (s CancelJobRunInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CancelJobRunInput) SetApplicationId

func (s *CancelJobRunInput) SetApplicationId(v string) *CancelJobRunInput

SetApplicationId sets the ApplicationId field's value.

func (*CancelJobRunInput) SetJobRunId

func (s *CancelJobRunInput) SetJobRunId(v string) *CancelJobRunInput

SetJobRunId sets the JobRunId field's value.

func (CancelJobRunInput) String

func (s CancelJobRunInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CancelJobRunInput) Validate

func (s *CancelJobRunInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CancelJobRunOutput

type CancelJobRunOutput struct {

    // The output contains the application ID on which the job run is cancelled.
    //
    // ApplicationId is a required field
    ApplicationId *string `locationName:"applicationId" min:"1" type:"string" required:"true"`

    // The output contains the ID of the cancelled job run.
    //
    // JobRunId is a required field
    JobRunId *string `locationName:"jobRunId" min:"1" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (CancelJobRunOutput) GoString

func (s CancelJobRunOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CancelJobRunOutput) SetApplicationId

func (s *CancelJobRunOutput) SetApplicationId(v string) *CancelJobRunOutput

SetApplicationId sets the ApplicationId field's value.

func (*CancelJobRunOutput) SetJobRunId

func (s *CancelJobRunOutput) SetJobRunId(v string) *CancelJobRunOutput

SetJobRunId sets the JobRunId field's value.

func (CancelJobRunOutput) String

func (s CancelJobRunOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type Configuration

type Configuration struct {

    // The classification within a configuration.
    //
    // Classification is a required field
    Classification *string `locationName:"classification" min:"1" type:"string" required:"true"`

    // A list of additional configurations to apply within a configuration object.
    Configurations []*Configuration `locationName:"configurations" type:"list"`

    // A set of properties specified within a configuration classification.
    //
    // Properties is a sensitive parameter and its value will be
    // replaced with "sensitive" in string returned by Configuration's
    // String and GoString methods.
    Properties map[string]*string `locationName:"properties" type:"map" sensitive:"true"`
    // contains filtered or unexported fields
}

A configuration specification to be used when provisioning an application. A configuration consists of a classification, properties, and optional nested configurations. A classification refers to an application-specific configuration file. Properties are the settings you want to change in that file.

func (Configuration) GoString

func (s Configuration) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*Configuration) SetClassification

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

SetClassification sets the Classification field's value.

func (*Configuration) SetConfigurations

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

SetConfigurations sets the Configurations field's value.

func (*Configuration) SetProperties

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

SetProperties sets the Properties field's value.

func (Configuration) String

func (s Configuration) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*Configuration) Validate

func (s *Configuration) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ConfigurationOverrides

type ConfigurationOverrides struct {

    // The override configurations for the application.
    ApplicationConfiguration []*Configuration `locationName:"applicationConfiguration" type:"list"`

    // The override configurations for monitoring.
    MonitoringConfiguration *MonitoringConfiguration `locationName:"monitoringConfiguration" type:"structure"`
    // contains filtered or unexported fields
}

A configuration specification to be used to override existing configurations.

func (ConfigurationOverrides) GoString

func (s ConfigurationOverrides) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ConfigurationOverrides) SetApplicationConfiguration

func (s *ConfigurationOverrides) SetApplicationConfiguration(v []*Configuration) *ConfigurationOverrides

SetApplicationConfiguration sets the ApplicationConfiguration field's value.

func (*ConfigurationOverrides) SetMonitoringConfiguration

func (s *ConfigurationOverrides) SetMonitoringConfiguration(v *MonitoringConfiguration) *ConfigurationOverrides

SetMonitoringConfiguration sets the MonitoringConfiguration field's value.

func (ConfigurationOverrides) String

func (s ConfigurationOverrides) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ConfigurationOverrides) Validate

func (s *ConfigurationOverrides) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ConflictException

type ConflictException struct {
    RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

    Message_ *string `locationName:"message" min:"1" type:"string"`
    // contains filtered or unexported fields
}

The request could not be processed because of conflict in the current state of the resource.

func (*ConflictException) Code

func (s *ConflictException) Code() string

Code returns the exception type name.

func (*ConflictException) Error

func (s *ConflictException) Error() string

func (ConflictException) GoString

func (s ConflictException) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ConflictException) Message

func (s *ConflictException) Message() string

Message returns the exception's message.

func (*ConflictException) OrigErr

func (s *ConflictException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ConflictException) RequestID

func (s *ConflictException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ConflictException) StatusCode

func (s *ConflictException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ConflictException) String

func (s ConflictException) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type CreateApplicationInput

type CreateApplicationInput struct {

    // The CPU architecture of an application.
    Architecture *string `locationName:"architecture" type:"string" enum:"Architecture"`

    // The configuration for an application to automatically start on job submission.
    AutoStartConfiguration *AutoStartConfig `locationName:"autoStartConfiguration" type:"structure"`

    // The configuration for an application to automatically stop after a certain
    // amount of time being idle.
    AutoStopConfiguration *AutoStopConfig `locationName:"autoStopConfiguration" type:"structure"`

    // The client idempotency token of the application to create. Its value must
    // be unique for each request.
    ClientToken *string `locationName:"clientToken" min:"1" type:"string" idempotencyToken:"true"`

    // The capacity to initialize when the application is created.
    InitialCapacity map[string]*InitialCapacityConfig `locationName:"initialCapacity" type:"map"`

    // The maximum capacity to allocate when the application is created. This is
    // cumulative across all workers at any given point in time, not just when an
    // application is created. No new resources will be created once any one of
    // the defined limits is hit.
    MaximumCapacity *MaximumAllowedResources `locationName:"maximumCapacity" type:"structure"`

    // The name of the application.
    Name *string `locationName:"name" min:"1" type:"string"`

    // The network configuration for customer VPC connectivity.
    NetworkConfiguration *NetworkConfiguration `locationName:"networkConfiguration" type:"structure"`

    // The EMR release version associated with the application.
    //
    // ReleaseLabel is a required field
    ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string" required:"true"`

    // The tags assigned to the application.
    Tags map[string]*string `locationName:"tags" type:"map"`

    // The type of application you want to start, such as Spark or Hive.
    //
    // Type is a required field
    Type *string `locationName:"type" min:"1" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (CreateApplicationInput) GoString

func (s CreateApplicationInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CreateApplicationInput) SetArchitecture

func (s *CreateApplicationInput) SetArchitecture(v string) *CreateApplicationInput

SetArchitecture sets the Architecture field's value.

func (*CreateApplicationInput) SetAutoStartConfiguration

func (s *CreateApplicationInput) SetAutoStartConfiguration(v *AutoStartConfig) *CreateApplicationInput

SetAutoStartConfiguration sets the AutoStartConfiguration field's value.

func (*CreateApplicationInput) SetAutoStopConfiguration

func (s *CreateApplicationInput) SetAutoStopConfiguration(v *AutoStopConfig) *CreateApplicationInput

SetAutoStopConfiguration sets the AutoStopConfiguration field's value.

func (*CreateApplicationInput) SetClientToken

func (s *CreateApplicationInput) SetClientToken(v string) *CreateApplicationInput

SetClientToken sets the ClientToken field's value.

func (*CreateApplicationInput) SetInitialCapacity

func (s *CreateApplicationInput) SetInitialCapacity(v map[string]*InitialCapacityConfig) *CreateApplicationInput

SetInitialCapacity sets the InitialCapacity field's value.

func (*CreateApplicationInput) SetMaximumCapacity

func (s *CreateApplicationInput) SetMaximumCapacity(v *MaximumAllowedResources) *CreateApplicationInput

SetMaximumCapacity sets the MaximumCapacity field's value.

func (*CreateApplicationInput) SetName

func (s *CreateApplicationInput) SetName(v string) *CreateApplicationInput

SetName sets the Name field's value.

func (*CreateApplicationInput) SetNetworkConfiguration

func (s *CreateApplicationInput) SetNetworkConfiguration(v *NetworkConfiguration) *CreateApplicationInput

SetNetworkConfiguration sets the NetworkConfiguration field's value.

func (*CreateApplicationInput) SetReleaseLabel

func (s *CreateApplicationInput) SetReleaseLabel(v string) *CreateApplicationInput

SetReleaseLabel sets the ReleaseLabel field's value.

func (*CreateApplicationInput) SetTags

func (s *CreateApplicationInput) SetTags(v map[string]*string) *CreateApplicationInput

SetTags sets the Tags field's value.

func (*CreateApplicationInput) SetType

func (s *CreateApplicationInput) SetType(v string) *CreateApplicationInput

SetType sets the Type field's value.

func (CreateApplicationInput) String

func (s CreateApplicationInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CreateApplicationInput) Validate

func (s *CreateApplicationInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CreateApplicationOutput

type CreateApplicationOutput struct {

    // The output contains the application ID.
    //
    // ApplicationId is a required field
    ApplicationId *string `locationName:"applicationId" min:"1" type:"string" required:"true"`

    // The output contains the ARN of the application.
    //
    // Arn is a required field
    Arn *string `locationName:"arn" min:"60" type:"string" required:"true"`

    // The output contains the name of the application.
    Name *string `locationName:"name" min:"1" type:"string"`
    // contains filtered or unexported fields
}

func (CreateApplicationOutput) GoString

func (s CreateApplicationOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CreateApplicationOutput) SetApplicationId

func (s *CreateApplicationOutput) SetApplicationId(v string) *CreateApplicationOutput

SetApplicationId sets the ApplicationId field's value.

func (*CreateApplicationOutput) SetArn

func (s *CreateApplicationOutput) SetArn(v string) *CreateApplicationOutput

SetArn sets the Arn field's value.

func (*CreateApplicationOutput) SetName

func (s *CreateApplicationOutput) SetName(v string) *CreateApplicationOutput

SetName sets the Name field's value.

func (CreateApplicationOutput) String

func (s CreateApplicationOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type DeleteApplicationInput

type DeleteApplicationInput struct {

    // The ID of the application that will be deleted.
    //
    // ApplicationId is a required field
    ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (DeleteApplicationInput) GoString

func (s DeleteApplicationInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DeleteApplicationInput) SetApplicationId

func (s *DeleteApplicationInput) SetApplicationId(v string) *DeleteApplicationInput

SetApplicationId sets the ApplicationId field's value.

func (DeleteApplicationInput) String

func (s DeleteApplicationInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DeleteApplicationInput) Validate

func (s *DeleteApplicationInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DeleteApplicationOutput

type DeleteApplicationOutput struct {
    // contains filtered or unexported fields
}

func (DeleteApplicationOutput) GoString

func (s DeleteApplicationOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (DeleteApplicationOutput) String

func (s DeleteApplicationOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type EMRServerless

type EMRServerless struct {
    *client.Client
}

EMRServerless provides the API operation methods for making requests to EMR Serverless. See this package's package overview docs for details on the service.

EMRServerless methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.

func New

func New(p client.ConfigProvider, cfgs ...*aws.Config) *EMRServerless

New creates a new instance of the EMRServerless client with a session. If additional configuration is needed for the client instance use the optional aws.Config parameter to add your extra config.

Example:

mySession := session.Must(session.NewSession())

// Create a EMRServerless client from just a session.
svc := emrserverless.New(mySession)

// Create a EMRServerless client with additional configuration
svc := emrserverless.New(mySession, aws.NewConfig().WithRegion("us-west-2"))

func (*EMRServerless) CancelJobRun

func (c *EMRServerless) CancelJobRun(input *CancelJobRunInput) (*CancelJobRunOutput, error)

CancelJobRun API operation for EMR Serverless.

Cancels a job run.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation CancelJobRun for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException Request processing failed because of an error or failure with the service.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/CancelJobRun

func (*EMRServerless) CancelJobRunRequest

func (c *EMRServerless) CancelJobRunRequest(input *CancelJobRunInput) (req *request.Request, output *CancelJobRunOutput)

CancelJobRunRequest generates a "aws/request.Request" representing the client's request for the CancelJobRun operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See CancelJobRun for more information on using the CancelJobRun API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the CancelJobRunRequest method.
req, resp := client.CancelJobRunRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/CancelJobRun

func (*EMRServerless) CancelJobRunWithContext

func (c *EMRServerless) CancelJobRunWithContext(ctx aws.Context, input *CancelJobRunInput, opts ...request.Option) (*CancelJobRunOutput, error)

CancelJobRunWithContext is the same as CancelJobRun with the addition of the ability to pass a context and additional request options.

See CancelJobRun for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) CreateApplication

func (c *EMRServerless) CreateApplication(input *CreateApplicationInput) (*CreateApplicationOutput, error)

CreateApplication API operation for EMR Serverless.

Creates an application.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation CreateApplication for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • InternalServerException Request processing failed because of an error or failure with the service.

  • ConflictException The request could not be processed because of conflict in the current state of the resource.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/CreateApplication

func (*EMRServerless) CreateApplicationRequest

func (c *EMRServerless) CreateApplicationRequest(input *CreateApplicationInput) (req *request.Request, output *CreateApplicationOutput)

CreateApplicationRequest generates a "aws/request.Request" representing the client's request for the CreateApplication operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See CreateApplication for more information on using the CreateApplication API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the CreateApplicationRequest method.
req, resp := client.CreateApplicationRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/CreateApplication

func (*EMRServerless) CreateApplicationWithContext

func (c *EMRServerless) CreateApplicationWithContext(ctx aws.Context, input *CreateApplicationInput, opts ...request.Option) (*CreateApplicationOutput, error)

CreateApplicationWithContext is the same as CreateApplication with the addition of the ability to pass a context and additional request options.

See CreateApplication for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) DeleteApplication

func (c *EMRServerless) DeleteApplication(input *DeleteApplicationInput) (*DeleteApplicationOutput, error)

DeleteApplication API operation for EMR Serverless.

Deletes an application. An application has to be in a stopped or created state in order to be deleted.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation DeleteApplication for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException Request processing failed because of an error or failure with the service.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/DeleteApplication

func (*EMRServerless) DeleteApplicationRequest

func (c *EMRServerless) DeleteApplicationRequest(input *DeleteApplicationInput) (req *request.Request, output *DeleteApplicationOutput)

DeleteApplicationRequest generates a "aws/request.Request" representing the client's request for the DeleteApplication operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DeleteApplication for more information on using the DeleteApplication API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the DeleteApplicationRequest method.
req, resp := client.DeleteApplicationRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/DeleteApplication

func (*EMRServerless) DeleteApplicationWithContext

func (c *EMRServerless) DeleteApplicationWithContext(ctx aws.Context, input *DeleteApplicationInput, opts ...request.Option) (*DeleteApplicationOutput, error)

DeleteApplicationWithContext is the same as DeleteApplication with the addition of the ability to pass a context and additional request options.

See DeleteApplication for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) GetApplication

func (c *EMRServerless) GetApplication(input *GetApplicationInput) (*GetApplicationOutput, error)

GetApplication API operation for EMR Serverless.

Displays detailed information about a specified application.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation GetApplication for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException Request processing failed because of an error or failure with the service.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/GetApplication

func (*EMRServerless) GetApplicationRequest

func (c *EMRServerless) GetApplicationRequest(input *GetApplicationInput) (req *request.Request, output *GetApplicationOutput)

GetApplicationRequest generates a "aws/request.Request" representing the client's request for the GetApplication operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See GetApplication for more information on using the GetApplication API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the GetApplicationRequest method.
req, resp := client.GetApplicationRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/GetApplication

func (*EMRServerless) GetApplicationWithContext

func (c *EMRServerless) GetApplicationWithContext(ctx aws.Context, input *GetApplicationInput, opts ...request.Option) (*GetApplicationOutput, error)

GetApplicationWithContext is the same as GetApplication with the addition of the ability to pass a context and additional request options.

See GetApplication for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) GetDashboardForJobRun

func (c *EMRServerless) GetDashboardForJobRun(input *GetDashboardForJobRunInput) (*GetDashboardForJobRunOutput, error)

GetDashboardForJobRun API operation for EMR Serverless.

Returns a URL to access the job run dashboard.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation GetDashboardForJobRun for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException Request processing failed because of an error or failure with the service.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/GetDashboardForJobRun

func (*EMRServerless) GetDashboardForJobRunRequest

func (c *EMRServerless) GetDashboardForJobRunRequest(input *GetDashboardForJobRunInput) (req *request.Request, output *GetDashboardForJobRunOutput)

GetDashboardForJobRunRequest generates a "aws/request.Request" representing the client's request for the GetDashboardForJobRun operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See GetDashboardForJobRun for more information on using the GetDashboardForJobRun API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the GetDashboardForJobRunRequest method.
req, resp := client.GetDashboardForJobRunRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/GetDashboardForJobRun

func (*EMRServerless) GetDashboardForJobRunWithContext

func (c *EMRServerless) GetDashboardForJobRunWithContext(ctx aws.Context, input *GetDashboardForJobRunInput, opts ...request.Option) (*GetDashboardForJobRunOutput, error)

GetDashboardForJobRunWithContext is the same as GetDashboardForJobRun with the addition of the ability to pass a context and additional request options.

See GetDashboardForJobRun for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) GetJobRun

func (c *EMRServerless) GetJobRun(input *GetJobRunInput) (*GetJobRunOutput, error)

GetJobRun API operation for EMR Serverless.

Displays detailed information about a job run.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation GetJobRun for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException Request processing failed because of an error or failure with the service.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/GetJobRun

func (*EMRServerless) GetJobRunRequest

func (c *EMRServerless) GetJobRunRequest(input *GetJobRunInput) (req *request.Request, output *GetJobRunOutput)

GetJobRunRequest generates a "aws/request.Request" representing the client's request for the GetJobRun operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See GetJobRun for more information on using the GetJobRun API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the GetJobRunRequest method.
req, resp := client.GetJobRunRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/GetJobRun

func (*EMRServerless) GetJobRunWithContext

func (c *EMRServerless) GetJobRunWithContext(ctx aws.Context, input *GetJobRunInput, opts ...request.Option) (*GetJobRunOutput, error)

GetJobRunWithContext is the same as GetJobRun with the addition of the ability to pass a context and additional request options.

See GetJobRun for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) ListApplications

func (c *EMRServerless) ListApplications(input *ListApplicationsInput) (*ListApplicationsOutput, error)

ListApplications API operation for EMR Serverless.

Lists applications based on a set of parameters.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation ListApplications for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • InternalServerException Request processing failed because of an error or failure with the service.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/ListApplications

func (*EMRServerless) ListApplicationsPages

func (c *EMRServerless) ListApplicationsPages(input *ListApplicationsInput, fn func(*ListApplicationsOutput, bool) bool) error

ListApplicationsPages iterates over the pages of a ListApplications operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See ListApplications method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service.

// Example iterating over at most 3 pages of a ListApplications operation.
pageNum := 0
err := client.ListApplicationsPages(params,
    func(page *emrserverless.ListApplicationsOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*EMRServerless) ListApplicationsPagesWithContext

func (c *EMRServerless) ListApplicationsPagesWithContext(ctx aws.Context, input *ListApplicationsInput, fn func(*ListApplicationsOutput, bool) bool, opts ...request.Option) error

ListApplicationsPagesWithContext same as ListApplicationsPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) ListApplicationsRequest

func (c *EMRServerless) ListApplicationsRequest(input *ListApplicationsInput) (req *request.Request, output *ListApplicationsOutput)

ListApplicationsRequest generates a "aws/request.Request" representing the client's request for the ListApplications operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListApplications for more information on using the ListApplications API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the ListApplicationsRequest method.
req, resp := client.ListApplicationsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/ListApplications

func (*EMRServerless) ListApplicationsWithContext

func (c *EMRServerless) ListApplicationsWithContext(ctx aws.Context, input *ListApplicationsInput, opts ...request.Option) (*ListApplicationsOutput, error)

ListApplicationsWithContext is the same as ListApplications with the addition of the ability to pass a context and additional request options.

See ListApplications for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) ListJobRuns

func (c *EMRServerless) ListJobRuns(input *ListJobRunsInput) (*ListJobRunsOutput, error)

ListJobRuns API operation for EMR Serverless.

Lists job runs based on a set of parameters.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation ListJobRuns for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • InternalServerException Request processing failed because of an error or failure with the service.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/ListJobRuns

func (*EMRServerless) ListJobRunsPages

func (c *EMRServerless) ListJobRunsPages(input *ListJobRunsInput, fn func(*ListJobRunsOutput, bool) bool) error

ListJobRunsPages iterates over the pages of a ListJobRuns operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See ListJobRuns method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service.

// Example iterating over at most 3 pages of a ListJobRuns operation.
pageNum := 0
err := client.ListJobRunsPages(params,
    func(page *emrserverless.ListJobRunsOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*EMRServerless) ListJobRunsPagesWithContext

func (c *EMRServerless) ListJobRunsPagesWithContext(ctx aws.Context, input *ListJobRunsInput, fn func(*ListJobRunsOutput, bool) bool, opts ...request.Option) error

ListJobRunsPagesWithContext same as ListJobRunsPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) ListJobRunsRequest

func (c *EMRServerless) ListJobRunsRequest(input *ListJobRunsInput) (req *request.Request, output *ListJobRunsOutput)

ListJobRunsRequest generates a "aws/request.Request" representing the client's request for the ListJobRuns operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListJobRuns for more information on using the ListJobRuns API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the ListJobRunsRequest method.
req, resp := client.ListJobRunsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/ListJobRuns

func (*EMRServerless) ListJobRunsWithContext

func (c *EMRServerless) ListJobRunsWithContext(ctx aws.Context, input *ListJobRunsInput, opts ...request.Option) (*ListJobRunsOutput, error)

ListJobRunsWithContext is the same as ListJobRuns with the addition of the ability to pass a context and additional request options.

See ListJobRuns for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) ListTagsForResource

func (c *EMRServerless) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)

ListTagsForResource API operation for EMR Serverless.

Lists the tags assigned to the resources.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation ListTagsForResource for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException Request processing failed because of an error or failure with the service.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/ListTagsForResource

func (*EMRServerless) ListTagsForResourceRequest

func (c *EMRServerless) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)

ListTagsForResourceRequest generates a "aws/request.Request" representing the client's request for the ListTagsForResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListTagsForResource for more information on using the ListTagsForResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the ListTagsForResourceRequest method.
req, resp := client.ListTagsForResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/ListTagsForResource

func (*EMRServerless) ListTagsForResourceWithContext

func (c *EMRServerless) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)

ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of the ability to pass a context and additional request options.

See ListTagsForResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) StartApplication

func (c *EMRServerless) StartApplication(input *StartApplicationInput) (*StartApplicationOutput, error)

StartApplication API operation for EMR Serverless.

Starts a specified application and initializes initial capacity if configured.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation StartApplication for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException Request processing failed because of an error or failure with the service.

  • ServiceQuotaExceededException The maximum number of resources per account has been reached.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/StartApplication

func (*EMRServerless) StartApplicationRequest

func (c *EMRServerless) StartApplicationRequest(input *StartApplicationInput) (req *request.Request, output *StartApplicationOutput)

StartApplicationRequest generates a "aws/request.Request" representing the client's request for the StartApplication operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See StartApplication for more information on using the StartApplication API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the StartApplicationRequest method.
req, resp := client.StartApplicationRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/StartApplication

func (*EMRServerless) StartApplicationWithContext

func (c *EMRServerless) StartApplicationWithContext(ctx aws.Context, input *StartApplicationInput, opts ...request.Option) (*StartApplicationOutput, error)

StartApplicationWithContext is the same as StartApplication with the addition of the ability to pass a context and additional request options.

See StartApplication for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) StartJobRun

func (c *EMRServerless) StartJobRun(input *StartJobRunInput) (*StartJobRunOutput, error)

StartJobRun API operation for EMR Serverless.

Starts a job run.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation StartJobRun for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException Request processing failed because of an error or failure with the service.

  • ConflictException The request could not be processed because of conflict in the current state of the resource.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/StartJobRun

func (*EMRServerless) StartJobRunRequest

func (c *EMRServerless) StartJobRunRequest(input *StartJobRunInput) (req *request.Request, output *StartJobRunOutput)

StartJobRunRequest generates a "aws/request.Request" representing the client's request for the StartJobRun operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See StartJobRun for more information on using the StartJobRun API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the StartJobRunRequest method.
req, resp := client.StartJobRunRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/StartJobRun

func (*EMRServerless) StartJobRunWithContext

func (c *EMRServerless) StartJobRunWithContext(ctx aws.Context, input *StartJobRunInput, opts ...request.Option) (*StartJobRunOutput, error)

StartJobRunWithContext is the same as StartJobRun with the addition of the ability to pass a context and additional request options.

See StartJobRun for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) StopApplication

func (c *EMRServerless) StopApplication(input *StopApplicationInput) (*StopApplicationOutput, error)

StopApplication API operation for EMR Serverless.

Stops a specified application and releases initial capacity if configured. All scheduled and running jobs must be completed or cancelled before stopping an application.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation StopApplication for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException Request processing failed because of an error or failure with the service.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/StopApplication

func (*EMRServerless) StopApplicationRequest

func (c *EMRServerless) StopApplicationRequest(input *StopApplicationInput) (req *request.Request, output *StopApplicationOutput)

StopApplicationRequest generates a "aws/request.Request" representing the client's request for the StopApplication operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See StopApplication for more information on using the StopApplication API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the StopApplicationRequest method.
req, resp := client.StopApplicationRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/StopApplication

func (*EMRServerless) StopApplicationWithContext

func (c *EMRServerless) StopApplicationWithContext(ctx aws.Context, input *StopApplicationInput, opts ...request.Option) (*StopApplicationOutput, error)

StopApplicationWithContext is the same as StopApplication with the addition of the ability to pass a context and additional request options.

See StopApplication for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) TagResource

func (c *EMRServerless) TagResource(input *TagResourceInput) (*TagResourceOutput, error)

TagResource API operation for EMR Serverless.

Assigns tags to resources. A tag is a label that you assign to an AWS resource. Each tag consists of a key and an optional value, both of which you define. Tags enable you to categorize your AWS resources by attributes such as purpose, owner, or environment. When you have many resources of the same type, you can quickly identify a specific resource based on the tags you've assigned to it.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation TagResource for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException Request processing failed because of an error or failure with the service.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/TagResource

func (*EMRServerless) TagResourceRequest

func (c *EMRServerless) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)

TagResourceRequest generates a "aws/request.Request" representing the client's request for the TagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See TagResource for more information on using the TagResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the TagResourceRequest method.
req, resp := client.TagResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/TagResource

func (*EMRServerless) TagResourceWithContext

func (c *EMRServerless) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)

TagResourceWithContext is the same as TagResource with the addition of the ability to pass a context and additional request options.

See TagResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) UntagResource

func (c *EMRServerless) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)

UntagResource API operation for EMR Serverless.

Removes tags from resources.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation UntagResource for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException Request processing failed because of an error or failure with the service.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/UntagResource

func (*EMRServerless) UntagResourceRequest

func (c *EMRServerless) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)

UntagResourceRequest generates a "aws/request.Request" representing the client's request for the UntagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See UntagResource for more information on using the UntagResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the UntagResourceRequest method.
req, resp := client.UntagResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/UntagResource

func (*EMRServerless) UntagResourceWithContext

func (c *EMRServerless) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)

UntagResourceWithContext is the same as UntagResource with the addition of the ability to pass a context and additional request options.

See UntagResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRServerless) UpdateApplication

func (c *EMRServerless) UpdateApplication(input *UpdateApplicationInput) (*UpdateApplicationOutput, error)

UpdateApplication API operation for EMR Serverless.

Updates a specified application. An application has to be in a stopped or created state in order to be updated.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for EMR Serverless's API operation UpdateApplication for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an AWS service.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException Request processing failed because of an error or failure with the service.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/UpdateApplication

func (*EMRServerless) UpdateApplicationRequest

func (c *EMRServerless) UpdateApplicationRequest(input *UpdateApplicationInput) (req *request.Request, output *UpdateApplicationOutput)

UpdateApplicationRequest generates a "aws/request.Request" representing the client's request for the UpdateApplication operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See UpdateApplication for more information on using the UpdateApplication API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.

// Example sending a request using the UpdateApplicationRequest method.
req, resp := client.UpdateApplicationRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/UpdateApplication

func (*EMRServerless) UpdateApplicationWithContext

func (c *EMRServerless) UpdateApplicationWithContext(ctx aws.Context, input *UpdateApplicationInput, opts ...request.Option) (*UpdateApplicationOutput, error)

UpdateApplicationWithContext is the same as UpdateApplication with the addition of the ability to pass a context and additional request options.

See UpdateApplication for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

type GetApplicationInput

type GetApplicationInput struct {

    // The ID of the application that will be described.
    //
    // ApplicationId is a required field
    ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (GetApplicationInput) GoString

func (s GetApplicationInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*GetApplicationInput) SetApplicationId

func (s *GetApplicationInput) SetApplicationId(v string) *GetApplicationInput

SetApplicationId sets the ApplicationId field's value.

func (GetApplicationInput) String

func (s GetApplicationInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*GetApplicationInput) Validate

func (s *GetApplicationInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type GetApplicationOutput

type GetApplicationOutput struct {

    // The output displays information about the specified application.
    //
    // Application is a required field
    Application *Application `locationName:"application" type:"structure" required:"true"`
    // contains filtered or unexported fields
}

func (GetApplicationOutput) GoString

func (s GetApplicationOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*GetApplicationOutput) SetApplication

func (s *GetApplicationOutput) SetApplication(v *Application) *GetApplicationOutput

SetApplication sets the Application field's value.

func (GetApplicationOutput) String

func (s GetApplicationOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type GetDashboardForJobRunInput

type GetDashboardForJobRunInput struct {

    // The ID of the application.
    //
    // ApplicationId is a required field
    ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"`

    // The ID of the job run.
    //
    // JobRunId is a required field
    JobRunId *string `location:"uri" locationName:"jobRunId" min:"1" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (GetDashboardForJobRunInput) GoString

func (s GetDashboardForJobRunInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*GetDashboardForJobRunInput) SetApplicationId

func (s *GetDashboardForJobRunInput) SetApplicationId(v string) *GetDashboardForJobRunInput

SetApplicationId sets the ApplicationId field's value.

func (*GetDashboardForJobRunInput) SetJobRunId

func (s *GetDashboardForJobRunInput) SetJobRunId(v string) *GetDashboardForJobRunInput

SetJobRunId sets the JobRunId field's value.

func (GetDashboardForJobRunInput) String

func (s GetDashboardForJobRunInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*GetDashboardForJobRunInput) Validate

func (s *GetDashboardForJobRunInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type GetDashboardForJobRunOutput

type GetDashboardForJobRunOutput struct {

    // The URL to view job run's dashboard.
    Url *string `locationName:"url" min:"1" type:"string"`
    // contains filtered or unexported fields
}

func (GetDashboardForJobRunOutput) GoString

func (s GetDashboardForJobRunOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*GetDashboardForJobRunOutput) SetUrl

func (s *GetDashboardForJobRunOutput) SetUrl(v string) *GetDashboardForJobRunOutput

SetUrl sets the Url field's value.

func (GetDashboardForJobRunOutput) String

func (s GetDashboardForJobRunOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type GetJobRunInput

type GetJobRunInput struct {

    // The ID of the application on which the job run is submitted.
    //
    // ApplicationId is a required field
    ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"`

    // The ID of the job run.
    //
    // JobRunId is a required field
    JobRunId *string `location:"uri" locationName:"jobRunId" min:"1" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (GetJobRunInput) GoString

func (s GetJobRunInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*GetJobRunInput) SetApplicationId

func (s *GetJobRunInput) SetApplicationId(v string) *GetJobRunInput

SetApplicationId sets the ApplicationId field's value.

func (*GetJobRunInput) SetJobRunId

func (s *GetJobRunInput) SetJobRunId(v string) *GetJobRunInput

SetJobRunId sets the JobRunId field's value.

func (GetJobRunInput) String

func (s GetJobRunInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*GetJobRunInput) Validate

func (s *GetJobRunInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type GetJobRunOutput

type GetJobRunOutput struct {

    // The output displays information about the job run.
    //
    // JobRun is a required field
    JobRun *JobRun `locationName:"jobRun" type:"structure" required:"true"`
    // contains filtered or unexported fields
}

func (GetJobRunOutput) GoString

func (s GetJobRunOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*GetJobRunOutput) SetJobRun

func (s *GetJobRunOutput) SetJobRun(v *JobRun) *GetJobRunOutput

SetJobRun sets the JobRun field's value.

func (GetJobRunOutput) String

func (s GetJobRunOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type Hive

type Hive struct {

    // The query file for the Hive job run.
    //
    // InitQueryFile is a sensitive parameter and its value will be
    // replaced with "sensitive" in string returned by Hive's
    // String and GoString methods.
    InitQueryFile *string `locationName:"initQueryFile" min:"1" type:"string" sensitive:"true"`

    // The parameters for the Hive job run.
    //
    // Parameters is a sensitive parameter and its value will be
    // replaced with "sensitive" in string returned by Hive's
    // String and GoString methods.
    Parameters *string `locationName:"parameters" min:"1" type:"string" sensitive:"true"`

    // The query for the Hive job run.
    //
    // Query is a sensitive parameter and its value will be
    // replaced with "sensitive" in string returned by Hive's
    // String and GoString methods.
    //
    // Query is a required field
    Query *string `locationName:"query" min:"1" type:"string" required:"true" sensitive:"true"`
    // contains filtered or unexported fields
}

The configurations for the Hive job driver.

func (Hive) GoString

func (s Hive) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*Hive) SetInitQueryFile

func (s *Hive) SetInitQueryFile(v string) *Hive

SetInitQueryFile sets the InitQueryFile field's value.

func (*Hive) SetParameters

func (s *Hive) SetParameters(v string) *Hive

SetParameters sets the Parameters field's value.

func (*Hive) SetQuery

func (s *Hive) SetQuery(v string) *Hive

SetQuery sets the Query field's value.

func (Hive) String

func (s Hive) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*Hive) Validate

func (s *Hive) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type InitialCapacityConfig

type InitialCapacityConfig struct {

    // The resource configuration of the initial capacity configuration.
    WorkerConfiguration *WorkerResourceConfig `locationName:"workerConfiguration" type:"structure"`

    // The number of workers in the initial capacity configuration.
    //
    // WorkerCount is a required field
    WorkerCount *int64 `locationName:"workerCount" min:"1" type:"long" required:"true"`
    // contains filtered or unexported fields
}

The initial capacity configuration per worker.

func (InitialCapacityConfig) GoString

func (s InitialCapacityConfig) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*InitialCapacityConfig) SetWorkerConfiguration

func (s *InitialCapacityConfig) SetWorkerConfiguration(v *WorkerResourceConfig) *InitialCapacityConfig

SetWorkerConfiguration sets the WorkerConfiguration field's value.

func (*InitialCapacityConfig) SetWorkerCount

func (s *InitialCapacityConfig) SetWorkerCount(v int64) *InitialCapacityConfig

SetWorkerCount sets the WorkerCount field's value.

func (InitialCapacityConfig) String

func (s InitialCapacityConfig) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*InitialCapacityConfig) Validate

func (s *InitialCapacityConfig) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type InternalServerException

type InternalServerException struct {
    RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

    Message_ *string `locationName:"message" min:"1" type:"string"`
    // contains filtered or unexported fields
}

Request processing failed because of an error or failure with the service.

func (*InternalServerException) Code

func (s *InternalServerException) Code() string

Code returns the exception type name.

func (*InternalServerException) Error

func (s *InternalServerException) Error() string

func (InternalServerException) GoString

func (s InternalServerException) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*InternalServerException) Message

func (s *InternalServerException) Message() string

Message returns the exception's message.

func (*InternalServerException) OrigErr

func (s *InternalServerException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*InternalServerException) RequestID

func (s *InternalServerException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*InternalServerException) StatusCode

func (s *InternalServerException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (InternalServerException) String

func (s InternalServerException) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type JobDriver

type JobDriver struct {

    // The job driver parameters specified for Hive.
    Hive *Hive `locationName:"hive" type:"structure"`

    // The job driver parameters specified for Spark.
    SparkSubmit *SparkSubmit `locationName:"sparkSubmit" type:"structure"`
    // contains filtered or unexported fields
}

The driver that the job runs on.

func (JobDriver) GoString

func (s JobDriver) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*JobDriver) SetHive

func (s *JobDriver) SetHive(v *Hive) *JobDriver

SetHive sets the Hive field's value.

func (*JobDriver) SetSparkSubmit

func (s *JobDriver) SetSparkSubmit(v *SparkSubmit) *JobDriver

SetSparkSubmit sets the SparkSubmit field's value.

func (JobDriver) String

func (s JobDriver) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*JobDriver) Validate

func (s *JobDriver) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type JobRun

type JobRun struct {

    // The ID of the application the job is running on.
    //
    // ApplicationId is a required field
    ApplicationId *string `locationName:"applicationId" min:"1" type:"string" required:"true"`

    // The execution role ARN of the job run.
    //
    // Arn is a required field
    Arn *string `locationName:"arn" min:"60" type:"string" required:"true"`

    // The configuration settings that are used to override default configuration.
    ConfigurationOverrides *ConfigurationOverrides `locationName:"configurationOverrides" type:"structure"`

    // The date and time when the job run was created.
    //
    // CreatedAt is a required field
    CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" required:"true"`

    // The user who created the job run.
    //
    // CreatedBy is a required field
    CreatedBy *string `locationName:"createdBy" min:"20" type:"string" required:"true"`

    // The execution role ARN of the job run.
    //
    // ExecutionRole is a required field
    ExecutionRole *string `locationName:"executionRole" min:"20" type:"string" required:"true"`

    // The job driver for the job run.
    //
    // JobDriver is a required field
    JobDriver *JobDriver `locationName:"jobDriver" type:"structure" required:"true"`

    // The ID of the job run.
    //
    // JobRunId is a required field
    JobRunId *string `locationName:"jobRunId" min:"1" type:"string" required:"true"`

    // The optional job run name. This doesn't have to be unique.
    Name *string `locationName:"name" min:"1" type:"string"`

    // The network configuration for customer VPC connectivity.
    NetworkConfiguration *NetworkConfiguration `locationName:"networkConfiguration" type:"structure"`

    // The EMR release version associated with the application your job is running
    // on.
    //
    // ReleaseLabel is a required field
    ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string" required:"true"`

    // The state of the job run.
    //
    // State is a required field
    State *string `locationName:"state" type:"string" required:"true" enum:"JobRunState"`

    // The state details of the job run.
    //
    // StateDetails is a required field
    StateDetails *string `locationName:"stateDetails" min:"1" type:"string" required:"true"`

    // The tags assigned to the job run.
    Tags map[string]*string `locationName:"tags" type:"map"`

    // The job run total execution duration in seconds. This field is only available
    // for job runs in a COMPLETED, FAILED, or CANCELLED state.
    TotalExecutionDurationSeconds *int64 `locationName:"totalExecutionDurationSeconds" type:"integer"`

    // The aggregate vCPU, memory, and storage resources used from the time job
    // start executing till the time job is terminated, rounded up to the nearest
    // second.
    TotalResourceUtilization *TotalResourceUtilization `locationName:"totalResourceUtilization" type:"structure"`

    // The date and time when the job run was updated.
    //
    // UpdatedAt is a required field
    UpdatedAt *time.Time `locationName:"updatedAt" type:"timestamp" required:"true"`
    // contains filtered or unexported fields
}

Information about a job run. A job run is a unit of work, such as a Spark JAR, Hive query, or SparkSQL query, that you submit to an EMR Serverless application.

func (JobRun) GoString

func (s JobRun) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*JobRun) SetApplicationId

func (s *JobRun) SetApplicationId(v string) *JobRun

SetApplicationId sets the ApplicationId field's value.

func (*JobRun) SetArn

func (s *JobRun) SetArn(v string) *JobRun

SetArn sets the Arn field's value.

func (*JobRun) SetConfigurationOverrides

func (s *JobRun) SetConfigurationOverrides(v *ConfigurationOverrides) *JobRun

SetConfigurationOverrides sets the ConfigurationOverrides field's value.

func (*JobRun) SetCreatedAt

func (s *JobRun) SetCreatedAt(v time.Time) *JobRun

SetCreatedAt sets the CreatedAt field's value.

func (*JobRun) SetCreatedBy

func (s *JobRun) SetCreatedBy(v string) *JobRun

SetCreatedBy sets the CreatedBy field's value.

func (*JobRun) SetExecutionRole

func (s *JobRun) SetExecutionRole(v string) *JobRun

SetExecutionRole sets the ExecutionRole field's value.

func (*JobRun) SetJobDriver

func (s *JobRun) SetJobDriver(v *JobDriver) *JobRun

SetJobDriver sets the JobDriver field's value.

func (*JobRun) SetJobRunId

func (s *JobRun) SetJobRunId(v string) *JobRun

SetJobRunId sets the JobRunId field's value.

func (*JobRun) SetName

func (s *JobRun) SetName(v string) *JobRun

SetName sets the Name field's value.

func (*JobRun) SetNetworkConfiguration

func (s *JobRun) SetNetworkConfiguration(v *NetworkConfiguration) *JobRun

SetNetworkConfiguration sets the NetworkConfiguration field's value.

func (*JobRun) SetReleaseLabel

func (s *JobRun) SetReleaseLabel(v string) *JobRun

SetReleaseLabel sets the ReleaseLabel field's value.

func (*JobRun) SetState

func (s *JobRun) SetState(v string) *JobRun

SetState sets the State field's value.

func (*JobRun) SetStateDetails

func (s *JobRun) SetStateDetails(v string) *JobRun

SetStateDetails sets the StateDetails field's value.

func (*JobRun) SetTags

func (s *JobRun) SetTags(v map[string]*string) *JobRun

SetTags sets the Tags field's value.

func (*JobRun) SetTotalExecutionDurationSeconds

func (s *JobRun) SetTotalExecutionDurationSeconds(v int64) *JobRun

SetTotalExecutionDurationSeconds sets the TotalExecutionDurationSeconds field's value.

func (*JobRun) SetTotalResourceUtilization

func (s *JobRun) SetTotalResourceUtilization(v *TotalResourceUtilization) *JobRun

SetTotalResourceUtilization sets the TotalResourceUtilization field's value.

func (*JobRun) SetUpdatedAt

func (s *JobRun) SetUpdatedAt(v time.Time) *JobRun

SetUpdatedAt sets the UpdatedAt field's value.

func (JobRun) String

func (s JobRun) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type JobRunSummary

type JobRunSummary struct {

    // The ID of the application the job is running on.
    //
    // ApplicationId is a required field
    ApplicationId *string `locationName:"applicationId" min:"1" type:"string" required:"true"`

    // The ARN of the job run.
    //
    // Arn is a required field
    Arn *string `locationName:"arn" min:"60" type:"string" required:"true"`

    // The date and time when the job run was created.
    //
    // CreatedAt is a required field
    CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" required:"true"`

    // The user who created the job run.
    //
    // CreatedBy is a required field
    CreatedBy *string `locationName:"createdBy" min:"20" type:"string" required:"true"`

    // The execution role ARN of the job run.
    //
    // ExecutionRole is a required field
    ExecutionRole *string `locationName:"executionRole" min:"20" type:"string" required:"true"`

    // The ID of the job run.
    //
    // Id is a required field
    Id *string `locationName:"id" min:"1" type:"string" required:"true"`

    // The optional job run name. This doesn't have to be unique.
    Name *string `locationName:"name" min:"1" type:"string"`

    // The EMR release version associated with the application your job is running
    // on.
    //
    // ReleaseLabel is a required field
    ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string" required:"true"`

    // The state of the job run.
    //
    // State is a required field
    State *string `locationName:"state" type:"string" required:"true" enum:"JobRunState"`

    // The state details of the job run.
    //
    // StateDetails is a required field
    StateDetails *string `locationName:"stateDetails" min:"1" type:"string" required:"true"`

    // The type of job run, such as Spark or Hive.
    Type *string `locationName:"type" type:"string"`

    // The date and time when the job run was last updated.
    //
    // UpdatedAt is a required field
    UpdatedAt *time.Time `locationName:"updatedAt" type:"timestamp" required:"true"`
    // contains filtered or unexported fields
}

The summary of attributes associated with a job run.

func (JobRunSummary) GoString

func (s JobRunSummary) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*JobRunSummary) SetApplicationId

func (s *JobRunSummary) SetApplicationId(v string) *JobRunSummary

SetApplicationId sets the ApplicationId field's value.

func (*JobRunSummary) SetArn

func (s *JobRunSummary) SetArn(v string) *JobRunSummary

SetArn sets the Arn field's value.

func (*JobRunSummary) SetCreatedAt

func (s *JobRunSummary) SetCreatedAt(v time.Time) *JobRunSummary

SetCreatedAt sets the CreatedAt field's value.

func (*JobRunSummary) SetCreatedBy

func (s *JobRunSummary) SetCreatedBy(v string) *JobRunSummary

SetCreatedBy sets the CreatedBy field's value.

func (*JobRunSummary) SetExecutionRole

func (s *JobRunSummary) SetExecutionRole(v string) *JobRunSummary

SetExecutionRole sets the ExecutionRole field's value.

func (*JobRunSummary) SetId

func (s *JobRunSummary) SetId(v string) *JobRunSummary

SetId sets the Id field's value.

func (*JobRunSummary) SetName

func (s *JobRunSummary) SetName(v string) *JobRunSummary

SetName sets the Name field's value.

func (*JobRunSummary) SetReleaseLabel

func (s *JobRunSummary) SetReleaseLabel(v string) *JobRunSummary

SetReleaseLabel sets the ReleaseLabel field's value.

func (*JobRunSummary) SetState

func (s *JobRunSummary) SetState(v string) *JobRunSummary

SetState sets the State field's value.

func (*JobRunSummary) SetStateDetails

func (s *JobRunSummary) SetStateDetails(v string) *JobRunSummary

SetStateDetails sets the StateDetails field's value.

func (*JobRunSummary) SetType

func (s *JobRunSummary) SetType(v string) *JobRunSummary

SetType sets the Type field's value.

func (*JobRunSummary) SetUpdatedAt

func (s *JobRunSummary) SetUpdatedAt(v time.Time) *JobRunSummary

SetUpdatedAt sets the UpdatedAt field's value.

func (JobRunSummary) String

func (s JobRunSummary) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ListApplicationsInput

type ListApplicationsInput struct {

    // The maximum number of applications that can be listed.
    MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`

    // The token for the next set of application results.
    NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"`

    // An optional filter for application states. Note that if this filter contains
    // multiple states, the resulting list will be grouped by the state.
    States []*string `location:"querystring" locationName:"states" min:"1" type:"list" enum:"ApplicationState"`
    // contains filtered or unexported fields
}

func (ListApplicationsInput) GoString

func (s ListApplicationsInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListApplicationsInput) SetMaxResults

func (s *ListApplicationsInput) SetMaxResults(v int64) *ListApplicationsInput

SetMaxResults sets the MaxResults field's value.

func (*ListApplicationsInput) SetNextToken

func (s *ListApplicationsInput) SetNextToken(v string) *ListApplicationsInput

SetNextToken sets the NextToken field's value.

func (*ListApplicationsInput) SetStates

func (s *ListApplicationsInput) SetStates(v []*string) *ListApplicationsInput

SetStates sets the States field's value.

func (ListApplicationsInput) String

func (s ListApplicationsInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListApplicationsInput) Validate

func (s *ListApplicationsInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListApplicationsOutput

type ListApplicationsOutput struct {

    // The output lists the specified applications.
    //
    // Applications is a required field
    Applications []*ApplicationSummary `locationName:"applications" type:"list" required:"true"`

    // The output displays the token for the next set of application results. This
    // is required for pagination and is available as a response of the previous
    // request.
    NextToken *string `locationName:"nextToken" min:"1" type:"string"`
    // contains filtered or unexported fields
}

func (ListApplicationsOutput) GoString

func (s ListApplicationsOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListApplicationsOutput) SetApplications

func (s *ListApplicationsOutput) SetApplications(v []*ApplicationSummary) *ListApplicationsOutput

SetApplications sets the Applications field's value.

func (*ListApplicationsOutput) SetNextToken

func (s *ListApplicationsOutput) SetNextToken(v string) *ListApplicationsOutput

SetNextToken sets the NextToken field's value.

func (ListApplicationsOutput) String

func (s ListApplicationsOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ListJobRunsInput

type ListJobRunsInput struct {

    // The ID of the application for which to list the job run.
    //
    // ApplicationId is a required field
    ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"`

    // The lower bound of the option to filter by creation date and time.
    CreatedAtAfter *time.Time `location:"querystring" locationName:"createdAtAfter" type:"timestamp"`

    // The upper bound of the option to filter by creation date and time.
    CreatedAtBefore *time.Time `location:"querystring" locationName:"createdAtBefore" type:"timestamp"`

    // The maximum number of job runs that can be listed.
    MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`

    // The token for the next set of job run results.
    NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"`

    // An optional filter for job run states. Note that if this filter contains
    // multiple states, the resulting list will be grouped by the state.
    States []*string `location:"querystring" locationName:"states" type:"list" enum:"JobRunState"`
    // contains filtered or unexported fields
}

func (ListJobRunsInput) GoString

func (s ListJobRunsInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListJobRunsInput) SetApplicationId

func (s *ListJobRunsInput) SetApplicationId(v string) *ListJobRunsInput

SetApplicationId sets the ApplicationId field's value.

func (*ListJobRunsInput) SetCreatedAtAfter

func (s *ListJobRunsInput) SetCreatedAtAfter(v time.Time) *ListJobRunsInput

SetCreatedAtAfter sets the CreatedAtAfter field's value.

func (*ListJobRunsInput) SetCreatedAtBefore

func (s *ListJobRunsInput) SetCreatedAtBefore(v time.Time) *ListJobRunsInput

SetCreatedAtBefore sets the CreatedAtBefore field's value.

func (*ListJobRunsInput) SetMaxResults

func (s *ListJobRunsInput) SetMaxResults(v int64) *ListJobRunsInput

SetMaxResults sets the MaxResults field's value.

func (*ListJobRunsInput) SetNextToken

func (s *ListJobRunsInput) SetNextToken(v string) *ListJobRunsInput

SetNextToken sets the NextToken field's value.

func (*ListJobRunsInput) SetStates

func (s *ListJobRunsInput) SetStates(v []*string) *ListJobRunsInput

SetStates sets the States field's value.

func (ListJobRunsInput) String

func (s ListJobRunsInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListJobRunsInput) Validate

func (s *ListJobRunsInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListJobRunsOutput

type ListJobRunsOutput struct {

    // The output lists information about the specified job runs.
    //
    // JobRuns is a required field
    JobRuns []*JobRunSummary `locationName:"jobRuns" type:"list" required:"true"`

    // The output displays the token for the next set of job run results. This is
    // required for pagination and is available as a response of the previous request.
    NextToken *string `locationName:"nextToken" min:"1" type:"string"`
    // contains filtered or unexported fields
}

func (ListJobRunsOutput) GoString

func (s ListJobRunsOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListJobRunsOutput) SetJobRuns

func (s *ListJobRunsOutput) SetJobRuns(v []*JobRunSummary) *ListJobRunsOutput

SetJobRuns sets the JobRuns field's value.

func (*ListJobRunsOutput) SetNextToken

func (s *ListJobRunsOutput) SetNextToken(v string) *ListJobRunsOutput

SetNextToken sets the NextToken field's value.

func (ListJobRunsOutput) String

func (s ListJobRunsOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ListTagsForResourceInput

type ListTagsForResourceInput struct {

    // The Amazon Resource Name (ARN) that identifies the resource to list the tags
    // for. Currently, the supported resources are Amazon EMR Serverless applications
    // and job runs.
    //
    // ResourceArn is a required field
    ResourceArn *string `location:"uri" locationName:"resourceArn" min:"60" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (ListTagsForResourceInput) GoString

func (s ListTagsForResourceInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListTagsForResourceInput) SetResourceArn

func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput

SetResourceArn sets the ResourceArn field's value.

func (ListTagsForResourceInput) String

func (s ListTagsForResourceInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListTagsForResourceInput) Validate

func (s *ListTagsForResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListTagsForResourceOutput

type ListTagsForResourceOutput struct {

    // The tags for the resource.
    Tags map[string]*string `locationName:"tags" type:"map"`
    // contains filtered or unexported fields
}

func (ListTagsForResourceOutput) GoString

func (s ListTagsForResourceOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListTagsForResourceOutput) SetTags

func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput

SetTags sets the Tags field's value.

func (ListTagsForResourceOutput) String

func (s ListTagsForResourceOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ManagedPersistenceMonitoringConfiguration

type ManagedPersistenceMonitoringConfiguration struct {

    // Enables managed logging and defaults to true. If set to false, managed logging
    // will be turned off.
    Enabled *bool `locationName:"enabled" type:"boolean"`

    // The KMS key ARN to encrypt the logs stored in managed log persistence.
    EncryptionKeyArn *string `locationName:"encryptionKeyArn" min:"20" type:"string"`
    // contains filtered or unexported fields
}

The managed log persistence configuration for a job run.

func (ManagedPersistenceMonitoringConfiguration) GoString

func (s ManagedPersistenceMonitoringConfiguration) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ManagedPersistenceMonitoringConfiguration) SetEnabled

func (s *ManagedPersistenceMonitoringConfiguration) SetEnabled(v bool) *ManagedPersistenceMonitoringConfiguration

SetEnabled sets the Enabled field's value.

func (*ManagedPersistenceMonitoringConfiguration) SetEncryptionKeyArn

func (s *ManagedPersistenceMonitoringConfiguration) SetEncryptionKeyArn(v string) *ManagedPersistenceMonitoringConfiguration

SetEncryptionKeyArn sets the EncryptionKeyArn field's value.

func (ManagedPersistenceMonitoringConfiguration) String

func (s ManagedPersistenceMonitoringConfiguration) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ManagedPersistenceMonitoringConfiguration) Validate

func (s *ManagedPersistenceMonitoringConfiguration) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type MaximumAllowedResources

type MaximumAllowedResources struct {

    // The maximum allowed CPU for an application.
    //
    // Cpu is a required field
    Cpu *string `locationName:"cpu" min:"1" type:"string" required:"true"`

    // The maximum allowed disk for an application.
    Disk *string `locationName:"disk" min:"1" type:"string"`

    // The maximum allowed resources for an application.
    //
    // Memory is a required field
    Memory *string `locationName:"memory" min:"1" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The maximum allowed cumulative resources for an application. No new resources will be created once the limit is hit.

func (MaximumAllowedResources) GoString

func (s MaximumAllowedResources) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*MaximumAllowedResources) SetCpu

func (s *MaximumAllowedResources) SetCpu(v string) *MaximumAllowedResources

SetCpu sets the Cpu field's value.

func (*MaximumAllowedResources) SetDisk

func (s *MaximumAllowedResources) SetDisk(v string) *MaximumAllowedResources

SetDisk sets the Disk field's value.

func (*MaximumAllowedResources) SetMemory

func (s *MaximumAllowedResources) SetMemory(v string) *MaximumAllowedResources

SetMemory sets the Memory field's value.

func (MaximumAllowedResources) String

func (s MaximumAllowedResources) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*MaximumAllowedResources) Validate

func (s *MaximumAllowedResources) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type MonitoringConfiguration

type MonitoringConfiguration struct {

    // The managed log persistence configuration for a job run.
    ManagedPersistenceMonitoringConfiguration *ManagedPersistenceMonitoringConfiguration `locationName:"managedPersistenceMonitoringConfiguration" type:"structure"`

    // The Amazon S3 configuration for monitoring log publishing.
    S3MonitoringConfiguration *S3MonitoringConfiguration `locationName:"s3MonitoringConfiguration" type:"structure"`
    // contains filtered or unexported fields
}

The configuration setting for monitoring.

func (MonitoringConfiguration) GoString

func (s MonitoringConfiguration) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*MonitoringConfiguration) SetManagedPersistenceMonitoringConfiguration

func (s *MonitoringConfiguration) SetManagedPersistenceMonitoringConfiguration(v *ManagedPersistenceMonitoringConfiguration) *MonitoringConfiguration

SetManagedPersistenceMonitoringConfiguration sets the ManagedPersistenceMonitoringConfiguration field's value.

func (*MonitoringConfiguration) SetS3MonitoringConfiguration

func (s *MonitoringConfiguration) SetS3MonitoringConfiguration(v *S3MonitoringConfiguration) *MonitoringConfiguration

SetS3MonitoringConfiguration sets the S3MonitoringConfiguration field's value.

func (MonitoringConfiguration) String

func (s MonitoringConfiguration) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*MonitoringConfiguration) Validate

func (s *MonitoringConfiguration) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type NetworkConfiguration

type NetworkConfiguration struct {

    // The array of security group Ids for customer VPC connectivity.
    SecurityGroupIds []*string `locationName:"securityGroupIds" type:"list"`

    // The array of subnet Ids for customer VPC connectivity.
    SubnetIds []*string `locationName:"subnetIds" type:"list"`
    // contains filtered or unexported fields
}

The network configuration for customer VPC connectivity.

func (NetworkConfiguration) GoString

func (s NetworkConfiguration) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*NetworkConfiguration) SetSecurityGroupIds

func (s *NetworkConfiguration) SetSecurityGroupIds(v []*string) *NetworkConfiguration

SetSecurityGroupIds sets the SecurityGroupIds field's value.

func (*NetworkConfiguration) SetSubnetIds

func (s *NetworkConfiguration) SetSubnetIds(v []*string) *NetworkConfiguration

SetSubnetIds sets the SubnetIds field's value.

func (NetworkConfiguration) String

func (s NetworkConfiguration) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ResourceNotFoundException

type ResourceNotFoundException struct {
    RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

    Message_ *string `locationName:"message" min:"1" type:"string"`
    // contains filtered or unexported fields
}

The specified resource was not found.

func (*ResourceNotFoundException) Code

func (s *ResourceNotFoundException) Code() string

Code returns the exception type name.

func (*ResourceNotFoundException) Error

func (s *ResourceNotFoundException) Error() string

func (ResourceNotFoundException) GoString

func (s ResourceNotFoundException) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ResourceNotFoundException) Message

func (s *ResourceNotFoundException) Message() string

Message returns the exception's message.

func (*ResourceNotFoundException) OrigErr

func (s *ResourceNotFoundException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ResourceNotFoundException) RequestID

func (s *ResourceNotFoundException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ResourceNotFoundException) StatusCode

func (s *ResourceNotFoundException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ResourceNotFoundException) String

func (s ResourceNotFoundException) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type S3MonitoringConfiguration

type S3MonitoringConfiguration struct {

    // The KMS key ARN to encrypt the logs published to the given Amazon S3 destination.
    EncryptionKeyArn *string `locationName:"encryptionKeyArn" min:"20" type:"string"`

    // The Amazon S3 destination URI for log publishing.
    LogUri *string `locationName:"logUri" min:"1" type:"string"`
    // contains filtered or unexported fields
}

The Amazon S3 configuration for monitoring log publishing. You can configure your jobs to send log information to Amazon S3.

func (S3MonitoringConfiguration) GoString

func (s S3MonitoringConfiguration) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*S3MonitoringConfiguration) SetEncryptionKeyArn

func (s *S3MonitoringConfiguration) SetEncryptionKeyArn(v string) *S3MonitoringConfiguration

SetEncryptionKeyArn sets the EncryptionKeyArn field's value.

func (*S3MonitoringConfiguration) SetLogUri

func (s *S3MonitoringConfiguration) SetLogUri(v string) *S3MonitoringConfiguration

SetLogUri sets the LogUri field's value.

func (S3MonitoringConfiguration) String

func (s S3MonitoringConfiguration) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*S3MonitoringConfiguration) Validate

func (s *S3MonitoringConfiguration) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ServiceQuotaExceededException

type ServiceQuotaExceededException struct {
    RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

    Message_ *string `locationName:"message" min:"1" type:"string"`
    // contains filtered or unexported fields
}

The maximum number of resources per account has been reached.

func (*ServiceQuotaExceededException) Code

func (s *ServiceQuotaExceededException) Code() string

Code returns the exception type name.

func (*ServiceQuotaExceededException) Error

func (s *ServiceQuotaExceededException) Error() string

func (ServiceQuotaExceededException) GoString

func (s ServiceQuotaExceededException) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ServiceQuotaExceededException) Message

func (s *ServiceQuotaExceededException) Message() string

Message returns the exception's message.

func (*ServiceQuotaExceededException) OrigErr

func (s *ServiceQuotaExceededException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ServiceQuotaExceededException) RequestID

func (s *ServiceQuotaExceededException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ServiceQuotaExceededException) StatusCode

func (s *ServiceQuotaExceededException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ServiceQuotaExceededException) String

func (s ServiceQuotaExceededException) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type SparkSubmit

type SparkSubmit struct {

    // The entry point for the Spark submit job run.
    //
    // EntryPoint is a sensitive parameter and its value will be
    // replaced with "sensitive" in string returned by SparkSubmit's
    // String and GoString methods.
    //
    // EntryPoint is a required field
    EntryPoint *string `locationName:"entryPoint" min:"1" type:"string" required:"true" sensitive:"true"`

    // The arguments for the Spark submit job run.
    EntryPointArguments []*string `locationName:"entryPointArguments" type:"list"`

    // The parameters for the Spark submit job run.
    //
    // SparkSubmitParameters is a sensitive parameter and its value will be
    // replaced with "sensitive" in string returned by SparkSubmit's
    // String and GoString methods.
    SparkSubmitParameters *string `locationName:"sparkSubmitParameters" min:"1" type:"string" sensitive:"true"`
    // contains filtered or unexported fields
}

The configurations for the Spark submit job driver.

func (SparkSubmit) GoString

func (s SparkSubmit) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*SparkSubmit) SetEntryPoint

func (s *SparkSubmit) SetEntryPoint(v string) *SparkSubmit

SetEntryPoint sets the EntryPoint field's value.

func (*SparkSubmit) SetEntryPointArguments

func (s *SparkSubmit) SetEntryPointArguments(v []*string) *SparkSubmit

SetEntryPointArguments sets the EntryPointArguments field's value.

func (*SparkSubmit) SetSparkSubmitParameters

func (s *SparkSubmit) SetSparkSubmitParameters(v string) *SparkSubmit

SetSparkSubmitParameters sets the SparkSubmitParameters field's value.

func (SparkSubmit) String

func (s SparkSubmit) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*SparkSubmit) Validate

func (s *SparkSubmit) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type StartApplicationInput

type StartApplicationInput struct {

    // The ID of the application to start.
    //
    // ApplicationId is a required field
    ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (StartApplicationInput) GoString

func (s StartApplicationInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StartApplicationInput) SetApplicationId

func (s *StartApplicationInput) SetApplicationId(v string) *StartApplicationInput

SetApplicationId sets the ApplicationId field's value.

func (StartApplicationInput) String

func (s StartApplicationInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StartApplicationInput) Validate

func (s *StartApplicationInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type StartApplicationOutput

type StartApplicationOutput struct {
    // contains filtered or unexported fields
}

func (StartApplicationOutput) GoString

func (s StartApplicationOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (StartApplicationOutput) String

func (s StartApplicationOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type StartJobRunInput

type StartJobRunInput struct {

    // The ID of the application on which to run the job.
    //
    // ApplicationId is a required field
    ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"`

    // The client idempotency token of the job run to start. Its value must be unique
    // for each request.
    ClientToken *string `locationName:"clientToken" min:"1" type:"string" idempotencyToken:"true"`

    // The configuration overrides for the job run.
    ConfigurationOverrides *ConfigurationOverrides `locationName:"configurationOverrides" type:"structure"`

    // The execution role ARN for the job run.
    //
    // ExecutionRoleArn is a required field
    ExecutionRoleArn *string `locationName:"executionRoleArn" min:"20" type:"string" required:"true"`

    // The maximum duration for the job run to run. If the job run runs beyond this
    // duration, it will be automatically cancelled.
    ExecutionTimeoutMinutes *int64 `locationName:"executionTimeoutMinutes" type:"long"`

    // The job driver for the job run.
    JobDriver *JobDriver `locationName:"jobDriver" type:"structure"`

    // The optional job run name. This doesn't have to be unique.
    Name *string `locationName:"name" min:"1" type:"string"`

    // The tags assigned to the job run.
    Tags map[string]*string `locationName:"tags" type:"map"`
    // contains filtered or unexported fields
}

func (StartJobRunInput) GoString

func (s StartJobRunInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StartJobRunInput) SetApplicationId

func (s *StartJobRunInput) SetApplicationId(v string) *StartJobRunInput

SetApplicationId sets the ApplicationId field's value.

func (*StartJobRunInput) SetClientToken

func (s *StartJobRunInput) SetClientToken(v string) *StartJobRunInput

SetClientToken sets the ClientToken field's value.

func (*StartJobRunInput) SetConfigurationOverrides

func (s *StartJobRunInput) SetConfigurationOverrides(v *ConfigurationOverrides) *StartJobRunInput

SetConfigurationOverrides sets the ConfigurationOverrides field's value.

func (*StartJobRunInput) SetExecutionRoleArn

func (s *StartJobRunInput) SetExecutionRoleArn(v string) *StartJobRunInput

SetExecutionRoleArn sets the ExecutionRoleArn field's value.

func (*StartJobRunInput) SetExecutionTimeoutMinutes

func (s *StartJobRunInput) SetExecutionTimeoutMinutes(v int64) *StartJobRunInput

SetExecutionTimeoutMinutes sets the ExecutionTimeoutMinutes field's value.

func (*StartJobRunInput) SetJobDriver

func (s *StartJobRunInput) SetJobDriver(v *JobDriver) *StartJobRunInput

SetJobDriver sets the JobDriver field's value.

func (*StartJobRunInput) SetName

func (s *StartJobRunInput) SetName(v string) *StartJobRunInput

SetName sets the Name field's value.

func (*StartJobRunInput) SetTags

func (s *StartJobRunInput) SetTags(v map[string]*string) *StartJobRunInput

SetTags sets the Tags field's value.

func (StartJobRunInput) String

func (s StartJobRunInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StartJobRunInput) Validate

func (s *StartJobRunInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type StartJobRunOutput

type StartJobRunOutput struct {

    // This output displays the application ID on which the job run was submitted.
    //
    // ApplicationId is a required field
    ApplicationId *string `locationName:"applicationId" min:"1" type:"string" required:"true"`

    // The output lists the execution role ARN of the job run.
    //
    // Arn is a required field
    Arn *string `locationName:"arn" min:"60" type:"string" required:"true"`

    // The output contains the ID of the started job run.
    //
    // JobRunId is a required field
    JobRunId *string `locationName:"jobRunId" min:"1" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (StartJobRunOutput) GoString

func (s StartJobRunOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StartJobRunOutput) SetApplicationId

func (s *StartJobRunOutput) SetApplicationId(v string) *StartJobRunOutput

SetApplicationId sets the ApplicationId field's value.

func (*StartJobRunOutput) SetArn

func (s *StartJobRunOutput) SetArn(v string) *StartJobRunOutput

SetArn sets the Arn field's value.

func (*StartJobRunOutput) SetJobRunId

func (s *StartJobRunOutput) SetJobRunId(v string) *StartJobRunOutput

SetJobRunId sets the JobRunId field's value.

func (StartJobRunOutput) String

func (s StartJobRunOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type StopApplicationInput

type StopApplicationInput struct {

    // The ID of the application to stop.
    //
    // ApplicationId is a required field
    ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (StopApplicationInput) GoString

func (s StopApplicationInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StopApplicationInput) SetApplicationId

func (s *StopApplicationInput) SetApplicationId(v string) *StopApplicationInput

SetApplicationId sets the ApplicationId field's value.

func (StopApplicationInput) String

func (s StopApplicationInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StopApplicationInput) Validate

func (s *StopApplicationInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type StopApplicationOutput

type StopApplicationOutput struct {
    // contains filtered or unexported fields
}

func (StopApplicationOutput) GoString

func (s StopApplicationOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (StopApplicationOutput) String

func (s StopApplicationOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type TagResourceInput

type TagResourceInput struct {

    // The Amazon Resource Name (ARN) that identifies the resource to list the tags
    // for. Currently, the supported resources are Amazon EMR Serverless applications
    // and job runs.
    //
    // ResourceArn is a required field
    ResourceArn *string `location:"uri" locationName:"resourceArn" min:"60" type:"string" required:"true"`

    // The tags to add to the resource. A tag is an array of key-value pairs.
    //
    // Tags is a required field
    Tags map[string]*string `locationName:"tags" type:"map" required:"true"`
    // contains filtered or unexported fields
}

func (TagResourceInput) GoString

func (s TagResourceInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*TagResourceInput) SetResourceArn

func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput

SetResourceArn sets the ResourceArn field's value.

func (*TagResourceInput) SetTags

func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput

SetTags sets the Tags field's value.

func (TagResourceInput) String

func (s TagResourceInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*TagResourceInput) Validate

func (s *TagResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type TagResourceOutput

type TagResourceOutput struct {
    // contains filtered or unexported fields
}

func (TagResourceOutput) GoString

func (s TagResourceOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (TagResourceOutput) String

func (s TagResourceOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type TotalResourceUtilization

type TotalResourceUtilization struct {

    // The aggregated memory used per hour from the time job start executing till
    // the time job is terminated.
    MemoryGBHour *float64 `locationName:"memoryGBHour" type:"double"`

    // The aggregated storage used per hour from the time job start executing till
    // the time job is terminated.
    StorageGBHour *float64 `locationName:"storageGBHour" type:"double"`

    // The aggregated vCPU used per hour from the time job start executing till
    // the time job is terminated.
    VCPUHour *float64 `locationName:"vCPUHour" type:"double"`
    // contains filtered or unexported fields
}

The aggregate vCPU, memory, and storage resources used from the time job start executing till the time job is terminated, rounded up to the nearest second.

func (TotalResourceUtilization) GoString

func (s TotalResourceUtilization) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*TotalResourceUtilization) SetMemoryGBHour

func (s *TotalResourceUtilization) SetMemoryGBHour(v float64) *TotalResourceUtilization

SetMemoryGBHour sets the MemoryGBHour field's value.

func (*TotalResourceUtilization) SetStorageGBHour

func (s *TotalResourceUtilization) SetStorageGBHour(v float64) *TotalResourceUtilization

SetStorageGBHour sets the StorageGBHour field's value.

func (*TotalResourceUtilization) SetVCPUHour

func (s *TotalResourceUtilization) SetVCPUHour(v float64) *TotalResourceUtilization

SetVCPUHour sets the VCPUHour field's value.

func (TotalResourceUtilization) String

func (s TotalResourceUtilization) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type UntagResourceInput

type UntagResourceInput struct {

    // The Amazon Resource Name (ARN) that identifies the resource to list the tags
    // for. Currently, the supported resources are Amazon EMR Serverless applications
    // and job runs.
    //
    // ResourceArn is a required field
    ResourceArn *string `location:"uri" locationName:"resourceArn" min:"60" type:"string" required:"true"`

    // The keys of the tags to be removed.
    //
    // TagKeys is a required field
    TagKeys []*string `location:"querystring" locationName:"tagKeys" min:"1" type:"list" required:"true"`
    // contains filtered or unexported fields
}

func (UntagResourceInput) GoString

func (s UntagResourceInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UntagResourceInput) SetResourceArn

func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput

SetResourceArn sets the ResourceArn field's value.

func (*UntagResourceInput) SetTagKeys

func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput

SetTagKeys sets the TagKeys field's value.

func (UntagResourceInput) String

func (s UntagResourceInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UntagResourceInput) Validate

func (s *UntagResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UntagResourceOutput

type UntagResourceOutput struct {
    // contains filtered or unexported fields
}

func (UntagResourceOutput) GoString

func (s UntagResourceOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (UntagResourceOutput) String

func (s UntagResourceOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type UpdateApplicationInput

type UpdateApplicationInput struct {

    // The ID of the application to update.
    //
    // ApplicationId is a required field
    ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"`

    // The CPU architecture of an application.
    Architecture *string `locationName:"architecture" type:"string" enum:"Architecture"`

    // The configuration for an application to automatically start on job submission.
    AutoStartConfiguration *AutoStartConfig `locationName:"autoStartConfiguration" type:"structure"`

    // The configuration for an application to automatically stop after a certain
    // amount of time being idle.
    AutoStopConfiguration *AutoStopConfig `locationName:"autoStopConfiguration" type:"structure"`

    // The client idempotency token of the application to update. Its value must
    // be unique for each request.
    ClientToken *string `locationName:"clientToken" min:"1" type:"string" idempotencyToken:"true"`

    // The capacity to initialize when the application is updated.
    InitialCapacity map[string]*InitialCapacityConfig `locationName:"initialCapacity" type:"map"`

    // The maximum capacity to allocate when the application is updated. This is
    // cumulative across all workers at any given point in time during the lifespan
    // of the application. No new resources will be created once any one of the
    // defined limits is hit.
    MaximumCapacity *MaximumAllowedResources `locationName:"maximumCapacity" type:"structure"`

    // The network configuration for customer VPC connectivity.
    NetworkConfiguration *NetworkConfiguration `locationName:"networkConfiguration" type:"structure"`
    // contains filtered or unexported fields
}

func (UpdateApplicationInput) GoString

func (s UpdateApplicationInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdateApplicationInput) SetApplicationId

func (s *UpdateApplicationInput) SetApplicationId(v string) *UpdateApplicationInput

SetApplicationId sets the ApplicationId field's value.

func (*UpdateApplicationInput) SetArchitecture

func (s *UpdateApplicationInput) SetArchitecture(v string) *UpdateApplicationInput

SetArchitecture sets the Architecture field's value.

func (*UpdateApplicationInput) SetAutoStartConfiguration

func (s *UpdateApplicationInput) SetAutoStartConfiguration(v *AutoStartConfig) *UpdateApplicationInput

SetAutoStartConfiguration sets the AutoStartConfiguration field's value.

func (*UpdateApplicationInput) SetAutoStopConfiguration

func (s *UpdateApplicationInput) SetAutoStopConfiguration(v *AutoStopConfig) *UpdateApplicationInput

SetAutoStopConfiguration sets the AutoStopConfiguration field's value.

func (*UpdateApplicationInput) SetClientToken

func (s *UpdateApplicationInput) SetClientToken(v string) *UpdateApplicationInput

SetClientToken sets the ClientToken field's value.

func (*UpdateApplicationInput) SetInitialCapacity

func (s *UpdateApplicationInput) SetInitialCapacity(v map[string]*InitialCapacityConfig) *UpdateApplicationInput

SetInitialCapacity sets the InitialCapacity field's value.

func (*UpdateApplicationInput) SetMaximumCapacity

func (s *UpdateApplicationInput) SetMaximumCapacity(v *MaximumAllowedResources) *UpdateApplicationInput

SetMaximumCapacity sets the MaximumCapacity field's value.

func (*UpdateApplicationInput) SetNetworkConfiguration

func (s *UpdateApplicationInput) SetNetworkConfiguration(v *NetworkConfiguration) *UpdateApplicationInput

SetNetworkConfiguration sets the NetworkConfiguration field's value.

func (UpdateApplicationInput) String

func (s UpdateApplicationInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdateApplicationInput) Validate

func (s *UpdateApplicationInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UpdateApplicationOutput

type UpdateApplicationOutput struct {

    // Information about the updated application.
    //
    // Application is a required field
    Application *Application `locationName:"application" type:"structure" required:"true"`
    // contains filtered or unexported fields
}

func (UpdateApplicationOutput) GoString

func (s UpdateApplicationOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*UpdateApplicationOutput) SetApplication

func (s *UpdateApplicationOutput) SetApplication(v *Application) *UpdateApplicationOutput

SetApplication sets the Application field's value.

func (UpdateApplicationOutput) String

func (s UpdateApplicationOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ValidationException

type ValidationException struct {
    RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

    Message_ *string `locationName:"message" min:"1" type:"string"`
    // contains filtered or unexported fields
}

The input fails to satisfy the constraints specified by an AWS service.

func (*ValidationException) Code

func (s *ValidationException) Code() string

Code returns the exception type name.

func (*ValidationException) Error

func (s *ValidationException) Error() string

func (ValidationException) GoString

func (s ValidationException) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ValidationException) Message

func (s *ValidationException) Message() string

Message returns the exception's message.

func (*ValidationException) OrigErr

func (s *ValidationException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ValidationException) RequestID

func (s *ValidationException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ValidationException) StatusCode

func (s *ValidationException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ValidationException) String

func (s ValidationException) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type WorkerResourceConfig

type WorkerResourceConfig struct {

    // The CPU requirements for every worker instance of the worker type.
    //
    // Cpu is a required field
    Cpu *string `locationName:"cpu" min:"1" type:"string" required:"true"`

    // The disk requirements for every worker instance of the worker type.
    Disk *string `locationName:"disk" min:"1" type:"string"`

    // The memory requirements for every worker instance of the worker type.
    //
    // Memory is a required field
    Memory *string `locationName:"memory" min:"1" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The cumulative configuration requirements for every worker instance of the worker type.

func (WorkerResourceConfig) GoString

func (s WorkerResourceConfig) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*WorkerResourceConfig) SetCpu

func (s *WorkerResourceConfig) SetCpu(v string) *WorkerResourceConfig

SetCpu sets the Cpu field's value.

func (*WorkerResourceConfig) SetDisk

func (s *WorkerResourceConfig) SetDisk(v string) *WorkerResourceConfig

SetDisk sets the Disk field's value.

func (*WorkerResourceConfig) SetMemory

func (s *WorkerResourceConfig) SetMemory(v string) *WorkerResourceConfig

SetMemory sets the Memory field's value.

func (WorkerResourceConfig) String

func (s WorkerResourceConfig) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*WorkerResourceConfig) Validate

func (s *WorkerResourceConfig) Validate() error

Validate inspects the fields of the type to determine if they are valid.