diff --git a/sdk/synapse/synapse-spark/CHANGELOG.md b/sdk/synapse/synapse-spark/CHANGELOG.md index fe60eedce469..292c3d4aa828 100644 --- a/sdk/synapse/synapse-spark/CHANGELOG.md +++ b/sdk/synapse/synapse-spark/CHANGELOG.md @@ -1,14 +1,11 @@ # Release History -## 1.0.0-beta.4 (Unreleased) +## 1.0.0-beta.4 (2021-10-05) ### Features Added -### Breaking Changes - -### Bugs Fixed - -### Other Changes +- Re-generate with latest release tag `package-spark-2020-12-01` +- Update `LivyState` to be an extensible enum. ## 1.0.0-beta.3 (2021-08-10) diff --git a/sdk/synapse/synapse-spark/review/synapse-spark.api.md b/sdk/synapse/synapse-spark/review/synapse-spark.api.md index 510b81bc3abb..a59de7f59636 100644 --- a/sdk/synapse/synapse-spark/review/synapse-spark.api.md +++ b/sdk/synapse/synapse-spark/review/synapse-spark.api.md @@ -7,6 +7,48 @@ import * as coreAuth from '@azure/core-auth'; import * as coreClient from '@azure/core-client'; +// @public +export enum KnownLivyStatementStates { + // (undocumented) + Available = "available", + // (undocumented) + Cancelled = "cancelled", + // (undocumented) + Cancelling = "cancelling", + // (undocumented) + Error = "error", + // (undocumented) + Running = "running", + // (undocumented) + Waiting = "waiting" +} + +// @public +export enum KnownLivyStates { + // (undocumented) + Busy = "busy", + // (undocumented) + Dead = "dead", + // (undocumented) + Error = "error", + // (undocumented) + Idle = "idle", + // (undocumented) + Killed = "killed", + // (undocumented) + NotStarted = "not_started", + // (undocumented) + Recovering = "recovering", + // (undocumented) + Running = "running", + // (undocumented) + ShuttingDown = "shutting_down", + // (undocumented) + Starting = "starting", + // (undocumented) + Success = "success" +} + // @public export enum KnownPluginCurrentState { // (undocumented) @@ -91,6 +133,12 @@ export enum KnownSparkStatementLanguageType { Sql = "sql" } +// @public +export type LivyStatementStates = string; + +// @public +export type LivyStates = string; + // @public export type PluginCurrentState = string; @@ -153,7 +201,7 @@ export interface SparkBatchJob { result?: SparkBatchJobResultType; scheduler?: SparkScheduler; sparkPoolName?: string; - state?: string; + state?: LivyStates; submitterId?: string; submitterName?: string; tags?: { @@ -357,8 +405,7 @@ export interface SparkSession { scheduler?: SparkScheduler; // (undocumented) sparkPoolName?: string; - // (undocumented) - state?: string; + state?: LivyStates; // (undocumented) submitterId?: string; // (undocumented) @@ -370,6 +417,17 @@ export interface SparkSession { workspaceName?: string; } +// @public +export interface SparkSessionCancelSparkSessionOptionalParams extends coreClient.OperationOptions { +} + +// @public +export interface SparkSessionCancelSparkStatementOptionalParams extends coreClient.OperationOptions { +} + +// @public +export type SparkSessionCancelSparkStatementResponse = SparkStatementCancellationResult; + // @public (undocumented) export interface SparkSessionCollection { // (undocumented) @@ -381,78 +439,63 @@ export interface SparkSessionCollection { } // @public -export interface SparkSessionOperations { - cancelSparkSession(sessionId: number, options?: SparkSessionOperationsCancelSparkSessionOptionalParams): Promise; - cancelSparkStatement(sessionId: number, statementId: number, options?: SparkSessionOperationsCancelSparkStatementOptionalParams): Promise; - createSparkSession(sparkSessionOptions: SparkSessionOptions, options?: SparkSessionOperationsCreateSparkSessionOptionalParams): Promise; - createSparkStatement(sessionId: number, sparkStatementOptions: SparkStatementOptions, options?: SparkSessionOperationsCreateSparkStatementOptionalParams): Promise; - getSparkSession(sessionId: number, options?: SparkSessionOperationsGetSparkSessionOptionalParams): Promise; - getSparkSessions(options?: SparkSessionOperationsGetSparkSessionsOptionalParams): Promise; - getSparkStatement(sessionId: number, statementId: number, options?: SparkSessionOperationsGetSparkStatementOptionalParams): Promise; - getSparkStatements(sessionId: number, options?: SparkSessionOperationsGetSparkStatementsOptionalParams): Promise; - resetSparkSessionTimeout(sessionId: number, options?: SparkSessionOperationsResetSparkSessionTimeoutOptionalParams): Promise; -} - -// @public -export interface SparkSessionOperationsCancelSparkSessionOptionalParams extends coreClient.OperationOptions { -} - -// @public -export interface SparkSessionOperationsCancelSparkStatementOptionalParams extends coreClient.OperationOptions { -} - -// @public -export type SparkSessionOperationsCancelSparkStatementResponse = SparkStatementCancellationResult; - -// @public -export interface SparkSessionOperationsCreateSparkSessionOptionalParams extends coreClient.OperationOptions { +export interface SparkSessionCreateSparkSessionOptionalParams extends coreClient.OperationOptions { detailed?: boolean; } // @public -export type SparkSessionOperationsCreateSparkSessionResponse = SparkSession; +export type SparkSessionCreateSparkSessionResponse = SparkSession; // @public -export interface SparkSessionOperationsCreateSparkStatementOptionalParams extends coreClient.OperationOptions { +export interface SparkSessionCreateSparkStatementOptionalParams extends coreClient.OperationOptions { } // @public -export type SparkSessionOperationsCreateSparkStatementResponse = SparkStatement; +export type SparkSessionCreateSparkStatementResponse = SparkStatement; // @public -export interface SparkSessionOperationsGetSparkSessionOptionalParams extends coreClient.OperationOptions { +export interface SparkSessionGetSparkSessionOptionalParams extends coreClient.OperationOptions { detailed?: boolean; } // @public -export type SparkSessionOperationsGetSparkSessionResponse = SparkSession; +export type SparkSessionGetSparkSessionResponse = SparkSession; // @public -export interface SparkSessionOperationsGetSparkSessionsOptionalParams extends coreClient.OperationOptions { +export interface SparkSessionGetSparkSessionsOptionalParams extends coreClient.OperationOptions { detailed?: boolean; fromParam?: number; size?: number; } // @public -export type SparkSessionOperationsGetSparkSessionsResponse = SparkSessionCollection; +export type SparkSessionGetSparkSessionsResponse = SparkSessionCollection; // @public -export interface SparkSessionOperationsGetSparkStatementOptionalParams extends coreClient.OperationOptions { +export interface SparkSessionGetSparkStatementOptionalParams extends coreClient.OperationOptions { } // @public -export type SparkSessionOperationsGetSparkStatementResponse = SparkStatement; +export type SparkSessionGetSparkStatementResponse = SparkStatement; // @public -export interface SparkSessionOperationsGetSparkStatementsOptionalParams extends coreClient.OperationOptions { +export interface SparkSessionGetSparkStatementsOptionalParams extends coreClient.OperationOptions { } // @public -export type SparkSessionOperationsGetSparkStatementsResponse = SparkStatementCollection; +export type SparkSessionGetSparkStatementsResponse = SparkStatementCollection; // @public -export interface SparkSessionOperationsResetSparkSessionTimeoutOptionalParams extends coreClient.OperationOptions { +export interface SparkSessionOperations { + cancelSparkSession(sessionId: number, options?: SparkSessionCancelSparkSessionOptionalParams): Promise; + cancelSparkStatement(sessionId: number, statementId: number, options?: SparkSessionCancelSparkStatementOptionalParams): Promise; + createSparkSession(sparkSessionOptions: SparkSessionOptions, options?: SparkSessionCreateSparkSessionOptionalParams): Promise; + createSparkStatement(sessionId: number, sparkStatementOptions: SparkStatementOptions, options?: SparkSessionCreateSparkStatementOptionalParams): Promise; + getSparkSession(sessionId: number, options?: SparkSessionGetSparkSessionOptionalParams): Promise; + getSparkSessions(options?: SparkSessionGetSparkSessionsOptionalParams): Promise; + getSparkStatement(sessionId: number, statementId: number, options?: SparkSessionGetSparkStatementOptionalParams): Promise; + getSparkStatements(sessionId: number, options?: SparkSessionGetSparkStatementsOptionalParams): Promise; + resetSparkSessionTimeout(sessionId: number, options?: SparkSessionResetSparkSessionTimeoutOptionalParams): Promise; } // @public (undocumented) @@ -493,6 +536,10 @@ export interface SparkSessionOptions { }; } +// @public +export interface SparkSessionResetSparkSessionTimeoutOptionalParams extends coreClient.OperationOptions { +} + // @public export type SparkSessionResultType = string; @@ -531,7 +578,7 @@ export interface SparkStatement { // (undocumented) output?: SparkStatementOutput; // (undocumented) - state?: string; + state?: LivyStatementStates; } // @public (undocumented) diff --git a/sdk/synapse/synapse-spark/src/models/index.ts b/sdk/synapse/synapse-spark/src/models/index.ts index 571073ed9ccb..d38704fbe5da 100644 --- a/sdk/synapse/synapse-spark/src/models/index.ts +++ b/sdk/synapse/synapse-spark/src/models/index.ts @@ -51,7 +51,7 @@ export interface SparkBatchJob { /** The detailed application info. */ appInfo?: { [propertyName: string]: string }; /** The batch state */ - state?: string; + state?: LivyStates; /** The log lines. */ logLines?: string[]; } @@ -164,7 +164,8 @@ export interface SparkSession { appId?: string; /** Dictionary of */ appInfo?: { [propertyName: string]: string }; - state?: string; + /** The session state. */ + state?: LivyStates; logLines?: string[]; } @@ -211,7 +212,7 @@ export interface SparkStatementCollection { export interface SparkStatement { id: number; code?: string; - state?: string; + state?: LivyStatementStates; output?: SparkStatementOutput; } @@ -335,6 +336,40 @@ export enum KnownSparkErrorSource { */ export type SparkErrorSource = string; +/** Known values of {@link LivyStates} that the service accepts. */ +export enum KnownLivyStates { + NotStarted = "not_started", + Starting = "starting", + Idle = "idle", + Busy = "busy", + ShuttingDown = "shutting_down", + Error = "error", + Dead = "dead", + Killed = "killed", + Success = "success", + Running = "running", + Recovering = "recovering" +} + +/** + * Defines values for LivyStates. \ + * {@link KnownLivyStates} can be used interchangeably with LivyStates, + * this enum contains the known values that the service supports. + * ### Known values supported by the service + * **not_started** \ + * **starting** \ + * **idle** \ + * **busy** \ + * **shutting_down** \ + * **error** \ + * **dead** \ + * **killed** \ + * **success** \ + * **running** \ + * **recovering** + */ +export type LivyStates = string; + /** Known values of {@link SparkSessionResultType} that the service accepts. */ export enum KnownSparkSessionResultType { Uncertain = "Uncertain", @@ -355,6 +390,30 @@ export enum KnownSparkSessionResultType { */ export type SparkSessionResultType = string; +/** Known values of {@link LivyStatementStates} that the service accepts. */ +export enum KnownLivyStatementStates { + Waiting = "waiting", + Running = "running", + Available = "available", + Error = "error", + Cancelling = "cancelling", + Cancelled = "cancelled" +} + +/** + * Defines values for LivyStatementStates. \ + * {@link KnownLivyStatementStates} can be used interchangeably with LivyStatementStates, + * this enum contains the known values that the service supports. + * ### Known values supported by the service + * **waiting** \ + * **running** \ + * **available** \ + * **error** \ + * **cancelling** \ + * **cancelled** + */ +export type LivyStatementStates = string; + /** Known values of {@link SparkStatementLanguageType} that the service accepts. */ export enum KnownSparkStatementLanguageType { Spark = "spark", @@ -417,7 +476,7 @@ export interface SparkBatchCancelSparkBatchJobOptionalParams extends coreClient.OperationOptions {} /** Optional parameters. */ -export interface SparkSessionOperationsGetSparkSessionsOptionalParams +export interface SparkSessionGetSparkSessionsOptionalParams extends coreClient.OperationOptions { /** Optional param specifying which index the list should begin from. */ fromParam?: number; @@ -431,63 +490,63 @@ export interface SparkSessionOperationsGetSparkSessionsOptionalParams } /** Contains response data for the getSparkSessions operation. */ -export type SparkSessionOperationsGetSparkSessionsResponse = SparkSessionCollection; +export type SparkSessionGetSparkSessionsResponse = SparkSessionCollection; /** Optional parameters. */ -export interface SparkSessionOperationsCreateSparkSessionOptionalParams +export interface SparkSessionCreateSparkSessionOptionalParams extends coreClient.OperationOptions { /** Optional query param specifying whether detailed response is returned beyond plain livy. */ detailed?: boolean; } /** Contains response data for the createSparkSession operation. */ -export type SparkSessionOperationsCreateSparkSessionResponse = SparkSession; +export type SparkSessionCreateSparkSessionResponse = SparkSession; /** Optional parameters. */ -export interface SparkSessionOperationsGetSparkSessionOptionalParams +export interface SparkSessionGetSparkSessionOptionalParams extends coreClient.OperationOptions { /** Optional query param specifying whether detailed response is returned beyond plain livy. */ detailed?: boolean; } /** Contains response data for the getSparkSession operation. */ -export type SparkSessionOperationsGetSparkSessionResponse = SparkSession; +export type SparkSessionGetSparkSessionResponse = SparkSession; /** Optional parameters. */ -export interface SparkSessionOperationsCancelSparkSessionOptionalParams +export interface SparkSessionCancelSparkSessionOptionalParams extends coreClient.OperationOptions {} /** Optional parameters. */ -export interface SparkSessionOperationsResetSparkSessionTimeoutOptionalParams +export interface SparkSessionResetSparkSessionTimeoutOptionalParams extends coreClient.OperationOptions {} /** Optional parameters. */ -export interface SparkSessionOperationsGetSparkStatementsOptionalParams +export interface SparkSessionGetSparkStatementsOptionalParams extends coreClient.OperationOptions {} /** Contains response data for the getSparkStatements operation. */ -export type SparkSessionOperationsGetSparkStatementsResponse = SparkStatementCollection; +export type SparkSessionGetSparkStatementsResponse = SparkStatementCollection; /** Optional parameters. */ -export interface SparkSessionOperationsCreateSparkStatementOptionalParams +export interface SparkSessionCreateSparkStatementOptionalParams extends coreClient.OperationOptions {} /** Contains response data for the createSparkStatement operation. */ -export type SparkSessionOperationsCreateSparkStatementResponse = SparkStatement; +export type SparkSessionCreateSparkStatementResponse = SparkStatement; /** Optional parameters. */ -export interface SparkSessionOperationsGetSparkStatementOptionalParams +export interface SparkSessionGetSparkStatementOptionalParams extends coreClient.OperationOptions {} /** Contains response data for the getSparkStatement operation. */ -export type SparkSessionOperationsGetSparkStatementResponse = SparkStatement; +export type SparkSessionGetSparkStatementResponse = SparkStatement; /** Optional parameters. */ -export interface SparkSessionOperationsCancelSparkStatementOptionalParams +export interface SparkSessionCancelSparkStatementOptionalParams extends coreClient.OperationOptions {} /** Contains response data for the cancelSparkStatement operation. */ -export type SparkSessionOperationsCancelSparkStatementResponse = SparkStatementCancellationResult; +export type SparkSessionCancelSparkStatementResponse = SparkStatementCancellationResult; /** Optional parameters. */ export interface SparkClientOptionalParams diff --git a/sdk/synapse/synapse-spark/src/operations/sparkBatch.ts b/sdk/synapse/synapse-spark/src/operations/sparkBatch.ts index 6c35d5b2b353..92f0b19e8fc7 100644 --- a/sdk/synapse/synapse-spark/src/operations/sparkBatch.ts +++ b/sdk/synapse/synapse-spark/src/operations/sparkBatch.ts @@ -24,7 +24,7 @@ import { SparkBatchCancelSparkBatchJobOptionalParams } from "../models"; -/** Class representing a SparkBatch. */ +/** Class containing SparkBatch operations. */ export class SparkBatchImpl implements SparkBatch { private readonly client: SparkClientContext; diff --git a/sdk/synapse/synapse-spark/src/operations/sparkSessionOperations.ts b/sdk/synapse/synapse-spark/src/operations/sparkSessionOperations.ts index 20bb23fc8174..ace34b30906a 100644 --- a/sdk/synapse/synapse-spark/src/operations/sparkSessionOperations.ts +++ b/sdk/synapse/synapse-spark/src/operations/sparkSessionOperations.ts @@ -14,27 +14,27 @@ import * as Mappers from "../models/mappers"; import * as Parameters from "../models/parameters"; import { SparkClientContext } from "../sparkClientContext"; import { - SparkSessionOperationsGetSparkSessionsOptionalParams, - SparkSessionOperationsGetSparkSessionsResponse, + SparkSessionGetSparkSessionsOptionalParams, + SparkSessionGetSparkSessionsResponse, SparkSessionOptions, - SparkSessionOperationsCreateSparkSessionOptionalParams, - SparkSessionOperationsCreateSparkSessionResponse, - SparkSessionOperationsGetSparkSessionOptionalParams, - SparkSessionOperationsGetSparkSessionResponse, - SparkSessionOperationsCancelSparkSessionOptionalParams, - SparkSessionOperationsResetSparkSessionTimeoutOptionalParams, - SparkSessionOperationsGetSparkStatementsOptionalParams, - SparkSessionOperationsGetSparkStatementsResponse, + SparkSessionCreateSparkSessionOptionalParams, + SparkSessionCreateSparkSessionResponse, + SparkSessionGetSparkSessionOptionalParams, + SparkSessionGetSparkSessionResponse, + SparkSessionCancelSparkSessionOptionalParams, + SparkSessionResetSparkSessionTimeoutOptionalParams, + SparkSessionGetSparkStatementsOptionalParams, + SparkSessionGetSparkStatementsResponse, SparkStatementOptions, - SparkSessionOperationsCreateSparkStatementOptionalParams, - SparkSessionOperationsCreateSparkStatementResponse, - SparkSessionOperationsGetSparkStatementOptionalParams, - SparkSessionOperationsGetSparkStatementResponse, - SparkSessionOperationsCancelSparkStatementOptionalParams, - SparkSessionOperationsCancelSparkStatementResponse + SparkSessionCreateSparkStatementOptionalParams, + SparkSessionCreateSparkStatementResponse, + SparkSessionGetSparkStatementOptionalParams, + SparkSessionGetSparkStatementResponse, + SparkSessionCancelSparkStatementOptionalParams, + SparkSessionCancelSparkStatementResponse } from "../models"; -/** Class representing a SparkSessionOperations. */ +/** Class containing SparkSessionOperations operations. */ export class SparkSessionOperationsImpl implements SparkSessionOperations { private readonly client: SparkClientContext; @@ -51,15 +51,15 @@ export class SparkSessionOperationsImpl implements SparkSessionOperations { * @param options The options parameters. */ async getSparkSessions( - options?: SparkSessionOperationsGetSparkSessionsOptionalParams - ): Promise { + options?: SparkSessionGetSparkSessionsOptionalParams + ): Promise { const { span } = createSpan("SparkClient-getSparkSessions", options || {}); try { const result = await this.client.sendOperationRequest( { options }, getSparkSessionsOperationSpec ); - return result as SparkSessionOperationsGetSparkSessionsResponse; + return result as SparkSessionGetSparkSessionsResponse; } catch (error) { span.setStatus({ code: coreTracing.SpanStatusCode.UNSET, @@ -78,8 +78,8 @@ export class SparkSessionOperationsImpl implements SparkSessionOperations { */ async createSparkSession( sparkSessionOptions: SparkSessionOptions, - options?: SparkSessionOperationsCreateSparkSessionOptionalParams - ): Promise { + options?: SparkSessionCreateSparkSessionOptionalParams + ): Promise { const { span } = createSpan( "SparkClient-createSparkSession", options || {} @@ -89,7 +89,7 @@ export class SparkSessionOperationsImpl implements SparkSessionOperations { { sparkSessionOptions, options }, createSparkSessionOperationSpec ); - return result as SparkSessionOperationsCreateSparkSessionResponse; + return result as SparkSessionCreateSparkSessionResponse; } catch (error) { span.setStatus({ code: coreTracing.SpanStatusCode.UNSET, @@ -108,15 +108,15 @@ export class SparkSessionOperationsImpl implements SparkSessionOperations { */ async getSparkSession( sessionId: number, - options?: SparkSessionOperationsGetSparkSessionOptionalParams - ): Promise { + options?: SparkSessionGetSparkSessionOptionalParams + ): Promise { const { span } = createSpan("SparkClient-getSparkSession", options || {}); try { const result = await this.client.sendOperationRequest( { sessionId, options }, getSparkSessionOperationSpec ); - return result as SparkSessionOperationsGetSparkSessionResponse; + return result as SparkSessionGetSparkSessionResponse; } catch (error) { span.setStatus({ code: coreTracing.SpanStatusCode.UNSET, @@ -135,7 +135,7 @@ export class SparkSessionOperationsImpl implements SparkSessionOperations { */ async cancelSparkSession( sessionId: number, - options?: SparkSessionOperationsCancelSparkSessionOptionalParams + options?: SparkSessionCancelSparkSessionOptionalParams ): Promise { const { span } = createSpan( "SparkClient-cancelSparkSession", @@ -165,7 +165,7 @@ export class SparkSessionOperationsImpl implements SparkSessionOperations { */ async resetSparkSessionTimeout( sessionId: number, - options?: SparkSessionOperationsResetSparkSessionTimeoutOptionalParams + options?: SparkSessionResetSparkSessionTimeoutOptionalParams ): Promise { const { span } = createSpan( "SparkClient-resetSparkSessionTimeout", @@ -195,8 +195,8 @@ export class SparkSessionOperationsImpl implements SparkSessionOperations { */ async getSparkStatements( sessionId: number, - options?: SparkSessionOperationsGetSparkStatementsOptionalParams - ): Promise { + options?: SparkSessionGetSparkStatementsOptionalParams + ): Promise { const { span } = createSpan( "SparkClient-getSparkStatements", options || {} @@ -206,7 +206,7 @@ export class SparkSessionOperationsImpl implements SparkSessionOperations { { sessionId, options }, getSparkStatementsOperationSpec ); - return result as SparkSessionOperationsGetSparkStatementsResponse; + return result as SparkSessionGetSparkStatementsResponse; } catch (error) { span.setStatus({ code: coreTracing.SpanStatusCode.UNSET, @@ -227,8 +227,8 @@ export class SparkSessionOperationsImpl implements SparkSessionOperations { async createSparkStatement( sessionId: number, sparkStatementOptions: SparkStatementOptions, - options?: SparkSessionOperationsCreateSparkStatementOptionalParams - ): Promise { + options?: SparkSessionCreateSparkStatementOptionalParams + ): Promise { const { span } = createSpan( "SparkClient-createSparkStatement", options || {} @@ -238,7 +238,7 @@ export class SparkSessionOperationsImpl implements SparkSessionOperations { { sessionId, sparkStatementOptions, options }, createSparkStatementOperationSpec ); - return result as SparkSessionOperationsCreateSparkStatementResponse; + return result as SparkSessionCreateSparkStatementResponse; } catch (error) { span.setStatus({ code: coreTracing.SpanStatusCode.UNSET, @@ -259,15 +259,15 @@ export class SparkSessionOperationsImpl implements SparkSessionOperations { async getSparkStatement( sessionId: number, statementId: number, - options?: SparkSessionOperationsGetSparkStatementOptionalParams - ): Promise { + options?: SparkSessionGetSparkStatementOptionalParams + ): Promise { const { span } = createSpan("SparkClient-getSparkStatement", options || {}); try { const result = await this.client.sendOperationRequest( { sessionId, statementId, options }, getSparkStatementOperationSpec ); - return result as SparkSessionOperationsGetSparkStatementResponse; + return result as SparkSessionGetSparkStatementResponse; } catch (error) { span.setStatus({ code: coreTracing.SpanStatusCode.UNSET, @@ -288,8 +288,8 @@ export class SparkSessionOperationsImpl implements SparkSessionOperations { async cancelSparkStatement( sessionId: number, statementId: number, - options?: SparkSessionOperationsCancelSparkStatementOptionalParams - ): Promise { + options?: SparkSessionCancelSparkStatementOptionalParams + ): Promise { const { span } = createSpan( "SparkClient-cancelSparkStatement", options || {} @@ -299,7 +299,7 @@ export class SparkSessionOperationsImpl implements SparkSessionOperations { { sessionId, statementId, options }, cancelSparkStatementOperationSpec ); - return result as SparkSessionOperationsCancelSparkStatementResponse; + return result as SparkSessionCancelSparkStatementResponse; } catch (error) { span.setStatus({ code: coreTracing.SpanStatusCode.UNSET, diff --git a/sdk/synapse/synapse-spark/src/operationsInterfaces/sparkSessionOperations.ts b/sdk/synapse/synapse-spark/src/operationsInterfaces/sparkSessionOperations.ts index 30d0f0691ed2..68a5575c8ca1 100644 --- a/sdk/synapse/synapse-spark/src/operationsInterfaces/sparkSessionOperations.ts +++ b/sdk/synapse/synapse-spark/src/operationsInterfaces/sparkSessionOperations.ts @@ -7,24 +7,24 @@ */ import { - SparkSessionOperationsGetSparkSessionsOptionalParams, - SparkSessionOperationsGetSparkSessionsResponse, + SparkSessionGetSparkSessionsOptionalParams, + SparkSessionGetSparkSessionsResponse, SparkSessionOptions, - SparkSessionOperationsCreateSparkSessionOptionalParams, - SparkSessionOperationsCreateSparkSessionResponse, - SparkSessionOperationsGetSparkSessionOptionalParams, - SparkSessionOperationsGetSparkSessionResponse, - SparkSessionOperationsCancelSparkSessionOptionalParams, - SparkSessionOperationsResetSparkSessionTimeoutOptionalParams, - SparkSessionOperationsGetSparkStatementsOptionalParams, - SparkSessionOperationsGetSparkStatementsResponse, + SparkSessionCreateSparkSessionOptionalParams, + SparkSessionCreateSparkSessionResponse, + SparkSessionGetSparkSessionOptionalParams, + SparkSessionGetSparkSessionResponse, + SparkSessionCancelSparkSessionOptionalParams, + SparkSessionResetSparkSessionTimeoutOptionalParams, + SparkSessionGetSparkStatementsOptionalParams, + SparkSessionGetSparkStatementsResponse, SparkStatementOptions, - SparkSessionOperationsCreateSparkStatementOptionalParams, - SparkSessionOperationsCreateSparkStatementResponse, - SparkSessionOperationsGetSparkStatementOptionalParams, - SparkSessionOperationsGetSparkStatementResponse, - SparkSessionOperationsCancelSparkStatementOptionalParams, - SparkSessionOperationsCancelSparkStatementResponse + SparkSessionCreateSparkStatementOptionalParams, + SparkSessionCreateSparkStatementResponse, + SparkSessionGetSparkStatementOptionalParams, + SparkSessionGetSparkStatementResponse, + SparkSessionCancelSparkStatementOptionalParams, + SparkSessionCancelSparkStatementResponse } from "../models"; /** Interface representing a SparkSessionOperations. */ @@ -34,8 +34,8 @@ export interface SparkSessionOperations { * @param options The options parameters. */ getSparkSessions( - options?: SparkSessionOperationsGetSparkSessionsOptionalParams - ): Promise; + options?: SparkSessionGetSparkSessionsOptionalParams + ): Promise; /** * Create new spark session. * @param sparkSessionOptions Livy compatible batch job request payload. @@ -43,8 +43,8 @@ export interface SparkSessionOperations { */ createSparkSession( sparkSessionOptions: SparkSessionOptions, - options?: SparkSessionOperationsCreateSparkSessionOptionalParams - ): Promise; + options?: SparkSessionCreateSparkSessionOptionalParams + ): Promise; /** * Gets a single spark session. * @param sessionId Identifier for the session. @@ -52,8 +52,8 @@ export interface SparkSessionOperations { */ getSparkSession( sessionId: number, - options?: SparkSessionOperationsGetSparkSessionOptionalParams - ): Promise; + options?: SparkSessionGetSparkSessionOptionalParams + ): Promise; /** * Cancels a running spark session. * @param sessionId Identifier for the session. @@ -61,7 +61,7 @@ export interface SparkSessionOperations { */ cancelSparkSession( sessionId: number, - options?: SparkSessionOperationsCancelSparkSessionOptionalParams + options?: SparkSessionCancelSparkSessionOptionalParams ): Promise; /** * Sends a keep alive call to the current session to reset the session timeout. @@ -70,7 +70,7 @@ export interface SparkSessionOperations { */ resetSparkSessionTimeout( sessionId: number, - options?: SparkSessionOperationsResetSparkSessionTimeoutOptionalParams + options?: SparkSessionResetSparkSessionTimeoutOptionalParams ): Promise; /** * Gets a list of statements within a spark session. @@ -79,8 +79,8 @@ export interface SparkSessionOperations { */ getSparkStatements( sessionId: number, - options?: SparkSessionOperationsGetSparkStatementsOptionalParams - ): Promise; + options?: SparkSessionGetSparkStatementsOptionalParams + ): Promise; /** * Create statement within a spark session. * @param sessionId Identifier for the session. @@ -90,8 +90,8 @@ export interface SparkSessionOperations { createSparkStatement( sessionId: number, sparkStatementOptions: SparkStatementOptions, - options?: SparkSessionOperationsCreateSparkStatementOptionalParams - ): Promise; + options?: SparkSessionCreateSparkStatementOptionalParams + ): Promise; /** * Gets a single statement within a spark session. * @param sessionId Identifier for the session. @@ -101,8 +101,8 @@ export interface SparkSessionOperations { getSparkStatement( sessionId: number, statementId: number, - options?: SparkSessionOperationsGetSparkStatementOptionalParams - ): Promise; + options?: SparkSessionGetSparkStatementOptionalParams + ): Promise; /** * Kill a statement within a session. * @param sessionId Identifier for the session. @@ -112,6 +112,6 @@ export interface SparkSessionOperations { cancelSparkStatement( sessionId: number, statementId: number, - options?: SparkSessionOperationsCancelSparkStatementOptionalParams - ): Promise; + options?: SparkSessionCancelSparkStatementOptionalParams + ): Promise; } diff --git a/sdk/synapse/synapse-spark/swagger/README.md b/sdk/synapse/synapse-spark/swagger/README.md index 2467c7e6eff8..b52e2bce0d55 100644 --- a/sdk/synapse/synapse-spark/swagger/README.md +++ b/sdk/synapse/synapse-spark/swagger/README.md @@ -18,6 +18,7 @@ tracing-info: require: https://raw.githubusercontent.com/Azure/azure-rest-api-specs/main/specification/synapse/data-plane/readme.md use-extension: "@autorest/typescript": "latest" +tag: package-spark-2020-12-01 typescript: generate-metadata: false