Overview

Create and manage replication policies using Cloudera Replication Manager.

Version information

Version : 0.9.112

License information

URI scheme

Schemes : HTTPS

Consumes

  • application/json

Produces

  • application/json

Paths

Resume all replication tasks defined by the policy.

POST /api/v1/replicationmanager/activatePolicy

Description

Resumes all replication tasks defined by the policy if the policy is currently suspended.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Collect diagnostic bundle for a policy.

POST /api/v1/replicationmanager/collectDiagnosticBundle

Description

Triggers the collection of diagnostic bundle for a policy.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Create an ABFS Cloud Credential.

POST /api/v1/replicationmanager/createAbfsCredential

Description

Creates a new ABFS cloud credential.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Create an AWS Cloud Credential.

POST /api/v1/replicationmanager/createAwsCredential

Description

Creates a new AWS cloud credential.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Create a Replication Policy.

POST /api/v1/replicationmanager/createPolicy

Description

Creates a new replication policy with the given name on a specific cluster.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Delete Cloud Credential.

POST /api/v1/replicationmanager/deleteCredential

Description

Permanently deletes a specific cloud credential.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Delete Replication Policy.

POST /api/v1/replicationmanager/deletePolicy

Description

Permanently deletes a specific replication policy.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Download diagnostic bundle for a policy.

POST /api/v1/replicationmanager/downloadDiagnosticBundle

Description

Downloads the previously collected diagnostic bundle if available. Before calling, the get-command-status command shall be polled until the command’s status shows 'DOWNLOADABLE_WITH_CLI'. If the status is 'DOWNLOADABLE_WITH_URL', the result can be downloaded with the given result data URL only.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Get the status of the given CM command.

POST /api/v1/replicationmanager/getCommandStatus

Description

Return the current status of the given CM command.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Get Cloud Credentials from a Cluster.

POST /api/v1/replicationmanager/getCredentials

Description

Returns cloud credentials on a specific cluster.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Lists Cloud Credentials.

POST /api/v1/replicationmanager/listAllCredentials

Description

Provides a detailed list of cloud credentials across all available clusters.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Lists Cluster Service Statuses.

POST /api/v1/replicationmanager/listClusterServiceStatuses

Description

Provides a list of cluster service (e.g. HDFS, Hive, YARN, etc.) statuses.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Lists all clusters.

POST /api/v1/replicationmanager/listClusters

Description

Provides a detailed list of all available clusters.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Get All Replication Policies.

POST /api/v1/replicationmanager/listPolicies

Description

Provides a list of all replication policies across all available clusters.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Stop all replication tasks defined by the policy.

POST /api/v1/replicationmanager/suspendPolicy

Description

Stops all replication tasks defined by the policy. Replication will resume after activating the policy.

Parameters

Type Name Schema

Body

input
required

Responses

HTTP Code Description Schema

200

Describes a successful response to a valid request.

default

The default response on an error.

Definitions

AbfsCloudCredentialType

ABFS cloud credential type.

Type : enum (ACCESSKEY, CLIENTKEY)

ActivatePolicyRequest

Activate a replication policy.

Name Description Schema

clusterCrn
required

CRN of the cluster where the policy is.

string

policyName
required

Policy name to resume.

string

ActivatePolicyResponse

Response object for resumePolicy.

Type : object

Alert

Cloudera Manager alerting behavior.

Name Description Schema

onAbort
required

Alert on abort.

boolean

onFailure
required

Alert on failure.

boolean

onStart
required

Alert on start.

boolean

onSuccess
required

ALert on success.

boolean

ApiError

API error.

Name Description Schema

clusterUrl
optional

Cluster URL.

string

code
required

Error code.

integer (int32)

message
required

Error message.

string

requestId
optional

Request ID.

string

status
required

Error status.

string

AwsCloudCredentialType

AWS cloud credential type.

Type : enum (IAM, ACCESSKEY)

Cluster

Describes a Datalake, Datahub or Classic cluster.

Name Description Schema

cloudAccountProvider
optional

Cloud account provider.

enum (AWS, ADLS, WASB, ABFS, GCS)

clusterManagerType
required

Cluster Manager type.

enum (CLOUDERA_MANAGER, AMBARI)

clusterManagerUrl
required

Cluster Manager URL.

string

clusterType
required

Cluster type.

enum (CLASSIC, SDX, DISTROX)

clusterUrl
required

Cluster URL.

string

cmName
optional

Cloudera Manager name.

string

codProperties
optional

Additional properties for operational databases.

crn
required

Cluster CRN.

string

dataCenter
required

Cluster data center.

string

description
optional

Cluster description.

string

environmentCrn
optional

CRN of the cluster’s environment.

string

knoxUrl
optional

Knox URL if the cluster was registered with one, null otherwise.

string

location
optional

Cluster location.

name
required

Cluster name.

string

replicationEngineType
required

Replication engine type.

enum (CM, DLM_ENGINE)

stackCrn
optional

Stack CRN.

string

stackMajorVersion
optional

Stack major version.

string

stackVersion
optional

Stack version.

string

totalHosts
optional

Total hosts on the cluster.

integer (int32)

uuid
optional

Cluster UUID from Cloudera Manager if the cluster has CM backend.

string

ClusterServiceStatuses

Describes the status of services running on a cluster.

Name Description Schema

clusterCrn
required

Cluster CRN.

string

serviceStatuses
required

List of service statuses.

< ServiceInfo > array

CmPolicySubmitUser

CM Policy submit user.

Name Description Schema

sourceUser
optional

Source user.

string

userName
optional

Username.

string

CodProperties

Additional properties for operational databases.

Name Description Schema

operationalDatabaseName
optional

Name of the corresponding operational database..

string

CollectDiagnosticBundleRequest

Triggers a diagnostic bundle collect command for the given cluster and policyName.

Name Description Schema

clusterCrn
required

The CRN of the target cluster.

string

policyName
required

Name of the policy.

string

CollectDiagnosticBundleResponse

Response object for collect-diagnostic-bundle.

Name Description Schema

active
optional

Whether the diagnostic bundle command is active.

boolean

commandId
required

ID of the diagnostic bundle collection command issued against the CM. Polling get-command-status with this command id returns the current state of the command.

integer (int64)

name
optional

Name of the policy.

string

resultMessage
optional

Diagnostic bundle collection command result message.

string

startTime
optional

Start time of the diagnostic bundle collection command.

string

CreateAbfsCredentialRequest

Request object for creating ABFS cloud credentials. Currently supported cloud credentials: ABFS Access Key for Ambari clusters, ABFS Client Secret for CM clusters.

Name Description Schema

accessKey
optional

ABFS access key.

string

clientId
optional

Client ID of an Active Directory service principal account.

string

clientSecretKey
optional

Client Key of an Active Directory service principal account.

string

clusters
required

List of cluster CRNs where the credential should be created.

< string > array

name
required

Name of the credential.

string

storageAccountName
optional

ABFS storage account name.

string

tenantId
optional

Tenant ID of an Active Directory service principal account.

string

type
required

Type of the credential. Additional required parameters by type: ACCESSKEY: storageAccountName, accessKey; CLIENTKEY: clientId, clientSecretKey, tenantId. Superfluous parameters are ignored. Providing ACCESSKEY will create an ABFS Access Key based account in Ambari. Providing CLIENTKEY will create an Azure Active Directory Service Principal account in Cloudera Manager. ACCESSKEY is only supported on Ambari, while CLIENTKEY is only supported on Cloudera Manager.

CreateAbfsCredentialResponse

Response object for creating ABFS credentials.

Name Description Schema

errors
optional

The list of response errors in case of a partial failure while creating the credential.

< ApiError > array

CreateAwsCredentialRequest

Request object for creating AWS IAM or Access & Secret Key cloud credentials.

Name Description Schema

accessKey
optional

AWS access key.

string

clusters
required

List of cluster CRNs where the credential should be created.

< string > array

name
required

Name of the credential.

string

secretKey
optional

AWS secret key.

string

type
required

Type of the credential. Additional required parameters by type: IAM: none; ACCESSKEY: accessKey, secretKey. Superfluous parameters are ignored. Providing IAM will create an IAM Role-based Authentication account in Cloudera Manager. Providing ACCESSKEY will create an AWS Access Key Authentication account in Cloudera Manager.

CreateAwsCredentialResponse

Response object for creating AWS credentials.

Name Description Schema

errors
optional

The list of response errors in case of a partial failure while creating the credential.

< ApiError > array

CreatePolicyRequest

Create a replication policy.

Name Description Schema

clusterCrn
required

CRN of the cluster where the policy will be created.

string

policyDefinition
required

Policy definition.

policyName
required

Name of the new policy.

string

CreatePolicyResponse

Response object for createPolicy.

Type : object

CredentialCollection

Cloud Credentials listing.

Name Description Schema

credentials
required

Cloud credential details.

< CredentialDetails > array

results
required

Number of cloud credentials in the response.

integer (int64)

totalResults
required

Total number cloud credentials.

integer (int64)

CredentialDetails

Cloud credential details for by-name or by-id cloud credential request.

Name Description Schema

authType
required

Authentication type.

string

configs
optional

Configurations.

< string, string > map

creationTime
required

Creation time.

string (date-time)

customConfigs
optional

Custom configurations.

< CustomConfigs > array

id
required

Credential id.

string

lastModifiedTime
required

Last modified time.

string (date-time)

name
required

Credential name.

string

provider
required

Credential provider.

string

CredentialsResponse

Response object for cloud credentials.

Name Description Schema

clusterCrn
required

Cluster CRN.

string

clusterUrl
required

Cluster URL.

string

credentials
required

Cloud credentials.

replicationEngineType
required

Replication engine type.

enum (CM, DLMENGINE)

CustomConfigs

Custom key/value configurations.

Name Description Schema

confidential
required

Whether the value is confidential.

boolean

name
required

Name.

string

value
required

Value.

string

DeleteCredentialRequest

Request object for deleting a credential.

Name Description Schema

name
required

Name of the cloud credential to delete.

string

DeleteCredentialResponse

Response object for delete credential operation.

Name Description Schema

errors
optional

The list of response errors in case of a partial failure while deleting the credential.

< ApiError > array

DeletePolicyRequest

Delete a replication policy.

Name Description Schema

clusterCrn
required

CRN of the cluster where the policy is.

string

policyName
required

Policy name to delete.

string

DeletePolicyResponse

Response object for deletePolicy.

Type : object

DownloadDiagnosticBundleRequest

Request to download the diagnostic bundle for the given cluster and command id.

Name Description Schema

clusterCrn
required

The CRN of the target cluster.

string

commandId
required

The command ID from the response of collect-diagnostic-bundle command.

string

DownloadDiagnosticBundleResponse

Response object for download-diagnostic-bundle. On certain clusters this response will show if the download is only available directly from CM.

Name Description Schema

bundleFile
optional

Base64 encoded content of the diagnostic bundle zip file. A script like this can be used to save the response as file 'cat response.json | jq -r '.bundleFile' | base64 -D > bundle.zip'
Pattern : "^(?:[A-Za-z0-9+/]{4})*(?:[A-Za-z0-9+/]{2}==|[A-Za-z0-9+/]{3}=)?$"

string (byte)

Error

An object returned on an error.

Name Description Schema

code
optional

The error code.

string

message
optional

The error message.

string

ErrorHandling

Error handling behavior.

Name Description Schema

abortOnError
required

Abort policy on error.

boolean

abortOnSnapshotDiffFailures
required

Abort policy if there are snapshot diff failures.

boolean

skipChecksumChecks
required

Skip checksum checks.

boolean

skipListingChecksumChecks
required

Skip checksum checks for copy-listing.

boolean

GetCommandStatusRequest

Get the current status of any CM command.

Name Description Schema

clusterCrn
required

The CRN of the target cluster.

string

commandId
required

ID of a CM command on the cluster.

string

GetCommandStatusResponse

Response object for get command status.

Name Description Schema

active
optional

Whether the command is still active.

boolean

bundleStatus
optional

The current status of the command.

enum (IN_PROGRESS, DOWNLOADABLE_WITH_URL, DOWNLOADABLE_WITH_CLI, FAILED)

bundleStatusMessage
optional

Further information about the current command status.

string

commandId
required

Id of the CM command.

integer (int64)

endTime
optional

End time of the CM command.

string

name
optional

Name of the policy.

string

resultDataUrl
optional

Some commands have result data URL for downloading the diagnostic bundle. On certain CM versions the bundle download is only available through this URL, but not with download-diagnostic-bundle operation.

string

resultMessage
optional

Result message of the command.

string

startTime
optional

Start time of the CM command.

string

success
optional

Whether the diagnostic collection is successful.

boolean

GetCredentialsRequest

Request object to retrieve specific cloud credentials.

Name Description Schema

clusterCrn
required

CRN of the cluster where the credential is.

string

credentialId
optional

Id of the credential. If both name and Id are specified, the Id is considered.

string

credentialName
optional

Name of the credential. If both name and Id are specified, the Id is considered.

string

GetCredentialsResponse

Response for credential request.

Name Description Schema

credentials
optional

List of credentials.

< CredentialDetails > array

HdfsArguments

Extra properties for HDFS.

Name Description Schema

alert
optional

Alerting behavior.

deletePolicy
optional

Deletion behavior.

enum (KEEP_DELETED_FILES, DELETE_TO_TRASH, DELETE_PERMANENTLY)

errorHandling
optional

Error handling strategy.

exclusionFilters
optional

Exclusion filters in glob format.

< string > array

logPath
optional

Job log path.

string

mapReduceService
optional

Name of the mapreduce service.

string

path
optional

HDFS path. Mandatory for HDFS policies, otherwise optional.

string

preserve
optional

Properties to preserve.

replicationStrategy
optional

Replication strategy.

enum (DYNAMIC, STATIC)

HiveArguments

Hive replication arguments.

Name Description Schema

databasesAndTables
optional

Scope of the replication.

numThreads
optional

Number of threads to use during replication.

integer (int64)

sentryPermissions
optional

Include or exclude Sentry permissions.

enum (INCLUDE, EXCLUDE)

skipUrlPermissions
optional

Skip URL permissions.

boolean

HiveDatabaseAndTables

Hive replication scope.

Name Description Schema

database
required

Database to replicate.

string

tablesExcludeRegex
optional

Regex to match excluded tables.

string

tablesIncludeRegex
optional

Regex to match included tables.

string

ListAllCredentialsRequest

Request object for listing all cloud credentials on all clusters.

Type : object

ListAllCredentialsResponse

Response object for list credentials request.

Name Description Schema

credentials
required

List of credentials by cluster.

unreachableClusters
required

List of errors for unreachable clusters.

< ApiError > array

ListClusterServiceStatusesRequest

Request object to list cluster statuses.

Type : object

ListClusterServiceStatusesResponse

Response object for listing of cluster statuses.

Name Description Schema

statuses
optional

List of statuses by cluster.

ListClustersRequest

Request to list clusters.

Type : object

ListClustersResponse

Response object for list clusters request.

Name Description Schema

clusters
required

List of clusters.

< Cluster > array

unreachableClusters
required

List of errors for unreachable clusters.

< ApiError > array

ListPoliciesRequest

Request object for listing all policies.

Type : object

ListPoliciesResponse

Response object for a list policies request.

Name Description Schema

policies
required

List of policies.

< Policy > array

policyErrors
required

List of policy errors.

< ApiError > array

unreachableClusters
required

List of errors for unreachable clusters.

< ApiError > array

Location

Location object.

Name Description Schema

city
required

City.

string

country
required

Country.

string

id
required

Location ID.

integer (int64)

latitude
required

Latitude.

number (double)

longitude
required

Longitude.

number (double)

Policy

Replication policy definition.

Name Description Schema

creationTime
optional

Policy creation time.

string (date-time)

customProperties
optional

Custom replication properties.

< string, string > map

description
optional

Policy description.

string

endTime
required

End time of policy run or when it repeats.

string (date-time)

executionType
optional

Policy execution type.

string

frequency
required

Frequency in seconds when the policy runs.

integer (int64)

jobs
required

List of policy runs.

name
required

Policy name.

string

nextRun
optional

Next expected run of the policy.

string

plugins
optional

Plugins.

< string > array

policyId
required

Policy id.

string

report
required

Policy report.

sourceCluster
optional

Source cluster of replication.

string

sourceClusterCrn
optional

CRN of the source cluster.

string

sourceDataset
optional

Source dataset of replication.

< string > array

startTime
optional

Policy start time.

string (date-time)

status
required

Current status of the policy.

string

target
optional

Replication target details.

targetCluster
optional

Target cluster of replication if not cloud.

string

targetClusterCrn
optional

CRN of the target cluster.

string

targetDataset
optional

Target dataset of replication.

< string > array

type
required

Policy type.

string

PolicyDefinition

Policy creation request definition.

Name Description Schema

cloudCredential
optional

Cloud credentials to use if replicating to Cloud.

string

cloudEncryptionAlgorithm
optional

The type of cloud encryption algorithm. Can be used only for HDP/Ambari managed clusters. Supported values are AES256,SSE-KMS.

string

cloudEncryptionKey
optional

Cloud encryption key.

string

cmPolicySubmitUser
optional

CM policy submit user.

description
optional

Description of the policy.

string

distcpMapBandwidth
optional

Maximum bandwidth to use for replication.

integer (int64)

distcpMaxMaps
optional

Maximum Map jobs to use for replication.

integer (int64)

enableSnapshotBasedReplication
optional

Enable snapshot based replication.

boolean

endTime
optional

End time.

string (date-time)

frequencyInSec
required

Policy’s frequency in seconds.

integer (int64)

hiveExternalTableBaseDirectory
optional

Hive external table base directory.

string

name
required

Name of the new policy.

string

plugins
optional

Plugins.

< string > array

queueName
optional

YARN queue name if not default.

string

sourceCluster
optional

Name of source cluster in the format: "dataCenterName$cluster name", for example "DC-Europe$My Source 42.

string

sourceDataset
required

Source dataset to replicate.

startTime
optional

Start time.

string (date-time)

targetCluster
optional

Name of destination cluster in the format: "dataCenterName$cluster name", for example "DC-US$My Destination 17".

string

targetDataset
optional

Dataset to replicate to.

string

tdeSameKey
optional

TDE same key.

boolean

type
required

Policy replication type.

enum (FS, HIVE, HBASE)

PolicyInstanceResponse

Policy execution details.

Name Description Schema

completedSteps
optional

Number of completed steps.

integer (int32)

endTime
optional

Command end time.

string (date-time)

id
required

Policy instance command id.

string

jobType
optional

Job type.

string

message
optional

Output of the policy command.

string

policyId
required

Policy id.

string

startTime
required

Command start time.

string (date-time)

status
required

Policy command status.

string

totalSteps
optional

Total number of steps.

integer (int32)

trackingInfo
optional

JSON data to track polciy status.

string

PolicyReport

Policy report.

Name Description Schema

lastFailedInstance
optional

Last failed instance.

lastSucceededInstance
optional

Last successful instance.

PolicyReportDetails

Policy report details.

Name Description Schema

endTime
required

End time.

string (date-time)

status
required

Status of the command.

string

Preserve

Properties to preserve after replication.

Name Description Schema

blockSize
required

Block size.

boolean

extendedAttributes
required

Extended attributes.

boolean

permissions
required

Permissions.

boolean

replicationCount
required

Replication count.

boolean

ServiceInfo

Service status definition.

Name Description Schema

serviceName
required

Service name.

string

status
required

Service status.

string

SourceDataset

Extra properties for the source dataset.

Name Description Schema

hdfsArguments
optional

HDFS arguments for HDFS and Hive replication.

hiveArguments
optional

Arguments for Hive replication, null if HDFS replication.

SuspendPolicyRequest

Suspend a replication policy.

Name Description Schema

clusterCrn
required

CRN of the cluster where the policy is.

string

policyName
required

Policy name to suspend.

string

SuspendPolicyResponse

Response object for suspendPolicy.

Type : object

TargetDetails

Target details.

Name Description Schema

environmentCrn
required

Target’s environment CRN.

string

warehouseCrn
optional

Target’s warehouse CRN.

string


Copyright © 2024 Cloudera, Inc. All rights reserved.