Package software.amazon.awscdk.services.glue.alpha

Class PySparkEtlJob

java.lang.Object

software.amazon.jsii.JsiiObject

software.constructs.Construct

software.amazon.awscdk.Resource

software.amazon.awscdk.services.glue.alpha.JobBase

software.amazon.awscdk.services.glue.alpha.Job

software.amazon.awscdk.services.glue.alpha.SparkJob

software.amazon.awscdk.services.glue.alpha.PySparkEtlJob

All Implemented Interfaces:

IEnvironmentAware, IResource, IJob, IGrantable, software.amazon.jsii.JsiiSerializable, software.constructs.IConstruct, software.constructs.IDependable

@Generated(value="jsii-pacmak/1.119.0 (build 1634eac)",
           date="2025-11-13T16:10:18.323Z")
@Stability(Experimental)
public class PySparkEtlJob
extends SparkJob

(experimental) PySpark ETL Jobs class.

ETL jobs support pySpark and Scala languages, for which there are separate but similar constructors. ETL jobs default to the G2 worker type, but you can override this default with other supported worker type values (G1, G2, G4 and G8). ETL jobs defaults to Glue version 4.0, which you can override to 3.0. The following ETL features are enabled by default: —enable-metrics, —enable-spark-ui, —enable-continuous-cloudwatch-log. You can find more details about version, worker type and other features in Glue's public documentation.

Example:

 import software.amazon.awscdk.*;
 import software.amazon.awscdk.services.iam.*;
 Stack stack;
 IRole role;
 Code script;
 // Disable both metrics for cost optimization
 // Disable both metrics for cost optimization
 PySparkEtlJob.Builder.create(stack, "CostOptimizedJob")
         .role(role)
         .script(script)
         .enableMetrics(false)
         .enableObservabilityMetrics(false)
         .build();
 // Selective control - keep observability, disable profiling
 // Selective control - keep observability, disable profiling
 PySparkEtlJob.Builder.create(stack, "SelectiveJob")
         .role(role)
         .script(script)
         .enableMetrics(false)
         .build();
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	PySparkEtlJob.Builder	(experimental) A fluent builder for PySparkEtlJob.

Nested classes/interfaces inherited from class software.amazon.jsii.JsiiObject

software.amazon.jsii.JsiiObject.InitializationMode

Nested classes/interfaces inherited from interface software.constructs.IConstruct

software.constructs.IConstruct.Jsii$Default

Nested classes/interfaces inherited from interface software.amazon.awscdk.services.glue.alpha.IJob

IJob.Jsii$Default

Nested classes/interfaces inherited from interface software.amazon.awscdk.IResource

IResource.Jsii$Default

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PROPERTY_INJECTION_ID	(experimental) Uniquely identifies this class.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PySparkEtlJob(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)
protected	PySparkEtlJob(software.amazon.jsii.JsiiObjectRef objRef)
	PySparkEtlJob(software.constructs.Construct scope, String id, PySparkEtlJobProps props)	(experimental) PySparkEtlJob constructor.

Method Summary

Modifier and Type	Method	Description
String	getJobArn()	(experimental) The ARN of the job.
String	getJobName()	(experimental) The name of the job.

Methods inherited from class software.amazon.awscdk.services.glue.alpha.SparkJob

getGrantPrincipal, getRole, getSparkUILoggingLocation, nonExecutableCommonArguments, setupExtraCodeArguments

Methods inherited from class software.amazon.awscdk.services.glue.alpha.Job

checkNoReservedArgs, checkNoReservedArgs, codeS3ObjectUrl, fromJobAttributes, setupContinuousLogging, setupContinuousLogging

Methods inherited from class software.amazon.awscdk.services.glue.alpha.JobBase

buildJobArn, metric, metric, metricFailure, metricFailure, metricSuccess, metricSuccess, metricTimeout, metricTimeout, onEvent, onEvent, onFailure, onFailure, onStateChange, onStateChange, onSuccess, onSuccess, onTimeout, onTimeout

Methods inherited from class software.amazon.awscdk.Resource

applyRemovalPolicy, generatePhysicalName, getEnv, getPhysicalName, getResourceArnAttribute, getResourceNameAttribute, getStack, isOwnedResource, isResource

Methods inherited from class software.constructs.Construct

getNode, isConstruct, toString

Methods inherited from class software.amazon.jsii.JsiiObject

jsiiAsyncCall, jsiiAsyncCall, jsiiCall, jsiiCall, jsiiGet, jsiiGet, jsiiSet, jsiiStaticCall, jsiiStaticCall, jsiiStaticGet, jsiiStaticGet, jsiiStaticSet, jsiiStaticSet

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface software.constructs.IConstruct

getNode

Methods inherited from interface software.amazon.awscdk.interfaces.IEnvironmentAware

getEnv

Methods inherited from interface software.amazon.awscdk.IResource

applyRemovalPolicy, getStack

Methods inherited from interface software.amazon.jsii.JsiiSerializable

$jsii$toJson

Field Details

PROPERTY_INJECTION_ID

@Stability(Experimental)
public static final String PROPERTY_INJECTION_ID

(experimental) Uniquely identifies this class.

Constructor Details

PySparkEtlJob

protected PySparkEtlJob(software.amazon.jsii.JsiiObjectRef objRef)

PySparkEtlJob

protected PySparkEtlJob(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)

PySparkEtlJob

@Stability(Experimental)
public PySparkEtlJob(@NotNull
 software.constructs.Construct scope,
 @NotNull
 String id,
 @NotNull
 PySparkEtlJobProps props)

(experimental) PySparkEtlJob constructor.

Parameters:

scope - This parameter is required.

id - This parameter is required.

props - This parameter is required.

Method Details

getJobArn

@Stability(Experimental)
@NotNull
public String getJobArn()

(experimental) The ARN of the job.

Specified by:

getJobArn in interface IJob

Specified by:

getJobArn in class JobBase

getJobName

@Stability(Experimental)
@NotNull
public String getJobName()

(experimental) The name of the job.

Specified by:

getJobName in interface IJob

Specified by:

getJobName in class JobBase