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

Class PySparkStreamingJob

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

All Implemented Interfaces:

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

@Generated(value="jsii-pacmak/1.139.0 (build 26a6b54)",
           date="2026-09-17T14:54:30.106Z")
@Stability(Deprecated)
@Deprecated
public class PySparkStreamingJob
extends SparkJob

Deprecated.

(deprecated) Python Spark Streaming Jobs class.

A Streaming job is similar to an ETL job, except that it performs ETL on data streams using the Apache Spark Structured Streaming framework. These jobs will default to use Python 3.9.

Similar to ETL jobs, streaming job supports Scala and Python languages. Similar to ETL, it supports G1 and G2 worker type and 2.0, 3.0 and 4.0 version. We’ll default to G1 worker and 4.0 version for streaming jobs which developers can override. We will enable --enable-metrics, --enable-continuous-cloudwatch-log. The Spark UI (--enable-spark-ui) is off by default; enable it by setting the sparkUI prop.

Example:

 import software.amazon.awscdk.*;
 import software.amazon.awscdk.services.iam.*;
 Stack stack;
 IRole role;
 Code script;
 PySparkStreamingJob.Builder.create(stack, "ImportedJob").role(role).script(script).build();
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	PySparkStreamingJob.Builder	Deprecated.

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PySparkStreamingJob(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)	Deprecated.
protected	PySparkStreamingJob(software.amazon.jsii.JsiiObjectRef objRef)	Deprecated.
	PySparkStreamingJob(software.constructs.Construct scope, String id, PySparkStreamingJobProps props)	Deprecated.

Method Summary

Modifier and Type	Method	Description
String	getJobArn()	Deprecated.
String	getJobName()	Deprecated.

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

codeS3ObjectUrl, fromJobAttributes, mergeDefaultArguments, mergeDefaultArguments, setManagedArgument, setManagedArgument, setupContinuousLogging, setupContinuousLogging, setupContinuousLogging

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

buildJobArn, getJobRef, 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

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

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, with

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(Deprecated)
@Deprecated
public static final String PROPERTY_INJECTION_ID

Deprecated.

(deprecated) Uniquely identifies this class.

Constructor Details

PySparkStreamingJob

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

Deprecated.

PySparkStreamingJob

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

Deprecated.

PySparkStreamingJob

@Stability(Deprecated)
@Deprecated
public PySparkStreamingJob(@NotNull
 software.constructs.Construct scope,
 @NotNull
 String id,
 @NotNull
 PySparkStreamingJobProps props)

Deprecated.

(deprecated) PySparkStreamingJob constructor.

Parameters:

scope - This parameter is required.

id - This parameter is required.

props - This parameter is required.

Method Details

getJobArn

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

Deprecated.

(deprecated) The ARN of the job.

Specified by:

getJobArn in interface IJob

Specified by:

getJobArn in class JobBase

getJobName

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

Deprecated.

(deprecated) The name of the job.

Specified by:

getJobName in interface IJob

Specified by:

getJobName in class JobBase