ClustersResourceApi

All URIs are relative to /api/v57

Method HTTP request Description
addHosts POST /clusters/{clusterName}/hosts
addTags PUT /clusters/{clusterName}/tags Attach tags to the cluster.
autoAssignRoles PUT /clusters/{clusterName}/autoAssignRoles Automatically assign roles to hosts and create the roles for all the services in a cluster.
autoConfigure PUT /clusters/{clusterName}/autoConfigure Automatically configures roles and services in a cluster.
checkEcsPrerequisitesCommand POST /clusters/{clusterName}/commands/checkEcsPrerequisites
configureAutoTlsServicesCommand POST /clusters/{clusterName}/commands/configureAutoTlsServices Configures all services in a cluster to use Auto-TLS.
configureForKerberos POST /clusters/{clusterName}/commands/configureForKerberos Command to configure the cluster to use Kerberos for authentication.
createClusters POST /clusters Creates a collection of clusters.
deleteCluster DELETE /clusters/{clusterName} Deletes a cluster.
deleteClusterCredentialsCommand POST /clusters/{clusterName}/commands/deleteCredentials Delete existing Kerberos credentials for the cluster.
deleteTags DELETE /clusters/{clusterName}/tags Remove the tags associated with the cluster.
deployClientConfig POST /clusters/{clusterName}/commands/deployClientConfig Deploy the cluster-wide client configuration.
deployClientConfigsAndRefresh POST /clusters/{clusterName}/commands/deployClientConfigsAndRefresh Performs a command with the 2 steps - deploy cc - cluster refresh This orchestration is needed for the staleness wizard, so it can invoke a single command at wizard finish.
deployClusterClientConfig POST /clusters/{clusterName}/commands/deployClusterClientConfig Deploy the Cluster's Kerberos client configuration.
disableTls POST /clusters/{clusterName}/commands/disableTls Disables TLS settings on a cluster.
enterMaintenanceMode POST /clusters/{clusterName}/commands/enterMaintenanceMode Put the cluster into maintenance mode.
exitMaintenanceMode POST /clusters/{clusterName}/commands/exitMaintenanceMode Take the cluster out of maintenance mode.
expireLogs POST /clusters/{clusterName}/commands/expireLogs Remove backup and disaster related log files in hdfs.
export GET /clusters/{clusterName}/export Export the cluster template for the given cluster.
firstRun POST /clusters/{clusterName}/commands/firstRun Prepare and start services in a cluster.
getClientConfig GET /clusters/{clusterName}/clientConfig Download a zip-compressed archive of the client configuration, of a specific cluster.
getClusterSupportToken GET /clusters/{clusterName}/clusterSupportToken Gets the support token for a cluster.
getKerberosInfo GET /clusters/{clusterName}/kerberosInfo Provides Cluster Kerberos information.
getOzoneBucketInfo GET /clusters/{clusterName}/getOzoneBucketInfo Returns the properties of the provided ozone bucket if the bucket exists.
getOzoneS3GatewayInfo POST /clusters/{clusterName}/getOzoneS3GatewayInfo Returns the REST url for the Ozone S3 Gateway, as well as the AWS credentials needed to access the S3 endpoint.
getUtilizationReport GET /clusters/{clusterName}/utilization Provides the resource utilization of the entire cluster as well as the resource utilization per tenant.
inspectHostsCommand POST /clusters/{clusterName}/commands/inspectHosts Runs the host inspector on the configured hosts in the specified cluster.
isTlsEnabled GET /clusters/{clusterName}/isTlsEnabled Returns whether a cluster has any TLS settings enabled.
listActiveCommands GET /clusters/{clusterName}/commands List active cluster commands.
listDfsServices GET /clusters/{clusterName}/dfsServices List the services that can provide distributed file system (DFS) capabilities in this cluster.
listHosts GET /clusters/{clusterName}/hosts Returns hosts in the system filtered by optional host configuration parameters, if specified.
listServiceTypes GET /clusters/{clusterName}/serviceTypes List the supported service types for a cluster.
listUpgradeDomains GET /clusters/{clusterName}/upgradeDomains Returns the Upgrade Domains associated with the cluster and the host names that belong to each Upgrade Domain.
perfInspectorCommand POST /clusters/{clusterName}/commands/perfInspector Run cluster performance diagnostics test.
poolsRefresh POST /clusters/{clusterName}/commands/poolsRefresh Updates all refreshable configuration files for services with Dynamic Resource Pools.
postClouderaRuntimeUpgrade POST /clusters/{clusterName}/commands/postClouderaRuntimeUpgrade Post Cloudera Runtime upgrade API.
preUpgradeCheckCommand POST /clusters/{clusterName}/commands/preUpgradeCheck Run cluster pre-upgrade check(s) when upgrading from specified version of CDH to the other.
readCluster GET /clusters/{clusterName} Reads information about a cluster.
readClusters GET /clusters List all known clusters.
readTags GET /clusters/{clusterName}/tags Returns the tags associated with this cluster.
refresh POST /clusters/{clusterName}/commands/refresh Updates all refreshable configuration files in the cluster.
removeAllHosts DELETE /clusters/{clusterName}/hosts
removeHost DELETE /clusters/{clusterName}/hosts/{hostId}
restartCommand POST /clusters/{clusterName}/commands/restart Restart all services in the cluster.
rollingRestart POST /clusters/{clusterName}/commands/rollingRestart Command to do a "best-effort" rolling restart of the given cluster, i.
rollingUpgrade POST /clusters/{clusterName}/commands/rollingUpgrade Command to do a rolling upgrade of specific services in the given cluster This command does not handle any services that don't support rolling upgrades.
runOzoneCommand POST /clusters/{clusterName}/runOzoneCommand Executes an Ozone shell command on an Ozone Role.
startCommand POST /clusters/{clusterName}/commands/start Start all services in the cluster.
stopCommand POST /clusters/{clusterName}/commands/stop Stop all services in the cluster.
tearDownWorkloadCluster POST /clusters/{clusterName}/commands/tearDownWorkload/{workloadClusterName} Tear Down Workload cluster.
updateCluster PUT /clusters/{clusterName} Update an existing cluster.
upgradeCdhCommand POST /clusters/{clusterName}/commands/upgradeCdh Perform CDH upgrade to the specified version.
upgradeServicesCommand POST /clusters/{clusterName}/commands/upgradeServices Upgrades the services in the cluster to the CDH5 version.

addHosts

ApiHostRefList addHosts(clusterName, body)

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | 
ApiHostRefList body = new ApiHostRefList(); // ApiHostRefList | 
try {
    ApiHostRefList result = apiInstance.addHosts(clusterName, body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#addHosts");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String
body ApiHostRefList [optional]

Return type

ApiHostRefList

Authorization

basic

HTTP request headers

addTags

List<ApiEntityTag> addTags(clusterName, body)

Attach tags to the cluster.

Attach tags to the cluster. Tag names beginning with the prefix cldr (case insensitive) are reserved for internal use by Cloudera.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | Name of the cluster
List<ApiEntityTag> body = Arrays.asList(new ApiEntityTag()); // List<ApiEntityTag> | list of tags to add
try {
    List<ApiEntityTag> result = apiInstance.addTags(clusterName, body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#addTags");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String Name of the cluster
body List<ApiEntityTag> list of tags to add [optional]

Return type

List<ApiEntityTag>

Authorization

basic

HTTP request headers

autoAssignRoles

autoAssignRoles(clusterName)

Automatically assign roles to hosts and create the roles for all the services in a cluster.

Automatically assign roles to hosts and create the roles for all the services in a cluster.

Assignments are done based on services and hosts in the cluster, and hardware specifications. If no hosts are added to the cluster, an exception will be thrown preventing any role assignments. Existing roles will be taken into account and their assignments will be not be modified.

Available since API v6.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
try {
    apiInstance.autoAssignRoles(clusterName);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#autoAssignRoles");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.

Return type

null (empty response body)

Authorization

basic

HTTP request headers

autoConfigure

autoConfigure(clusterName)

Automatically configures roles and services in a cluster.

Automatically configures roles and services in a cluster.

Overwrites some existing configurations. Might create new role config groups. Only default role config groups must exist before calling this endpoint. Other role config groups must not exist. If they do, an exception will be thrown preventing any configuration. Ignores the Cloudera Management Service even if colocated with roles of this cluster. To avoid over-committing the heap on hosts, assign hosts to this cluster that are not being used by the Cloudera Management Service.

Available since API v6.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
try {
    apiInstance.autoConfigure(clusterName);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#autoConfigure");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.

Return type

null (empty response body)

Authorization

basic

HTTP request headers

checkEcsPrerequisitesCommand

ApiCommand checkEcsPrerequisitesCommand(clusterName)

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | 
try {
    ApiCommand result = apiInstance.checkEcsPrerequisitesCommand(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#checkEcsPrerequisitesCommand");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String

Return type

ApiCommand

Authorization

basic

HTTP request headers

configureAutoTlsServicesCommand

ApiCommand configureAutoTlsServicesCommand(clusterName)

Configures all services in a cluster to use Auto-TLS.

Configures all services in a cluster to use Auto-TLS

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
try {
    ApiCommand result = apiInstance.configureAutoTlsServicesCommand(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#configureAutoTlsServicesCommand");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.

Return type

ApiCommand

Authorization

basic

HTTP request headers

configureForKerberos

ApiCommand configureForKerberos(clusterName, body)

Command to configure the cluster to use Kerberos for authentication.

Command to configure the cluster to use Kerberos for authentication. This command will configure all relevant services on a cluster for Kerberos usage. This command will trigger a GenerateCredentials command to create Kerberos keytabs for all roles in the cluster.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
ApiConfigureForKerberosArguments body = new ApiConfigureForKerberosArguments(); // ApiConfigureForKerberosArguments | Arguments for the configure for kerberos command.
try {
    ApiCommand result = apiInstance.configureForKerberos(clusterName, body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#configureForKerberos");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.
body ApiConfigureForKerberosArguments Arguments for the configure for kerberos command. [optional]

Return type

ApiCommand

Authorization

basic

HTTP request headers

createClusters

ApiClusterList createClusters(body)

Creates a collection of clusters.

Creates a collection of clusters.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
ApiClusterList body = new ApiClusterList(); // ApiClusterList | List of clusters to created.
try {
    ApiClusterList result = apiInstance.createClusters(body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#createClusters");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
body ApiClusterList List of clusters to created. [optional]

Return type

ApiClusterList

Authorization

basic

HTTP request headers

deleteCluster

ApiCluster deleteCluster(clusterName)

Deletes a cluster.

Deletes a cluster.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | Name of cluster to delete.
try {
    ApiCluster result = apiInstance.deleteCluster(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#deleteCluster");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String Name of cluster to delete.

Return type

ApiCluster

Authorization

basic

HTTP request headers

deleteClusterCredentialsCommand

ApiCommand deleteClusterCredentialsCommand(clusterName)

Delete existing Kerberos credentials for the cluster.

Delete existing Kerberos credentials for the cluster.

This command will affect all services that have been configured to use Kerberos, and have existing credentials.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | cluster name
try {
    ApiCommand result = apiInstance.deleteClusterCredentialsCommand(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#deleteClusterCredentialsCommand");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String cluster name

Return type

ApiCommand

Authorization

basic

HTTP request headers

deleteTags

List<ApiEntityTag> deleteTags(clusterName, body)

Remove the tags associated with the cluster.

Remove the tags associated with the cluster. Tag names beginning with the prefix cldr (case insensitive) are reserved for internal use by Cloudera.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | Name of the cluster to remove tags from
List<ApiEntityTag> body = Arrays.asList(new ApiEntityTag()); // List<ApiEntityTag> | 
try {
    List<ApiEntityTag> result = apiInstance.deleteTags(clusterName, body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#deleteTags");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String Name of the cluster to remove tags from
body List<ApiEntityTag> [optional]

Return type

List<ApiEntityTag>

Authorization

basic

HTTP request headers

deployClientConfig

ApiCommand deployClientConfig(clusterName)

Deploy the cluster-wide client configuration.

Deploy the cluster-wide client configuration.

For each service in the cluster, deploy the service's client configuration to all the hosts that the service runs on.

Available since API v2.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster
try {
    ApiCommand result = apiInstance.deployClientConfig(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#deployClientConfig");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster

Return type

ApiCommand

Authorization

basic

HTTP request headers

deployClientConfigsAndRefresh

ApiCommand deployClientConfigsAndRefresh(clusterName)

Performs a command with the 2 steps - deploy cc - cluster refresh This orchestration is needed for the staleness wizard, so it can invoke a single command at wizard finish.

Performs a command with the 2 steps - deploy cc - cluster refresh This orchestration is needed for the staleness wizard, so it can invoke a single command at wizard finish.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
try {
    ApiCommand result = apiInstance.deployClientConfigsAndRefresh(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#deployClientConfigsAndRefresh");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.

Return type

ApiCommand

Authorization

basic

HTTP request headers

deployClusterClientConfig

ApiCommand deployClusterClientConfig(clusterName, body)

Deploy the Cluster's Kerberos client configuration.

Deploy the Cluster's Kerberos client configuration.

Deploy krb5.conf to hosts in a cluster. Does not deploy to decommissioned hosts or hosts with active processes.

Available since API v7.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster
ApiHostRefList body = new ApiHostRefList(); // ApiHostRefList | Hosts in cluster to deploy to. If empty, will target all eligible
hosts in the cluster.
try {
    ApiCommand result = apiInstance.deployClusterClientConfig(clusterName, body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#deployClusterClientConfig");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster
body ApiHostRefList Hosts in cluster to deploy to. If empty, will target all eligible
hosts in the cluster. [optional]

Return type

ApiCommand

Authorization

basic

HTTP request headers

disableTls

ApiCommand disableTls(clusterName)

Disables TLS settings on a cluster.

Disables TLS settings on a cluster.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster
try {
    ApiCommand result = apiInstance.disableTls(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#disableTls");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster

Return type

ApiCommand

Authorization

basic

HTTP request headers

enterMaintenanceMode

ApiCommand enterMaintenanceMode(clusterName)

Put the cluster into maintenance mode.

Put the cluster into maintenance mode. This is a synchronous command. The result is known immediately upon return.

Available since API v2.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster
try {
    ApiCommand result = apiInstance.enterMaintenanceMode(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#enterMaintenanceMode");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster

Return type

ApiCommand

Authorization

basic

HTTP request headers

exitMaintenanceMode

ApiCommand exitMaintenanceMode(clusterName)

Take the cluster out of maintenance mode.

Take the cluster out of maintenance mode. This is a synchronous command. The result is known immediately upon return.

Available since API v2.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster
try {
    ApiCommand result = apiInstance.exitMaintenanceMode(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#exitMaintenanceMode");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster

Return type

ApiCommand

Authorization

basic

HTTP request headers

expireLogs

ApiCommand expireLogs(clusterName, days, scheduleNext)

Remove backup and disaster related log files in hdfs.

Remove backup and disaster related log files in hdfs.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
java.math.BigDecimal days = new java.math.BigDecimal(); // java.math.BigDecimal | Logs more than these many days old are purged. By default, it uses the value defined in the CM configuration. Set to -2 to explicitly set to default.
Boolean scheduleNext = false; // Boolean | Whether to schedule a next run for the command, or not. If set to , the next run will get scheduled after this one finished. If a schedule already exists, it will be updated. Can be omitted, the default value is false.
try {
    ApiCommand result = apiInstance.expireLogs(clusterName, days, scheduleNext);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#expireLogs");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.
days java.math.BigDecimal Logs more than these many days old are purged. By default, it uses the value defined in the CM configuration. Set to -2 to explicitly set to default. [optional] [default to -2]
scheduleNext Boolean Whether to schedule a next run for the command, or not. If set to , the next run will get scheduled after this one finished. If a schedule already exists, it will be updated. Can be omitted, the default value is false. [optional] [default to false]

Return type

ApiCommand

Authorization

basic

HTTP request headers

export

ApiClusterTemplate export(clusterName, exportAutoConfig)

Export the cluster template for the given cluster.

Export the cluster template for the given cluster. If cluster does not have host templates defined it will export host templates based on roles assignment.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | cluster name
Boolean exportAutoConfig = false; // Boolean | export configs set by the auto configuration
try {
    ApiClusterTemplate result = apiInstance.export(clusterName, exportAutoConfig);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#export");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String cluster name
exportAutoConfig Boolean export configs set by the auto configuration [optional] [default to false]

Return type

ApiClusterTemplate

Authorization

basic

HTTP request headers

firstRun

ApiCommand firstRun(clusterName)

Prepare and start services in a cluster.

Prepare and start services in a cluster.

Perform all the steps needed to prepare each service in a cluster and start the services in order.

Available since API v7.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
try {
    ApiCommand result = apiInstance.firstRun(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#firstRun");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.

Return type

ApiCommand

Authorization

basic

HTTP request headers

getClientConfig

File getClientConfig(clusterName)

Download a zip-compressed archive of the client configuration, of a specific cluster.

Download a zip-compressed archive of the client configuration, of a specific cluster. Currently, this only includes Kerberos Client Configuration (krb5.conf). For client configuration of services, use the clientConfig endpoint of the services resource. This resource does not require any authentication.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The cluster name.
try {
    File result = apiInstance.getClientConfig(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#getClientConfig");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The cluster name.

Return type

File

Authorization

basic

HTTP request headers

getClusterSupportToken

ApiClusterSupportToken getClusterSupportToken(clusterName)

Gets the support token for a cluster.

Gets the support token for a cluster.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
try {
    ApiClusterSupportToken result = apiInstance.getClusterSupportToken(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#getClusterSupportToken");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.

Return type

ApiClusterSupportToken

Authorization

basic

HTTP request headers

getKerberosInfo

ApiKerberosInfo getKerberosInfo(clusterName)

Provides Cluster Kerberos information.

Provides Cluster Kerberos information

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The cluster name.
try {
    ApiKerberosInfo result = apiInstance.getKerberosInfo(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#getKerberosInfo");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The cluster name.

Return type

ApiKerberosInfo

Authorization

basic

HTTP request headers

getOzoneBucketInfo

ApiOzoneBucketInfo getOzoneBucketInfo(clusterName, bucketName, volumeName)

Returns the properties of the provided ozone bucket if the bucket exists.

Returns the properties of the provided ozone bucket if the bucket exists.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | 
String bucketName = "bucketName_example"; // String | 
String volumeName = "volumeName_example"; // String | 
try {
    ApiOzoneBucketInfo result = apiInstance.getOzoneBucketInfo(clusterName, bucketName, volumeName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#getOzoneBucketInfo");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String
bucketName String [optional]
volumeName String [optional]

Return type

ApiOzoneBucketInfo

Authorization

basic

HTTP request headers

getOzoneS3GatewayInfo

ApiOzoneS3GatewayInfo getOzoneS3GatewayInfo(clusterName, bucketName)

Returns the REST url for the Ozone S3 Gateway, as well as the AWS credentials needed to access the S3 endpoint.

Returns the REST url for the Ozone S3 Gateway, as well as the AWS credentials needed to access the S3 endpoint. Additionally, creates a bucket with the specified name under the volume s3v. If no Ozone is present, or Ozone is not running, returns success with an empty response. Currently, we get the credentials for the Hive kerberos principal, and give ownership of the created bucket to the same. This is likely not a permanent solution. If the cluster is not kerberizied, we return dummy credentials. Requires CDH 7.2.1+ or CDH 7.1.3+

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster
String bucketName = "bucketName_example"; // String | the name of the bucket to create
try {
    ApiOzoneS3GatewayInfo result = apiInstance.getOzoneS3GatewayInfo(clusterName, bucketName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#getOzoneS3GatewayInfo");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster
bucketName String the name of the bucket to create [optional]

Return type

ApiOzoneS3GatewayInfo

Authorization

basic

HTTP request headers

getUtilizationReport

ApiClusterUtilization getUtilizationReport(clusterName, daysOfWeek, endHourOfDay, from, startHourOfDay, tenantType, to)

Provides the resource utilization of the entire cluster as well as the resource utilization per tenant.

Provides the resource utilization of the entire cluster as well as the resource utilization per tenant. Only available with Cloudera Manager Enterprise Edition.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | cluster name
List<String> daysOfWeek = Arrays.asList("daysOfWeek_example"); // List<String> | The days of the week for which the user wants to report utilization. Days is a list of number between 1 to 7, where 1 corresponds to Monday, and 7 corrensponds to Sunday. All 7 days are included if this is not specified.
java.math.BigDecimal endHourOfDay = new java.math.BigDecimal(); // java.math.BigDecimal | The end hour of a day for which the user wants to report utilization. The hour is a number between [0-23]. Default value is 23 if this is not specified.
String from = "from_example"; // String | Start of the time range to report utilization in ISO 8601 format.
java.math.BigDecimal startHourOfDay = new java.math.BigDecimal(); // java.math.BigDecimal | The start hour of a day for which the user wants to report utilization. The hour is a number between [0-23]. Default value is 0 if this is not specified.
String tenantType = "POOL"; // String | The type of the tenant (POOL or USER).
String to = "now"; // String | End of the the time range to report utilization in ISO 8601 format (defaults to now).
try {
    ApiClusterUtilization result = apiInstance.getUtilizationReport(clusterName, daysOfWeek, endHourOfDay, from, startHourOfDay, tenantType, to);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#getUtilizationReport");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String cluster name
daysOfWeek List<String> The days of the week for which the user wants to report utilization. Days is a list of number between 1 to 7, where 1 corresponds to Monday, and 7 corrensponds to Sunday. All 7 days are included if this is not specified. [optional]
endHourOfDay java.math.BigDecimal The end hour of a day for which the user wants to report utilization. The hour is a number between [0-23]. Default value is 23 if this is not specified. [optional] [default to 23]
from String Start of the time range to report utilization in ISO 8601 format. [optional]
startHourOfDay java.math.BigDecimal The start hour of a day for which the user wants to report utilization. The hour is a number between [0-23]. Default value is 0 if this is not specified. [optional] [default to 0]
tenantType String The type of the tenant (POOL or USER). [optional] [default to POOL]
to String End of the the time range to report utilization in ISO 8601 format (defaults to now). [optional] [default to now]

Return type

ApiClusterUtilization

Authorization

basic

HTTP request headers

inspectHostsCommand

ApiCommand inspectHostsCommand(clusterName)

Runs the host inspector on the configured hosts in the specified cluster.

Runs the host inspector on the configured hosts in the specified cluster. Available since V8.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster
try {
    ApiCommand result = apiInstance.inspectHostsCommand(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#inspectHostsCommand");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster

Return type

ApiCommand

Authorization

basic

HTTP request headers

isTlsEnabled

Boolean isTlsEnabled(clusterName)

Returns whether a cluster has any TLS settings enabled.

Returns whether a cluster has any TLS settings enabled. This only checks settings that would have been enabled by Auto-TLS.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster
try {
    Boolean result = apiInstance.isTlsEnabled(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#isTlsEnabled");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster

Return type

Boolean

Authorization

basic

HTTP request headers

listActiveCommands

ApiCommandList listActiveCommands(clusterName, commandName, view)

List active cluster commands.

List active cluster commands.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The cluster to which the role belongs.
String commandName = "commandName_example"; // String | the command name, unique for the command class RestartClusterCommand#COMMAND_NAME
String view = "summary"; // String | The view of the data to materialize, either \"summary\" or \"full\".
try {
    ApiCommandList result = apiInstance.listActiveCommands(clusterName, commandName, view);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#listActiveCommands");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The cluster to which the role belongs.
commandName String the command name, unique for the command class RestartClusterCommand#COMMAND_NAME [optional]
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, FULL_WITH_NO_HEALTH_CHECK, SUMMARY]

Return type

ApiCommandList

Authorization

basic

HTTP request headers

listDfsServices

ApiServiceList listDfsServices(clusterName, view)

List the services that can provide distributed file system (DFS) capabilities in this cluster.

List the services that can provide distributed file system (DFS) capabilities in this cluster.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | cluster name
String view = "summary"; // String | data view required for matching services
try {
    ApiServiceList result = apiInstance.listDfsServices(clusterName, view);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#listDfsServices");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String cluster name
view String data view required for matching services [optional] [default to summary] [enum: EXPORT, EXPORT_REDACTED, FULL, FULL_WITH_HEALTH_CHECK_EXPLANATION, FULL_WITH_NO_HEALTH_CHECK, SUMMARY]

Return type

ApiServiceList

Authorization

basic

HTTP request headers

listHosts

ApiHostList listHosts(clusterName, configName, configValue, view)

Returns hosts in the system filtered by optional host configuration parameters, if specified.

Returns hosts in the system filtered by optional host configuration parameters, if specified.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | Name of the cluster
String configName = "configName_example"; // String | optional host config name to filter hosts by. Available from v40.
String configValue = "configValue_example"; // String | host config value associated with config name. Available from v40.
String view = "summary"; // String | The view to materialize
try {
    ApiHostList result = apiInstance.listHosts(clusterName, configName, configValue, view);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#listHosts");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String Name of the cluster
configName String optional host config name to filter hosts by. Available from v40. [optional]
configValue String host config value associated with config name. Available from v40. [optional]
view String The view to materialize [optional] [default to summary] [enum: EXPORT, EXPORT_REDACTED, FULL, FULL_WITH_HEALTH_CHECK_EXPLANATION, FULL_WITH_NO_HEALTH_CHECK, SUMMARY]

Return type

ApiHostList

Authorization

basic

HTTP request headers

listServiceTypes

ApiServiceTypeList listServiceTypes(clusterName)

List the supported service types for a cluster.

List the supported service types for a cluster.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The cluster.
try {
    ApiServiceTypeList result = apiInstance.listServiceTypes(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#listServiceTypes");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The cluster.

Return type

ApiServiceTypeList

Authorization

basic

HTTP request headers

listUpgradeDomains

ApiHdfsUpgradeDomainList listUpgradeDomains(clusterName)

Returns the Upgrade Domains associated with the cluster and the host names that belong to each Upgrade Domain.

Returns the Upgrade Domains associated with the cluster and the host names that belong to each Upgrade Domain. Hosts without an Upgrade Domain set will default to using the rack assignment of the host.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
try {
    ApiHdfsUpgradeDomainList result = apiInstance.listUpgradeDomains(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#listUpgradeDomains");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.

Return type

ApiHdfsUpgradeDomainList

Authorization

basic

HTTP request headers

perfInspectorCommand

ApiCommand perfInspectorCommand(clusterName, body)

Run cluster performance diagnostics test.

Run cluster performance diagnostics test.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
ApiClusterPerfInspectorArgs body = new ApiClusterPerfInspectorArgs(); // ApiClusterPerfInspectorArgs | Optional arguments for the command. See ApiClusterPerfInspectorArgs.
try {
    ApiCommand result = apiInstance.perfInspectorCommand(clusterName, body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#perfInspectorCommand");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.
body ApiClusterPerfInspectorArgs Optional arguments for the command. See ApiClusterPerfInspectorArgs. [optional]

Return type

ApiCommand

Authorization

basic

HTTP request headers

poolsRefresh

ApiCommand poolsRefresh(clusterName)

Updates all refreshable configuration files for services with Dynamic Resource Pools.

Updates all refreshable configuration files for services with Dynamic Resource Pools.

Available since API v6.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster
try {
    ApiCommand result = apiInstance.poolsRefresh(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#poolsRefresh");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster

Return type

ApiCommand

Authorization

basic

HTTP request headers

postClouderaRuntimeUpgrade

ApiCommand postClouderaRuntimeUpgrade(clusterName)

Post Cloudera Runtime upgrade API.

Post Cloudera Runtime upgrade API.

This API executes special finalization tasks (already part of regular CDH upgrade) after the installation of an updated build of Cloudera Runtime (no version change). No version change of Cloudera Rumtime means when first 3 digits of build remains the same (e.g. from 7.2.1.a to 7.2.1.b) during upgrade. Purpose of this is to automate manual tasks of CDH upgrade.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | 
try {
    ApiCommand result = apiInstance.postClouderaRuntimeUpgrade(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#postClouderaRuntimeUpgrade");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String

Return type

ApiCommand

Authorization

basic

HTTP request headers

preUpgradeCheckCommand

ApiCommand preUpgradeCheckCommand(clusterName, body)

Run cluster pre-upgrade check(s) when upgrading from specified version of CDH to the other.

Run cluster pre-upgrade check(s) when upgrading from specified version of CDH to the other.

Allows the following upgrade checks:

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
ApiCdhUpgradeArgs body = new ApiCdhUpgradeArgs(); // ApiCdhUpgradeArgs | Arguments for the command. See ApiCdhUpgradeArgs.
try {
    ApiCommand result = apiInstance.preUpgradeCheckCommand(clusterName, body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#preUpgradeCheckCommand");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.
body ApiCdhUpgradeArgs Arguments for the command. See ApiCdhUpgradeArgs. [optional]

Return type

ApiCommand

Authorization

basic

HTTP request headers

readCluster

ApiCluster readCluster(clusterName)

Reads information about a cluster.

Reads information about a cluster.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | Name of cluster to look up.
try {
    ApiCluster result = apiInstance.readCluster(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#readCluster");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String Name of cluster to look up.

Return type

ApiCluster

Authorization

basic

HTTP request headers

readClusters

ApiClusterList readClusters(clusterType, view)

List all known clusters.

List all known clusters.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterType = "base"; // String | Type of cluster, either \"any\", \"base\", \"compute\" or \"experience\". Default is \"base\".
String view = "summary"; // String | The view of the data to materialize, either \"summary\" or \"full\".
try {
    ApiClusterList result = apiInstance.readClusters(clusterType, view);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#readClusters");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterType String Type of cluster, either "any", "base", "compute" or "experience". Default is "base". [optional] [default to base] [enum: ANY, BASE, COMPUTE, DATA_SERVICES, EXPERIENCE]
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, FULL_WITH_NO_HEALTH_CHECK, SUMMARY]

Return type

ApiClusterList

Authorization

basic

HTTP request headers

readTags

List<ApiEntityTag> readTags(clusterName, limit, offset)

Returns the tags associated with this cluster.

Returns the tags associated with this cluster. Tag names beginning with the prefix cldr (case insensitive) are reserved for internal use by Cloudera.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster
java.math.BigDecimal limit = new java.math.BigDecimal(); // java.math.BigDecimal | Number of tags
java.math.BigDecimal offset = new java.math.BigDecimal(); // java.math.BigDecimal | Index of the first tag to retrieve
try {
    List<ApiEntityTag> result = apiInstance.readTags(clusterName, limit, offset);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#readTags");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster
limit java.math.BigDecimal Number of tags [optional] [default to 10]
offset java.math.BigDecimal Index of the first tag to retrieve [optional] [default to 0]

Return type

List<ApiEntityTag>

Authorization

basic

HTTP request headers

refresh

ApiCommand refresh(clusterName)

Updates all refreshable configuration files in the cluster.

Updates all refreshable configuration files in the cluster. Will not restart any roles.

Available since API v6.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster
try {
    ApiCommand result = apiInstance.refresh(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#refresh");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster

Return type

ApiCommand

Authorization

basic

HTTP request headers

removeAllHosts

ApiHostRefList removeAllHosts(clusterName)

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | 
try {
    ApiHostRefList result = apiInstance.removeAllHosts(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#removeAllHosts");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String

Return type

ApiHostRefList

Authorization

basic

HTTP request headers

removeHost

ApiHostRef removeHost(clusterName, hostId)

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | 
String hostId = "hostId_example"; // String | 
try {
    ApiHostRef result = apiInstance.removeHost(clusterName, hostId);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#removeHost");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String
hostId String

Return type

ApiHostRef

Authorization

basic

HTTP request headers

restartCommand

ApiCommand restartCommand(clusterName, body)

Restart all services in the cluster.

Restart all services in the cluster.

Services are stopped then started in the appropriate order given their dependencies. The command can optionally restart only stale services and their dependencies as well as redeploy client configuration on all services in the cluster.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
ApiRestartClusterArgs body = new ApiRestartClusterArgs(); // ApiRestartClusterArgs | arguments for the restart command.
try {
    ApiCommand result = apiInstance.restartCommand(clusterName, body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#restartCommand");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.
body ApiRestartClusterArgs arguments for the restart command. [optional]

Return type

ApiCommand

Authorization

basic

HTTP request headers

rollingRestart

ApiCommand rollingRestart(clusterName, body)

Command to do a "best-effort" rolling restart of the given cluster, i.

Command to do a "best-effort" rolling restart of the given cluster, i.e. it does plain restart of services that cannot be rolling restarted, followed by first rolling restarting non-slaves and then rolling restarting the slave roles of services that can be rolling restarted. The slave restarts are done host-by-host.

Available since API v4. Only available with Cloudera Manager Enterprise Edition.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
ApiRollingRestartClusterArgs body = new ApiRollingRestartClusterArgs(); // ApiRollingRestartClusterArgs | Arguments for the rolling restart command.
try {
    ApiCommand result = apiInstance.rollingRestart(clusterName, body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#rollingRestart");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.
body ApiRollingRestartClusterArgs Arguments for the rolling restart command. [optional]

Return type

ApiCommand

Authorization

basic

HTTP request headers

rollingUpgrade

ApiCommand rollingUpgrade(clusterName, body)

Command to do a rolling upgrade of specific services in the given cluster This command does not handle any services that don't support rolling upgrades.

Command to do a rolling upgrade of specific services in the given cluster This command does not handle any services that don't support rolling upgrades. The command will throw an error and not start if upgrade of any such service is requested. This command does not upgrade the full CDH Cluster. You should normally use the upgradeCDH Command for upgrading the cluster. This is primarily helpful if you need to need to recover from an upgrade failure or for advanced users to script an alternative to the upgradeCdhCommand. This command expects the binaries to be available on hosts and activated. It does not change any binaries on the hosts.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
ApiRollingUpgradeServicesArgs body = new ApiRollingUpgradeServicesArgs(); // ApiRollingUpgradeServicesArgs | Arguments for the rolling upgrade command.
try {
    ApiCommand result = apiInstance.rollingUpgrade(clusterName, body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#rollingUpgrade");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.
body ApiRollingUpgradeServicesArgs Arguments for the rolling upgrade command. [optional]

Return type

ApiCommand

Authorization

basic

HTTP request headers

runOzoneCommand

ApiCommand runOzoneCommand(clusterName, bucketName, commandName, volumeName)

Executes an Ozone shell command on an Ozone Role.

Executes an Ozone shell command on an Ozone Role. The command needs to be defined as a RoleCommand in CM (Eg GetOzoneBucketInfoCommand).

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The cluster to which the role belongs.
String bucketName = "bucketName_example"; // String | name of the Ozone bucket
String commandName = "commandName_example"; // String | The command to run on an Ozone Role.
String volumeName = "volumeName_example"; // String | name of the Ozone volume
try {
    ApiCommand result = apiInstance.runOzoneCommand(clusterName, bucketName, commandName, volumeName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#runOzoneCommand");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The cluster to which the role belongs.
bucketName String name of the Ozone bucket [optional]
commandName String The command to run on an Ozone Role. [optional]
volumeName String name of the Ozone volume [optional]

Return type

ApiCommand

Authorization

basic

HTTP request headers

startCommand

ApiCommand startCommand(clusterName)

Start all services in the cluster.

Start all services in the cluster.

Services are started in the appropriate order given their dependencies.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
try {
    ApiCommand result = apiInstance.startCommand(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#startCommand");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.

Return type

ApiCommand

Authorization

basic

HTTP request headers

stopCommand

ApiCommand stopCommand(clusterName)

Stop all services in the cluster.

Stop all services in the cluster.

Services are stopped in the appropriate order given their dependencies.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
try {
    ApiCommand result = apiInstance.stopCommand(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#stopCommand");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.

Return type

ApiCommand

Authorization

basic

HTTP request headers

tearDownWorkloadCluster

ApiCommand tearDownWorkloadCluster(clusterName, workloadClusterName)

Tear Down Workload cluster.

Tear Down Workload cluster.

Tear Down Ranger plugin service (repository) associated with the workload cluster.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
String workloadClusterName = "workloadClusterName_example"; // String | The name of the workload cluster.
try {
    ApiCommand result = apiInstance.tearDownWorkloadCluster(clusterName, workloadClusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#tearDownWorkloadCluster");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.
workloadClusterName String The name of the workload cluster.

Return type

ApiCommand

Authorization

basic

HTTP request headers

updateCluster

ApiCluster updateCluster(clusterName, body)

Update an existing cluster.

Update an existing cluster.

To update the CDH version, provide the new value in the "fullVersion" property. Setting a correct version that matches the actual installed software will ensure the correct version-specific features, such as services, roles, commands, and configurations. This need not be manually set for clusters using parcels. In general this action is only necessary after the CDH packages have been manually updated. Note that a downgrade may be rejected if it would render existing services or roles unusable. For major upgrade, the "upgradeService" cluster command should be used instead.

To rename the cluster, provide the new name in the "displayName" property for API >= 6, or in the "name" property for API <=5.

Available since API v2.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
ApiCluster body = new ApiCluster(); // ApiCluster | 
try {
    ApiCluster result = apiInstance.updateCluster(clusterName, body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#updateCluster");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.
body ApiCluster [optional]

Return type

ApiCluster

Authorization

basic

HTTP request headers

upgradeCdhCommand

ApiCommand upgradeCdhCommand(clusterName, body)

Perform CDH upgrade to the specified version.

Perform CDH upgrade to the specified version.

Allows the following upgrades:

If using packages, CDH packages on all hosts of the cluster must be manually upgraded before this command is issued.

The command will upgrade the services and their configuration to the version available in the CDH5 distribution.

Unless rolling upgrade options are provided, the entire cluster will experience downtime. If rolling upgrade options are provided, command will do a "best-effort" rolling upgrade of the given cluster, i.e. it does plain upgrade of services that cannot be rolling upgraded, followed by first rolling upgrading non-slaves and then rolling restarting the slave roles of services that can be rolling restarted. The slave restarts are done host-by-host.

Available since v9. Rolling upgrade is only available with Cloudera Manager Enterprise Edition. A more limited upgrade variant available since v6.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
ApiCdhUpgradeArgs body = new ApiCdhUpgradeArgs(); // ApiCdhUpgradeArgs | Arguments for the command. See ApiCdhUpgradeArgs.
try {
    ApiCommand result = apiInstance.upgradeCdhCommand(clusterName, body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#upgradeCdhCommand");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.
body ApiCdhUpgradeArgs Arguments for the command. See ApiCdhUpgradeArgs. [optional]

Return type

ApiCommand

Authorization

basic

HTTP request headers

upgradeServicesCommand

ApiCommand upgradeServicesCommand(clusterName)

Upgrades the services in the cluster to the CDH5 version.

Upgrades the services in the cluster to the CDH5 version.

This command requires that the CDH packages in the hosts used by the cluster be upgraded to CDH5 before this command is issued. Once issued, this command will stop all running services before proceeding.

If parcels are used instead of CDH system packages then the following steps need to happen in order:

  1. Stop all services manually
  2. Activate parcel
  3. Run this upgrade command
The command will upgrade the services and their configuration to the version available in the CDH5 distribution.

Example

// 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.ClustersResourceApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();
// Configure HTTP basic authorization: basic
HttpBasicAuth basic = (HttpBasicAuth) defaultClient.getAuthentication("basic");
basic.setUsername("YOUR USERNAME");
basic.setPassword("YOUR PASSWORD");

ClustersResourceApi apiInstance = new ClustersResourceApi();
String clusterName = "clusterName_example"; // String | The name of the cluster.
try {
    ApiCommand result = apiInstance.upgradeServicesCommand(clusterName);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ClustersResourceApi#upgradeServicesCommand");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
clusterName String The name of the cluster.

Return type

ApiCommand

Authorization

basic

HTTP request headers