MRS
The SDK interfaces based on the MRS v1.1 API are as follows. For details about the invoking methods, see the sample codes.
|
Interface |
Method |
API |
|---|---|---|
|
ClusterService |
MapReduceClusterCreateResult createAndRunJob(MapReduceClusterCreate cluster, MapReduceJobExeCreate jobExe) |
POST /v1.1/{project_id}/run-job-flow |
|
ActionResponse expand(String clusterId, int amount) |
PUT /v1.1/{project_id}/cluster_infos/{cluster_id} |
|
|
ActionResponse reduce(String clusterId, int amount, List<String> includes, List<String> excludes) |
PUT /v1.1/{project_id}/cluster_infos/{cluster_id} |
|
|
MapReduceClusterInfo get(String clusterId) |
GET /v1.1/{project_id}/cluster_infos/{cluster_id} |
|
|
ActionResponse delete(String clusterId) |
DELETE /v1.1/{project_id}/clusters/{cluster_id} |
|
|
JobExeServiceImpl |
MapReduceJobExe create(MapReduceJobExeCreate jobExeCreate) |
POST /v1.1/{project_id}/jobs/submit-job |
|
List<? extends MapReduceJobExe> list(JobExeListOptions options) |
GET /v1.1/{project_id}/job-exes |
|
|
MapReduceJobExe get(String jobExeId) |
GET /v1.1/{project_id}/job-exes/{job_exe_id} |
|
|
JobExecutionService |
ActionResponse delete(String jobExecutionId) |
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.