SparkSessionAsyncClient.createSparkStatementWithResponse(int sessionId, SparkStatementOptions sparkStatementOptions) Method

Definition

Create statement within a spark session.

public Mono<Response<SparkStatement>> createSparkStatementWithResponse(int sessionId, SparkStatementOptions sparkStatementOptions)

Parameters

sessionId
int

Identifier for the session.

sparkStatementOptions
SparkStatementOptions

Livy compatible batch job request payload.

Returns

reactor.core.publisher.Mono<Response<SparkStatement>>

the response.

Applies to