emrserverless

package
v1.55.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 30, 2024 License: Apache-2.0 Imports: 10 Imported by: 13

Documentation

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. Amazon 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 Amazon 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

Index

Constants

View Source 
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"
)
View Source 
const (
	// ArchitectureArm64 is a Architecture enum value
	ArchitectureArm64 = "ARM64"

	// ArchitectureX8664 is a Architecture enum value
	ArchitectureX8664 = "X86_64"
)
View Source 
const (
	// JobRunModeBatch is a JobRunMode enum value
	JobRunModeBatch = "BATCH"

	// JobRunModeStreaming is a JobRunMode enum value
	JobRunModeStreaming = "STREAMING"
)
View Source 
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"
)
View Source 
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 Amazon Web Services
	// service.
	ErrCodeValidationException = "ValidationException"
)
View Source 
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

Variables

This section is empty.

Functions

func ApplicationState_Values 

func ApplicationState_Values() []string

ApplicationState_Values returns all elements of the ApplicationState enum

func Architecture_Values added in v1.44.140 

func Architecture_Values() []string

Architecture_Values returns all elements of the Architecture enum

func JobRunMode_Values added in v1.53.13 

func JobRunMode_Values() []string

JobRunMode_Values returns all elements of the JobRunMode enum

func JobRunState_Values 

func JobRunState_Values() []string

JobRunState_Values returns all elements of the JobRunState enum

Types

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 image configuration applied to all worker types.
	ImageConfiguration *ImageConfiguration `locationName:"imageConfiguration" type:"structure"`

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

	// The interactive configuration object that enables the interactive use cases
	// for an application.
	InteractiveConfiguration *InteractiveConfiguration `locationName:"interactiveConfiguration" type:"structure"`

	// 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 configuration setting for monitoring.
	MonitoringConfiguration *MonitoringConfiguration `locationName:"monitoringConfiguration" 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 Amazon EMR release associated with the application.
	//
	// ReleaseLabel is a required field
	ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string" required:"true"`

	// The Configuration (https://docs.aws.amazon.com/emr-serverless/latest/APIReference/API_Configuration.html)
	// specifications of an application. Each configuration consists of a classification
	// and properties. You use this parameter when creating or updating an application.
	// To see the runtimeConfiguration object of an application, run the GetApplication
	// (https://docs.aws.amazon.com/emr-serverless/latest/APIReference/API_GetApplication.html)
	// API operation.
	RuntimeConfiguration []*Configuration `locationName:"runtimeConfiguration" type:"list"`

	// 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"`

	// The specification applied to each worker type.
	WorkerTypeSpecifications map[string]*WorkerTypeSpecification `locationName:"workerTypeSpecifications" type:"map"`
	// contains filtered or unexported fields
}

Information about an application. Amazon 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 added in v1.44.140 

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) SetImageConfiguration added in v1.44.174 

func (s *Application) SetImageConfiguration(v *ImageConfiguration) *Application

SetImageConfiguration sets the ImageConfiguration field's value.

func (*Application) SetInitialCapacity 

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

SetInitialCapacity sets the InitialCapacity field's value.

func (*Application) SetInteractiveConfiguration added in v1.53.9 

func (s *Application) SetInteractiveConfiguration(v *InteractiveConfiguration) *Application

SetInteractiveConfiguration sets the InteractiveConfiguration field's value.

func (*Application) SetMaximumCapacity 

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

SetMaximumCapacity sets the MaximumCapacity field's value.

func (*Application) SetMonitoringConfiguration added in v1.45.16 

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

SetMonitoringConfiguration sets the MonitoringConfiguration 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) SetRuntimeConfiguration added in v1.45.16 

func (s *Application) SetRuntimeConfiguration(v []*Configuration) *Application

SetRuntimeConfiguration sets the RuntimeConfiguration 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) SetWorkerTypeSpecifications added in v1.44.174 

func (s *Application) SetWorkerTypeSpecifications(v map[string]*WorkerTypeSpecification) *Application

SetWorkerTypeSpecifications sets the WorkerTypeSpecifications 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 Amazon EMR release 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 added in v1.44.140 

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 CloudWatchLoggingConfiguration added in v1.44.308 

type CloudWatchLoggingConfiguration struct {

	// Enables CloudWatch logging.
	//
	// Enabled is a required field
	Enabled *bool `locationName:"enabled" type:"boolean" required:"true"`

	// The Key Management Service (KMS) key ARN to encrypt the logs that you store
	// in CloudWatch Logs.
	EncryptionKeyArn *string `locationName:"encryptionKeyArn" min:"20" type:"string"`

	// The name of the log group in Amazon CloudWatch Logs where you want to publish
	// your logs.
	LogGroupName *string `locationName:"logGroupName" min:"1" type:"string"`

	// Prefix for the CloudWatch log stream name.
	LogStreamNamePrefix *string `locationName:"logStreamNamePrefix" min:"1" type:"string"`

	// The types of logs that you want to publish to CloudWatch. If you don't specify
	// any log types, driver STDOUT and STDERR logs will be published to CloudWatch
	// Logs by default. For more information including the supported worker types
	// for Hive and Spark, see Logging for EMR Serverless with CloudWatch (https://docs.aws.amazon.com/emr/latest/EMR-Serverless-UserGuide/logging.html#jobs-log-storage-cw).
	//
	//    * Key Valid Values: SPARK_DRIVER, SPARK_EXECUTOR, HIVE_DRIVER, TEZ_TASK
	//
	//    * Array Members Valid Values: STDOUT, STDERR, HIVE_LOG, TEZ_AM, SYSTEM_LOGS
	LogTypes map[string][]*string `locationName:"logTypes" min:"1" type:"map"`
	// contains filtered or unexported fields
}

The Amazon CloudWatch configuration for monitoring logs. You can configure your jobs to send log information to CloudWatch.

func (CloudWatchLoggingConfiguration) GoString added in v1.44.308 

func (s CloudWatchLoggingConfiguration) 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 (*CloudWatchLoggingConfiguration) SetEnabled added in v1.44.308 

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

SetEnabled sets the Enabled field's value.

func (*CloudWatchLoggingConfiguration) SetEncryptionKeyArn added in v1.44.308 

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

SetEncryptionKeyArn sets the EncryptionKeyArn field's value.

func (*CloudWatchLoggingConfiguration) SetLogGroupName added in v1.44.308 

func (s *CloudWatchLoggingConfiguration) SetLogGroupName(v string) *CloudWatchLoggingConfiguration

SetLogGroupName sets the LogGroupName field's value.

func (*CloudWatchLoggingConfiguration) SetLogStreamNamePrefix added in v1.44.308 

func (s *CloudWatchLoggingConfiguration) SetLogStreamNamePrefix(v string) *CloudWatchLoggingConfiguration

SetLogStreamNamePrefix sets the LogStreamNamePrefix field's value.

func (*CloudWatchLoggingConfiguration) SetLogTypes added in v1.44.308 

func (s *CloudWatchLoggingConfiguration) SetLogTypes(v map[string][]*string) *CloudWatchLoggingConfiguration

SetLogTypes sets the LogTypes field's value.

func (CloudWatchLoggingConfiguration) String added in v1.44.308 

func (s CloudWatchLoggingConfiguration) 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 (*CloudWatchLoggingConfiguration) Validate added in v1.44.308 

func (s *CloudWatchLoggingConfiguration) Validate() error

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

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 image configuration for all worker types. You can either set this parameter
	// or imageConfiguration for each worker type in workerTypeSpecifications.
	ImageConfiguration *ImageConfigurationInput_ `locationName:"imageConfiguration" type:"structure"`

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

	// The interactive configuration object that enables the interactive use cases
	// to use when running an application.
	InteractiveConfiguration *InteractiveConfiguration `locationName:"interactiveConfiguration" type:"structure"`

	// 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 configuration setting for monitoring.
	MonitoringConfiguration *MonitoringConfiguration `locationName:"monitoringConfiguration" 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 Amazon EMR release associated with the application.
	//
	// ReleaseLabel is a required field
	ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string" required:"true"`

	// The Configuration (https://docs.aws.amazon.com/emr-serverless/latest/APIReference/API_Configuration.html)
	// specifications to use when creating an application. Each configuration consists
	// of a classification and properties. This configuration is applied to all
	// the job runs submitted under the application.
	RuntimeConfiguration []*Configuration `locationName:"runtimeConfiguration" type:"list"`

	// 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"`

	// The key-value pairs that specify worker type to WorkerTypeSpecificationInput.
	// This parameter must contain all valid worker types for a Spark or Hive application.
	// Valid worker types include Driver and Executor for Spark applications and
	// HiveDriver and TezTask for Hive applications. You can either set image details
	// in this parameter for each worker type, or in imageConfiguration for all
	// worker types.
	WorkerTypeSpecifications map[string]*WorkerTypeSpecificationInput_ `locationName:"workerTypeSpecifications" type:"map"`
	// 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 added in v1.44.140 

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) SetImageConfiguration added in v1.44.174 

func (s *CreateApplicationInput) SetImageConfiguration(v *ImageConfigurationInput_) *CreateApplicationInput

SetImageConfiguration sets the ImageConfiguration field's value.

func (*CreateApplicationInput) SetInitialCapacity 

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

SetInitialCapacity sets the InitialCapacity field's value.

func (*CreateApplicationInput) SetInteractiveConfiguration added in v1.53.9 

func (s *CreateApplicationInput) SetInteractiveConfiguration(v *InteractiveConfiguration) *CreateApplicationInput

SetInteractiveConfiguration sets the InteractiveConfiguration field's value.

func (*CreateApplicationInput) SetMaximumCapacity 

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

SetMaximumCapacity sets the MaximumCapacity field's value.

func (*CreateApplicationInput) SetMonitoringConfiguration added in v1.45.16 

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

SetMonitoringConfiguration sets the MonitoringConfiguration 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) SetRuntimeConfiguration added in v1.45.16 

func (s *CreateApplicationInput) SetRuntimeConfiguration(v []*Configuration) *CreateApplicationInput

SetRuntimeConfiguration sets the RuntimeConfiguration 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) SetWorkerTypeSpecifications added in v1.44.174 

func (s *CreateApplicationInput) SetWorkerTypeSpecifications(v map[string]*WorkerTypeSpecificationInput_) *CreateApplicationInput

SetWorkerTypeSpecifications sets the WorkerTypeSpecifications 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 Amazon Web Services 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 Amazon Web Services 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/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 Amazon Web Services 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 Amazon Web Services 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 added in v1.44.108 

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

GetDashboardForJobRun API operation for EMR Serverless.

Creates and returns a URL that you can use to access the application UIs for a job run.

For jobs in a running state, the application UI is a live user interface such as the Spark or Tez web UI. For completed jobs, the application UI is a persistent application user interface such as the Spark History Server or persistent Tez UI.

The URL is valid for one hour after you generate it. To access the application UI after that hour elapses, you must invoke the API again to generate a new URL.

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 Amazon Web Services 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 added in v1.44.108 

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 added in v1.44.108 

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 Amazon Web Services 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 Amazon Web Services 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) ListJobRunAttempts added in v1.53.13 

func (c *EMRServerless) ListJobRunAttempts(input *ListJobRunAttemptsInput) (*ListJobRunAttemptsOutput, error)

ListJobRunAttempts API operation for EMR Serverless.

Lists all attempt of 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 ListJobRunAttempts for usage and error information.

Returned Error Types:

  • ValidationException The input fails to satisfy the constraints specified by an Amazon Web Services 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/ListJobRunAttempts

func (*EMRServerless) ListJobRunAttemptsPages added in v1.53.13 

func (c *EMRServerless) ListJobRunAttemptsPages(input *ListJobRunAttemptsInput, fn func(*ListJobRunAttemptsOutput, bool) bool) error

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

See ListJobRunAttempts 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 ListJobRunAttempts operation.
pageNum := 0
err := client.ListJobRunAttemptsPages(params,
    func(page *emrserverless.ListJobRunAttemptsOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*EMRServerless) ListJobRunAttemptsPagesWithContext added in v1.53.13 

func (c *EMRServerless) ListJobRunAttemptsPagesWithContext(ctx aws.Context, input *ListJobRunAttemptsInput, fn func(*ListJobRunAttemptsOutput, bool) bool, opts ...request.Option) error

ListJobRunAttemptsPagesWithContext same as ListJobRunAttemptsPages 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) ListJobRunAttemptsRequest added in v1.53.13 

func (c *EMRServerless) ListJobRunAttemptsRequest(input *ListJobRunAttemptsInput) (req *request.Request, output *ListJobRunAttemptsOutput)

ListJobRunAttemptsRequest generates a "aws/request.Request" representing the client's request for the ListJobRunAttempts 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 ListJobRunAttempts for more information on using the ListJobRunAttempts 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 ListJobRunAttemptsRequest method.
req, resp := client.ListJobRunAttemptsRequest(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/ListJobRunAttempts

func (*EMRServerless) ListJobRunAttemptsWithContext added in v1.53.13 

func (c *EMRServerless) ListJobRunAttemptsWithContext(ctx aws.Context, input *ListJobRunAttemptsInput, opts ...request.Option) (*ListJobRunAttemptsOutput, error)

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

See ListJobRunAttempts 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 Amazon Web Services 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 Amazon Web Services 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 Amazon Web Services 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 Amazon Web Services 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 Amazon Web Services 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 Amazon Web Services resource. Each tag consists of a key and an optional value, both of which you define. Tags enable you to categorize your Amazon Web Services 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 Amazon Web Services 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 Amazon Web Services 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 Amazon Web Services 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 added in v1.44.108 

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"`

	// An optimal parameter that indicates the amount of attempts for the job. If
	// not specified, this value defaults to the attempt of the latest job.
	Attempt *int64 `location:"querystring" locationName:"attempt" min:"1" type:"integer"`

	// 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 added in v1.44.108 

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 added in v1.44.108 

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

SetApplicationId sets the ApplicationId field's value.

func (*GetDashboardForJobRunInput) SetAttempt added in v1.53.13 

func (s *GetDashboardForJobRunInput) SetAttempt(v int64) *GetDashboardForJobRunInput

SetAttempt sets the Attempt field's value.

func (*GetDashboardForJobRunInput) SetJobRunId added in v1.44.108 

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

SetJobRunId sets the JobRunId field's value.

func (GetDashboardForJobRunInput) String added in v1.44.108 

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 added in v1.44.108 

func (s *GetDashboardForJobRunInput) Validate() error

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

type GetDashboardForJobRunOutput added in v1.44.108 

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 added in v1.44.108 

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 added in v1.44.108 

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

SetUrl sets the Url field's value.

func (GetDashboardForJobRunOutput) String added in v1.44.108 

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"`

	// An optimal parameter that indicates the amount of attempts for the job. If
	// not specified, this value defaults to the attempt of the latest job.
	Attempt *int64 `location:"querystring" locationName:"attempt" min:"1" type:"integer"`

	// 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) SetAttempt added in v1.53.13 

func (s *GetJobRunInput) SetAttempt(v int64) *GetJobRunInput

SetAttempt sets the Attempt 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 ImageConfiguration added in v1.44.174 

type ImageConfiguration struct {

	// The image URI.
	//
	// ImageUri is a required field
	ImageUri *string `locationName:"imageUri" min:"1" type:"string" required:"true"`

	// The SHA256 digest of the image URI. This indicates which specific image the
	// application is configured for. The image digest doesn't exist until an application
	// has started.
	ResolvedImageDigest *string `locationName:"resolvedImageDigest" type:"string"`
	// contains filtered or unexported fields
}

The applied image configuration.

func (ImageConfiguration) GoString added in v1.44.174 

func (s ImageConfiguration) 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 (*ImageConfiguration) SetImageUri added in v1.44.174 

func (s *ImageConfiguration) SetImageUri(v string) *ImageConfiguration

SetImageUri sets the ImageUri field's value.

func (*ImageConfiguration) SetResolvedImageDigest added in v1.44.174 

func (s *ImageConfiguration) SetResolvedImageDigest(v string) *ImageConfiguration

SetResolvedImageDigest sets the ResolvedImageDigest field's value.

func (ImageConfiguration) String added in v1.44.174 

func (s ImageConfiguration) 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 ImageConfigurationInput_ added in v1.44.174 

type ImageConfigurationInput_ struct {

	// The URI of an image in the Amazon ECR registry. This field is required when
	// you create a new application. If you leave this field blank in an update,
	// Amazon EMR will remove the image configuration.
	ImageUri *string `locationName:"imageUri" min:"1" type:"string"`
	// contains filtered or unexported fields
}

The image configuration.

func (ImageConfigurationInput_) GoString added in v1.44.174 

func (s ImageConfigurationInput_) 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 (*ImageConfigurationInput_) SetImageUri added in v1.44.174 

func (s *ImageConfigurationInput_) SetImageUri(v string) *ImageConfigurationInput_

SetImageUri sets the ImageUri field's value.

func (ImageConfigurationInput_) String added in v1.44.174 

func (s ImageConfigurationInput_) 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 (*ImageConfigurationInput_) Validate added in v1.44.174 

func (s *ImageConfigurationInput_) 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 InteractiveConfiguration added in v1.53.9 

type InteractiveConfiguration struct {

	// Enables an Apache Livy endpoint that you can connect to and run interactive
	// jobs.
	LivyEndpointEnabled *bool `locationName:"livyEndpointEnabled" type:"boolean"`

	// Enables you to connect an application to Amazon EMR Studio to run interactive
	// workloads in a notebook.
	StudioEnabled *bool `locationName:"studioEnabled" type:"boolean"`
	// contains filtered or unexported fields
}

The configuration to use to enable the different types of interactive use cases in an application.

func (InteractiveConfiguration) GoString added in v1.53.9 

func (s InteractiveConfiguration) 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 (*InteractiveConfiguration) SetLivyEndpointEnabled added in v1.53.9 

func (s *InteractiveConfiguration) SetLivyEndpointEnabled(v bool) *InteractiveConfiguration

SetLivyEndpointEnabled sets the LivyEndpointEnabled field's value.

func (*InteractiveConfiguration) SetStudioEnabled added in v1.53.9 

func (s *InteractiveConfiguration) SetStudioEnabled(v bool) *InteractiveConfiguration

SetStudioEnabled sets the StudioEnabled field's value.

func (InteractiveConfiguration) String added in v1.53.9 

func (s InteractiveConfiguration) 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 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 attempt of the job run.
	Attempt *int64 `locationName:"attempt" min:"1" type:"integer"`

	// The date and time of when the job run attempt was created.
	AttemptCreatedAt *time.Time `locationName:"attemptCreatedAt" type:"timestamp"`

	// The date and time of when the job run attempt was last updated.
	AttemptUpdatedAt *time.Time `locationName:"attemptUpdatedAt" type:"timestamp"`

	// The aggregate vCPU, memory, and storage that Amazon Web Services has billed
	// for the job run. The billed resources include a 1-minute minimum usage for
	// workers, plus additional storage over 20 GB per worker. Note that billed
	// resources do not include usage for idle pre-initialized workers.
	BilledResourceUtilization *ResourceUtilization `locationName:"billedResourceUtilization" type:"structure"`

	// 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"`

	// Returns the job run timeout value from the StartJobRun call. If no timeout
	// was specified, then it returns the default timeout of 720 minutes.
	ExecutionTimeoutMinutes *int64 `locationName:"executionTimeoutMinutes" type:"long"`

	// 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 mode of the job run.
	Mode *string `locationName:"mode" type:"string" enum:"JobRunMode"`

	// 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 Amazon EMR release 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 retry policy of the job run.
	RetryPolicy *RetryPolicy `locationName:"retryPolicy" type:"structure"`

	// 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 the
	// job starts to execute, until the time the job terminates, 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 Amazon 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) SetAttempt added in v1.53.13 

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

SetAttempt sets the Attempt field's value.

func (*JobRun) SetAttemptCreatedAt added in v1.53.13 

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

SetAttemptCreatedAt sets the AttemptCreatedAt field's value.

func (*JobRun) SetAttemptUpdatedAt added in v1.53.13 

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

SetAttemptUpdatedAt sets the AttemptUpdatedAt field's value.

func (*JobRun) SetBilledResourceUtilization added in v1.44.245 

func (s *JobRun) SetBilledResourceUtilization(v *ResourceUtilization) *JobRun

SetBilledResourceUtilization sets the BilledResourceUtilization 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) SetExecutionTimeoutMinutes added in v1.44.241 

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

SetExecutionTimeoutMinutes sets the ExecutionTimeoutMinutes 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) SetMode added in v1.53.13 

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

SetMode sets the Mode 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) SetRetryPolicy added in v1.53.13 

func (s *JobRun) SetRetryPolicy(v *RetryPolicy) *JobRun

SetRetryPolicy sets the RetryPolicy 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 JobRunAttemptSummary added in v1.53.13 

type JobRunAttemptSummary 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 Amazon Resource Name (ARN) of the job run.
	//
	// Arn is a required field
	Arn *string `locationName:"arn" min:"60" type:"string" required:"true"`

	// The attempt number of the job run execution.
	Attempt *int64 `locationName:"attempt" min:"1" type:"integer"`

	// The date and time when the job run attempt 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 Amazon Resource Name (ARN) of the execution role 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 attempt.
	//
	// Id is a required field
	Id *string `locationName:"id" min:"1" type:"string" required:"true"`

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

	// The mode of the job run attempt.
	Mode *string `locationName:"mode" type:"string" enum:"JobRunMode"`

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

	// The Amazon EMR release label of the job run attempt.
	//
	// ReleaseLabel is a required field
	ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string" required:"true"`

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

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

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

	// The date and time of when the job run attempt 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 attempt.

func (JobRunAttemptSummary) GoString added in v1.53.13 

func (s JobRunAttemptSummary) 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 (*JobRunAttemptSummary) SetApplicationId added in v1.53.13 

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

SetApplicationId sets the ApplicationId field's value.

func (*JobRunAttemptSummary) SetArn added in v1.53.13 

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

SetArn sets the Arn field's value.

func (*JobRunAttemptSummary) SetAttempt added in v1.53.13 

func (s *JobRunAttemptSummary) SetAttempt(v int64) *JobRunAttemptSummary

SetAttempt sets the Attempt field's value.

func (*JobRunAttemptSummary) SetCreatedAt added in v1.53.13 

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

SetCreatedAt sets the CreatedAt field's value.

func (*JobRunAttemptSummary) SetCreatedBy added in v1.53.13 

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

SetCreatedBy sets the CreatedBy field's value.

func (*JobRunAttemptSummary) SetExecutionRole added in v1.53.13 

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

SetExecutionRole sets the ExecutionRole field's value.

func (*JobRunAttemptSummary) SetId added in v1.53.13 

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

SetId sets the Id field's value.

func (*JobRunAttemptSummary) SetJobCreatedAt added in v1.53.13 

func (s *JobRunAttemptSummary) SetJobCreatedAt(v time.Time) *JobRunAttemptSummary

SetJobCreatedAt sets the JobCreatedAt field's value.

func (*JobRunAttemptSummary) SetMode added in v1.53.13 

func (s *JobRunAttemptSummary) SetMode(v string) *JobRunAttemptSummary

SetMode sets the Mode field's value.

func (*JobRunAttemptSummary) SetName added in v1.53.13 

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

SetName sets the Name field's value.

func (*JobRunAttemptSummary) SetReleaseLabel added in v1.53.13 

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

SetReleaseLabel sets the ReleaseLabel field's value.

func (*JobRunAttemptSummary) SetState added in v1.53.13 

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

SetState sets the State field's value.

func (*JobRunAttemptSummary) SetStateDetails added in v1.53.13 

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

SetStateDetails sets the StateDetails field's value.

func (*JobRunAttemptSummary) SetType added in v1.53.13 

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

SetType sets the Type field's value.

func (*JobRunAttemptSummary) SetUpdatedAt added in v1.53.13 

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

SetUpdatedAt sets the UpdatedAt field's value.

func (JobRunAttemptSummary) String added in v1.53.13 

func (s JobRunAttemptSummary) 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 attempt number of the job run execution.
	Attempt *int64 `locationName:"attempt" min:"1" type:"integer"`

	// The date and time of when the job run attempt was created.
	AttemptCreatedAt *time.Time `locationName:"attemptCreatedAt" type:"timestamp"`

	// The date and time of when the job run attempt was last updated.
	AttemptUpdatedAt *time.Time `locationName:"attemptUpdatedAt" type:"timestamp"`

	// 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 mode of the job run.
	Mode *string `locationName:"mode" type:"string" enum:"JobRunMode"`

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

	// The Amazon EMR release 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) SetAttempt added in v1.53.13 

func (s *JobRunSummary) SetAttempt(v int64) *JobRunSummary

SetAttempt sets the Attempt field's value.

func (*JobRunSummary) SetAttemptCreatedAt added in v1.53.13 

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

SetAttemptCreatedAt sets the AttemptCreatedAt field's value.

func (*JobRunSummary) SetAttemptUpdatedAt added in v1.53.13 

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

SetAttemptUpdatedAt sets the AttemptUpdatedAt 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) SetMode added in v1.53.13 

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

SetMode sets the Mode 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 ListJobRunAttemptsInput added in v1.53.13 

type ListJobRunAttemptsInput struct {

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

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

	// The maximum number of job run attempts to list.
	MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`

	// The token for the next set of job run attempt results.
	NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (ListJobRunAttemptsInput) GoString added in v1.53.13 

func (s ListJobRunAttemptsInput) 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 (*ListJobRunAttemptsInput) SetApplicationId added in v1.53.13 

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

SetApplicationId sets the ApplicationId field's value.

func (*ListJobRunAttemptsInput) SetJobRunId added in v1.53.13 

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

SetJobRunId sets the JobRunId field's value.

func (*ListJobRunAttemptsInput) SetMaxResults added in v1.53.13 

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

SetMaxResults sets the MaxResults field's value.

func (*ListJobRunAttemptsInput) SetNextToken added in v1.53.13 

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

SetNextToken sets the NextToken field's value.

func (ListJobRunAttemptsInput) String added in v1.53.13 

func (s ListJobRunAttemptsInput) 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 (*ListJobRunAttemptsInput) Validate added in v1.53.13 

func (s *ListJobRunAttemptsInput) Validate() error

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

type ListJobRunAttemptsOutput added in v1.53.13 

type ListJobRunAttemptsOutput struct {

	// The array of the listed job run attempt objects.
	//
	// JobRunAttempts is a required field
	JobRunAttempts []*JobRunAttemptSummary `locationName:"jobRunAttempts" 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 (ListJobRunAttemptsOutput) GoString added in v1.53.13 

func (s ListJobRunAttemptsOutput) 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 (*ListJobRunAttemptsOutput) SetJobRunAttempts added in v1.53.13 

func (s *ListJobRunAttemptsOutput) SetJobRunAttempts(v []*JobRunAttemptSummary) *ListJobRunAttemptsOutput

SetJobRunAttempts sets the JobRunAttempts field's value.

func (*ListJobRunAttemptsOutput) SetNextToken added in v1.53.13 

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

SetNextToken sets the NextToken field's value.

func (ListJobRunAttemptsOutput) String added in v1.53.13 

func (s ListJobRunAttemptsOutput) 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 mode of the job runs to list.
	Mode *string `location:"querystring" locationName:"mode" type:"string" enum:"JobRunMode"`

	// 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) SetMode added in v1.53.13 

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

SetMode sets the Mode 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 Amazon CloudWatch configuration for monitoring logs. You can configure
	// your jobs to send log information to CloudWatch.
	CloudWatchLoggingConfiguration *CloudWatchLoggingConfiguration `locationName:"cloudWatchLoggingConfiguration" type:"structure"`

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

	// The monitoring configuration object you can configure to send metrics to
	// Amazon Managed Service for Prometheus for a job run.
	PrometheusMonitoringConfiguration *PrometheusMonitoringConfiguration `locationName:"prometheusMonitoringConfiguration" 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) SetCloudWatchLoggingConfiguration added in v1.44.308 

func (s *MonitoringConfiguration) SetCloudWatchLoggingConfiguration(v *CloudWatchLoggingConfiguration) *MonitoringConfiguration

SetCloudWatchLoggingConfiguration sets the CloudWatchLoggingConfiguration field's value.

func (*MonitoringConfiguration) SetManagedPersistenceMonitoringConfiguration 

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

SetManagedPersistenceMonitoringConfiguration sets the ManagedPersistenceMonitoringConfiguration field's value.

func (*MonitoringConfiguration) SetPrometheusMonitoringConfiguration added in v1.51.24 

func (s *MonitoringConfiguration) SetPrometheusMonitoringConfiguration(v *PrometheusMonitoringConfiguration) *MonitoringConfiguration

SetPrometheusMonitoringConfiguration sets the PrometheusMonitoringConfiguration 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 PrometheusMonitoringConfiguration added in v1.51.24 

type PrometheusMonitoringConfiguration struct {

	// The remote write URL in the Amazon Managed Service for Prometheus workspace
	// to send metrics to.
	RemoteWriteUrl *string `locationName:"remoteWriteUrl" min:"1" type:"string"`
	// contains filtered or unexported fields
}

The monitoring configuration object you can configure to send metrics to Amazon Managed Service for Prometheus for a job run.

func (PrometheusMonitoringConfiguration) GoString added in v1.51.24 

func (s PrometheusMonitoringConfiguration) 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 (*PrometheusMonitoringConfiguration) SetRemoteWriteUrl added in v1.51.24 

func (s *PrometheusMonitoringConfiguration) SetRemoteWriteUrl(v string) *PrometheusMonitoringConfiguration

SetRemoteWriteUrl sets the RemoteWriteUrl field's value.

func (PrometheusMonitoringConfiguration) String added in v1.51.24 

func (s PrometheusMonitoringConfiguration) 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 (*PrometheusMonitoringConfiguration) Validate added in v1.51.24 

func (s *PrometheusMonitoringConfiguration) Validate() error

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

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 ResourceUtilization added in v1.44.245 

type ResourceUtilization struct {

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

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

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

The resource utilization for memory, storage, and vCPU for jobs.

func (ResourceUtilization) GoString added in v1.44.245 

func (s ResourceUtilization) 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 (*ResourceUtilization) SetMemoryGBHour added in v1.44.245 

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

SetMemoryGBHour sets the MemoryGBHour field's value.

func (*ResourceUtilization) SetStorageGBHour added in v1.44.245 

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

SetStorageGBHour sets the StorageGBHour field's value.

func (*ResourceUtilization) SetVCPUHour added in v1.44.245 

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

SetVCPUHour sets the VCPUHour field's value.

func (ResourceUtilization) String added in v1.44.245 

func (s ResourceUtilization) 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 RetryPolicy added in v1.53.13 

type RetryPolicy struct {

	// Maximum number of attempts for the job run. This parameter is only applicable
	// for BATCH mode.
	MaxAttempts *int64 `locationName:"maxAttempts" min:"1" type:"integer"`

	// Maximum number of failed attempts per hour. This [arameter is only applicable
	// for STREAMING mode.
	MaxFailedAttemptsPerHour *int64 `locationName:"maxFailedAttemptsPerHour" min:"1" type:"integer"`
	// contains filtered or unexported fields
}

The retry policy to use for a job run.

func (RetryPolicy) GoString added in v1.53.13 

func (s RetryPolicy) 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 (*RetryPolicy) SetMaxAttempts added in v1.53.13 

func (s *RetryPolicy) SetMaxAttempts(v int64) *RetryPolicy

SetMaxAttempts sets the MaxAttempts field's value.

func (*RetryPolicy) SetMaxFailedAttemptsPerHour added in v1.53.13 

func (s *RetryPolicy) SetMaxFailedAttemptsPerHour(v int64) *RetryPolicy

SetMaxFailedAttemptsPerHour sets the MaxFailedAttemptsPerHour field's value.

func (RetryPolicy) String added in v1.53.13 

func (s RetryPolicy) 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 (*RetryPolicy) Validate added in v1.53.13 

func (s *RetryPolicy) Validate() error

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

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" sensitive:"true"`

	// 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 mode of the job run when it starts.
	Mode *string `locationName:"mode" type:"string" enum:"JobRunMode"`

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

	// The retry policy when job run starts.
	RetryPolicy *RetryPolicy `locationName:"retryPolicy" type:"structure"`

	// 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) SetMode added in v1.53.13 

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

SetMode sets the Mode field's value.

func (*StartJobRunInput) SetName 

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

SetName sets the Name field's value.

func (*StartJobRunInput) SetRetryPolicy added in v1.53.13 

func (s *StartJobRunInput) SetRetryPolicy(v *RetryPolicy) *StartJobRunInput

SetRetryPolicy sets the RetryPolicy 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"`

	// This output displays the 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 image configuration to be used for all worker types. You can either set
	// this parameter or imageConfiguration for each worker type in WorkerTypeSpecificationInput.
	ImageConfiguration *ImageConfigurationInput_ `locationName:"imageConfiguration" type:"structure"`

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

	// The interactive configuration object that contains new interactive use cases
	// when the application is updated.
	InteractiveConfiguration *InteractiveConfiguration `locationName:"interactiveConfiguration" type:"structure"`

	// 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 configuration setting for monitoring.
	MonitoringConfiguration *MonitoringConfiguration `locationName:"monitoringConfiguration" type:"structure"`

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

	// The Amazon EMR release label for the application. You can change the release
	// label to use a different release of Amazon EMR.
	ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string"`

	// The Configuration (https://docs.aws.amazon.com/emr-serverless/latest/APIReference/API_Configuration.html)
	// specifications to use when updating an application. Each configuration consists
	// of a classification and properties. This configuration is applied across
	// all the job runs submitted under the application.
	RuntimeConfiguration []*Configuration `locationName:"runtimeConfiguration" type:"list"`

	// The key-value pairs that specify worker type to WorkerTypeSpecificationInput.
	// This parameter must contain all valid worker types for a Spark or Hive application.
	// Valid worker types include Driver and Executor for Spark applications and
	// HiveDriver and TezTask for Hive applications. You can either set image details
	// in this parameter for each worker type, or in imageConfiguration for all
	// worker types.
	WorkerTypeSpecifications map[string]*WorkerTypeSpecificationInput_ `locationName:"workerTypeSpecifications" type:"map"`
	// 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 added in v1.44.140 

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) SetImageConfiguration added in v1.44.174 

func (s *UpdateApplicationInput) SetImageConfiguration(v *ImageConfigurationInput_) *UpdateApplicationInput

SetImageConfiguration sets the ImageConfiguration field's value.

func (*UpdateApplicationInput) SetInitialCapacity 

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

SetInitialCapacity sets the InitialCapacity field's value.

func (*UpdateApplicationInput) SetInteractiveConfiguration added in v1.53.9 

func (s *UpdateApplicationInput) SetInteractiveConfiguration(v *InteractiveConfiguration) *UpdateApplicationInput

SetInteractiveConfiguration sets the InteractiveConfiguration field's value.

func (*UpdateApplicationInput) SetMaximumCapacity 

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

SetMaximumCapacity sets the MaximumCapacity field's value.

func (*UpdateApplicationInput) SetMonitoringConfiguration added in v1.45.16 

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

SetMonitoringConfiguration sets the MonitoringConfiguration field's value.

func (*UpdateApplicationInput) SetNetworkConfiguration 

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

SetNetworkConfiguration sets the NetworkConfiguration field's value.

func (*UpdateApplicationInput) SetReleaseLabel added in v1.44.291 

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

SetReleaseLabel sets the ReleaseLabel field's value.

func (*UpdateApplicationInput) SetRuntimeConfiguration added in v1.45.16 

func (s *UpdateApplicationInput) SetRuntimeConfiguration(v []*Configuration) *UpdateApplicationInput

SetRuntimeConfiguration sets the RuntimeConfiguration field's value.

func (*UpdateApplicationInput) SetWorkerTypeSpecifications added in v1.44.174 

func (s *UpdateApplicationInput) SetWorkerTypeSpecifications(v map[string]*WorkerTypeSpecificationInput_) *UpdateApplicationInput

SetWorkerTypeSpecifications sets the WorkerTypeSpecifications 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 Amazon Web Services 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 disk type for every worker instance of the work type. Shuffle optimized
	// disks have higher performance characteristics and are better for shuffle
	// heavy workloads. Default is STANDARD.
	DiskType *string `locationName:"diskType" 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) SetDiskType added in v1.51.22 

func (s *WorkerResourceConfig) SetDiskType(v string) *WorkerResourceConfig

SetDiskType sets the DiskType 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.

type WorkerTypeSpecification added in v1.44.174 

type WorkerTypeSpecification struct {

	// The image configuration for a worker type.
	ImageConfiguration *ImageConfiguration `locationName:"imageConfiguration" type:"structure"`
	// contains filtered or unexported fields
}

The specifications for a worker type.

func (WorkerTypeSpecification) GoString added in v1.44.174 

func (s WorkerTypeSpecification) 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 (*WorkerTypeSpecification) SetImageConfiguration added in v1.44.174 

func (s *WorkerTypeSpecification) SetImageConfiguration(v *ImageConfiguration) *WorkerTypeSpecification

SetImageConfiguration sets the ImageConfiguration field's value.

func (WorkerTypeSpecification) String added in v1.44.174 

func (s WorkerTypeSpecification) 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 WorkerTypeSpecificationInput_ added in v1.44.174 

type WorkerTypeSpecificationInput_ struct {

	// The image configuration for a worker type.
	ImageConfiguration *ImageConfigurationInput_ `locationName:"imageConfiguration" type:"structure"`
	// contains filtered or unexported fields
}

The specifications for a worker type.

func (WorkerTypeSpecificationInput_) GoString added in v1.44.174 

func (s WorkerTypeSpecificationInput_) 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 (*WorkerTypeSpecificationInput_) SetImageConfiguration added in v1.44.174 

func (s *WorkerTypeSpecificationInput_) SetImageConfiguration(v *ImageConfigurationInput_) *WorkerTypeSpecificationInput_

SetImageConfiguration sets the ImageConfiguration field's value.

func (WorkerTypeSpecificationInput_) String added in v1.44.174 

func (s WorkerTypeSpecificationInput_) 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 (*WorkerTypeSpecificationInput_) Validate added in v1.44.174 

func (s *WorkerTypeSpecificationInput_) Validate() error

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

Source Files

View all Source files

Directories

Path Synopsis
Package emrserverlessiface provides an interface to enable mocking the EMR Serverless service client for testing your code.
 Package emrserverlessiface provides an interface to enable mocking the EMR Serverless service client for testing your code.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.