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.