SparkSessionOperations interface
Interface die een SparkSessionOperations vertegenwoordigt.
Methoden
Methodedetails
cancelSparkSession(number, SparkSessionCancelSparkSessionOptionalParams)
Hiermee wordt een actieve Spark-sessie geannuleerd.
function cancelSparkSession(sessionId: number, options?: SparkSessionCancelSparkSessionOptionalParams): Promise<void>Parameters
- sessionId
-
number
Id voor de sessie.
De optiesparameters.
Retouren
Promise<void>
cancelSparkStatement(number, number, SparkSessionCancelSparkStatementOptionalParams)
Een verklaring binnen een sessie beëindigen.
function cancelSparkStatement(sessionId: number, statementId: number, options?: SparkSessionCancelSparkStatementOptionalParams): Promise<SparkStatementCancellationResult>Parameters
- sessionId
-
number
Id voor de sessie.
- statementId
-
number
Id voor de instructie.
De optiesparameters.
Retouren
Promise<SparkStatementCancellationResult>
createSparkSession(SparkSessionOptions, SparkSessionCreateSparkSessionOptionalParams)
Maak een nieuwe Spark-sessie.
function createSparkSession(sparkSessionOptions: SparkSessionOptions, options?: SparkSessionCreateSparkSessionOptionalParams): Promise<SparkSession>Parameters
- sparkSessionOptions
- SparkSessionOptions
Livy-compatibele nettolading voor batchtaken.
De optiesparameters.
Retouren
Promise<SparkSession>
createSparkStatement(number, SparkStatementOptions, SparkSessionCreateSparkStatementOptionalParams)
Instructie maken binnen een Spark-sessie.
function createSparkStatement(sessionId: number, sparkStatementOptions: SparkStatementOptions, options?: SparkSessionCreateSparkStatementOptionalParams): Promise<SparkStatement>Parameters
- sessionId
-
number
Id voor de sessie.
- sparkStatementOptions
- SparkStatementOptions
Livy-compatibele nettolading voor batchtaken.
De optiesparameters.
Retouren
Promise<SparkStatement>
getSparkSession(number, SparkSessionGetSparkSessionOptionalParams)
Hiermee haalt u één Spark-sessie op.
function getSparkSession(sessionId: number, options?: SparkSessionGetSparkSessionOptionalParams): Promise<SparkSession>Parameters
- sessionId
-
number
Id voor de sessie.
De optiesparameters.
Retouren
Promise<SparkSession>
getSparkSessions(SparkSessionGetSparkSessionsOptionalParams)
Vermeld alle Spark-sessies die worden uitgevoerd onder een bepaalde Spark-pool.
function getSparkSessions(options?: SparkSessionGetSparkSessionsOptionalParams): Promise<SparkSessionCollection>Parameters
De optiesparameters.
Retouren
Promise<SparkSessionCollection>
getSparkStatement(number, number, SparkSessionGetSparkStatementOptionalParams)
Hiermee haalt u één instructie op binnen een Spark-sessie.
function getSparkStatement(sessionId: number, statementId: number, options?: SparkSessionGetSparkStatementOptionalParams): Promise<SparkStatement>Parameters
- sessionId
-
number
Id voor de sessie.
- statementId
-
number
Id voor de instructie.
De optiesparameters.
Retouren
Promise<SparkStatement>
getSparkStatements(number, SparkSessionGetSparkStatementsOptionalParams)
Hiermee haalt u een lijst met instructies op binnen een Spark-sessie.
function getSparkStatements(sessionId: number, options?: SparkSessionGetSparkStatementsOptionalParams): Promise<SparkStatementCollection>Parameters
- sessionId
-
number
Id voor de sessie.
De optiesparameters.
Retouren
Promise<SparkStatementCollection>
resetSparkSessionTimeout(number, SparkSessionResetSparkSessionTimeoutOptionalParams)
Hiermee wordt een keep alive-aanroep naar de huidige sessie verzonden om de time-out van de sessie opnieuw in te stellen.
function resetSparkSessionTimeout(sessionId: number, options?: SparkSessionResetSparkSessionTimeoutOptionalParams): Promise<void>Parameters
- sessionId
-
number
Id voor de sessie.
De optiesparameters.
Retouren
Promise<void>
