SparkSession class

Paket:: @azure/synapse

Klass som representerar en SparkSession.

Konstruktorer

Skapa en SparkSession.

Metoder

create(string, string, ExtendedLivySessionRequest, ServiceCallback<ExtendedLivySessionResponse>)
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)	Skapa en ny Spark-session.
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)	Skapa -instruktion i en Spark-session.
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)
deleteMethod(string, string, number, RequestOptionsBase)	Avbryter en spark-session som körs.
deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)
deleteMethod(string, string, number, ServiceCallback<void>)
deleteStatement(string, string, number, number, RequestOptionsBase)	Avsluta en instruktion inom en session.
deleteStatement(string, string, number, number, RequestOptionsBase, ServiceCallback<LivyStatementCancellationResponse>)
deleteStatement(string, string, number, number, ServiceCallback<LivyStatementCancellationResponse>)
get(string, string, number, ServiceCallback<ExtendedLivySessionResponse>)
get(string, string, number, SparkSessionGetOptionalParams)	Hämtar en enda Spark-session.
get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
getStatement(string, string, number, number, RequestOptionsBase)	Hämtar en enda instruktion i en Spark-session.
getStatement(string, string, number, number, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)
getStatement(string, string, number, number, ServiceCallback<LivyStatementResponseBody>)
list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)
list(string, string, SparkSessionListOptionalParams)	Visa en lista över alla spark-sessioner som körs under en viss Spark-pool.
list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)
listStatements(string, string, number, RequestOptionsBase)	Hämtar en lista över instruktioner i en Spark-session.
listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)
listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)
resetTimeout(string, string, number, RequestOptionsBase)	Skickar ett keep alive-anrop till den aktuella sessionen för att återställa tidsgränsen för sessionen.
resetTimeout(string, string, number, RequestOptionsBase, ServiceCallback<void>)
resetTimeout(string, string, number, ServiceCallback<void>)

Konstruktorinformation

SparkSession(SynapseClientContext)

Skapa en SparkSession.

new SparkSession(client: SynapseClientContext)

Parametrar

client: SynapseClientContext

Referens till tjänstklienten.

Metodinformation

create(string, string, ExtendedLivySessionRequest, ServiceCallback<ExtendedLivySessionResponse>)

function create(workspaceName: string, sparkPoolName: string, livyRequest: ExtendedLivySessionRequest, callback: ServiceCallback<ExtendedLivySessionResponse>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

livyRequest: ExtendedLivySessionRequest

Livy-kompatibel batchjobb begär nyttolast.

callback: ServiceCallback<ExtendedLivySessionResponse>

Återanropet

create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)

Skapa en ny Spark-session.

function create(workspaceName: string, sparkPoolName: string, livyRequest: ExtendedLivySessionRequest, options?: SparkSessionCreateOptionalParams): Promise<SparkSessionCreateResponse>

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

livyRequest: ExtendedLivySessionRequest

Livy-kompatibel batchjobb begär nyttolast.

options: SparkSessionCreateOptionalParams

De valfria parametrarna

Returer

Promise<SparkSessionCreateResponse>

Löfte<Models.SparkSessionCreateResponse>

create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)

function create(workspaceName: string, sparkPoolName: string, livyRequest: ExtendedLivySessionRequest, options: SparkSessionCreateOptionalParams, callback: ServiceCallback<ExtendedLivySessionResponse>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

livyRequest: ExtendedLivySessionRequest

Livy-kompatibel batchjobb begär nyttolast.

options: SparkSessionCreateOptionalParams

De valfria parametrarna

callback: ServiceCallback<ExtendedLivySessionResponse>

Återanropet

createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)

Skapa -instruktion i en Spark-session.

function createStatement(workspaceName: string, sparkPoolName: string, sessionId: number, livyRequest: LivyStatementRequestBody, options?: RequestOptionsBase): Promise<SparkSessionCreateStatementResponse>

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

livyRequest: LivyStatementRequestBody

Livy-kompatibel batchjobb begär nyttolast.

options: RequestOptionsBase

De valfria parametrarna

Returer

Promise<SparkSessionCreateStatementResponse>

Löfte<Models.SparkSessionCreateStatementResponse>

createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)

function createStatement(workspaceName: string, sparkPoolName: string, sessionId: number, livyRequest: LivyStatementRequestBody, options: RequestOptionsBase, callback: ServiceCallback<LivyStatementResponseBody>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

livyRequest: LivyStatementRequestBody

Livy-kompatibel batchjobb begär nyttolast.

options: RequestOptionsBase

De valfria parametrarna

callback: ServiceCallback<LivyStatementResponseBody>

Återanropet

createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)

function createStatement(workspaceName: string, sparkPoolName: string, sessionId: number, livyRequest: LivyStatementRequestBody, callback: ServiceCallback<LivyStatementResponseBody>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

livyRequest: LivyStatementRequestBody

Livy-kompatibel batchjobb begär nyttolast.

callback: ServiceCallback<LivyStatementResponseBody>

Återanropet

deleteMethod(string, string, number, RequestOptionsBase)

Avbryter en spark-session som körs.

function deleteMethod(workspaceName: string, sparkPoolName: string, sessionId: number, options?: RequestOptionsBase): Promise<RestResponse>

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

options: RequestOptionsBase

De valfria parametrarna

Returer

Promise<RestResponse>

Löfte<msRest.RestResponse>

deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)

function deleteMethod(workspaceName: string, sparkPoolName: string, sessionId: number, options: RequestOptionsBase, callback: ServiceCallback<void>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

options: RequestOptionsBase

De valfria parametrarna

callback: ServiceCallback<void>

Återanropet

deleteMethod(string, string, number, ServiceCallback<void>)

function deleteMethod(workspaceName: string, sparkPoolName: string, sessionId: number, callback: ServiceCallback<void>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

callback: ServiceCallback<void>

Återanropet

deleteStatement(string, string, number, number, RequestOptionsBase)

Avsluta en instruktion inom en session.

function deleteStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, options?: RequestOptionsBase): Promise<SparkSessionDeleteStatementResponse>

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

statementId: number

Identifierare för -instruktionen.

options: RequestOptionsBase

De valfria parametrarna

Returer

Promise<SparkSessionDeleteStatementResponse>

Löfte<Models.SparkSessionDeleteStatementResponse>

deleteStatement(string, string, number, number, RequestOptionsBase, ServiceCallback<LivyStatementCancellationResponse>)

function deleteStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, options: RequestOptionsBase, callback: ServiceCallback<LivyStatementCancellationResponse>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

statementId: number

Identifierare för -instruktionen.

options: RequestOptionsBase

De valfria parametrarna

callback: ServiceCallback<LivyStatementCancellationResponse>

Återanropet

deleteStatement(string, string, number, number, ServiceCallback<LivyStatementCancellationResponse>)

function deleteStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, callback: ServiceCallback<LivyStatementCancellationResponse>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

statementId: number

Identifierare för -instruktionen.

callback: ServiceCallback<LivyStatementCancellationResponse>

Återanropet

get(string, string, number, ServiceCallback<ExtendedLivySessionResponse>)

function get(workspaceName: string, sparkPoolName: string, sessionId: number, callback: ServiceCallback<ExtendedLivySessionResponse>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

callback: ServiceCallback<ExtendedLivySessionResponse>

Återanropet

get(string, string, number, SparkSessionGetOptionalParams)

Hämtar en enda Spark-session.

function get(workspaceName: string, sparkPoolName: string, sessionId: number, options?: SparkSessionGetOptionalParams): Promise<SparkSessionGetResponse>

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

options: SparkSessionGetOptionalParams

De valfria parametrarna

Returer

Promise<SparkSessionGetResponse>

Löfte<Models.SparkSessionGetResponse>

get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)

function get(workspaceName: string, sparkPoolName: string, sessionId: number, options: SparkSessionGetOptionalParams, callback: ServiceCallback<ExtendedLivySessionResponse>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

options: SparkSessionGetOptionalParams

De valfria parametrarna

callback: ServiceCallback<ExtendedLivySessionResponse>

Återanropet

getStatement(string, string, number, number, RequestOptionsBase)

Hämtar en enda instruktion i en Spark-session.

function getStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, options?: RequestOptionsBase): Promise<SparkSessionGetStatementResponse>

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

statementId: number

Identifierare för -instruktionen.

options: RequestOptionsBase

De valfria parametrarna

Returer

Promise<SparkSessionGetStatementResponse>

Löfte<Models.SparkSessionGetStatementResponse>

getStatement(string, string, number, number, RequestOptionsBase, ServiceCallback<LivyStatementResponseBody>)

function getStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, options: RequestOptionsBase, callback: ServiceCallback<LivyStatementResponseBody>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

statementId: number

Identifierare för -instruktionen.

options: RequestOptionsBase

De valfria parametrarna

callback: ServiceCallback<LivyStatementResponseBody>

Återanropet

getStatement(string, string, number, number, ServiceCallback<LivyStatementResponseBody>)

function getStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, callback: ServiceCallback<LivyStatementResponseBody>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

statementId: number

Identifierare för -instruktionen.

callback: ServiceCallback<LivyStatementResponseBody>

Återanropet

list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)

function list(workspaceName: string, sparkPoolName: string, callback: ServiceCallback<ExtendedLivyListSessionResponse>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

callback: ServiceCallback<ExtendedLivyListSessionResponse>

Återanropet

list(string, string, SparkSessionListOptionalParams)

Visa en lista över alla spark-sessioner som körs under en viss Spark-pool.

function list(workspaceName: string, sparkPoolName: string, options?: SparkSessionListOptionalParams): Promise<SparkSessionListResponse>

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

options: SparkSessionListOptionalParams

De valfria parametrarna

Returer

Promise<SparkSessionListResponse>

Löfte<Models.SparkSessionListResponse>

list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)

function list(workspaceName: string, sparkPoolName: string, options: SparkSessionListOptionalParams, callback: ServiceCallback<ExtendedLivyListSessionResponse>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

options: SparkSessionListOptionalParams

De valfria parametrarna

callback: ServiceCallback<ExtendedLivyListSessionResponse>

Återanropet

listStatements(string, string, number, RequestOptionsBase)

Hämtar en lista över instruktioner i en Spark-session.

function listStatements(workspaceName: string, sparkPoolName: string, sessionId: number, options?: RequestOptionsBase): Promise<SparkSessionListStatementsResponse>

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

options: RequestOptionsBase

De valfria parametrarna

Returer

Promise<SparkSessionListStatementsResponse>

Löfte<Models.SparkSessionListStatementsResponse>

listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)

function listStatements(workspaceName: string, sparkPoolName: string, sessionId: number, options: RequestOptionsBase, callback: ServiceCallback<LivyStatementsResponseBody>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

options: RequestOptionsBase

De valfria parametrarna

callback: ServiceCallback<LivyStatementsResponseBody>

Återanropet

listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)

function listStatements(workspaceName: string, sparkPoolName: string, sessionId: number, callback: ServiceCallback<LivyStatementsResponseBody>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

callback: ServiceCallback<LivyStatementsResponseBody>

Återanropet

resetTimeout(string, string, number, RequestOptionsBase)

Skickar ett keep alive-anrop till den aktuella sessionen för att återställa tidsgränsen för sessionen.

function resetTimeout(workspaceName: string, sparkPoolName: string, sessionId: number, options?: RequestOptionsBase): Promise<RestResponse>

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

options: RequestOptionsBase

De valfria parametrarna

Returer

Promise<RestResponse>

Löfte<msRest.RestResponse>

resetTimeout(string, string, number, RequestOptionsBase, ServiceCallback<void>)

function resetTimeout(workspaceName: string, sparkPoolName: string, sessionId: number, options: RequestOptionsBase, callback: ServiceCallback<void>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

options: RequestOptionsBase

De valfria parametrarna

callback: ServiceCallback<void>

Återanropet

resetTimeout(string, string, number, ServiceCallback<void>)

function resetTimeout(workspaceName: string, sparkPoolName: string, sessionId: number, callback: ServiceCallback<void>)

Parametrar

workspaceName: string

Namnet på arbetsytan som du vill köra åtgärder på.

sparkPoolName: string

Namnet på spark-poolen. "ondemand" riktar sig mot ondemand-poolen.

sessionId: number

Identifierare för sessionen.

callback: ServiceCallback<void>

Återanropet