SparkSession class
SparkSession을 나타내는 클래스입니다.
생성자
| Spark |
SparkSession을 만듭니다. |
메서드
생성자 세부 정보
SparkSession(SynapseClientContext)
SparkSession을 만듭니다.
new SparkSession(client: SynapseClientContext)매개 변수
- client
- SynapseClientContext
서비스 클라이언트에 대한 참조입니다.
메서드 세부 정보
create(string, string, ExtendedLivySessionRequest, ServiceCallback<ExtendedLivySessionResponse>)
function create(workspaceName: string, sparkPoolName: string, livyRequest: ExtendedLivySessionRequest, callback: ServiceCallback<ExtendedLivySessionResponse>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- livyRequest
- ExtendedLivySessionRequest
Livy 호환 일괄 처리 작업 요청 페이로드.
- callback
콜백
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams)
새 Spark 세션을 만듭니다.
function create(workspaceName: string, sparkPoolName: string, livyRequest: ExtendedLivySessionRequest, options?: SparkSessionCreateOptionalParams): Promise<SparkSessionCreateResponse>매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- livyRequest
- ExtendedLivySessionRequest
Livy 호환 일괄 처리 작업 요청 페이로드.
- options
- SparkSessionCreateOptionalParams
선택적 매개 변수
반환
Promise<SparkSessionCreateResponse>
Promise<Models.SparkSessionCreateResponse>
create(string, string, ExtendedLivySessionRequest, SparkSessionCreateOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
function create(workspaceName: string, sparkPoolName: string, livyRequest: ExtendedLivySessionRequest, options: SparkSessionCreateOptionalParams, callback: ServiceCallback<ExtendedLivySessionResponse>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- livyRequest
- ExtendedLivySessionRequest
Livy 호환 일괄 처리 작업 요청 페이로드.
- options
- SparkSessionCreateOptionalParams
선택적 매개 변수
- callback
콜백
createStatement(string, string, number, LivyStatementRequestBody, RequestOptionsBase)
Spark 세션 내에서 문을 만듭니다.
function createStatement(workspaceName: string, sparkPoolName: string, sessionId: number, livyRequest: LivyStatementRequestBody, options?: RequestOptionsBase): Promise<SparkSessionCreateStatementResponse>매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- livyRequest
- LivyStatementRequestBody
Livy 호환 일괄 처리 작업 요청 페이로드.
- options
- RequestOptionsBase
선택적 매개 변수
반환
Promise<SparkSessionCreateStatementResponse>
Promise<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>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- livyRequest
- LivyStatementRequestBody
Livy 호환 일괄 처리 작업 요청 페이로드.
- options
- RequestOptionsBase
선택적 매개 변수
- callback
콜백
createStatement(string, string, number, LivyStatementRequestBody, ServiceCallback<LivyStatementResponseBody>)
function createStatement(workspaceName: string, sparkPoolName: string, sessionId: number, livyRequest: LivyStatementRequestBody, callback: ServiceCallback<LivyStatementResponseBody>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- livyRequest
- LivyStatementRequestBody
Livy 호환 일괄 처리 작업 요청 페이로드.
- callback
콜백
deleteMethod(string, string, number, RequestOptionsBase)
실행 중인 Spark 세션을 취소합니다.
function deleteMethod(workspaceName: string, sparkPoolName: string, sessionId: number, options?: RequestOptionsBase): Promise<RestResponse>매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- options
- RequestOptionsBase
선택적 매개 변수
반환
Promise<RestResponse>
promise<msRest.RestResponse>
deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)
function deleteMethod(workspaceName: string, sparkPoolName: string, sessionId: number, options: RequestOptionsBase, callback: ServiceCallback<void>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- options
- RequestOptionsBase
선택적 매개 변수
- callback
-
ServiceCallback<void>
콜백
deleteMethod(string, string, number, ServiceCallback<void>)
function deleteMethod(workspaceName: string, sparkPoolName: string, sessionId: number, callback: ServiceCallback<void>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- callback
-
ServiceCallback<void>
콜백
deleteStatement(string, string, number, number, RequestOptionsBase)
세션 내에서 문을 종료합니다.
function deleteStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, options?: RequestOptionsBase): Promise<SparkSessionDeleteStatementResponse>매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- statementId
-
number
문의 식별자입니다.
- options
- RequestOptionsBase
선택적 매개 변수
반환
Promise<SparkSessionDeleteStatementResponse>
Promise<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>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- statementId
-
number
문의 식별자입니다.
- options
- RequestOptionsBase
선택적 매개 변수
콜백
deleteStatement(string, string, number, number, ServiceCallback<LivyStatementCancellationResponse>)
function deleteStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, callback: ServiceCallback<LivyStatementCancellationResponse>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- statementId
-
number
문의 식별자입니다.
콜백
get(string, string, number, ServiceCallback<ExtendedLivySessionResponse>)
function get(workspaceName: string, sparkPoolName: string, sessionId: number, callback: ServiceCallback<ExtendedLivySessionResponse>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- callback
콜백
get(string, string, number, SparkSessionGetOptionalParams)
단일 Spark 세션을 가져옵니다.
function get(workspaceName: string, sparkPoolName: string, sessionId: number, options?: SparkSessionGetOptionalParams): Promise<SparkSessionGetResponse>매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- options
- SparkSessionGetOptionalParams
선택적 매개 변수
반환
Promise<SparkSessionGetResponse>
Promise<Models.SparkSessionGetResponse>
get(string, string, number, SparkSessionGetOptionalParams, ServiceCallback<ExtendedLivySessionResponse>)
function get(workspaceName: string, sparkPoolName: string, sessionId: number, options: SparkSessionGetOptionalParams, callback: ServiceCallback<ExtendedLivySessionResponse>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- options
- SparkSessionGetOptionalParams
선택적 매개 변수
- callback
콜백
getStatement(string, string, number, number, RequestOptionsBase)
Spark 세션 내에서 단일 문을 가져옵니다.
function getStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, options?: RequestOptionsBase): Promise<SparkSessionGetStatementResponse>매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- statementId
-
number
문의 식별자입니다.
- options
- RequestOptionsBase
선택적 매개 변수
반환
Promise<SparkSessionGetStatementResponse>
Promise<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>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- statementId
-
number
문의 식별자입니다.
- options
- RequestOptionsBase
선택적 매개 변수
- callback
콜백
getStatement(string, string, number, number, ServiceCallback<LivyStatementResponseBody>)
function getStatement(workspaceName: string, sparkPoolName: string, sessionId: number, statementId: number, callback: ServiceCallback<LivyStatementResponseBody>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- statementId
-
number
문의 식별자입니다.
- callback
콜백
list(string, string, ServiceCallback<ExtendedLivyListSessionResponse>)
function list(workspaceName: string, sparkPoolName: string, callback: ServiceCallback<ExtendedLivyListSessionResponse>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
콜백
list(string, string, SparkSessionListOptionalParams)
특정 Spark 풀에서 실행되는 모든 Spark 세션을 나열합니다.
function list(workspaceName: string, sparkPoolName: string, options?: SparkSessionListOptionalParams): Promise<SparkSessionListResponse>매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- options
- SparkSessionListOptionalParams
선택적 매개 변수
반환
Promise<SparkSessionListResponse>
Promise<Models.SparkSessionListResponse를 사용합니다.>
list(string, string, SparkSessionListOptionalParams, ServiceCallback<ExtendedLivyListSessionResponse>)
function list(workspaceName: string, sparkPoolName: string, options: SparkSessionListOptionalParams, callback: ServiceCallback<ExtendedLivyListSessionResponse>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- options
- SparkSessionListOptionalParams
선택적 매개 변수
콜백
listStatements(string, string, number, RequestOptionsBase)
Spark 세션 내의 문 목록을 가져옵니다.
function listStatements(workspaceName: string, sparkPoolName: string, sessionId: number, options?: RequestOptionsBase): Promise<SparkSessionListStatementsResponse>매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- options
- RequestOptionsBase
선택적 매개 변수
반환
Promise<SparkSessionListStatementsResponse>
Promise<Models.SparkSessionListStatementsResponse입니다.>
listStatements(string, string, number, RequestOptionsBase, ServiceCallback<LivyStatementsResponseBody>)
function listStatements(workspaceName: string, sparkPoolName: string, sessionId: number, options: RequestOptionsBase, callback: ServiceCallback<LivyStatementsResponseBody>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- options
- RequestOptionsBase
선택적 매개 변수
- callback
콜백
listStatements(string, string, number, ServiceCallback<LivyStatementsResponseBody>)
function listStatements(workspaceName: string, sparkPoolName: string, sessionId: number, callback: ServiceCallback<LivyStatementsResponseBody>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- callback
콜백
resetTimeout(string, string, number, RequestOptionsBase)
세션 시간 제한을 다시 설정하기 위해 현재 세션에 keep alive 호출을 보냅니다.
function resetTimeout(workspaceName: string, sparkPoolName: string, sessionId: number, options?: RequestOptionsBase): Promise<RestResponse>매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- options
- RequestOptionsBase
선택적 매개 변수
반환
Promise<RestResponse>
promise<msRest.RestResponse>
resetTimeout(string, string, number, RequestOptionsBase, ServiceCallback<void>)
function resetTimeout(workspaceName: string, sparkPoolName: string, sessionId: number, options: RequestOptionsBase, callback: ServiceCallback<void>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- options
- RequestOptionsBase
선택적 매개 변수
- callback
-
ServiceCallback<void>
콜백
resetTimeout(string, string, number, ServiceCallback<void>)
function resetTimeout(workspaceName: string, sparkPoolName: string, sessionId: number, callback: ServiceCallback<void>)매개 변수
- workspaceName
-
string
작업을 실행할 작업 영역의 이름입니다.
- sparkPoolName
-
string
Spark 풀의 이름입니다. "ondemand"는 온디맨드 풀을 대상으로 합니다.
- sessionId
-
number
세션의 식별자입니다.
- callback
-
ServiceCallback<void>
콜백