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:
It is the prefix in the CLI commands for Amazon EMR Serverless. For example, aws emr-serverless start-job-run.
It is the prefix before IAM policy actions for Amazon EMR Serverless. For example, "Action": ["emr-serverless:StartJobRun"]. For more information, see Policy actions for Amazon EMR Serverless (https://docs.aws.amazon.com/emr/latest/EMR-Serverless-UserGuide/security_iam_service-with-iam.html#security_iam_service-with-iam-id-based-policies-actions).
It is the prefix used in Amazon EMR Serverless service endpoints. For example, emr-serverless.us-east-2.amazonaws.com.
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
- func ApplicationState_Values() []string
- func Architecture_Values() []string
- func JobRunState_Values() []string
- type Application
- func (s Application) GoString() string
- func (s *Application) SetApplicationId(v string) *Application
- func (s *Application) SetArchitecture(v string) *Application
- func (s *Application) SetArn(v string) *Application
- func (s *Application) SetAutoStartConfiguration(v *AutoStartConfig) *Application
- func (s *Application) SetAutoStopConfiguration(v *AutoStopConfig) *Application
- func (s *Application) SetCreatedAt(v time.Time) *Application
- func (s *Application) SetImageConfiguration(v *ImageConfiguration) *Application
- func (s *Application) SetInitialCapacity(v map[string]*InitialCapacityConfig) *Application
- func (s *Application) SetMaximumCapacity(v *MaximumAllowedResources) *Application
- func (s *Application) SetName(v string) *Application
- func (s *Application) SetNetworkConfiguration(v *NetworkConfiguration) *Application
- func (s *Application) SetReleaseLabel(v string) *Application
- func (s *Application) SetState(v string) *Application
- func (s *Application) SetStateDetails(v string) *Application
- func (s *Application) SetTags(v map[string]*string) *Application
- func (s *Application) SetType(v string) *Application
- func (s *Application) SetUpdatedAt(v time.Time) *Application
- func (s *Application) SetWorkerTypeSpecifications(v map[string]*WorkerTypeSpecification) *Application
- func (s Application) String() string
- type ApplicationSummary
- func (s ApplicationSummary) GoString() string
- func (s *ApplicationSummary) SetArchitecture(v string) *ApplicationSummary
- func (s *ApplicationSummary) SetArn(v string) *ApplicationSummary
- func (s *ApplicationSummary) SetCreatedAt(v time.Time) *ApplicationSummary
- func (s *ApplicationSummary) SetId(v string) *ApplicationSummary
- func (s *ApplicationSummary) SetName(v string) *ApplicationSummary
- func (s *ApplicationSummary) SetReleaseLabel(v string) *ApplicationSummary
- func (s *ApplicationSummary) SetState(v string) *ApplicationSummary
- func (s *ApplicationSummary) SetStateDetails(v string) *ApplicationSummary
- func (s *ApplicationSummary) SetType(v string) *ApplicationSummary
- func (s *ApplicationSummary) SetUpdatedAt(v time.Time) *ApplicationSummary
- func (s ApplicationSummary) String() string
- type AutoStartConfig
- type AutoStopConfig
- type CancelJobRunInput
- type CancelJobRunOutput
- type CloudWatchLoggingConfiguration
- func (s CloudWatchLoggingConfiguration) GoString() string
- func (s *CloudWatchLoggingConfiguration) SetEnabled(v bool) *CloudWatchLoggingConfiguration
- func (s *CloudWatchLoggingConfiguration) SetEncryptionKeyArn(v string) *CloudWatchLoggingConfiguration
- func (s *CloudWatchLoggingConfiguration) SetLogGroupName(v string) *CloudWatchLoggingConfiguration
- func (s *CloudWatchLoggingConfiguration) SetLogStreamNamePrefix(v string) *CloudWatchLoggingConfiguration
- func (s *CloudWatchLoggingConfiguration) SetLogTypes(v map[string][]*string) *CloudWatchLoggingConfiguration
- func (s CloudWatchLoggingConfiguration) String() string
- func (s *CloudWatchLoggingConfiguration) Validate() error
- type Configuration
- func (s Configuration) GoString() string
- func (s *Configuration) SetClassification(v string) *Configuration
- func (s *Configuration) SetConfigurations(v []*Configuration) *Configuration
- func (s *Configuration) SetProperties(v map[string]*string) *Configuration
- func (s Configuration) String() string
- func (s *Configuration) Validate() error
- type ConfigurationOverrides
- func (s ConfigurationOverrides) GoString() string
- func (s *ConfigurationOverrides) SetApplicationConfiguration(v []*Configuration) *ConfigurationOverrides
- func (s *ConfigurationOverrides) SetMonitoringConfiguration(v *MonitoringConfiguration) *ConfigurationOverrides
- func (s ConfigurationOverrides) String() string
- func (s *ConfigurationOverrides) Validate() error
- type ConflictException
- func (s *ConflictException) Code() string
- func (s *ConflictException) Error() string
- func (s ConflictException) GoString() string
- func (s *ConflictException) Message() string
- func (s *ConflictException) OrigErr() error
- func (s *ConflictException) RequestID() string
- func (s *ConflictException) StatusCode() int
- func (s ConflictException) String() string
- type CreateApplicationInput
- func (s CreateApplicationInput) GoString() string
- func (s *CreateApplicationInput) SetArchitecture(v string) *CreateApplicationInput
- func (s *CreateApplicationInput) SetAutoStartConfiguration(v *AutoStartConfig) *CreateApplicationInput
- func (s *CreateApplicationInput) SetAutoStopConfiguration(v *AutoStopConfig) *CreateApplicationInput
- func (s *CreateApplicationInput) SetClientToken(v string) *CreateApplicationInput
- func (s *CreateApplicationInput) SetImageConfiguration(v *ImageConfigurationInput_) *CreateApplicationInput
- func (s *CreateApplicationInput) SetInitialCapacity(v map[string]*InitialCapacityConfig) *CreateApplicationInput
- func (s *CreateApplicationInput) SetMaximumCapacity(v *MaximumAllowedResources) *CreateApplicationInput
- func (s *CreateApplicationInput) SetName(v string) *CreateApplicationInput
- func (s *CreateApplicationInput) SetNetworkConfiguration(v *NetworkConfiguration) *CreateApplicationInput
- func (s *CreateApplicationInput) SetReleaseLabel(v string) *CreateApplicationInput
- func (s *CreateApplicationInput) SetTags(v map[string]*string) *CreateApplicationInput
- func (s *CreateApplicationInput) SetType(v string) *CreateApplicationInput
- func (s *CreateApplicationInput) SetWorkerTypeSpecifications(v map[string]*WorkerTypeSpecificationInput_) *CreateApplicationInput
- func (s CreateApplicationInput) String() string
- func (s *CreateApplicationInput) Validate() error
- type CreateApplicationOutput
- func (s CreateApplicationOutput) GoString() string
- func (s *CreateApplicationOutput) SetApplicationId(v string) *CreateApplicationOutput
- func (s *CreateApplicationOutput) SetArn(v string) *CreateApplicationOutput
- func (s *CreateApplicationOutput) SetName(v string) *CreateApplicationOutput
- func (s CreateApplicationOutput) String() string
- type DeleteApplicationInput
- type DeleteApplicationOutput
- type EMRServerless
- func (c *EMRServerless) CancelJobRun(input *CancelJobRunInput) (*CancelJobRunOutput, error)
- func (c *EMRServerless) CancelJobRunRequest(input *CancelJobRunInput) (req *request.Request, output *CancelJobRunOutput)
- func (c *EMRServerless) CancelJobRunWithContext(ctx aws.Context, input *CancelJobRunInput, opts ...request.Option) (*CancelJobRunOutput, error)
- func (c *EMRServerless) CreateApplication(input *CreateApplicationInput) (*CreateApplicationOutput, error)
- func (c *EMRServerless) CreateApplicationRequest(input *CreateApplicationInput) (req *request.Request, output *CreateApplicationOutput)
- func (c *EMRServerless) CreateApplicationWithContext(ctx aws.Context, input *CreateApplicationInput, opts ...request.Option) (*CreateApplicationOutput, error)
- func (c *EMRServerless) DeleteApplication(input *DeleteApplicationInput) (*DeleteApplicationOutput, error)
- func (c *EMRServerless) DeleteApplicationRequest(input *DeleteApplicationInput) (req *request.Request, output *DeleteApplicationOutput)
- func (c *EMRServerless) DeleteApplicationWithContext(ctx aws.Context, input *DeleteApplicationInput, opts ...request.Option) (*DeleteApplicationOutput, error)
- func (c *EMRServerless) GetApplication(input *GetApplicationInput) (*GetApplicationOutput, error)
- func (c *EMRServerless) GetApplicationRequest(input *GetApplicationInput) (req *request.Request, output *GetApplicationOutput)
- func (c *EMRServerless) GetApplicationWithContext(ctx aws.Context, input *GetApplicationInput, opts ...request.Option) (*GetApplicationOutput, error)
- func (c *EMRServerless) GetDashboardForJobRun(input *GetDashboardForJobRunInput) (*GetDashboardForJobRunOutput, error)
- func (c *EMRServerless) GetDashboardForJobRunRequest(input *GetDashboardForJobRunInput) (req *request.Request, output *GetDashboardForJobRunOutput)
- func (c *EMRServerless) GetDashboardForJobRunWithContext(ctx aws.Context, input *GetDashboardForJobRunInput, opts ...request.Option) (*GetDashboardForJobRunOutput, error)
- func (c *EMRServerless) GetJobRun(input *GetJobRunInput) (*GetJobRunOutput, error)
- func (c *EMRServerless) GetJobRunRequest(input *GetJobRunInput) (req *request.Request, output *GetJobRunOutput)
- func (c *EMRServerless) GetJobRunWithContext(ctx aws.Context, input *GetJobRunInput, opts ...request.Option) (*GetJobRunOutput, error)
- func (c *EMRServerless) ListApplications(input *ListApplicationsInput) (*ListApplicationsOutput, error)
- func (c *EMRServerless) ListApplicationsPages(input *ListApplicationsInput, fn func(*ListApplicationsOutput, bool) bool) error
- func (c *EMRServerless) ListApplicationsPagesWithContext(ctx aws.Context, input *ListApplicationsInput, ...) error
- func (c *EMRServerless) ListApplicationsRequest(input *ListApplicationsInput) (req *request.Request, output *ListApplicationsOutput)
- func (c *EMRServerless) ListApplicationsWithContext(ctx aws.Context, input *ListApplicationsInput, opts ...request.Option) (*ListApplicationsOutput, error)
- func (c *EMRServerless) ListJobRuns(input *ListJobRunsInput) (*ListJobRunsOutput, error)
- func (c *EMRServerless) ListJobRunsPages(input *ListJobRunsInput, fn func(*ListJobRunsOutput, bool) bool) error
- func (c *EMRServerless) ListJobRunsPagesWithContext(ctx aws.Context, input *ListJobRunsInput, ...) error
- func (c *EMRServerless) ListJobRunsRequest(input *ListJobRunsInput) (req *request.Request, output *ListJobRunsOutput)
- func (c *EMRServerless) ListJobRunsWithContext(ctx aws.Context, input *ListJobRunsInput, opts ...request.Option) (*ListJobRunsOutput, error)
- func (c *EMRServerless) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)
- func (c *EMRServerless) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)
- func (c *EMRServerless) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)
- func (c *EMRServerless) StartApplication(input *StartApplicationInput) (*StartApplicationOutput, error)
- func (c *EMRServerless) StartApplicationRequest(input *StartApplicationInput) (req *request.Request, output *StartApplicationOutput)
- func (c *EMRServerless) StartApplicationWithContext(ctx aws.Context, input *StartApplicationInput, opts ...request.Option) (*StartApplicationOutput, error)
- func (c *EMRServerless) StartJobRun(input *StartJobRunInput) (*StartJobRunOutput, error)
- func (c *EMRServerless) StartJobRunRequest(input *StartJobRunInput) (req *request.Request, output *StartJobRunOutput)
- func (c *EMRServerless) StartJobRunWithContext(ctx aws.Context, input *StartJobRunInput, opts ...request.Option) (*StartJobRunOutput, error)
- func (c *EMRServerless) StopApplication(input *StopApplicationInput) (*StopApplicationOutput, error)
- func (c *EMRServerless) StopApplicationRequest(input *StopApplicationInput) (req *request.Request, output *StopApplicationOutput)
- func (c *EMRServerless) StopApplicationWithContext(ctx aws.Context, input *StopApplicationInput, opts ...request.Option) (*StopApplicationOutput, error)
- func (c *EMRServerless) TagResource(input *TagResourceInput) (*TagResourceOutput, error)
- func (c *EMRServerless) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)
- func (c *EMRServerless) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)
- func (c *EMRServerless) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)
- func (c *EMRServerless) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)
- func (c *EMRServerless) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)
- func (c *EMRServerless) UpdateApplication(input *UpdateApplicationInput) (*UpdateApplicationOutput, error)
- func (c *EMRServerless) UpdateApplicationRequest(input *UpdateApplicationInput) (req *request.Request, output *UpdateApplicationOutput)
- func (c *EMRServerless) UpdateApplicationWithContext(ctx aws.Context, input *UpdateApplicationInput, opts ...request.Option) (*UpdateApplicationOutput, error)
- type GetApplicationInput
- type GetApplicationOutput
- type GetDashboardForJobRunInput
- func (s GetDashboardForJobRunInput) GoString() string
- func (s *GetDashboardForJobRunInput) SetApplicationId(v string) *GetDashboardForJobRunInput
- func (s *GetDashboardForJobRunInput) SetJobRunId(v string) *GetDashboardForJobRunInput
- func (s GetDashboardForJobRunInput) String() string
- func (s *GetDashboardForJobRunInput) Validate() error
- type GetDashboardForJobRunOutput
- type GetJobRunInput
- type GetJobRunOutput
- type Hive
- type ImageConfiguration
- type ImageConfigurationInput_
- type InitialCapacityConfig
- func (s InitialCapacityConfig) GoString() string
- func (s *InitialCapacityConfig) SetWorkerConfiguration(v *WorkerResourceConfig) *InitialCapacityConfig
- func (s *InitialCapacityConfig) SetWorkerCount(v int64) *InitialCapacityConfig
- func (s InitialCapacityConfig) String() string
- func (s *InitialCapacityConfig) Validate() error
- type InternalServerException
- func (s *InternalServerException) Code() string
- func (s *InternalServerException) Error() string
- func (s InternalServerException) GoString() string
- func (s *InternalServerException) Message() string
- func (s *InternalServerException) OrigErr() error
- func (s *InternalServerException) RequestID() string
- func (s *InternalServerException) StatusCode() int
- func (s InternalServerException) String() string
- type JobDriver
- type JobRun
- func (s JobRun) GoString() string
- func (s *JobRun) SetApplicationId(v string) *JobRun
- func (s *JobRun) SetArn(v string) *JobRun
- func (s *JobRun) SetBilledResourceUtilization(v *ResourceUtilization) *JobRun
- func (s *JobRun) SetConfigurationOverrides(v *ConfigurationOverrides) *JobRun
- func (s *JobRun) SetCreatedAt(v time.Time) *JobRun
- func (s *JobRun) SetCreatedBy(v string) *JobRun
- func (s *JobRun) SetExecutionRole(v string) *JobRun
- func (s *JobRun) SetExecutionTimeoutMinutes(v int64) *JobRun
- func (s *JobRun) SetJobDriver(v *JobDriver) *JobRun
- func (s *JobRun) SetJobRunId(v string) *JobRun
- func (s *JobRun) SetName(v string) *JobRun
- func (s *JobRun) SetNetworkConfiguration(v *NetworkConfiguration) *JobRun
- func (s *JobRun) SetReleaseLabel(v string) *JobRun
- func (s *JobRun) SetState(v string) *JobRun
- func (s *JobRun) SetStateDetails(v string) *JobRun
- func (s *JobRun) SetTags(v map[string]*string) *JobRun
- func (s *JobRun) SetTotalExecutionDurationSeconds(v int64) *JobRun
- func (s *JobRun) SetTotalResourceUtilization(v *TotalResourceUtilization) *JobRun
- func (s *JobRun) SetUpdatedAt(v time.Time) *JobRun
- func (s JobRun) String() string
- type JobRunSummary
- func (s JobRunSummary) GoString() string
- func (s *JobRunSummary) SetApplicationId(v string) *JobRunSummary
- func (s *JobRunSummary) SetArn(v string) *JobRunSummary
- func (s *JobRunSummary) SetCreatedAt(v time.Time) *JobRunSummary
- func (s *JobRunSummary) SetCreatedBy(v string) *JobRunSummary
- func (s *JobRunSummary) SetExecutionRole(v string) *JobRunSummary
- func (s *JobRunSummary) SetId(v string) *JobRunSummary
- func (s *JobRunSummary) SetName(v string) *JobRunSummary
- func (s *JobRunSummary) SetReleaseLabel(v string) *JobRunSummary
- func (s *JobRunSummary) SetState(v string) *JobRunSummary
- func (s *JobRunSummary) SetStateDetails(v string) *JobRunSummary
- func (s *JobRunSummary) SetType(v string) *JobRunSummary
- func (s *JobRunSummary) SetUpdatedAt(v time.Time) *JobRunSummary
- func (s JobRunSummary) String() string
- type ListApplicationsInput
- func (s ListApplicationsInput) GoString() string
- func (s *ListApplicationsInput) SetMaxResults(v int64) *ListApplicationsInput
- func (s *ListApplicationsInput) SetNextToken(v string) *ListApplicationsInput
- func (s *ListApplicationsInput) SetStates(v []*string) *ListApplicationsInput
- func (s ListApplicationsInput) String() string
- func (s *ListApplicationsInput) Validate() error
- type ListApplicationsOutput
- type ListJobRunsInput
- func (s ListJobRunsInput) GoString() string
- func (s *ListJobRunsInput) SetApplicationId(v string) *ListJobRunsInput
- func (s *ListJobRunsInput) SetCreatedAtAfter(v time.Time) *ListJobRunsInput
- func (s *ListJobRunsInput) SetCreatedAtBefore(v time.Time) *ListJobRunsInput
- func (s *ListJobRunsInput) SetMaxResults(v int64) *ListJobRunsInput
- func (s *ListJobRunsInput) SetNextToken(v string) *ListJobRunsInput
- func (s *ListJobRunsInput) SetStates(v []*string) *ListJobRunsInput
- func (s ListJobRunsInput) String() string
- func (s *ListJobRunsInput) Validate() error
- type ListJobRunsOutput
- type ListTagsForResourceInput
- type ListTagsForResourceOutput
- type ManagedPersistenceMonitoringConfiguration
- func (s ManagedPersistenceMonitoringConfiguration) GoString() string
- func (s *ManagedPersistenceMonitoringConfiguration) SetEnabled(v bool) *ManagedPersistenceMonitoringConfiguration
- func (s *ManagedPersistenceMonitoringConfiguration) SetEncryptionKeyArn(v string) *ManagedPersistenceMonitoringConfiguration
- func (s ManagedPersistenceMonitoringConfiguration) String() string
- func (s *ManagedPersistenceMonitoringConfiguration) Validate() error
- type MaximumAllowedResources
- func (s MaximumAllowedResources) GoString() string
- func (s *MaximumAllowedResources) SetCpu(v string) *MaximumAllowedResources
- func (s *MaximumAllowedResources) SetDisk(v string) *MaximumAllowedResources
- func (s *MaximumAllowedResources) SetMemory(v string) *MaximumAllowedResources
- func (s MaximumAllowedResources) String() string
- func (s *MaximumAllowedResources) Validate() error
- type MonitoringConfiguration
- func (s MonitoringConfiguration) GoString() string
- func (s *MonitoringConfiguration) SetCloudWatchLoggingConfiguration(v *CloudWatchLoggingConfiguration) *MonitoringConfiguration
- func (s *MonitoringConfiguration) SetManagedPersistenceMonitoringConfiguration(v *ManagedPersistenceMonitoringConfiguration) *MonitoringConfiguration
- func (s *MonitoringConfiguration) SetS3MonitoringConfiguration(v *S3MonitoringConfiguration) *MonitoringConfiguration
- func (s MonitoringConfiguration) String() string
- func (s *MonitoringConfiguration) Validate() error
- type NetworkConfiguration
- type ResourceNotFoundException
- func (s *ResourceNotFoundException) Code() string
- func (s *ResourceNotFoundException) Error() string
- func (s ResourceNotFoundException) GoString() string
- func (s *ResourceNotFoundException) Message() string
- func (s *ResourceNotFoundException) OrigErr() error
- func (s *ResourceNotFoundException) RequestID() string
- func (s *ResourceNotFoundException) StatusCode() int
- func (s ResourceNotFoundException) String() string
- type ResourceUtilization
- func (s ResourceUtilization) GoString() string
- func (s *ResourceUtilization) SetMemoryGBHour(v float64) *ResourceUtilization
- func (s *ResourceUtilization) SetStorageGBHour(v float64) *ResourceUtilization
- func (s *ResourceUtilization) SetVCPUHour(v float64) *ResourceUtilization
- func (s ResourceUtilization) String() string
- type S3MonitoringConfiguration
- func (s S3MonitoringConfiguration) GoString() string
- func (s *S3MonitoringConfiguration) SetEncryptionKeyArn(v string) *S3MonitoringConfiguration
- func (s *S3MonitoringConfiguration) SetLogUri(v string) *S3MonitoringConfiguration
- func (s S3MonitoringConfiguration) String() string
- func (s *S3MonitoringConfiguration) Validate() error
- type ServiceQuotaExceededException
- func (s *ServiceQuotaExceededException) Code() string
- func (s *ServiceQuotaExceededException) Error() string
- func (s ServiceQuotaExceededException) GoString() string
- func (s *ServiceQuotaExceededException) Message() string
- func (s *ServiceQuotaExceededException) OrigErr() error
- func (s *ServiceQuotaExceededException) RequestID() string
- func (s *ServiceQuotaExceededException) StatusCode() int
- func (s ServiceQuotaExceededException) String() string
- type SparkSubmit
- func (s SparkSubmit) GoString() string
- func (s *SparkSubmit) SetEntryPoint(v string) *SparkSubmit
- func (s *SparkSubmit) SetEntryPointArguments(v []*string) *SparkSubmit
- func (s *SparkSubmit) SetSparkSubmitParameters(v string) *SparkSubmit
- func (s SparkSubmit) String() string
- func (s *SparkSubmit) Validate() error
- type StartApplicationInput
- type StartApplicationOutput
- type StartJobRunInput
- func (s StartJobRunInput) GoString() string
- func (s *StartJobRunInput) SetApplicationId(v string) *StartJobRunInput
- func (s *StartJobRunInput) SetClientToken(v string) *StartJobRunInput
- func (s *StartJobRunInput) SetConfigurationOverrides(v *ConfigurationOverrides) *StartJobRunInput
- func (s *StartJobRunInput) SetExecutionRoleArn(v string) *StartJobRunInput
- func (s *StartJobRunInput) SetExecutionTimeoutMinutes(v int64) *StartJobRunInput
- func (s *StartJobRunInput) SetJobDriver(v *JobDriver) *StartJobRunInput
- func (s *StartJobRunInput) SetName(v string) *StartJobRunInput
- func (s *StartJobRunInput) SetTags(v map[string]*string) *StartJobRunInput
- func (s StartJobRunInput) String() string
- func (s *StartJobRunInput) Validate() error
- type StartJobRunOutput
- type StopApplicationInput
- type StopApplicationOutput
- type TagResourceInput
- type TagResourceOutput
- type TotalResourceUtilization
- func (s TotalResourceUtilization) GoString() string
- func (s *TotalResourceUtilization) SetMemoryGBHour(v float64) *TotalResourceUtilization
- func (s *TotalResourceUtilization) SetStorageGBHour(v float64) *TotalResourceUtilization
- func (s *TotalResourceUtilization) SetVCPUHour(v float64) *TotalResourceUtilization
- func (s TotalResourceUtilization) String() string
- type UntagResourceInput
- type UntagResourceOutput
- type UpdateApplicationInput
- func (s UpdateApplicationInput) GoString() string
- func (s *UpdateApplicationInput) SetApplicationId(v string) *UpdateApplicationInput
- func (s *UpdateApplicationInput) SetArchitecture(v string) *UpdateApplicationInput
- func (s *UpdateApplicationInput) SetAutoStartConfiguration(v *AutoStartConfig) *UpdateApplicationInput
- func (s *UpdateApplicationInput) SetAutoStopConfiguration(v *AutoStopConfig) *UpdateApplicationInput
- func (s *UpdateApplicationInput) SetClientToken(v string) *UpdateApplicationInput
- func (s *UpdateApplicationInput) SetImageConfiguration(v *ImageConfigurationInput_) *UpdateApplicationInput
- func (s *UpdateApplicationInput) SetInitialCapacity(v map[string]*InitialCapacityConfig) *UpdateApplicationInput
- func (s *UpdateApplicationInput) SetMaximumCapacity(v *MaximumAllowedResources) *UpdateApplicationInput
- func (s *UpdateApplicationInput) SetNetworkConfiguration(v *NetworkConfiguration) *UpdateApplicationInput
- func (s *UpdateApplicationInput) SetReleaseLabel(v string) *UpdateApplicationInput
- func (s *UpdateApplicationInput) SetWorkerTypeSpecifications(v map[string]*WorkerTypeSpecificationInput_) *UpdateApplicationInput
- func (s UpdateApplicationInput) String() string
- func (s *UpdateApplicationInput) Validate() error
- type UpdateApplicationOutput
- type ValidationException
- func (s *ValidationException) Code() string
- func (s *ValidationException) Error() string
- func (s ValidationException) GoString() string
- func (s *ValidationException) Message() string
- func (s *ValidationException) OrigErr() error
- func (s *ValidationException) RequestID() string
- func (s *ValidationException) StatusCode() int
- func (s ValidationException) String() string
- type WorkerResourceConfig
- func (s WorkerResourceConfig) GoString() string
- func (s *WorkerResourceConfig) SetCpu(v string) *WorkerResourceConfig
- func (s *WorkerResourceConfig) SetDisk(v string) *WorkerResourceConfig
- func (s *WorkerResourceConfig) SetMemory(v string) *WorkerResourceConfig
- func (s WorkerResourceConfig) String() string
- func (s *WorkerResourceConfig) Validate() error
- type WorkerTypeSpecification
- type WorkerTypeSpecificationInput_
Constants ¶
const ( // ApplicationStateCreating is a ApplicationState enum value ApplicationStateCreating = "CREATING" // ApplicationStateCreated is a ApplicationState enum value ApplicationStateCreated = "CREATED" // ApplicationStateStarting is a ApplicationState enum value ApplicationStateStarting = "STARTING" // ApplicationStateStarted is a ApplicationState enum value ApplicationStateStarted = "STARTED" // ApplicationStateStopping is a ApplicationState enum value ApplicationStateStopping = "STOPPING" // ApplicationStateStopped is a ApplicationState enum value ApplicationStateStopped = "STOPPED" // ApplicationStateTerminated is a ApplicationState enum value ApplicationStateTerminated = "TERMINATED" )
const ( // ArchitectureArm64 is a Architecture enum value ArchitectureArm64 = "ARM64" // ArchitectureX8664 is a Architecture enum value ArchitectureX8664 = "X86_64" )
const ( // JobRunStateSubmitted is a JobRunState enum value JobRunStateSubmitted = "SUBMITTED" // JobRunStatePending is a JobRunState enum value JobRunStatePending = "PENDING" // JobRunStateScheduled is a JobRunState enum value JobRunStateScheduled = "SCHEDULED" // JobRunStateRunning is a JobRunState enum value JobRunStateRunning = "RUNNING" // JobRunStateSuccess is a JobRunState enum value JobRunStateSuccess = "SUCCESS" // JobRunStateFailed is a JobRunState enum value JobRunStateFailed = "FAILED" // JobRunStateCancelling is a JobRunState enum value JobRunStateCancelling = "CANCELLING" // JobRunStateCancelled is a JobRunState enum value JobRunStateCancelled = "CANCELLED" )
const ( // ErrCodeConflictException for service response error code // "ConflictException". // // The request could not be processed because of conflict in the current state // of the resource. ErrCodeConflictException = "ConflictException" // ErrCodeInternalServerException for service response error code // "InternalServerException". // // Request processing failed because of an error or failure with the service. ErrCodeInternalServerException = "InternalServerException" // ErrCodeResourceNotFoundException for service response error code // "ResourceNotFoundException". // // The specified resource was not found. ErrCodeResourceNotFoundException = "ResourceNotFoundException" // ErrCodeServiceQuotaExceededException for service response error code // "ServiceQuotaExceededException". // // The maximum number of resources per account has been reached. ErrCodeServiceQuotaExceededException = "ServiceQuotaExceededException" // ErrCodeValidationException for service response error code // "ValidationException". // // The input fails to satisfy the constraints specified by an Amazon Web Services // service. ErrCodeValidationException = "ValidationException" )
const ( ServiceName = "EMR Serverless" // Name of service. EndpointsID = "emr-serverless" // ID to lookup a service endpoint with. ServiceID = "EMR Serverless" // ServiceID is a unique identifier of a specific service. )
Service information constants
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 ¶
func Architecture_Values() []string
Architecture_Values returns all elements of the Architecture enum
func JobRunState_Values ¶
func JobRunState_Values() []string
JobRunState_Values returns all elements of the JobRunState enum
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 maximum capacity of the application. This is cumulative across all workers // at any given point in time during the lifespan of the application is created. // No new resources will be created once any one of the defined limits is hit. MaximumCapacity *MaximumAllowedResources `locationName:"maximumCapacity" type:"structure"` // The name of the application. Name *string `locationName:"name" min:"1" type:"string"` // The network configuration for customer VPC connectivity for the application. NetworkConfiguration *NetworkConfiguration `locationName:"networkConfiguration" type:"structure"` // The 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 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 ¶
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 ¶
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) SetMaximumCapacity ¶
func (s *Application) SetMaximumCapacity(v *MaximumAllowedResources) *Application
SetMaximumCapacity sets the MaximumCapacity field's value.
func (*Application) SetName ¶
func (s *Application) SetName(v string) *Application
SetName sets the Name field's value.
func (*Application) SetNetworkConfiguration ¶
func (s *Application) SetNetworkConfiguration(v *NetworkConfiguration) *Application
SetNetworkConfiguration sets the NetworkConfiguration field's value.
func (*Application) SetReleaseLabel ¶
func (s *Application) SetReleaseLabel(v string) *Application
SetReleaseLabel sets the ReleaseLabel field's value.
func (*Application) SetState ¶
func (s *Application) SetState(v string) *Application
SetState sets the State field's value.
func (*Application) SetStateDetails ¶
func (s *Application) SetStateDetails(v string) *Application
SetStateDetails sets the StateDetails field's value.
func (*Application) SetTags ¶
func (s *Application) SetTags(v map[string]*string) *Application
SetTags sets the Tags field's value.
func (*Application) SetType ¶
func (s *Application) SetType(v string) *Application
SetType sets the Type field's value.
func (*Application) SetUpdatedAt ¶
func (s *Application) SetUpdatedAt(v time.Time) *Application
SetUpdatedAt sets the UpdatedAt field's value.
func (*Application) SetWorkerTypeSpecifications ¶
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 ¶
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 ¶
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 ¶
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 ¶
func (s *CloudWatchLoggingConfiguration) SetEnabled(v bool) *CloudWatchLoggingConfiguration
SetEnabled sets the Enabled field's value.
func (*CloudWatchLoggingConfiguration) SetEncryptionKeyArn ¶
func (s *CloudWatchLoggingConfiguration) SetEncryptionKeyArn(v string) *CloudWatchLoggingConfiguration
SetEncryptionKeyArn sets the EncryptionKeyArn field's value.
func (*CloudWatchLoggingConfiguration) SetLogGroupName ¶
func (s *CloudWatchLoggingConfiguration) SetLogGroupName(v string) *CloudWatchLoggingConfiguration
SetLogGroupName sets the LogGroupName field's value.
func (*CloudWatchLoggingConfiguration) SetLogStreamNamePrefix ¶
func (s *CloudWatchLoggingConfiguration) SetLogStreamNamePrefix(v string) *CloudWatchLoggingConfiguration
SetLogStreamNamePrefix sets the LogStreamNamePrefix field's value.
func (*CloudWatchLoggingConfiguration) SetLogTypes ¶
func (s *CloudWatchLoggingConfiguration) SetLogTypes(v map[string][]*string) *CloudWatchLoggingConfiguration
SetLogTypes sets the LogTypes field's value.
func (CloudWatchLoggingConfiguration) String ¶
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 ¶
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 maximum capacity to allocate when the application is created. This is // cumulative across all workers at any given point in time, not just when an // application is created. No new resources will be created once any one of // the defined limits is hit. MaximumCapacity *MaximumAllowedResources `locationName:"maximumCapacity" type:"structure"` // The name of the application. Name *string `locationName:"name" min:"1" type:"string"` // The network configuration for customer VPC connectivity. NetworkConfiguration *NetworkConfiguration `locationName:"networkConfiguration" type:"structure"` // The Amazon EMR release associated with the application. // // ReleaseLabel is a required field ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string" required:"true"` // The tags assigned to the application. Tags map[string]*string `locationName:"tags" type:"map"` // The type of application you want to start, such as Spark or Hive. // // Type is a required field Type *string `locationName:"type" min:"1" type:"string" required:"true"` // 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 ¶
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 ¶
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) SetMaximumCapacity ¶
func (s *CreateApplicationInput) SetMaximumCapacity(v *MaximumAllowedResources) *CreateApplicationInput
SetMaximumCapacity sets the MaximumCapacity field's value.
func (*CreateApplicationInput) SetName ¶
func (s *CreateApplicationInput) SetName(v string) *CreateApplicationInput
SetName sets the Name field's value.
func (*CreateApplicationInput) SetNetworkConfiguration ¶
func (s *CreateApplicationInput) SetNetworkConfiguration(v *NetworkConfiguration) *CreateApplicationInput
SetNetworkConfiguration sets the NetworkConfiguration field's value.
func (*CreateApplicationInput) SetReleaseLabel ¶
func (s *CreateApplicationInput) SetReleaseLabel(v string) *CreateApplicationInput
SetReleaseLabel sets the ReleaseLabel field's value.
func (*CreateApplicationInput) SetTags ¶
func (s *CreateApplicationInput) SetTags(v map[string]*string) *CreateApplicationInput
SetTags sets the Tags field's value.
func (*CreateApplicationInput) SetType ¶
func (s *CreateApplicationInput) SetType(v string) *CreateApplicationInput
SetType sets the Type field's value.
func (*CreateApplicationInput) SetWorkerTypeSpecifications ¶
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 ¶
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 ¶
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 ¶
func (c *EMRServerless) GetDashboardForJobRunRequest(input *GetDashboardForJobRunInput) (req *request.Request, output *GetDashboardForJobRunOutput)
GetDashboardForJobRunRequest generates a "aws/request.Request" representing the client's request for the GetDashboardForJobRun operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See GetDashboardForJobRun for more information on using the GetDashboardForJobRun API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the GetDashboardForJobRunRequest method. req, resp := client.GetDashboardForJobRunRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
See also, https://docs.aws.amazon.com/goto/WebAPI/emr-serverless-2021-07-13/GetDashboardForJobRun
func (*EMRServerless) GetDashboardForJobRunWithContext ¶
func (c *EMRServerless) GetDashboardForJobRunWithContext(ctx aws.Context, input *GetDashboardForJobRunInput, opts ...request.Option) (*GetDashboardForJobRunOutput, error)
GetDashboardForJobRunWithContext is the same as GetDashboardForJobRun with the addition of the ability to pass a context and additional request options.
See GetDashboardForJobRun for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*EMRServerless) GetJobRun ¶
func (c *EMRServerless) GetJobRun(input *GetJobRunInput) (*GetJobRunOutput, error)
GetJobRun API operation for EMR Serverless.
Displays detailed information about a job run.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for EMR Serverless's API operation GetJobRun for usage and error information.
Returned Error Types:
ValidationException The input fails to satisfy the constraints specified by an 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) 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 ¶
type GetDashboardForJobRunInput struct { // The ID of the application. // // ApplicationId is a required field ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"` // The ID of the job run. // // JobRunId is a required field JobRunId *string `location:"uri" locationName:"jobRunId" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
func (GetDashboardForJobRunInput) GoString ¶
func (s GetDashboardForJobRunInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*GetDashboardForJobRunInput) SetApplicationId ¶
func (s *GetDashboardForJobRunInput) SetApplicationId(v string) *GetDashboardForJobRunInput
SetApplicationId sets the ApplicationId field's value.
func (*GetDashboardForJobRunInput) SetJobRunId ¶
func (s *GetDashboardForJobRunInput) SetJobRunId(v string) *GetDashboardForJobRunInput
SetJobRunId sets the JobRunId field's value.
func (GetDashboardForJobRunInput) String ¶
func (s GetDashboardForJobRunInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*GetDashboardForJobRunInput) Validate ¶
func (s *GetDashboardForJobRunInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type GetDashboardForJobRunOutput ¶
type GetDashboardForJobRunOutput struct { // The URL to view job run's dashboard. Url *string `locationName:"url" min:"1" type:"string"` // contains filtered or unexported fields }
func (GetDashboardForJobRunOutput) GoString ¶
func (s GetDashboardForJobRunOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*GetDashboardForJobRunOutput) SetUrl ¶
func (s *GetDashboardForJobRunOutput) SetUrl(v string) *GetDashboardForJobRunOutput
SetUrl sets the Url field's value.
func (GetDashboardForJobRunOutput) String ¶
func (s GetDashboardForJobRunOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type GetJobRunInput ¶
type GetJobRunInput struct { // The ID of the application on which the job run is submitted. // // ApplicationId is a required field ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"` // The ID of the job run. // // JobRunId is a required field JobRunId *string `location:"uri" locationName:"jobRunId" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
func (GetJobRunInput) GoString ¶
func (s GetJobRunInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*GetJobRunInput) SetApplicationId ¶
func (s *GetJobRunInput) SetApplicationId(v string) *GetJobRunInput
SetApplicationId sets the ApplicationId field's value.
func (*GetJobRunInput) SetJobRunId ¶
func (s *GetJobRunInput) SetJobRunId(v string) *GetJobRunInput
SetJobRunId sets the JobRunId field's value.
func (GetJobRunInput) String ¶
func (s GetJobRunInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*GetJobRunInput) Validate ¶
func (s *GetJobRunInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type GetJobRunOutput ¶
type GetJobRunOutput struct { // The output displays information about the job run. // // JobRun is a required field JobRun *JobRun `locationName:"jobRun" type:"structure" required:"true"` // contains filtered or unexported fields }
func (GetJobRunOutput) GoString ¶
func (s GetJobRunOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*GetJobRunOutput) SetJobRun ¶
func (s *GetJobRunOutput) SetJobRun(v *JobRun) *GetJobRunOutput
SetJobRun sets the JobRun field's value.
func (GetJobRunOutput) String ¶
func (s GetJobRunOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type Hive ¶
type Hive struct { // The query file for the Hive job run. // // InitQueryFile is a sensitive parameter and its value will be // replaced with "sensitive" in string returned by Hive's // String and GoString methods. InitQueryFile *string `locationName:"initQueryFile" min:"1" type:"string" sensitive:"true"` // The parameters for the Hive job run. // // Parameters is a sensitive parameter and its value will be // replaced with "sensitive" in string returned by Hive's // String and GoString methods. Parameters *string `locationName:"parameters" min:"1" type:"string" sensitive:"true"` // The query for the Hive job run. // // Query is a sensitive parameter and its value will be // replaced with "sensitive" in string returned by Hive's // String and GoString methods. // // Query is a required field Query *string `locationName:"query" min:"1" type:"string" required:"true" sensitive:"true"` // contains filtered or unexported fields }
The configurations for the Hive job driver.
func (Hive) GoString ¶
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 ¶
SetInitQueryFile sets the InitQueryFile field's value.
func (*Hive) SetParameters ¶
SetParameters sets the Parameters field's value.
type ImageConfiguration ¶
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 ¶
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 ¶
func (s *ImageConfiguration) SetImageUri(v string) *ImageConfiguration
SetImageUri sets the ImageUri field's value.
func (*ImageConfiguration) SetResolvedImageDigest ¶
func (s *ImageConfiguration) SetResolvedImageDigest(v string) *ImageConfiguration
SetResolvedImageDigest sets the ResolvedImageDigest field's value.
func (ImageConfiguration) String ¶
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_ ¶
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 ¶
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 ¶
func (s *ImageConfigurationInput_) SetImageUri(v string) *ImageConfigurationInput_
SetImageUri sets the ImageUri field's value.
func (ImageConfigurationInput_) String ¶
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 ¶
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 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 ¶
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) SetSparkSubmit ¶
func (s *JobDriver) SetSparkSubmit(v *SparkSubmit) *JobDriver
SetSparkSubmit sets the SparkSubmit field's value.
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 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 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 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 ¶
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 ¶
SetApplicationId sets the ApplicationId field's value.
func (*JobRun) SetBilledResourceUtilization ¶
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 ¶
SetCreatedAt sets the CreatedAt field's value.
func (*JobRun) SetCreatedBy ¶
SetCreatedBy sets the CreatedBy field's value.
func (*JobRun) SetExecutionRole ¶
SetExecutionRole sets the ExecutionRole field's value.
func (*JobRun) SetExecutionTimeoutMinutes ¶
SetExecutionTimeoutMinutes sets the ExecutionTimeoutMinutes field's value.
func (*JobRun) SetJobDriver ¶
SetJobDriver sets the JobDriver field's value.
func (*JobRun) SetJobRunId ¶
SetJobRunId sets the JobRunId field's value.
func (*JobRun) SetNetworkConfiguration ¶
func (s *JobRun) SetNetworkConfiguration(v *NetworkConfiguration) *JobRun
SetNetworkConfiguration sets the NetworkConfiguration field's value.
func (*JobRun) SetReleaseLabel ¶
SetReleaseLabel sets the ReleaseLabel field's value.
func (*JobRun) SetStateDetails ¶
SetStateDetails sets the StateDetails field's value.
func (*JobRun) SetTotalExecutionDurationSeconds ¶
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 ¶
SetUpdatedAt sets the UpdatedAt field's value.
type JobRunSummary ¶
type JobRunSummary struct { // The ID of the application the job is running on. // // ApplicationId is a required field ApplicationId *string `locationName:"applicationId" min:"1" type:"string" required:"true"` // The ARN of the job run. // // Arn is a required field Arn *string `locationName:"arn" min:"60" type:"string" required:"true"` // The date and time when the job run was created. // // CreatedAt is a required field CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" required:"true"` // The user who created the job run. // // CreatedBy is a required field CreatedBy *string `locationName:"createdBy" min:"20" type:"string" required:"true"` // The execution role ARN of the job run. // // ExecutionRole is a required field ExecutionRole *string `locationName:"executionRole" min:"20" type:"string" required:"true"` // The ID of the job run. // // Id is a required field Id *string `locationName:"id" min:"1" type:"string" required:"true"` // The optional job run name. This doesn't have to be unique. Name *string `locationName:"name" min:"1" type:"string"` // The 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) SetCreatedAt ¶
func (s *JobRunSummary) SetCreatedAt(v time.Time) *JobRunSummary
SetCreatedAt sets the CreatedAt field's value.
func (*JobRunSummary) SetCreatedBy ¶
func (s *JobRunSummary) SetCreatedBy(v string) *JobRunSummary
SetCreatedBy sets the CreatedBy field's value.
func (*JobRunSummary) SetExecutionRole ¶
func (s *JobRunSummary) SetExecutionRole(v string) *JobRunSummary
SetExecutionRole sets the ExecutionRole field's value.
func (*JobRunSummary) SetId ¶
func (s *JobRunSummary) SetId(v string) *JobRunSummary
SetId sets the Id field's value.
func (*JobRunSummary) SetName ¶
func (s *JobRunSummary) SetName(v string) *JobRunSummary
SetName sets the Name field's value.
func (*JobRunSummary) SetReleaseLabel ¶
func (s *JobRunSummary) SetReleaseLabel(v string) *JobRunSummary
SetReleaseLabel sets the ReleaseLabel field's value.
func (*JobRunSummary) SetState ¶
func (s *JobRunSummary) SetState(v string) *JobRunSummary
SetState sets the State field's value.
func (*JobRunSummary) SetStateDetails ¶
func (s *JobRunSummary) SetStateDetails(v string) *JobRunSummary
SetStateDetails sets the StateDetails field's value.
func (*JobRunSummary) SetType ¶
func (s *JobRunSummary) SetType(v string) *JobRunSummary
SetType sets the Type field's value.
func (*JobRunSummary) SetUpdatedAt ¶
func (s *JobRunSummary) SetUpdatedAt(v time.Time) *JobRunSummary
SetUpdatedAt sets the UpdatedAt field's value.
func (JobRunSummary) String ¶
func (s JobRunSummary) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ListApplicationsInput ¶
type ListApplicationsInput struct { // The maximum number of applications that can be listed. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` // The token for the next set of application results. NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"` // An optional filter for application states. Note that if this filter contains // multiple states, the resulting list will be grouped by the state. States []*string `location:"querystring" locationName:"states" min:"1" type:"list" enum:"ApplicationState"` // contains filtered or unexported fields }
func (ListApplicationsInput) GoString ¶
func (s ListApplicationsInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*ListApplicationsInput) SetMaxResults ¶
func (s *ListApplicationsInput) SetMaxResults(v int64) *ListApplicationsInput
SetMaxResults sets the MaxResults field's value.
func (*ListApplicationsInput) SetNextToken ¶
func (s *ListApplicationsInput) SetNextToken(v string) *ListApplicationsInput
SetNextToken sets the NextToken field's value.
func (*ListApplicationsInput) SetStates ¶
func (s *ListApplicationsInput) SetStates(v []*string) *ListApplicationsInput
SetStates sets the States field's value.
func (ListApplicationsInput) String ¶
func (s ListApplicationsInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*ListApplicationsInput) Validate ¶
func (s *ListApplicationsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListApplicationsOutput ¶
type ListApplicationsOutput struct { // The output lists the specified applications. // // Applications is a required field Applications []*ApplicationSummary `locationName:"applications" type:"list" required:"true"` // The output displays the token for the next set of application results. This // is required for pagination and is available as a response of the previous // request. NextToken *string `locationName:"nextToken" min:"1" type:"string"` // contains filtered or unexported fields }
func (ListApplicationsOutput) GoString ¶
func (s ListApplicationsOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*ListApplicationsOutput) SetApplications ¶
func (s *ListApplicationsOutput) SetApplications(v []*ApplicationSummary) *ListApplicationsOutput
SetApplications sets the Applications field's value.
func (*ListApplicationsOutput) SetNextToken ¶
func (s *ListApplicationsOutput) SetNextToken(v string) *ListApplicationsOutput
SetNextToken sets the NextToken field's value.
func (ListApplicationsOutput) String ¶
func (s ListApplicationsOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ListJobRunsInput ¶
type ListJobRunsInput struct { // The ID of the application for which to list the job run. // // ApplicationId is a required field ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"` // The lower bound of the option to filter by creation date and time. CreatedAtAfter *time.Time `location:"querystring" locationName:"createdAtAfter" type:"timestamp"` // The upper bound of the option to filter by creation date and time. CreatedAtBefore *time.Time `location:"querystring" locationName:"createdAtBefore" type:"timestamp"` // The maximum number of job runs that can be listed. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` // The token for the next set of job run results. NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"` // An optional filter for job run states. Note that if this filter contains // multiple states, the resulting list will be grouped by the state. States []*string `location:"querystring" locationName:"states" type:"list" enum:"JobRunState"` // contains filtered or unexported fields }
func (ListJobRunsInput) GoString ¶
func (s ListJobRunsInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*ListJobRunsInput) SetApplicationId ¶
func (s *ListJobRunsInput) SetApplicationId(v string) *ListJobRunsInput
SetApplicationId sets the ApplicationId field's value.
func (*ListJobRunsInput) SetCreatedAtAfter ¶
func (s *ListJobRunsInput) SetCreatedAtAfter(v time.Time) *ListJobRunsInput
SetCreatedAtAfter sets the CreatedAtAfter field's value.
func (*ListJobRunsInput) SetCreatedAtBefore ¶
func (s *ListJobRunsInput) SetCreatedAtBefore(v time.Time) *ListJobRunsInput
SetCreatedAtBefore sets the CreatedAtBefore field's value.
func (*ListJobRunsInput) SetMaxResults ¶
func (s *ListJobRunsInput) SetMaxResults(v int64) *ListJobRunsInput
SetMaxResults sets the MaxResults field's value.
func (*ListJobRunsInput) SetNextToken ¶
func (s *ListJobRunsInput) SetNextToken(v string) *ListJobRunsInput
SetNextToken sets the NextToken field's value.
func (*ListJobRunsInput) SetStates ¶
func (s *ListJobRunsInput) SetStates(v []*string) *ListJobRunsInput
SetStates sets the States field's value.
func (ListJobRunsInput) String ¶
func (s ListJobRunsInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*ListJobRunsInput) Validate ¶
func (s *ListJobRunsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListJobRunsOutput ¶
type ListJobRunsOutput struct { // The output lists information about the specified job runs. // // JobRuns is a required field JobRuns []*JobRunSummary `locationName:"jobRuns" type:"list" required:"true"` // The output displays the token for the next set of job run results. This is // required for pagination and is available as a response of the previous request. NextToken *string `locationName:"nextToken" min:"1" type:"string"` // contains filtered or unexported fields }
func (ListJobRunsOutput) GoString ¶
func (s ListJobRunsOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*ListJobRunsOutput) SetJobRuns ¶
func (s *ListJobRunsOutput) SetJobRuns(v []*JobRunSummary) *ListJobRunsOutput
SetJobRuns sets the JobRuns field's value.
func (*ListJobRunsOutput) SetNextToken ¶
func (s *ListJobRunsOutput) SetNextToken(v string) *ListJobRunsOutput
SetNextToken sets the NextToken field's value.
func (ListJobRunsOutput) String ¶
func (s ListJobRunsOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ListTagsForResourceInput ¶
type ListTagsForResourceInput struct { // The Amazon Resource Name (ARN) that identifies the resource to list the tags // for. Currently, the supported resources are Amazon EMR Serverless applications // and job runs. // // ResourceArn is a required field ResourceArn *string `location:"uri" locationName:"resourceArn" min:"60" type:"string" required:"true"` // contains filtered or unexported fields }
func (ListTagsForResourceInput) GoString ¶
func (s ListTagsForResourceInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*ListTagsForResourceInput) SetResourceArn ¶
func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput
SetResourceArn sets the ResourceArn field's value.
func (ListTagsForResourceInput) String ¶
func (s ListTagsForResourceInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*ListTagsForResourceInput) Validate ¶
func (s *ListTagsForResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListTagsForResourceOutput ¶
type ListTagsForResourceOutput struct { // The tags for the resource. Tags map[string]*string `locationName:"tags" type:"map"` // contains filtered or unexported fields }
func (ListTagsForResourceOutput) GoString ¶
func (s ListTagsForResourceOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*ListTagsForResourceOutput) SetTags ¶
func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput
SetTags sets the Tags field's value.
func (ListTagsForResourceOutput) String ¶
func (s ListTagsForResourceOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ManagedPersistenceMonitoringConfiguration ¶
type ManagedPersistenceMonitoringConfiguration struct { // Enables managed logging and defaults to true. If set to false, managed logging // will be turned off. Enabled *bool `locationName:"enabled" type:"boolean"` // The KMS key ARN to encrypt the logs stored in managed log persistence. EncryptionKeyArn *string `locationName:"encryptionKeyArn" min:"20" type:"string"` // contains filtered or unexported fields }
The managed log persistence configuration for a job run.
func (ManagedPersistenceMonitoringConfiguration) GoString ¶
func (s ManagedPersistenceMonitoringConfiguration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*ManagedPersistenceMonitoringConfiguration) SetEnabled ¶
func (s *ManagedPersistenceMonitoringConfiguration) SetEnabled(v bool) *ManagedPersistenceMonitoringConfiguration
SetEnabled sets the Enabled field's value.
func (*ManagedPersistenceMonitoringConfiguration) SetEncryptionKeyArn ¶
func (s *ManagedPersistenceMonitoringConfiguration) SetEncryptionKeyArn(v string) *ManagedPersistenceMonitoringConfiguration
SetEncryptionKeyArn sets the EncryptionKeyArn field's value.
func (ManagedPersistenceMonitoringConfiguration) String ¶
func (s ManagedPersistenceMonitoringConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*ManagedPersistenceMonitoringConfiguration) Validate ¶
func (s *ManagedPersistenceMonitoringConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type MaximumAllowedResources ¶
type MaximumAllowedResources struct { // The maximum allowed CPU for an application. // // Cpu is a required field Cpu *string `locationName:"cpu" min:"1" type:"string" required:"true"` // The maximum allowed disk for an application. Disk *string `locationName:"disk" min:"1" type:"string"` // The maximum allowed resources for an application. // // Memory is a required field Memory *string `locationName:"memory" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
The maximum allowed cumulative resources for an application. No new resources will be created once the limit is hit.
func (MaximumAllowedResources) GoString ¶
func (s MaximumAllowedResources) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*MaximumAllowedResources) SetCpu ¶
func (s *MaximumAllowedResources) SetCpu(v string) *MaximumAllowedResources
SetCpu sets the Cpu field's value.
func (*MaximumAllowedResources) SetDisk ¶
func (s *MaximumAllowedResources) SetDisk(v string) *MaximumAllowedResources
SetDisk sets the Disk field's value.
func (*MaximumAllowedResources) SetMemory ¶
func (s *MaximumAllowedResources) SetMemory(v string) *MaximumAllowedResources
SetMemory sets the Memory field's value.
func (MaximumAllowedResources) String ¶
func (s MaximumAllowedResources) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*MaximumAllowedResources) Validate ¶
func (s *MaximumAllowedResources) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type MonitoringConfiguration ¶
type MonitoringConfiguration struct { // The 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 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 ¶
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) SetS3MonitoringConfiguration ¶
func (s *MonitoringConfiguration) SetS3MonitoringConfiguration(v *S3MonitoringConfiguration) *MonitoringConfiguration
SetS3MonitoringConfiguration sets the S3MonitoringConfiguration field's value.
func (MonitoringConfiguration) String ¶
func (s MonitoringConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*MonitoringConfiguration) Validate ¶
func (s *MonitoringConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type NetworkConfiguration ¶
type NetworkConfiguration struct { // The array of security group Ids for customer VPC connectivity. SecurityGroupIds []*string `locationName:"securityGroupIds" type:"list"` // The array of subnet Ids for customer VPC connectivity. SubnetIds []*string `locationName:"subnetIds" type:"list"` // contains filtered or unexported fields }
The network configuration for customer VPC connectivity.
func (NetworkConfiguration) GoString ¶
func (s NetworkConfiguration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*NetworkConfiguration) SetSecurityGroupIds ¶
func (s *NetworkConfiguration) SetSecurityGroupIds(v []*string) *NetworkConfiguration
SetSecurityGroupIds sets the SecurityGroupIds field's value.
func (*NetworkConfiguration) SetSubnetIds ¶
func (s *NetworkConfiguration) SetSubnetIds(v []*string) *NetworkConfiguration
SetSubnetIds sets the SubnetIds field's value.
func (NetworkConfiguration) String ¶
func (s NetworkConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ResourceNotFoundException ¶
type ResourceNotFoundException struct { RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ *string `locationName:"message" min:"1" type:"string"` // contains filtered or unexported fields }
The specified resource was not found.
func (*ResourceNotFoundException) Code ¶
func (s *ResourceNotFoundException) Code() string
Code returns the exception type name.
func (*ResourceNotFoundException) Error ¶
func (s *ResourceNotFoundException) Error() string
func (ResourceNotFoundException) GoString ¶
func (s ResourceNotFoundException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*ResourceNotFoundException) Message ¶
func (s *ResourceNotFoundException) Message() string
Message returns the exception's message.
func (*ResourceNotFoundException) OrigErr ¶
func (s *ResourceNotFoundException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (*ResourceNotFoundException) RequestID ¶
func (s *ResourceNotFoundException) RequestID() string
RequestID returns the service's response RequestID for request.
func (*ResourceNotFoundException) StatusCode ¶
func (s *ResourceNotFoundException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (ResourceNotFoundException) String ¶
func (s ResourceNotFoundException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ResourceUtilization ¶
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 ¶
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 ¶
func (s *ResourceUtilization) SetMemoryGBHour(v float64) *ResourceUtilization
SetMemoryGBHour sets the MemoryGBHour field's value.
func (*ResourceUtilization) SetStorageGBHour ¶
func (s *ResourceUtilization) SetStorageGBHour(v float64) *ResourceUtilization
SetStorageGBHour sets the StorageGBHour field's value.
func (*ResourceUtilization) SetVCPUHour ¶
func (s *ResourceUtilization) SetVCPUHour(v float64) *ResourceUtilization
SetVCPUHour sets the VCPUHour field's value.
func (ResourceUtilization) String ¶
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 S3MonitoringConfiguration ¶
type S3MonitoringConfiguration struct { // The KMS key ARN to encrypt the logs published to the given Amazon S3 destination. EncryptionKeyArn *string `locationName:"encryptionKeyArn" min:"20" type:"string"` // The Amazon S3 destination URI for log publishing. LogUri *string `locationName:"logUri" min:"1" type:"string"` // contains filtered or unexported fields }
The Amazon S3 configuration for monitoring log publishing. You can configure your jobs to send log information to Amazon S3.
func (S3MonitoringConfiguration) GoString ¶
func (s S3MonitoringConfiguration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*S3MonitoringConfiguration) SetEncryptionKeyArn ¶
func (s *S3MonitoringConfiguration) SetEncryptionKeyArn(v string) *S3MonitoringConfiguration
SetEncryptionKeyArn sets the EncryptionKeyArn field's value.
func (*S3MonitoringConfiguration) SetLogUri ¶
func (s *S3MonitoringConfiguration) SetLogUri(v string) *S3MonitoringConfiguration
SetLogUri sets the LogUri field's value.
func (S3MonitoringConfiguration) String ¶
func (s S3MonitoringConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*S3MonitoringConfiguration) Validate ¶
func (s *S3MonitoringConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ServiceQuotaExceededException ¶
type ServiceQuotaExceededException struct { RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ *string `locationName:"message" min:"1" type:"string"` // contains filtered or unexported fields }
The maximum number of resources per account has been reached.
func (*ServiceQuotaExceededException) Code ¶
func (s *ServiceQuotaExceededException) Code() string
Code returns the exception type name.
func (*ServiceQuotaExceededException) Error ¶
func (s *ServiceQuotaExceededException) Error() string
func (ServiceQuotaExceededException) GoString ¶
func (s ServiceQuotaExceededException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*ServiceQuotaExceededException) Message ¶
func (s *ServiceQuotaExceededException) Message() string
Message returns the exception's message.
func (*ServiceQuotaExceededException) OrigErr ¶
func (s *ServiceQuotaExceededException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (*ServiceQuotaExceededException) RequestID ¶
func (s *ServiceQuotaExceededException) RequestID() string
RequestID returns the service's response RequestID for request.
func (*ServiceQuotaExceededException) StatusCode ¶
func (s *ServiceQuotaExceededException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (ServiceQuotaExceededException) String ¶
func (s ServiceQuotaExceededException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type SparkSubmit ¶
type SparkSubmit struct { // The entry point for the Spark submit job run. // // EntryPoint is a sensitive parameter and its value will be // replaced with "sensitive" in string returned by SparkSubmit's // String and GoString methods. // // EntryPoint is a required field EntryPoint *string `locationName:"entryPoint" min:"1" type:"string" required:"true" sensitive:"true"` // The arguments for the Spark submit job run. EntryPointArguments []*string `locationName:"entryPointArguments" type:"list"` // The parameters for the Spark submit job run. // // SparkSubmitParameters is a sensitive parameter and its value will be // replaced with "sensitive" in string returned by SparkSubmit's // String and GoString methods. SparkSubmitParameters *string `locationName:"sparkSubmitParameters" min:"1" type:"string" sensitive:"true"` // contains filtered or unexported fields }
The configurations for the Spark submit job driver.
func (SparkSubmit) GoString ¶
func (s SparkSubmit) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*SparkSubmit) SetEntryPoint ¶
func (s *SparkSubmit) SetEntryPoint(v string) *SparkSubmit
SetEntryPoint sets the EntryPoint field's value.
func (*SparkSubmit) SetEntryPointArguments ¶
func (s *SparkSubmit) SetEntryPointArguments(v []*string) *SparkSubmit
SetEntryPointArguments sets the EntryPointArguments field's value.
func (*SparkSubmit) SetSparkSubmitParameters ¶
func (s *SparkSubmit) SetSparkSubmitParameters(v string) *SparkSubmit
SetSparkSubmitParameters sets the SparkSubmitParameters field's value.
func (SparkSubmit) String ¶
func (s SparkSubmit) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*SparkSubmit) Validate ¶
func (s *SparkSubmit) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type StartApplicationInput ¶
type StartApplicationInput struct { // The ID of the application to start. // // ApplicationId is a required field ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
func (StartApplicationInput) GoString ¶
func (s StartApplicationInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*StartApplicationInput) SetApplicationId ¶
func (s *StartApplicationInput) SetApplicationId(v string) *StartApplicationInput
SetApplicationId sets the ApplicationId field's value.
func (StartApplicationInput) String ¶
func (s StartApplicationInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*StartApplicationInput) Validate ¶
func (s *StartApplicationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type StartApplicationOutput ¶
type StartApplicationOutput struct {
// contains filtered or unexported fields
}
func (StartApplicationOutput) GoString ¶
func (s StartApplicationOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (StartApplicationOutput) String ¶
func (s StartApplicationOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type StartJobRunInput ¶
type StartJobRunInput struct { // The ID of the application on which to run the job. // // ApplicationId is a required field ApplicationId *string `location:"uri" locationName:"applicationId" min:"1" type:"string" required:"true"` // The client idempotency token of the job run to start. Its value must be unique // for each request. ClientToken *string `locationName:"clientToken" min:"1" type:"string" idempotencyToken:"true"` // The configuration overrides for the job run. ConfigurationOverrides *ConfigurationOverrides `locationName:"configurationOverrides" type:"structure"` // The execution role ARN for the job run. // // ExecutionRoleArn is a required field ExecutionRoleArn *string `locationName:"executionRoleArn" min:"20" type:"string" required:"true"` // The maximum duration for the job run to run. If the job run runs beyond this // duration, it will be automatically cancelled. ExecutionTimeoutMinutes *int64 `locationName:"executionTimeoutMinutes" type:"long"` // The job driver for the job run. JobDriver *JobDriver `locationName:"jobDriver" type:"structure"` // The optional job run name. This doesn't have to be unique. Name *string `locationName:"name" min:"1" type:"string"` // The tags assigned to the job run. Tags map[string]*string `locationName:"tags" type:"map"` // contains filtered or unexported fields }
func (StartJobRunInput) GoString ¶
func (s StartJobRunInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*StartJobRunInput) SetApplicationId ¶
func (s *StartJobRunInput) SetApplicationId(v string) *StartJobRunInput
SetApplicationId sets the ApplicationId field's value.
func (*StartJobRunInput) SetClientToken ¶
func (s *StartJobRunInput) SetClientToken(v string) *StartJobRunInput
SetClientToken sets the ClientToken field's value.
func (*StartJobRunInput) SetConfigurationOverrides ¶
func (s *StartJobRunInput) SetConfigurationOverrides(v *ConfigurationOverrides) *StartJobRunInput
SetConfigurationOverrides sets the ConfigurationOverrides field's value.
func (*StartJobRunInput) SetExecutionRoleArn ¶
func (s *StartJobRunInput) SetExecutionRoleArn(v string) *StartJobRunInput
SetExecutionRoleArn sets the ExecutionRoleArn field's value.
func (*StartJobRunInput) SetExecutionTimeoutMinutes ¶
func (s *StartJobRunInput) SetExecutionTimeoutMinutes(v int64) *StartJobRunInput
SetExecutionTimeoutMinutes sets the ExecutionTimeoutMinutes field's value.
func (*StartJobRunInput) SetJobDriver ¶
func (s *StartJobRunInput) SetJobDriver(v *JobDriver) *StartJobRunInput
SetJobDriver sets the JobDriver field's value.
func (*StartJobRunInput) SetName ¶
func (s *StartJobRunInput) SetName(v string) *StartJobRunInput
SetName sets the Name field's value.
func (*StartJobRunInput) SetTags ¶
func (s *StartJobRunInput) SetTags(v map[string]*string) *StartJobRunInput
SetTags sets the Tags field's value.
func (StartJobRunInput) String ¶
func (s StartJobRunInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*StartJobRunInput) Validate ¶
func (s *StartJobRunInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type StartJobRunOutput ¶
type StartJobRunOutput struct { // This output displays the application ID on which the job run was submitted. // // ApplicationId is a required field ApplicationId *string `locationName:"applicationId" min:"1" type:"string" required:"true"` // 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 maximum capacity to allocate when the application is updated. This is // cumulative across all workers at any given point in time during the lifespan // of the application. No new resources will be created once any one of the // defined limits is hit. MaximumCapacity *MaximumAllowedResources `locationName:"maximumCapacity" type:"structure"` // The network configuration for customer VPC connectivity. NetworkConfiguration *NetworkConfiguration `locationName:"networkConfiguration" type:"structure"` // 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 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 ¶
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 ¶
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) SetMaximumCapacity ¶
func (s *UpdateApplicationInput) SetMaximumCapacity(v *MaximumAllowedResources) *UpdateApplicationInput
SetMaximumCapacity sets the MaximumCapacity field's value.
func (*UpdateApplicationInput) SetNetworkConfiguration ¶
func (s *UpdateApplicationInput) SetNetworkConfiguration(v *NetworkConfiguration) *UpdateApplicationInput
SetNetworkConfiguration sets the NetworkConfiguration field's value.
func (*UpdateApplicationInput) SetReleaseLabel ¶
func (s *UpdateApplicationInput) SetReleaseLabel(v string) *UpdateApplicationInput
SetReleaseLabel sets the ReleaseLabel field's value.
func (*UpdateApplicationInput) SetWorkerTypeSpecifications ¶
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 memory requirements for every worker instance of the worker type. // // Memory is a required field Memory *string `locationName:"memory" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
The cumulative configuration requirements for every worker instance of the worker type.
func (WorkerResourceConfig) GoString ¶
func (s WorkerResourceConfig) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*WorkerResourceConfig) SetCpu ¶
func (s *WorkerResourceConfig) SetCpu(v string) *WorkerResourceConfig
SetCpu sets the Cpu field's value.
func (*WorkerResourceConfig) SetDisk ¶
func (s *WorkerResourceConfig) SetDisk(v string) *WorkerResourceConfig
SetDisk sets the Disk field's value.
func (*WorkerResourceConfig) SetMemory ¶
func (s *WorkerResourceConfig) SetMemory(v string) *WorkerResourceConfig
SetMemory sets the Memory field's value.
func (WorkerResourceConfig) String ¶
func (s WorkerResourceConfig) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (*WorkerResourceConfig) Validate ¶
func (s *WorkerResourceConfig) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type WorkerTypeSpecification ¶
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 ¶
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 ¶
func (s *WorkerTypeSpecification) SetImageConfiguration(v *ImageConfiguration) *WorkerTypeSpecification
SetImageConfiguration sets the ImageConfiguration field's value.
func (WorkerTypeSpecification) String ¶
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_ ¶
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 ¶
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 ¶
func (s *WorkerTypeSpecificationInput_) SetImageConfiguration(v *ImageConfigurationInput_) *WorkerTypeSpecificationInput_
SetImageConfiguration sets the ImageConfiguration field's value.
func (WorkerTypeSpecificationInput_) String ¶
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 ¶
func (s *WorkerTypeSpecificationInput_) Validate() error
Validate inspects the fields of the type to determine if they are valid.
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. |