MRS
The SDK interfaces based on the MRS v1.1 API are as follows. Invocation example: conn.map_reduce.create_cluster_and_run_job()
|
Interface |
Method |
API |
|---|---|---|
|
Cluster Operations |
create_cluster_and_run_job(**cluster,**job) |
POST /v1.1/{project_id}/run-job-flow |
|
expand_cluster("cluster-id", expand_node_amount) |
PUT /v1.1/{project_id}/cluster_infos/{cluster_id} |
|
|
reduce_cluster("cluster-id", reduce_node_amount, includes=includes, excludes=excludes) |
PUT /v1.1/{project_id}/cluster_infos/{cluster_id} |
|
|
get_cluster("cluster-id") |
GET /v1.1/{project_id}/cluster_infos/{cluster_id} |
|
|
delete_cluster("cluster-id") |
DELETE /v1.1/{project_id}/clusters/{cluster_id} |
|
|
Job Operations |
exe_job(**exe) |
POST /v1.1/{project_id}/jobs/submit-job |
|
job_exes(**query) |
GET /v1.1/{project_id}/job-exes |
|
|
get_job_exe("job-exe-id") |
GET /v1.1/{project_id}/job-exes/{job_exe_id} |
|
|
JobExecution Operations |
delete_job_execution("job-execution-id") |
DELETE /v1.1/{project_id}/job-executions/{job_execution_id} |
Did this article solve your problem?
Thank you for your score！Your feedback would help us improve the website.