SparkBatch class
表示 SparkBatch 的类。
构造函数
| Spark |
创建 SparkBatch。 |
方法
构造函数详细信息
SparkBatch(SynapseClientContext)
创建 SparkBatch。
new SparkBatch(client: SynapseClientContext)
参数
- client
- SynapseClientContext
对服务客户端的引用。
方法详细信息
create(string, string, ExtendedLivyBatchRequest, ServiceCallback<ExtendedLivyBatchResponse>)
function create(workspaceName: string, sparkPoolName: string, livyRequest: ExtendedLivyBatchRequest, callback: ServiceCallback<ExtendedLivyBatchResponse>)
参数
- workspaceName
-
string
要在其中执行作的工作区的名称。
- sparkPoolName
-
string
Spark 池的名称。 “ondemand”面向 ondemand 池。
- livyRequest
- ExtendedLivyBatchRequest
Livy 兼容的批处理作业请求有效负载。
- callback
回调
create(string, string, ExtendedLivyBatchRequest, SparkBatchCreateOptionalParams)
创建新的 Spark 批处理作业。
function create(workspaceName: string, sparkPoolName: string, livyRequest: ExtendedLivyBatchRequest, options?: SparkBatchCreateOptionalParams): Promise<SparkBatchCreateResponse>
参数
- workspaceName
-
string
要在其中执行作的工作区的名称。
- sparkPoolName
-
string
Spark 池的名称。 “ondemand”面向 ondemand 池。
- livyRequest
- ExtendedLivyBatchRequest
Livy 兼容的批处理作业请求有效负载。
- options
- SparkBatchCreateOptionalParams
可选参数
返回
Promise<SparkBatchCreateResponse>
承诺<模型.SparkBatchCreateResponse>
create(string, string, ExtendedLivyBatchRequest, SparkBatchCreateOptionalParams, ServiceCallback<ExtendedLivyBatchResponse>)
function create(workspaceName: string, sparkPoolName: string, livyRequest: ExtendedLivyBatchRequest, options: SparkBatchCreateOptionalParams, callback: ServiceCallback<ExtendedLivyBatchResponse>)
参数
- workspaceName
-
string
要在其中执行作的工作区的名称。
- sparkPoolName
-
string
Spark 池的名称。 “ondemand”面向 ondemand 池。
- livyRequest
- ExtendedLivyBatchRequest
Livy 兼容的批处理作业请求有效负载。
- options
- SparkBatchCreateOptionalParams
可选参数
- callback
回调
deleteMethod(string, string, number, RequestOptionsBase)
取消正在运行的 Spark 批处理作业。
function deleteMethod(workspaceName: string, sparkPoolName: string, batchId: number, options?: RequestOptionsBase): Promise<RestResponse>
参数
- workspaceName
-
string
要在其中执行作的工作区的名称。
- sparkPoolName
-
string
Spark 池的名称。 “ondemand”面向 ondemand 池。
- batchId
-
number
批处理作业的标识符。
- options
- RequestOptionsBase
可选参数
返回
Promise<RestResponse>
承诺<msRest.RestResponse>
deleteMethod(string, string, number, RequestOptionsBase, ServiceCallback<void>)
function deleteMethod(workspaceName: string, sparkPoolName: string, batchId: number, options: RequestOptionsBase, callback: ServiceCallback<void>)
参数
- workspaceName
-
string
要在其中执行作的工作区的名称。
- sparkPoolName
-
string
Spark 池的名称。 “ondemand”面向 ondemand 池。
- batchId
-
number
批处理作业的标识符。
- options
- RequestOptionsBase
可选参数
- callback
-
ServiceCallback<void>
回调
deleteMethod(string, string, number, ServiceCallback<void>)
function deleteMethod(workspaceName: string, sparkPoolName: string, batchId: number, callback: ServiceCallback<void>)
参数
- workspaceName
-
string
要在其中执行作的工作区的名称。
- sparkPoolName
-
string
Spark 池的名称。 “ondemand”面向 ondemand 池。
- batchId
-
number
批处理作业的标识符。
- callback
-
ServiceCallback<void>
回调
get(string, string, number, ServiceCallback<ExtendedLivyBatchResponse>)
function get(workspaceName: string, sparkPoolName: string, batchId: number, callback: ServiceCallback<ExtendedLivyBatchResponse>)
参数
- workspaceName
-
string
要在其中执行作的工作区的名称。
- sparkPoolName
-
string
Spark 池的名称。 “ondemand”面向 ondemand 池。
- batchId
-
number
批处理作业的标识符。
- callback
回调
get(string, string, number, SparkBatchGetOptionalParams)
获取单个 Spark 批处理作业。
function get(workspaceName: string, sparkPoolName: string, batchId: number, options?: SparkBatchGetOptionalParams): Promise<SparkBatchGetResponse>
参数
- workspaceName
-
string
要在其中执行作的工作区的名称。
- sparkPoolName
-
string
Spark 池的名称。 “ondemand”面向 ondemand 池。
- batchId
-
number
批处理作业的标识符。
- options
- SparkBatchGetOptionalParams
可选参数
返回
Promise<SparkBatchGetResponse>
承诺<Models.SparkBatchGetResponse>
get(string, string, number, SparkBatchGetOptionalParams, ServiceCallback<ExtendedLivyBatchResponse>)
function get(workspaceName: string, sparkPoolName: string, batchId: number, options: SparkBatchGetOptionalParams, callback: ServiceCallback<ExtendedLivyBatchResponse>)
参数
- workspaceName
-
string
要在其中执行作的工作区的名称。
- sparkPoolName
-
string
Spark 池的名称。 “ondemand”面向 ondemand 池。
- batchId
-
number
批处理作业的标识符。
- options
- SparkBatchGetOptionalParams
可选参数
- callback
回调
list(string, string, ServiceCallback<ExtendedLivyListBatchResponse>)
function list(workspaceName: string, sparkPoolName: string, callback: ServiceCallback<ExtendedLivyListBatchResponse>)
参数
- workspaceName
-
string
要在其中执行作的工作区的名称。
- sparkPoolName
-
string
Spark 池的名称。 “ondemand”面向 ondemand 池。
- callback
回调
list(string, string, SparkBatchListOptionalParams)
列出在特定 Spark 池下运行的所有 Spark 批处理作业。
function list(workspaceName: string, sparkPoolName: string, options?: SparkBatchListOptionalParams): Promise<SparkBatchListResponse>
参数
- workspaceName
-
string
要在其中执行作的工作区的名称。
- sparkPoolName
-
string
Spark 池的名称。 “ondemand”面向 ondemand 池。
- options
- SparkBatchListOptionalParams
可选参数
返回
Promise<SparkBatchListResponse>
承诺<模型.SparkBatchList响应>
list(string, string, SparkBatchListOptionalParams, ServiceCallback<ExtendedLivyListBatchResponse>)
function list(workspaceName: string, sparkPoolName: string, options: SparkBatchListOptionalParams, callback: ServiceCallback<ExtendedLivyListBatchResponse>)
参数
- workspaceName
-
string
要在其中执行作的工作区的名称。
- sparkPoolName
-
string
Spark 池的名称。 “ondemand”面向 ondemand 池。
- options
- SparkBatchListOptionalParams
可选参数
- callback
回调