Struct aws_sdk_glue::client::fluent_builders::CreateSession

pub struct CreateSession { /* private fields */ }

Fluent builder constructing a request to CreateSession.

Creates a new session.

Implementations

impl CreateSession

pub async fn customize(
    self
) -> Result<CustomizableOperation<CreateSession, AwsResponseRetryClassifier>, SdkError<CreateSessionError>>

Consume this builder, creating a customizable operation that can be modified before being sent. The operation’s inner http::Request can be modified as well.

pub async fn send(
    self
) -> Result<CreateSessionOutput, SdkError<CreateSessionError>>

Sends the request and returns the response.

If an error occurs, an SdkError will be returned with additional details that can be matched against.

By default, any retryable failures will be retried twice. Retry behavior is configurable with the RetryConfig, which can be set when configuring the client.

pub fn id(self, input: impl Into<String>) -> Self

The ID of the session request.

pub fn set_id(self, input: Option<String>) -> Self

The ID of the session request.

pub fn description(self, input: impl Into<String>) -> Self

The description of the session.

pub fn set_description(self, input: Option<String>) -> Self

The description of the session.

pub fn role(self, input: impl Into<String>) -> Self

The IAM Role ARN

pub fn set_role(self, input: Option<String>) -> Self

The IAM Role ARN

pub fn command(self, input: SessionCommand) -> Self

The SessionCommand that runs the job.

pub fn set_command(self, input: Option<SessionCommand>) -> Self

The SessionCommand that runs the job.

pub fn timeout(self, input: i32) -> Self

The number of seconds before request times out.

pub fn set_timeout(self, input: Option<i32>) -> Self

The number of seconds before request times out.

pub fn idle_timeout(self, input: i32) -> Self

The number of seconds when idle before request times out.

pub fn set_idle_timeout(self, input: Option<i32>) -> Self

The number of seconds when idle before request times out.

pub fn default_arguments(self, k: impl Into<String>, v: impl Into<String>) -> Self

Adds a key-value pair to DefaultArguments.

To override the contents of this collection use set_default_arguments.

A map array of key-value pairs. Max is 75 pairs.

pub fn set_default_arguments(
    self,
    input: Option<HashMap<String, String>>
) -> Self

A map array of key-value pairs. Max is 75 pairs.

pub fn connections(self, input: ConnectionsList) -> Self

The number of connections to use for the session.

pub fn set_connections(self, input: Option<ConnectionsList>) -> Self

The number of connections to use for the session.

pub fn max_capacity(self, input: f64) -> Self

The number of Glue data processing units (DPUs) that can be allocated when the job runs. A DPU is a relative measure of processing power that consists of 4 vCPUs of compute capacity and 16 GB memory.

pub fn set_max_capacity(self, input: Option<f64>) -> Self

The number of Glue data processing units (DPUs) that can be allocated when the job runs. A DPU is a relative measure of processing power that consists of 4 vCPUs of compute capacity and 16 GB memory.

pub fn number_of_workers(self, input: i32) -> Self

The number of workers of a defined WorkerType to use for the session.

pub fn set_number_of_workers(self, input: Option<i32>) -> Self

The number of workers of a defined WorkerType to use for the session.

pub fn worker_type(self, input: WorkerType) -> Self

The type of predefined worker that is allocated to use for the session. Accepts a value of Standard, G.1X, G.2X, or G.025X.

• For the Standard worker type, each worker provides 4 vCPU, 16 GB of memory and a 50GB disk, and 2 executors per worker.

• For the G.1X worker type, each worker maps to 1 DPU (4 vCPU, 16 GB of memory, 64 GB disk), and provides 1 executor per worker. We recommend this worker type for memory-intensive jobs.

• For the G.2X worker type, each worker maps to 2 DPU (8 vCPU, 32 GB of memory, 128 GB disk), and provides 1 executor per worker. We recommend this worker type for memory-intensive jobs.

• For the G.025X worker type, each worker maps to 0.25 DPU (2 vCPU, 4 GB of memory, 64 GB disk), and provides 1 executor per worker. We recommend this worker type for low volume streaming jobs. This worker type is only available for Glue version 3.0 streaming jobs.

pub fn set_worker_type(self, input: Option<WorkerType>) -> Self

The type of predefined worker that is allocated to use for the session. Accepts a value of Standard, G.1X, G.2X, or G.025X.

• For the Standard worker type, each worker provides 4 vCPU, 16 GB of memory and a 50GB disk, and 2 executors per worker.

• For the G.1X worker type, each worker maps to 1 DPU (4 vCPU, 16 GB of memory, 64 GB disk), and provides 1 executor per worker. We recommend this worker type for memory-intensive jobs.

• For the G.2X worker type, each worker maps to 2 DPU (8 vCPU, 32 GB of memory, 128 GB disk), and provides 1 executor per worker. We recommend this worker type for memory-intensive jobs.

• For the G.025X worker type, each worker maps to 0.25 DPU (2 vCPU, 4 GB of memory, 64 GB disk), and provides 1 executor per worker. We recommend this worker type for low volume streaming jobs. This worker type is only available for Glue version 3.0 streaming jobs.

pub fn security_configuration(self, input: impl Into<String>) -> Self

The name of the SecurityConfiguration structure to be used with the session

pub fn set_security_configuration(self, input: Option<String>) -> Self

The name of the SecurityConfiguration structure to be used with the session

pub fn glue_version(self, input: impl Into<String>) -> Self

The Glue version determines the versions of Apache Spark and Python that Glue supports. The GlueVersion must be greater than 2.0.

pub fn set_glue_version(self, input: Option<String>) -> Self

The Glue version determines the versions of Apache Spark and Python that Glue supports. The GlueVersion must be greater than 2.0.

pub fn tags(self, k: impl Into<String>, v: impl Into<String>) -> Self

Adds a key-value pair to Tags.

To override the contents of this collection use set_tags.

The map of key value pairs (tags) belonging to the session.

pub fn set_tags(self, input: Option<HashMap<String, String>>) -> Self

The map of key value pairs (tags) belonging to the session.

pub fn request_origin(self, input: impl Into<String>) -> Self

The origin of the request.

pub fn set_request_origin(self, input: Option<String>) -> Self

The origin of the request.

Trait Implementations

impl Clone for CreateSession

fn clone(&self) -> CreateSession

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CreateSession

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.