All URIs are relative to https://localhost/api/v30
Method | HTTP request | Description |
---|---|---|
beginTrial | POST /cm/trial/begin | Begin trial license. |
collectDiagnosticDataCommand | POST /cm/commands/collectDiagnosticData | Collect diagnostic data from hosts managed by Cloudera Manager. |
deleteCredentialsCommand | POST /cm/commands/deleteCredentials | Delete existing Kerberos credentials. |
endTrial | POST /cm/trial/end | End trial license. |
generateCredentialsCommand | POST /cm/commands/generateCredentials | Generate missing Kerberos credentials. |
getConfig | GET /cm/config | Retrieve the Cloudera Manager settings. |
getDeployment2 | GET /cm/deployment | Retrieve full description of the entire Cloudera Manager deployment including all hosts, clusters, services, roles, users, settings, etc. |
getKerberosInfo | GET /cm/kerberosInfo | Provides Cloudera Manager Kerberos information. |
getKerberosPrincipals | GET /cm/kerberosPrincipals | Returns the Kerberos principals needed by the services being managed by Cloudera Manager. |
getLicensedFeatureUsage | GET /cm/licensedFeatureUsage | Retrieve a summary of licensed feature usage. |
getLog | GET /cm/log | Returns the entire contents of the Cloudera Manager log file. |
getScmDbInfo | GET /cm/scmDbInfo | Provides Cloudera Manager server's database information. |
getShutdownReadiness | GET /cm/shutdownReadiness | Retrieve Cloudera Manager's readiness for shutdown and destroy. |
getVersion | GET /cm/version | Provides version information of Cloudera Manager itself. |
hostInstallCommand | POST /cm/commands/hostInstall | Perform installation on a set of hosts. |
hostsDecommissionCommand | POST /cm/commands/hostsDecommission | Decommission the given hosts. |
hostsOfflineOrDecommissionCommand | POST /cm/commands/hostsOfflineOrDecommission | Decommission the given hosts. |
hostsRecommissionAndExitMaintenanceModeCommand | POST /cm/commands/hostsRecommissionAndExitMaintenanceMode | Recommission and exit maintenance on the given hosts. |
hostsRecommissionCommand | POST /cm/commands/hostsRecommission | Recommission the given hosts. |
hostsRecommissionWithStartCommand | POST /cm/commands/hostsRecommissionWithStart | Recommission the given hosts. |
hostsStartRolesCommand | POST /cm/commands/hostsStartRoles | Start all the roles on the given hosts. |
importAdminCredentials | POST /cm/commands/importAdminCredentials | Imports the KDC Account Manager credentials needed by Cloudera Manager to create kerberos principals needed by CDH services. |
importClusterTemplate | POST /cm/importClusterTemplate | Create cluster as per the given cluster template. |
importKerberosPrincipal | POST /cm/commands/importKerberosPrincipal | Imports the Kerberos credentials for the specified principal which can then be used to add to a role's keytab by running Generate Credentials command. |
inspectHostsCommand | POST /cm/commands/inspectHosts | Runs the host inspector on the configured hosts. |
listActiveCommands | GET /cm/commands | List active global commands. |
readLicense | GET /cm/license | Retrieve information about the Cloudera Manager license. |
refreshParcelRepos | POST /cm/commands/refreshParcelRepos | . |
updateConfig | PUT /cm/config | Update the Cloudera Manager settings. |
updateDeployment2 | PUT /cm/deployment | Apply the supplied deployment description to the system. |
updateLicense | POST /cm/license | Updates the Cloudera Manager license. |
beginTrial()
Begin trial license.
Begin trial license.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
try {
apiInstance.beginTrial();
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#beginTrial");
e.printStackTrace();
}
This endpoint does not need any parameter.
null (empty response body)
ApiCommand collectDiagnosticDataCommand(body)
Collect diagnostic data from hosts managed by Cloudera Manager.
Collect diagnostic data from hosts managed by Cloudera Manager.
After the command has completed, the ApiCommand will contain a resultDataUrl from where you can download the result.
Only available with Cloudera Manager Enterprise Edition.// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
ApiCollectDiagnosticDataArguments body = new ApiCollectDiagnosticDataArguments(); // ApiCollectDiagnosticDataArguments | The command arguments.
try {
ApiCommand result = apiInstance.collectDiagnosticDataCommand(body);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#collectDiagnosticDataCommand");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
body | ApiCollectDiagnosticDataArguments | The command arguments. | [optional] |
ApiCommand deleteCredentialsCommand(deleteCredentialsMode)
Delete existing Kerberos credentials.
Delete existing Kerberos credentials.
This command will affect all services that have been configured to use Kerberos, and have existing credentials. In V18 this takes a new paramater to determine whether it needs to delete all credentials or just unused ones.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
String deleteCredentialsMode = "all"; // String | this can be set to \"all\" or \"unused\"
try {
ApiCommand result = apiInstance.deleteCredentialsCommand(deleteCredentialsMode);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#deleteCredentialsCommand");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
deleteCredentialsMode | String | this can be set to "all" or "unused" | [optional] [default to all] |
endTrial()
End trial license.
End trial license.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
try {
apiInstance.endTrial();
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#endTrial");
e.printStackTrace();
}
This endpoint does not need any parameter.
null (empty response body)
ApiCommand generateCredentialsCommand()
Generate missing Kerberos credentials.
Generate missing Kerberos credentials.
This command will affect all services that have been configured to use Kerberos, and haven't had their credentials generated yet.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
try {
ApiCommand result = apiInstance.generateCredentialsCommand();
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#generateCredentialsCommand");
e.printStackTrace();
}
This endpoint does not need any parameter.
ApiConfigList getConfig(view)
Retrieve the Cloudera Manager settings.
Retrieve the Cloudera Manager settings.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
String view = "summary"; // String | The view to materialize, either \"summary\" or \"full\".
try {
ApiConfigList result = apiInstance.getConfig(view);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#getConfig");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
view | String | The view to materialize, either "summary" or "full". | [optional] [default to summary] [enum: EXPORT, EXPORT_REDACTED, FULL, FULL_WITH_HEALTH_CHECK_EXPLANATION, SUMMARY] |
ApiDeployment2 getDeployment2(view)
Retrieve full description of the entire Cloudera Manager deployment including all hosts, clusters, services, roles, users, settings, etc.
Retrieve full description of the entire Cloudera Manager deployment including all hosts, clusters, services, roles, users, settings, etc.
This object can be used to reconstruct your entire deployment Note: Only users with sufficient privileges are allowed to call this.// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
String view = "export"; // String | May be one of \"export\" (default) or \"export_redacted\". The latter replaces configurations that are sensitive with the word \"REDACTED\".
try {
ApiDeployment2 result = apiInstance.getDeployment2(view);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#getDeployment2");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
view | String | May be one of "export" (default) or "export_redacted". The latter replaces configurations that are sensitive with the word "REDACTED". | [optional] [default to export] [enum: EXPORT, EXPORT_REDACTED, FULL, FULL_WITH_HEALTH_CHECK_EXPLANATION, SUMMARY] |
ApiKerberosInfo getKerberosInfo()
Provides Cloudera Manager Kerberos information.
Provides Cloudera Manager Kerberos information
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
try {
ApiKerberosInfo result = apiInstance.getKerberosInfo();
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#getKerberosInfo");
e.printStackTrace();
}
This endpoint does not need any parameter.
ApiPrincipalList getKerberosPrincipals(missingOnly)
Returns the Kerberos principals needed by the services being managed by Cloudera Manager.
Returns the Kerberos principals needed by the services being managed by Cloudera Manager.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
Boolean missingOnly = true; // Boolean | Whether to include only those principals which do not already exist in Cloudera Manager's database.
try {
ApiPrincipalList result = apiInstance.getKerberosPrincipals(missingOnly);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#getKerberosPrincipals");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
missingOnly | Boolean | Whether to include only those principals which do not already exist in Cloudera Manager's database. | [optional] |
ApiLicensedFeatureUsage getLicensedFeatureUsage()
Retrieve a summary of licensed feature usage.
Retrieve a summary of licensed feature usage.
This command will return information about what Cloudera Enterprise licensed features are in use in the clusters being managed by this Cloudera Manager, as well as totals for usage across all clusters. The specific features described can vary between different versions of Cloudera Manager. Available since API v6.// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
try {
ApiLicensedFeatureUsage result = apiInstance.getLicensedFeatureUsage();
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#getLicensedFeatureUsage");
e.printStackTrace();
}
This endpoint does not need any parameter.
String getLog()
Returns the entire contents of the Cloudera Manager log file.
Returns the entire contents of the Cloudera Manager log file
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
try {
String result = apiInstance.getLog();
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#getLog");
e.printStackTrace();
}
This endpoint does not need any parameter.
String
ApiScmDbInfo getScmDbInfo()
Provides Cloudera Manager server's database information.
Provides Cloudera Manager server's database information
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
try {
ApiScmDbInfo result = apiInstance.getScmDbInfo();
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#getScmDbInfo");
e.printStackTrace();
}
This endpoint does not need any parameter.
ApiShutdownReadiness getShutdownReadiness(lastActivityTime)
Retrieve Cloudera Manager's readiness for shutdown and destroy.
Retrieve Cloudera Manager's readiness for shutdown and destroy. Applications that wish to destroy Cloudera Manager and its managed cluster should poll this API, repeatedly if necessary, to respect its readiness.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
String lastActivityTime = "lastActivityTime_example"; // String | End time of the last known activity/workload against the managed clusters, in ISO 8601 format.
try {
ApiShutdownReadiness result = apiInstance.getShutdownReadiness(lastActivityTime);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#getShutdownReadiness");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
lastActivityTime | String | End time of the last known activity/workload against the managed clusters, in ISO 8601 format. | [optional] |
ApiVersionInfo getVersion()
Provides version information of Cloudera Manager itself.
Provides version information of Cloudera Manager itself.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
try {
ApiVersionInfo result = apiInstance.getVersion();
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#getVersion");
e.printStackTrace();
}
This endpoint does not need any parameter.
ApiCommand hostInstallCommand(body)
Perform installation on a set of hosts.
Perform installation on a set of hosts.
This command installs Cloudera Manager Agent on a set of hosts. Available since API v6.// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
ApiHostInstallArguments body = new ApiHostInstallArguments(); // ApiHostInstallArguments | Hosts to perform installation on
try {
ApiCommand result = apiInstance.hostInstallCommand(body);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#hostInstallCommand");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
body | ApiHostInstallArguments | Hosts to perform installation on | [optional] |
ApiCommand hostsDecommissionCommand(body)
Decommission the given hosts.
Decommission the given hosts. All slave roles on the hosts will be decommissioned. All other roles will be stopped.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
ApiHostNameList body = new ApiHostNameList(); // ApiHostNameList |
try {
ApiCommand result = apiInstance.hostsDecommissionCommand(body);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#hostsDecommissionCommand");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
body | ApiHostNameList | [optional] |
ApiCommand hostsOfflineOrDecommissionCommand(offlineTimeout, body)
Decommission the given hosts.
Decommission the given hosts. All slave roles on the hosts will be offlined or decommissioned with preference being offlined if supported by the service.
Currently the offline operation is only supported by HDFS, where the offline operation will put DataNodes into HDFS IN MAINTENANCE state which prevents unnecessary re-replication which could occur if decommissioned.
All other roles on the hosts will be stopped.
The offlineTimeout parameter is used to specify a timeout for offline. For HDFS, when the timeout expires, the DataNode will automatically transition out of HDFS IN MAINTENANCE state, back to HDFS IN SERVICE state.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
BigDecimal offlineTimeout = new BigDecimal(); // BigDecimal | offline timeout in seconds. Specify as null to get the default timeout (4 hours). Ignored if service does not support he offline operation.
ApiHostNameList body = new ApiHostNameList(); // ApiHostNameList | list of host names to decommission.
try {
ApiCommand result = apiInstance.hostsOfflineOrDecommissionCommand(offlineTimeout, body);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#hostsOfflineOrDecommissionCommand");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
offlineTimeout | BigDecimal | offline timeout in seconds. Specify as null to get the default timeout (4 hours). Ignored if service does not support he offline operation. | [optional] |
body | ApiHostNameList | list of host names to decommission. | [optional] |
ApiCommand hostsRecommissionAndExitMaintenanceModeCommand(recommissionType, body)
Recommission and exit maintenance on the given hosts.
Recommission and exit maintenance on the given hosts. The recommission step may optionally start roles as well.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
String recommissionType = "recommission"; // String |
ApiHostNameList body = new ApiHostNameList(); // ApiHostNameList |
try {
ApiCommand result = apiInstance.hostsRecommissionAndExitMaintenanceModeCommand(recommissionType, body);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#hostsRecommissionAndExitMaintenanceModeCommand");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
recommissionType | String | [optional] [default to recommission] [enum: RECOMMISSION, RECOMMISSION_WITH_START] | |
body | ApiHostNameList | [optional] |
ApiCommand hostsRecommissionCommand(body)
Recommission the given hosts.
Recommission the given hosts. All slave roles on the hosts will be recommissioned. Roles are not started after this command. Use hostsStartRoles command for that.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
ApiHostNameList body = new ApiHostNameList(); // ApiHostNameList |
try {
ApiCommand result = apiInstance.hostsRecommissionCommand(body);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#hostsRecommissionCommand");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
body | ApiHostNameList | [optional] |
ApiCommand hostsRecommissionWithStartCommand(body)
Recommission the given hosts.
Recommission the given hosts. If slave roles support start when decommissioned, start those roles before recommission. All slave roles on the hosts will be recommissioned. Warning: Evolving. This method may change in the future and does not offer standard compatibility guarantees. Recommission the given hosts. If possible, start those roles before recommission. All slave roles on the hosts will be recommissioned. Do not use without guidance from Cloudera. Currently, only HDFS DataNodes will be started by this command.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
ApiHostNameList body = new ApiHostNameList(); // ApiHostNameList |
try {
ApiCommand result = apiInstance.hostsRecommissionWithStartCommand(body);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#hostsRecommissionWithStartCommand");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
body | ApiHostNameList | [optional] |
ApiCommand hostsStartRolesCommand(body)
Start all the roles on the given hosts.
Start all the roles on the given hosts.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
ApiHostNameList body = new ApiHostNameList(); // ApiHostNameList |
try {
ApiCommand result = apiInstance.hostsStartRolesCommand(body);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#hostsStartRolesCommand");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
body | ApiHostNameList | [optional] |
ApiCommand importAdminCredentials(password, username)
Imports the KDC Account Manager credentials needed by Cloudera Manager to create kerberos principals needed by CDH services.
Imports the KDC Account Manager credentials needed by Cloudera Manager to create kerberos principals needed by CDH services.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
String password = "password_example"; // String | Password for the Account Manager. return Information about the submitted command.
String username = "username_example"; // String | Username of the Account Manager. Full name including the Kerberos realm must be specified.
try {
ApiCommand result = apiInstance.importAdminCredentials(password, username);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#importAdminCredentials");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
password | String | Password for the Account Manager. return Information about the submitted command. | [optional] |
username | String | Username of the Account Manager. Full name including the Kerberos realm must be specified. | [optional] |
ApiCommand importClusterTemplate(addRepositories, body)
Create cluster as per the given cluster template.
Create cluster as per the given cluster template
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
Boolean addRepositories = false; // Boolean | if true the parcels repositories in the cluster template will be added.
ApiClusterTemplate body = new ApiClusterTemplate(); // ApiClusterTemplate | cluster template
try {
ApiCommand result = apiInstance.importClusterTemplate(addRepositories, body);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#importClusterTemplate");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
addRepositories | Boolean | if true the parcels repositories in the cluster template will be added. | [optional] [default to false] |
body | ApiClusterTemplate | cluster template | [optional] |
ApiCommand importKerberosPrincipal(kvno, password, principal)
Imports the Kerberos credentials for the specified principal which can then be used to add to a role's keytab by running Generate Credentials command.
Imports the Kerberos credentials for the specified principal which can then be used to add to a role's keytab by running Generate Credentials command.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
BigDecimal kvno = new BigDecimal(); // BigDecimal | Key-version number of the password. return Information about the submitted command.
String password = "password_example"; // String | Password for the Kerberos principal. Cloudera Manager will encrypt the principal and password and use it when needed for a daemon.
String principal = "principal_example"; // String | Name of the principal. Full name including the Kerberos realm must be specified. If it already exists, it will be overwritten.
try {
ApiCommand result = apiInstance.importKerberosPrincipal(kvno, password, principal);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#importKerberosPrincipal");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
kvno | BigDecimal | Key-version number of the password. return Information about the submitted command. | [optional] |
password | String | Password for the Kerberos principal. Cloudera Manager will encrypt the principal and password and use it when needed for a daemon. | [optional] |
principal | String | Name of the principal. Full name including the Kerberos realm must be specified. If it already exists, it will be overwritten. | [optional] |
ApiCommand inspectHostsCommand()
Runs the host inspector on the configured hosts.
Runs the host inspector on the configured hosts.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
try {
ApiCommand result = apiInstance.inspectHostsCommand();
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#inspectHostsCommand");
e.printStackTrace();
}
This endpoint does not need any parameter.
ApiCommandList listActiveCommands(view)
List active global commands.
List active global commands.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
String view = "summary"; // String | The view of the data to materialize, either \"summary\" or \"full\".
try {
ApiCommandList result = apiInstance.listActiveCommands(view);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#listActiveCommands");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
view | String | The view of the data to materialize, either "summary" or "full". | [optional] [default to summary] [enum: EXPORT, EXPORT_REDACTED, FULL, FULL_WITH_HEALTH_CHECK_EXPLANATION, SUMMARY] |
ApiLicense readLicense()
Retrieve information about the Cloudera Manager license.
Retrieve information about the Cloudera Manager license.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
try {
ApiLicense result = apiInstance.readLicense();
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#readLicense");
e.printStackTrace();
}
This endpoint does not need any parameter.
ApiCommand refreshParcelRepos()
.
Submit a command to refresh parcels information.
This API could be used following two scenarios.
- User updated Cloudera Manager's local parcel repository.
- User updated remote parcel locations.
User wants to invoke this API to make sure that Cloudera Manager gets latest parcels information. User can then monitor the returned command before proceeding to the next step.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
try {
ApiCommand result = apiInstance.refreshParcelRepos();
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#refreshParcelRepos");
e.printStackTrace();
}
This endpoint does not need any parameter.
ApiConfigList updateConfig(message, body)
Update the Cloudera Manager settings.
Update the Cloudera Manager settings.
If a value is set in the given configuration, it will be added to the manager's settings, replacing any existing entry. If a value is unset (its value is null), the existing the setting will be erased.
Settings that are not listed in the input will maintain their current values.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
String message = "message_example"; // String | Optional message describing the changes.
ApiConfigList body = new ApiConfigList(); // ApiConfigList | Settings to update.
try {
ApiConfigList result = apiInstance.updateConfig(message, body);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#updateConfig");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
message | String | Optional message describing the changes. | [optional] |
body | ApiConfigList | Settings to update. | [optional] |
ApiDeployment2 updateDeployment2(deleteCurrentDeployment, body)
Apply the supplied deployment description to the system.
Apply the supplied deployment description to the system. This will create the clusters, services, hosts and other objects specified in the argument. This call does not allow for any merge conflicts. If an entity already exists in the system, this call will fail. You can request, however, that all entities in the system are deleted before instantiating the new ones.
You may specify a complete or partial deployment, e.g. you can provide host info with no clusters. However, if you request that the current deployment be deleted, you are required to specify at least one admin user or this call will fail. This is to protect you from creating a system that cannot be logged into again. If there are any errors creating (or optionally deleting) a deployment, all changes will be rolled back leaving the system exactly as it was before calling this method. The system will never be left in a state where part of the deployment is created and other parts are not. If the submitted deployment contains entities that require Cloudera Enterprise license, then the license should be provided to Cloudera Manager before making this API call.// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
Boolean deleteCurrentDeployment = false; // Boolean | If true, the current deployment is deleted before the specified deployment is applied
ApiDeployment2 body = new ApiDeployment2(); // ApiDeployment2 | The deployment to create
try {
ApiDeployment2 result = apiInstance.updateDeployment2(deleteCurrentDeployment, body);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#updateDeployment2");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
deleteCurrentDeployment | Boolean | If true, the current deployment is deleted before the specified deployment is applied | [optional] [default to false] |
body | ApiDeployment2 | The deployment to create | [optional] |
ApiLicense updateLicense(body)
Updates the Cloudera Manager license.
Updates the Cloudera Manager license.
After a new license is installed, the Cloudera Manager needs to be restarted for the changes to take effect.
The license file should be uploaded using a request with content type "multipart/form-data", instead of being encoded into a JSON representation.
// Import classes:
//import com.cloudera.api.swagger.client.ApiClient;
//import com.cloudera.api.swagger.client.ApiException;
//import com.cloudera.api.swagger.client.Configuration;
//import com.cloudera.api.swagger.client.auth.*;
//import com.cloudera.api.swagger.ClouderaManagerResourceApi;
ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");
ClouderaManagerResourceApi apiInstance = new ClouderaManagerResourceApi();
File body = new File("/path/to/file.txt"); // File |
try {
ApiLicense result = apiInstance.updateLicense(body);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling ClouderaManagerResourceApi#updateLicense");
e.printStackTrace();
}
Name | Type | Description | Notes |
---|---|---|---|
body | File | [optional] |