public class ReplicationsResourceApi extends Object
Constructor and Description |
---|
ReplicationsResourceApi() |
ReplicationsResourceApi(ApiClient apiClient) |
Modifier and Type | Method and Description |
---|---|
ApiCommand |
addHBaseReplicationPeer(String clusterName,
String serviceName,
ApiHBaseAddReplicationPeerInput body)
Starts a command that adds a new replication peer to HBase.
|
com.squareup.okhttp.Call |
addHBaseReplicationPeerAsync(String clusterName,
String serviceName,
ApiHBaseAddReplicationPeerInput body,
ApiCallback<ApiCommand> callback)
Starts a command that adds a new replication peer to HBase.
|
com.squareup.okhttp.Call |
addHBaseReplicationPeerCall(String clusterName,
String serviceName,
ApiHBaseAddReplicationPeerInput body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for addHBaseReplicationPeer
|
ApiResponse<ApiCommand> |
addHBaseReplicationPeerWithHttpInfo(String clusterName,
String serviceName,
ApiHBaseAddReplicationPeerInput body)
Starts a command that adds a new replication peer to HBase.
|
ApiCommand |
addTablesToHBasePeer(String clusterName,
String serviceName,
ApiHBasePeerIdWithTableCFs body)
Starts a command that adds tables and column families to an existing HBase replication peer.
|
com.squareup.okhttp.Call |
addTablesToHBasePeerAsync(String clusterName,
String serviceName,
ApiHBasePeerIdWithTableCFs body,
ApiCallback<ApiCommand> callback)
Starts a command that adds tables and column families to an existing HBase replication peer.
|
com.squareup.okhttp.Call |
addTablesToHBasePeerCall(String clusterName,
String serviceName,
ApiHBasePeerIdWithTableCFs body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for addTablesToHBasePeer
|
ApiResponse<ApiCommand> |
addTablesToHBasePeerWithHttpInfo(String clusterName,
String serviceName,
ApiHBasePeerIdWithTableCFs body)
Starts a command that adds tables and column families to an existing HBase replication peer.
|
ApiCommand |
checkHBaseTablesExist(String clusterName,
String serviceName,
ApiHBaseTableNames body)
Starts a command that checks if the specified tables exist in HBase.
|
com.squareup.okhttp.Call |
checkHBaseTablesExistAsync(String clusterName,
String serviceName,
ApiHBaseTableNames body,
ApiCallback<ApiCommand> callback)
Starts a command that checks if the specified tables exist in HBase.
|
com.squareup.okhttp.Call |
checkHBaseTablesExistCall(String clusterName,
String serviceName,
ApiHBaseTableNames body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for checkHBaseTablesExist
|
ApiResponse<ApiCommand> |
checkHBaseTablesExistWithHttpInfo(String clusterName,
String serviceName,
ApiHBaseTableNames body)
Starts a command that checks if the specified tables exist in HBase.
|
ApiCommand |
collectDiagnosticData(String clusterName,
BigDecimal scheduleId,
String serviceName,
String view,
ApiReplicationDiagnosticsCollectionArgs body)
Collect diagnostic data for a schedule, optionally for a subset of commands on that schedule, matched by schedule ID.
|
com.squareup.okhttp.Call |
collectDiagnosticDataAsync(String clusterName,
BigDecimal scheduleId,
String serviceName,
String view,
ApiReplicationDiagnosticsCollectionArgs body,
ApiCallback<ApiCommand> callback)
Collect diagnostic data for a schedule, optionally for a subset of commands on that schedule, matched by schedule ID.
|
com.squareup.okhttp.Call |
collectDiagnosticDataCall(String clusterName,
BigDecimal scheduleId,
String serviceName,
String view,
ApiReplicationDiagnosticsCollectionArgs body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for collectDiagnosticData
|
ApiResponse<ApiCommand> |
collectDiagnosticDataWithHttpInfo(String clusterName,
BigDecimal scheduleId,
String serviceName,
String view,
ApiReplicationDiagnosticsCollectionArgs body)
Collect diagnostic data for a schedule, optionally for a subset of commands on that schedule, matched by schedule ID.
|
ApiCommand |
createCloudCredstoreOnHdfs(String clusterName,
String serviceName,
Boolean force,
String sourceAccount)
Creates a credstore provider jceks file on HDFS for the given service.
|
com.squareup.okhttp.Call |
createCloudCredstoreOnHdfsAsync(String clusterName,
String serviceName,
Boolean force,
String sourceAccount,
ApiCallback<ApiCommand> callback)
Creates a credstore provider jceks file on HDFS for the given service.
|
com.squareup.okhttp.Call |
createCloudCredstoreOnHdfsCall(String clusterName,
String serviceName,
Boolean force,
String sourceAccount,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createCloudCredstoreOnHdfs
|
ApiResponse<ApiCommand> |
createCloudCredstoreOnHdfsWithHttpInfo(String clusterName,
String serviceName,
Boolean force,
String sourceAccount)
Creates a credstore provider jceks file on HDFS for the given service.
|
ApiCommand |
createCredstore(String clusterName,
String serviceName,
String credstoreDirPath,
Boolean force,
String sourceAccount)
Use the following API endpoint instead:.
|
com.squareup.okhttp.Call |
createCredstoreAsync(String clusterName,
String serviceName,
String credstoreDirPath,
Boolean force,
String sourceAccount,
ApiCallback<ApiCommand> callback)
Use the following API endpoint instead:.
|
com.squareup.okhttp.Call |
createCredstoreCall(String clusterName,
String serviceName,
String credstoreDirPath,
Boolean force,
String sourceAccount,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createCredstore
|
ApiResponse<ApiCommand> |
createCredstoreWithHttpInfo(String clusterName,
String serviceName,
String credstoreDirPath,
Boolean force,
String sourceAccount)
Use the following API endpoint instead:.
|
ApiCommand |
createHBaseTable(String clusterName,
String serviceName,
ApiHBaseCreateTable body)
Starts a command that creates a new table in HBase.
|
com.squareup.okhttp.Call |
createHBaseTableAsync(String clusterName,
String serviceName,
ApiHBaseCreateTable body,
ApiCallback<ApiCommand> callback)
Starts a command that creates a new table in HBase.
|
com.squareup.okhttp.Call |
createHBaseTableCall(String clusterName,
String serviceName,
ApiHBaseCreateTable body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createHBaseTable
|
ApiResponse<ApiCommand> |
createHBaseTableWithHttpInfo(String clusterName,
String serviceName,
ApiHBaseCreateTable body)
Starts a command that creates a new table in HBase.
|
ApiReplicationScheduleList |
createSchedules(String clusterName,
String serviceName,
ApiReplicationScheduleList body)
Creates one or more replication schedules.
|
com.squareup.okhttp.Call |
createSchedulesAsync(String clusterName,
String serviceName,
ApiReplicationScheduleList body,
ApiCallback<ApiReplicationScheduleList> callback)
Creates one or more replication schedules.
|
com.squareup.okhttp.Call |
createSchedulesCall(String clusterName,
String serviceName,
ApiReplicationScheduleList body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createSchedules
|
ApiResponse<ApiReplicationScheduleList> |
createSchedulesWithHttpInfo(String clusterName,
String serviceName,
ApiReplicationScheduleList body)
Creates one or more replication schedules.
|
ApiReplicationScheduleList |
deleteAllSchedules(String clusterName,
String serviceName)
Deletes all existing replication schedules.
|
com.squareup.okhttp.Call |
deleteAllSchedulesAsync(String clusterName,
String serviceName,
ApiCallback<ApiReplicationScheduleList> callback)
Deletes all existing replication schedules.
|
com.squareup.okhttp.Call |
deleteAllSchedulesCall(String clusterName,
String serviceName,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteAllSchedules
|
ApiResponse<ApiReplicationScheduleList> |
deleteAllSchedulesWithHttpInfo(String clusterName,
String serviceName)
Deletes all existing replication schedules.
|
ApiReplicationSchedule |
deleteSchedule(String clusterName,
BigDecimal scheduleId,
String serviceName)
Deletes an existing replication schedule.
|
com.squareup.okhttp.Call |
deleteScheduleAsync(String clusterName,
BigDecimal scheduleId,
String serviceName,
ApiCallback<ApiReplicationSchedule> callback)
Deletes an existing replication schedule.
|
com.squareup.okhttp.Call |
deleteScheduleCall(String clusterName,
BigDecimal scheduleId,
String serviceName,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteSchedule
|
ApiResponse<ApiReplicationSchedule> |
deleteScheduleWithHttpInfo(String clusterName,
BigDecimal scheduleId,
String serviceName)
Deletes an existing replication schedule.
|
ApiCommand |
exportRangerServices(String clusterName,
String serviceName,
ApiRangerReplicationExportArgs body)
Exports the given Ranger services and policies (defined in the API body) to a zipped file.
|
com.squareup.okhttp.Call |
exportRangerServicesAsync(String clusterName,
String serviceName,
ApiRangerReplicationExportArgs body,
ApiCallback<ApiCommand> callback)
Exports the given Ranger services and policies (defined in the API body) to a zipped file.
|
com.squareup.okhttp.Call |
exportRangerServicesCall(String clusterName,
String serviceName,
ApiRangerReplicationExportArgs body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for exportRangerServices
|
ApiResponse<ApiCommand> |
exportRangerServicesWithHttpInfo(String clusterName,
String serviceName,
ApiRangerReplicationExportArgs body)
Exports the given Ranger services and policies (defined in the API body) to a zipped file.
|
ApiCommand |
fetchHBaseColumnFamilies(String clusterName,
String serviceName,
ApiHBaseTableNames body)
Starts a command that fetches column families for the desired tables.
|
com.squareup.okhttp.Call |
fetchHBaseColumnFamiliesAsync(String clusterName,
String serviceName,
ApiHBaseTableNames body,
ApiCallback<ApiCommand> callback)
Starts a command that fetches column families for the desired tables.
|
com.squareup.okhttp.Call |
fetchHBaseColumnFamiliesCall(String clusterName,
String serviceName,
ApiHBaseTableNames body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for fetchHBaseColumnFamilies
|
ApiResponse<ApiCommand> |
fetchHBaseColumnFamiliesWithHttpInfo(String clusterName,
String serviceName,
ApiHBaseTableNames body)
Starts a command that fetches column families for the desired tables.
|
ApiCommand |
fetchHBasePeerInfo(String clusterName,
String serviceName,
ApiHBasePeerId body)
Starts a command that fetches information about an HBase peer by its ID.
|
com.squareup.okhttp.Call |
fetchHBasePeerInfoAsync(String clusterName,
String serviceName,
ApiHBasePeerId body,
ApiCallback<ApiCommand> callback)
Starts a command that fetches information about an HBase peer by its ID.
|
com.squareup.okhttp.Call |
fetchHBasePeerInfoCall(String clusterName,
String serviceName,
ApiHBasePeerId body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for fetchHBasePeerInfo
|
ApiResponse<ApiCommand> |
fetchHBasePeerInfoWithHttpInfo(String clusterName,
String serviceName,
ApiHBasePeerId body)
Starts a command that fetches information about an HBase peer by its ID.
|
ApiReplicationSchedule |
forceDeleteSchedule(String clusterName,
BigDecimal scheduleId,
String serviceName)
Deletes an existing replication schedule only from the DB.
|
com.squareup.okhttp.Call |
forceDeleteScheduleAsync(String clusterName,
BigDecimal scheduleId,
String serviceName,
ApiCallback<ApiReplicationSchedule> callback)
Deletes an existing replication schedule only from the DB.
|
com.squareup.okhttp.Call |
forceDeleteScheduleCall(String clusterName,
BigDecimal scheduleId,
String serviceName,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for forceDeleteSchedule
|
ApiResponse<ApiReplicationSchedule> |
forceDeleteScheduleWithHttpInfo(String clusterName,
BigDecimal scheduleId,
String serviceName)
Deletes an existing replication schedule only from the DB.
|
Boolean |
generateCloudReplCredstorePassword(String clusterName,
String serviceName,
String passwordGenerateMode)
(Re)generates the cloud credential provider password, used by the given service, for replicating to the cloud.
|
com.squareup.okhttp.Call |
generateCloudReplCredstorePasswordAsync(String clusterName,
String serviceName,
String passwordGenerateMode,
ApiCallback<Boolean> callback)
(Re)generates the cloud credential provider password, used by the given service, for replicating to the cloud.
|
com.squareup.okhttp.Call |
generateCloudReplCredstorePasswordCall(String clusterName,
String serviceName,
String passwordGenerateMode,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for generateCloudReplCredstorePassword
|
ApiResponse<Boolean> |
generateCloudReplCredstorePasswordWithHttpInfo(String clusterName,
String serviceName,
String passwordGenerateMode)
(Re)generates the cloud credential provider password, used by the given service, for replicating to the cloud.
|
ApiClient |
getApiClient() |
ApiReplicationState |
getReplicationState(String clusterName,
String serviceName,
String view)
returns the replication state.
|
com.squareup.okhttp.Call |
getReplicationStateAsync(String clusterName,
String serviceName,
String view,
ApiCallback<ApiReplicationState> callback)
returns the replication state.
|
com.squareup.okhttp.Call |
getReplicationStateCall(String clusterName,
String serviceName,
String view,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getReplicationState
|
ApiResponse<ApiReplicationState> |
getReplicationStateWithHttpInfo(String clusterName,
String serviceName,
String view)
returns the replication state.
|
Boolean |
isHive3ReverseDirectionEnabled(String clusterName,
String serviceName,
String clusterUuidOnRemote,
String serviceNameOnRemote,
String sourceDbNameOnRemote,
String targetDbNameOnRemote)
This API endpoint checks if there is an ENABLED Hive3 replication policy on this server that replicates for the reverse direction.
|
com.squareup.okhttp.Call |
isHive3ReverseDirectionEnabledAsync(String clusterName,
String serviceName,
String clusterUuidOnRemote,
String serviceNameOnRemote,
String sourceDbNameOnRemote,
String targetDbNameOnRemote,
ApiCallback<Boolean> callback)
This API endpoint checks if there is an ENABLED Hive3 replication policy on this server that replicates for the reverse direction.
|
com.squareup.okhttp.Call |
isHive3ReverseDirectionEnabledCall(String clusterName,
String serviceName,
String clusterUuidOnRemote,
String serviceNameOnRemote,
String sourceDbNameOnRemote,
String targetDbNameOnRemote,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for isHive3ReverseDirectionEnabled
|
ApiResponse<Boolean> |
isHive3ReverseDirectionEnabledWithHttpInfo(String clusterName,
String serviceName,
String clusterUuidOnRemote,
String serviceNameOnRemote,
String sourceDbNameOnRemote,
String targetDbNameOnRemote)
This API endpoint checks if there is an ENABLED Hive3 replication policy on this server that replicates for the reverse direction.
|
ApiCommand |
listHBaseNamespaces(String clusterName,
String serviceName)
Starts a command that lists all namespaces in HBase.
|
com.squareup.okhttp.Call |
listHBaseNamespacesAsync(String clusterName,
String serviceName,
ApiCallback<ApiCommand> callback)
Starts a command that lists all namespaces in HBase.
|
com.squareup.okhttp.Call |
listHBaseNamespacesCall(String clusterName,
String serviceName,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listHBaseNamespaces
|
ApiResponse<ApiCommand> |
listHBaseNamespacesWithHttpInfo(String clusterName,
String serviceName)
Starts a command that lists all namespaces in HBase.
|
ApiCommand |
listHBasePeers(String clusterName,
String serviceName)
Starts a command that retrieves all peers registered in the HBase service.
|
com.squareup.okhttp.Call |
listHBasePeersAsync(String clusterName,
String serviceName,
ApiCallback<ApiCommand> callback)
Starts a command that retrieves all peers registered in the HBase service.
|
com.squareup.okhttp.Call |
listHBasePeersCall(String clusterName,
String serviceName,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listHBasePeers
|
ApiResponse<ApiCommand> |
listHBasePeersWithHttpInfo(String clusterName,
String serviceName)
Starts a command that retrieves all peers registered in the HBase service.
|
ApiCommand |
listHBaseTables(String clusterName,
String serviceName)
Starts a command that lists tables from the HBase service.
|
com.squareup.okhttp.Call |
listHBaseTablesAsync(String clusterName,
String serviceName,
ApiCallback<ApiCommand> callback)
Starts a command that lists tables from the HBase service.
|
com.squareup.okhttp.Call |
listHBaseTablesCall(String clusterName,
String serviceName,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listHBaseTables
|
ApiResponse<ApiCommand> |
listHBaseTablesWithHttpInfo(String clusterName,
String serviceName)
Starts a command that lists tables from the HBase service.
|
ApiReplicationCommandList |
readHistory(String clusterName,
BigDecimal scheduleId,
String serviceName,
BigDecimal limit,
BigDecimal offset,
String view)
Returns a list of commands triggered by a schedule.
|
com.squareup.okhttp.Call |
readHistoryAsync(String clusterName,
BigDecimal scheduleId,
String serviceName,
BigDecimal limit,
BigDecimal offset,
String view,
ApiCallback<ApiReplicationCommandList> callback)
Returns a list of commands triggered by a schedule.
|
com.squareup.okhttp.Call |
readHistoryCall(String clusterName,
BigDecimal scheduleId,
String serviceName,
BigDecimal limit,
BigDecimal offset,
String view,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for readHistory
|
ApiResponse<ApiReplicationCommandList> |
readHistoryWithHttpInfo(String clusterName,
BigDecimal scheduleId,
String serviceName,
BigDecimal limit,
BigDecimal offset,
String view)
Returns a list of commands triggered by a schedule.
|
ApiReplicationSchedule |
readSchedule(String clusterName,
BigDecimal scheduleId,
String serviceName,
String view)
Returns information for a specific replication schedule.
|
com.squareup.okhttp.Call |
readScheduleAsync(String clusterName,
BigDecimal scheduleId,
String serviceName,
String view,
ApiCallback<ApiReplicationSchedule> callback)
Returns information for a specific replication schedule.
|
com.squareup.okhttp.Call |
readScheduleCall(String clusterName,
BigDecimal scheduleId,
String serviceName,
String view,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for readSchedule
|
ApiReplicationScheduleList |
readSchedules(String clusterName,
String serviceName,
BigDecimal maxCommands,
BigDecimal maxErrors,
BigDecimal maxSchedules,
BigDecimal maxTables,
String view)
Retrieves information about replication schedules.
|
com.squareup.okhttp.Call |
readSchedulesAsync(String clusterName,
String serviceName,
BigDecimal maxCommands,
BigDecimal maxErrors,
BigDecimal maxSchedules,
BigDecimal maxTables,
String view,
ApiCallback<ApiReplicationScheduleList> callback)
Retrieves information about replication schedules.
|
com.squareup.okhttp.Call |
readSchedulesCall(String clusterName,
String serviceName,
BigDecimal maxCommands,
BigDecimal maxErrors,
BigDecimal maxSchedules,
BigDecimal maxTables,
String view,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for readSchedules
|
ApiResponse<ApiReplicationScheduleList> |
readSchedulesWithHttpInfo(String clusterName,
String serviceName,
BigDecimal maxCommands,
BigDecimal maxErrors,
BigDecimal maxSchedules,
BigDecimal maxTables,
String view)
Retrieves information about replication schedules.
|
ApiResponse<ApiReplicationSchedule> |
readScheduleWithHttpInfo(String clusterName,
BigDecimal scheduleId,
String serviceName,
String view)
Returns information for a specific replication schedule.
|
ApiCommand |
recreateCloudCredstoresOnHdfs(String clusterName,
String serviceName)
Recreates the existing credential provider jceks files on HDFS, that are used by the given service, for replicating to the cloud.
|
com.squareup.okhttp.Call |
recreateCloudCredstoresOnHdfsAsync(String clusterName,
String serviceName,
ApiCallback<ApiCommand> callback)
Recreates the existing credential provider jceks files on HDFS, that are used by the given service, for replicating to the cloud.
|
com.squareup.okhttp.Call |
recreateCloudCredstoresOnHdfsCall(String clusterName,
String serviceName,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for recreateCloudCredstoresOnHdfs
|
ApiResponse<ApiCommand> |
recreateCloudCredstoresOnHdfsWithHttpInfo(String clusterName,
String serviceName)
Recreates the existing credential provider jceks files on HDFS, that are used by the given service, for replicating to the cloud.
|
ApiCommand |
removeHBasePeer(String clusterName,
String serviceName,
ApiHBasePeerId body)
Starts a command that removes the specified HBase replication peer from the local HBase service.
|
com.squareup.okhttp.Call |
removeHBasePeerAsync(String clusterName,
String serviceName,
ApiHBasePeerId body,
ApiCallback<ApiCommand> callback)
Starts a command that removes the specified HBase replication peer from the local HBase service.
|
com.squareup.okhttp.Call |
removeHBasePeerCall(String clusterName,
String serviceName,
ApiHBasePeerId body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for removeHBasePeer
|
ApiResponse<ApiCommand> |
removeHBasePeerWithHttpInfo(String clusterName,
String serviceName,
ApiHBasePeerId body)
Starts a command that removes the specified HBase replication peer from the local HBase service.
|
ApiCommand |
removeTablesFromHBasePeer(String clusterName,
String serviceName,
ApiHBasePeerIdWithTableCFs body)
Starts a command that removes tables and column families from an existing HBase replication peer.
|
com.squareup.okhttp.Call |
removeTablesFromHBasePeerAsync(String clusterName,
String serviceName,
ApiHBasePeerIdWithTableCFs body,
ApiCallback<ApiCommand> callback)
Starts a command that removes tables and column families from an existing HBase replication peer.
|
com.squareup.okhttp.Call |
removeTablesFromHBasePeerCall(String clusterName,
String serviceName,
ApiHBasePeerIdWithTableCFs body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for removeTablesFromHBasePeer
|
ApiResponse<ApiCommand> |
removeTablesFromHBasePeerWithHttpInfo(String clusterName,
String serviceName,
ApiHBasePeerIdWithTableCFs body)
Starts a command that removes tables and column families from an existing HBase replication peer.
|
Boolean |
rescheduleHive3ReplicationMetricsGetter(String clusterName,
String serviceName,
BigDecimal nextStartMins)
Set the Hive3 Replication Metrics Getter next start time.
|
com.squareup.okhttp.Call |
rescheduleHive3ReplicationMetricsGetterAsync(String clusterName,
String serviceName,
BigDecimal nextStartMins,
ApiCallback<Boolean> callback)
Set the Hive3 Replication Metrics Getter next start time.
|
com.squareup.okhttp.Call |
rescheduleHive3ReplicationMetricsGetterCall(String clusterName,
String serviceName,
BigDecimal nextStartMins,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for rescheduleHive3ReplicationMetricsGetter
|
ApiResponse<Boolean> |
rescheduleHive3ReplicationMetricsGetterWithHttpInfo(String clusterName,
String serviceName,
BigDecimal nextStartMins)
Set the Hive3 Replication Metrics Getter next start time.
|
ApiCommand |
runCopyListing(String clusterName,
String serviceName,
String body)
Run the hdfs copy listing command.
|
com.squareup.okhttp.Call |
runCopyListingAsync(String clusterName,
String serviceName,
String body,
ApiCallback<ApiCommand> callback)
Run the hdfs copy listing command.
|
com.squareup.okhttp.Call |
runCopyListingCall(String clusterName,
String serviceName,
String body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for runCopyListing
|
ApiResponse<ApiCommand> |
runCopyListingWithHttpInfo(String clusterName,
String serviceName,
String body)
Run the hdfs copy listing command.
|
ApiCommand |
runHBaseReplicationRetryFailedSnapshots(String clusterName,
BigDecimal scheduleId,
String serviceName)
Executes a command to run a HBase replication retry on failed snapshots for the given schedule ID.
|
com.squareup.okhttp.Call |
runHBaseReplicationRetryFailedSnapshotsAsync(String clusterName,
BigDecimal scheduleId,
String serviceName,
ApiCallback<ApiCommand> callback)
Executes a command to run a HBase replication retry on failed snapshots for the given schedule ID.
|
com.squareup.okhttp.Call |
runHBaseReplicationRetryFailedSnapshotsCall(String clusterName,
BigDecimal scheduleId,
String serviceName,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for runHBaseReplicationRetryFailedSnapshots
|
ApiResponse<ApiCommand> |
runHBaseReplicationRetryFailedSnapshotsWithHttpInfo(String clusterName,
BigDecimal scheduleId,
String serviceName)
Executes a command to run a HBase replication retry on failed snapshots for the given schedule ID.
|
ApiCommand |
runHBaseReplicationSecurityTool(String clusterName,
String serviceName,
Object body)
Run the hbase replication security tool.
|
com.squareup.okhttp.Call |
runHBaseReplicationSecurityToolAsync(String clusterName,
String serviceName,
Object body,
ApiCallback<ApiCommand> callback)
Run the hbase replication security tool.
|
com.squareup.okhttp.Call |
runHBaseReplicationSecurityToolCall(String clusterName,
String serviceName,
Object body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for runHBaseReplicationSecurityTool
|
ApiResponse<ApiCommand> |
runHBaseReplicationSecurityToolWithHttpInfo(String clusterName,
String serviceName,
Object body)
Run the hbase replication security tool.
|
ApiCommand |
runHBaseReplicationValidationTool(String clusterName,
String serviceName,
String hbasePeerId)
Executes a command, which validates if HBase replication works properly for the given hbasePeerId.
|
com.squareup.okhttp.Call |
runHBaseReplicationValidationToolAsync(String clusterName,
String serviceName,
String hbasePeerId,
ApiCallback<ApiCommand> callback)
Executes a command, which validates if HBase replication works properly for the given hbasePeerId.
|
com.squareup.okhttp.Call |
runHBaseReplicationValidationToolCall(String clusterName,
String serviceName,
String hbasePeerId,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for runHBaseReplicationValidationTool
|
ApiResponse<ApiCommand> |
runHBaseReplicationValidationToolWithHttpInfo(String clusterName,
String serviceName,
String hbasePeerId)
Executes a command, which validates if HBase replication works properly for the given hbasePeerId.
|
ApiCommand |
runHiveReplicationQuery(String clusterName,
String serviceName,
ApiHive3ReplicationArguments body)
Execute a hive replication query on local HS2 service instance.
|
com.squareup.okhttp.Call |
runHiveReplicationQueryAsync(String clusterName,
String serviceName,
ApiHive3ReplicationArguments body,
ApiCallback<ApiCommand> callback)
Execute a hive replication query on local HS2 service instance.
|
com.squareup.okhttp.Call |
runHiveReplicationQueryCall(String clusterName,
String serviceName,
ApiHive3ReplicationArguments body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for runHiveReplicationQuery
|
ApiResponse<ApiCommand> |
runHiveReplicationQueryWithHttpInfo(String clusterName,
String serviceName,
ApiHive3ReplicationArguments body)
Execute a hive replication query on local HS2 service instance.
|
ApiCommand |
runSchedule(String clusterName,
BigDecimal scheduleId,
String serviceName,
Boolean dryRun)
Run the schedule immediately.
|
com.squareup.okhttp.Call |
runScheduleAsync(String clusterName,
BigDecimal scheduleId,
String serviceName,
Boolean dryRun,
ApiCallback<ApiCommand> callback)
Run the schedule immediately.
|
com.squareup.okhttp.Call |
runScheduleCall(String clusterName,
BigDecimal scheduleId,
String serviceName,
Boolean dryRun,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for runSchedule
|
ApiResponse<ApiCommand> |
runScheduleWithHttpInfo(String clusterName,
BigDecimal scheduleId,
String serviceName,
Boolean dryRun)
Run the schedule immediately.
|
void |
setApiClient(ApiClient apiClient) |
ApiCommand |
setCFsReplicationScope(String clusterName,
String serviceName,
ApiHBaseSetCFsReplicationScope body)
Starts a command that set the replication scope of the provided column families to the desired value.
|
com.squareup.okhttp.Call |
setCFsReplicationScopeAsync(String clusterName,
String serviceName,
ApiHBaseSetCFsReplicationScope body,
ApiCallback<ApiCommand> callback)
Starts a command that set the replication scope of the provided column families to the desired value.
|
com.squareup.okhttp.Call |
setCFsReplicationScopeCall(String clusterName,
String serviceName,
ApiHBaseSetCFsReplicationScope body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for setCFsReplicationScope
|
ApiResponse<ApiCommand> |
setCFsReplicationScopeWithHttpInfo(String clusterName,
String serviceName,
ApiHBaseSetCFsReplicationScope body)
Starts a command that set the replication scope of the provided column families to the desired value.
|
ApiCommand |
updateHBasePeerState(String clusterName,
String serviceName,
ApiHBaseReplicationUpdatePeerStateArgs body)
Update HBase peer state ('DISABLE' or 'ENABLE'),.
|
com.squareup.okhttp.Call |
updateHBasePeerStateAsync(String clusterName,
String serviceName,
ApiHBaseReplicationUpdatePeerStateArgs body,
ApiCallback<ApiCommand> callback)
Update HBase peer state ('DISABLE' or 'ENABLE'),.
|
com.squareup.okhttp.Call |
updateHBasePeerStateCall(String clusterName,
String serviceName,
ApiHBaseReplicationUpdatePeerStateArgs body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateHBasePeerState
|
ApiResponse<ApiCommand> |
updateHBasePeerStateWithHttpInfo(String clusterName,
String serviceName,
ApiHBaseReplicationUpdatePeerStateArgs body)
Update HBase peer state ('DISABLE' or 'ENABLE'),.
|
ApiCommand |
updateHBaseReplicationPeerState(String clusterName,
String serviceName,
ApiHBaseUpdateReplicationPeerState body)
Starts a command that updates the state of an existing HBase replication peer.
|
com.squareup.okhttp.Call |
updateHBaseReplicationPeerStateAsync(String clusterName,
String serviceName,
ApiHBaseUpdateReplicationPeerState body,
ApiCallback<ApiCommand> callback)
Starts a command that updates the state of an existing HBase replication peer.
|
com.squareup.okhttp.Call |
updateHBaseReplicationPeerStateCall(String clusterName,
String serviceName,
ApiHBaseUpdateReplicationPeerState body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateHBaseReplicationPeerState
|
ApiResponse<ApiCommand> |
updateHBaseReplicationPeerStateWithHttpInfo(String clusterName,
String serviceName,
ApiHBaseUpdateReplicationPeerState body)
Starts a command that updates the state of an existing HBase replication peer.
|
ApiReplicationSchedule |
updateSchedule(String clusterName,
BigDecimal scheduleId,
String serviceName,
ApiReplicationSchedule body)
Updates an existing replication schedule.
|
com.squareup.okhttp.Call |
updateScheduleAsync(String clusterName,
BigDecimal scheduleId,
String serviceName,
ApiReplicationSchedule body,
ApiCallback<ApiReplicationSchedule> callback)
Updates an existing replication schedule.
|
com.squareup.okhttp.Call |
updateScheduleCall(String clusterName,
BigDecimal scheduleId,
String serviceName,
ApiReplicationSchedule body,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateSchedule
|
ApiResponse<ApiReplicationSchedule> |
updateScheduleWithHttpInfo(String clusterName,
BigDecimal scheduleId,
String serviceName,
ApiReplicationSchedule body)
Updates an existing replication schedule.
|
public ReplicationsResourceApi()
public ReplicationsResourceApi(ApiClient apiClient)
public ApiClient getApiClient()
public void setApiClient(ApiClient apiClient)
public com.squareup.okhttp.Call addHBaseReplicationPeerCall(String clusterName, String serviceName, ApiHBaseAddReplicationPeerInput body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Information for peer creation. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand addHBaseReplicationPeer(String clusterName, String serviceName, ApiHBaseAddReplicationPeerInput body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Information for peer creation. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> addHBaseReplicationPeerWithHttpInfo(String clusterName, String serviceName, ApiHBaseAddReplicationPeerInput body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Information for peer creation. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call addHBaseReplicationPeerAsync(String clusterName, String serviceName, ApiHBaseAddReplicationPeerInput body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Information for peer creation. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call addTablesToHBasePeerCall(String clusterName, String serviceName, ApiHBasePeerIdWithTableCFs body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for the operation. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand addTablesToHBasePeer(String clusterName, String serviceName, ApiHBasePeerIdWithTableCFs body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for the operation. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> addTablesToHBasePeerWithHttpInfo(String clusterName, String serviceName, ApiHBasePeerIdWithTableCFs body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for the operation. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call addTablesToHBasePeerAsync(String clusterName, String serviceName, ApiHBasePeerIdWithTableCFs body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for the operation. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call checkHBaseTablesExistCall(String clusterName, String serviceName, ApiHBaseTableNames body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Names of the tables to be checked. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand checkHBaseTablesExist(String clusterName, String serviceName, ApiHBaseTableNames body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Names of the tables to be checked. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> checkHBaseTablesExistWithHttpInfo(String clusterName, String serviceName, ApiHBaseTableNames body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Names of the tables to be checked. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call checkHBaseTablesExistAsync(String clusterName, String serviceName, ApiHBaseTableNames body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Names of the tables to be checked. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call collectDiagnosticDataCall(String clusterName, BigDecimal scheduleId, String serviceName, String view, ApiReplicationDiagnosticsCollectionArgs body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)scheduleId
- Schedule ID (required)serviceName
- The service name. (required)view
- view to materialize (optional, default to summary)body
- Replication collection arguments (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand collectDiagnosticData(String clusterName, BigDecimal scheduleId, String serviceName, String view, ApiReplicationDiagnosticsCollectionArgs body) throws ApiException
clusterName
- (required)scheduleId
- Schedule ID (required)serviceName
- The service name. (required)view
- view to materialize (optional, default to summary)body
- Replication collection arguments (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> collectDiagnosticDataWithHttpInfo(String clusterName, BigDecimal scheduleId, String serviceName, String view, ApiReplicationDiagnosticsCollectionArgs body) throws ApiException
clusterName
- (required)scheduleId
- Schedule ID (required)serviceName
- The service name. (required)view
- view to materialize (optional, default to summary)body
- Replication collection arguments (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call collectDiagnosticDataAsync(String clusterName, BigDecimal scheduleId, String serviceName, String view, ApiReplicationDiagnosticsCollectionArgs body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)scheduleId
- Schedule ID (required)serviceName
- The service name. (required)view
- view to materialize (optional, default to summary)body
- Replication collection arguments (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call createCloudCredstoreOnHdfsCall(String clusterName, String serviceName, Boolean force, String sourceAccount, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)force
- if the jceks file already exists on HDFS and this parameter is set to true then it will be recreated, otherwise left untouched (optional)sourceAccount
- the External Account that has been already added to this CM, for which the credstore provider jceks file will be generated (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand createCloudCredstoreOnHdfs(String clusterName, String serviceName, Boolean force, String sourceAccount) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)force
- if the jceks file already exists on HDFS and this parameter is set to true then it will be recreated, otherwise left untouched (optional)sourceAccount
- the External Account that has been already added to this CM, for which the credstore provider jceks file will be generated (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> createCloudCredstoreOnHdfsWithHttpInfo(String clusterName, String serviceName, Boolean force, String sourceAccount) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)force
- if the jceks file already exists on HDFS and this parameter is set to true then it will be recreated, otherwise left untouched (optional)sourceAccount
- the External Account that has been already added to this CM, for which the credstore provider jceks file will be generated (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call createCloudCredstoreOnHdfsAsync(String clusterName, String serviceName, Boolean force, String sourceAccount, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)force
- if the jceks file already exists on HDFS and this parameter is set to true then it will be recreated, otherwise left untouched (optional)sourceAccount
- the External Account that has been already added to this CM, for which the credstore provider jceks file will be generated (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call createCredstoreCall(String clusterName, String serviceName, String credstoreDirPath, Boolean force, String sourceAccount, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)credstoreDirPath
- (optional)force
- (optional)sourceAccount
- (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand createCredstore(String clusterName, String serviceName, String credstoreDirPath, Boolean force, String sourceAccount) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)credstoreDirPath
- (optional)force
- (optional)sourceAccount
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> createCredstoreWithHttpInfo(String clusterName, String serviceName, String credstoreDirPath, Boolean force, String sourceAccount) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)credstoreDirPath
- (optional)force
- (optional)sourceAccount
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call createCredstoreAsync(String clusterName, String serviceName, String credstoreDirPath, Boolean force, String sourceAccount, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)credstoreDirPath
- (optional)force
- (optional)sourceAccount
- (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call createHBaseTableCall(String clusterName, String serviceName, ApiHBaseCreateTable body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for table creation. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand createHBaseTable(String clusterName, String serviceName, ApiHBaseCreateTable body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for table creation. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> createHBaseTableWithHttpInfo(String clusterName, String serviceName, ApiHBaseCreateTable body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for table creation. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call createHBaseTableAsync(String clusterName, String serviceName, ApiHBaseCreateTable body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for table creation. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call createSchedulesCall(String clusterName, String serviceName, ApiReplicationScheduleList body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- List of the replication schedules to create. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiReplicationScheduleList createSchedules(String clusterName, String serviceName, ApiReplicationScheduleList body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- List of the replication schedules to create. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiReplicationScheduleList> createSchedulesWithHttpInfo(String clusterName, String serviceName, ApiReplicationScheduleList body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- List of the replication schedules to create. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call createSchedulesAsync(String clusterName, String serviceName, ApiReplicationScheduleList body, ApiCallback<ApiReplicationScheduleList> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- List of the replication schedules to create. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call deleteAllSchedulesCall(String clusterName, String serviceName, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiReplicationScheduleList deleteAllSchedules(String clusterName, String serviceName) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiReplicationScheduleList> deleteAllSchedulesWithHttpInfo(String clusterName, String serviceName) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call deleteAllSchedulesAsync(String clusterName, String serviceName, ApiCallback<ApiReplicationScheduleList> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call deleteScheduleCall(String clusterName, BigDecimal scheduleId, String serviceName, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiReplicationSchedule deleteSchedule(String clusterName, BigDecimal scheduleId, String serviceName) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiReplicationSchedule> deleteScheduleWithHttpInfo(String clusterName, BigDecimal scheduleId, String serviceName) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call deleteScheduleAsync(String clusterName, BigDecimal scheduleId, String serviceName, ApiCallback<ApiReplicationSchedule> callback) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call exportRangerServicesCall(String clusterName, String serviceName, ApiRangerReplicationExportArgs body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- the arguments for the export operation. Contains the Ranger services to be exported. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand exportRangerServices(String clusterName, String serviceName, ApiRangerReplicationExportArgs body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- the arguments for the export operation. Contains the Ranger services to be exported. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> exportRangerServicesWithHttpInfo(String clusterName, String serviceName, ApiRangerReplicationExportArgs body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- the arguments for the export operation. Contains the Ranger services to be exported. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call exportRangerServicesAsync(String clusterName, String serviceName, ApiRangerReplicationExportArgs body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- the arguments for the export operation. Contains the Ranger services to be exported. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call fetchHBaseColumnFamiliesCall(String clusterName, String serviceName, ApiHBaseTableNames body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Names of tables to query for column families. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand fetchHBaseColumnFamilies(String clusterName, String serviceName, ApiHBaseTableNames body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Names of tables to query for column families. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> fetchHBaseColumnFamiliesWithHttpInfo(String clusterName, String serviceName, ApiHBaseTableNames body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Names of tables to query for column families. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call fetchHBaseColumnFamiliesAsync(String clusterName, String serviceName, ApiHBaseTableNames body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Names of tables to query for column families. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call fetchHBasePeerInfoCall(String clusterName, String serviceName, ApiHBasePeerId body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- ID of the fetched peer. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand fetchHBasePeerInfo(String clusterName, String serviceName, ApiHBasePeerId body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- ID of the fetched peer. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> fetchHBasePeerInfoWithHttpInfo(String clusterName, String serviceName, ApiHBasePeerId body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- ID of the fetched peer. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call fetchHBasePeerInfoAsync(String clusterName, String serviceName, ApiHBasePeerId body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- ID of the fetched peer. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call forceDeleteScheduleCall(String clusterName, BigDecimal scheduleId, String serviceName, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiReplicationSchedule forceDeleteSchedule(String clusterName, BigDecimal scheduleId, String serviceName) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiReplicationSchedule> forceDeleteScheduleWithHttpInfo(String clusterName, BigDecimal scheduleId, String serviceName) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call forceDeleteScheduleAsync(String clusterName, BigDecimal scheduleId, String serviceName, ApiCallback<ApiReplicationSchedule> callback) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call generateCloudReplCredstorePasswordCall(String clusterName, String serviceName, String passwordGenerateMode, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)passwordGenerateMode
- the CloudReplPasswordGenerateMode to be used for regenerating the password. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic Boolean generateCloudReplCredstorePassword(String clusterName, String serviceName, String passwordGenerateMode) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)passwordGenerateMode
- the CloudReplPasswordGenerateMode to be used for regenerating the password. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<Boolean> generateCloudReplCredstorePasswordWithHttpInfo(String clusterName, String serviceName, String passwordGenerateMode) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)passwordGenerateMode
- the CloudReplPasswordGenerateMode to be used for regenerating the password. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call generateCloudReplCredstorePasswordAsync(String clusterName, String serviceName, String passwordGenerateMode, ApiCallback<Boolean> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)passwordGenerateMode
- the CloudReplPasswordGenerateMode to be used for regenerating the password. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call getReplicationStateCall(String clusterName, String serviceName, String view, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)view
- view to materialize (optional, default to summary)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiReplicationState getReplicationState(String clusterName, String serviceName, String view) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)view
- view to materialize (optional, default to summary)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiReplicationState> getReplicationStateWithHttpInfo(String clusterName, String serviceName, String view) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)view
- view to materialize (optional, default to summary)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call getReplicationStateAsync(String clusterName, String serviceName, String view, ApiCallback<ApiReplicationState> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)view
- view to materialize (optional, default to summary)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call isHive3ReverseDirectionEnabledCall(String clusterName, String serviceName, String clusterUuidOnRemote, String serviceNameOnRemote, String sourceDbNameOnRemote, String targetDbNameOnRemote, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)clusterUuidOnRemote
- the uuid of the cluster on the remote CM server (optional)serviceNameOnRemote
- the Hive3 service name on the remote CM server, more specifically on the cluster specified by clusterUuidOnRemote (optional)sourceDbNameOnRemote
- the name of the source database on the remote CM server (optional)targetDbNameOnRemote
- the name of the target database on the remote CM server (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic Boolean isHive3ReverseDirectionEnabled(String clusterName, String serviceName, String clusterUuidOnRemote, String serviceNameOnRemote, String sourceDbNameOnRemote, String targetDbNameOnRemote) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)clusterUuidOnRemote
- the uuid of the cluster on the remote CM server (optional)serviceNameOnRemote
- the Hive3 service name on the remote CM server, more specifically on the cluster specified by clusterUuidOnRemote (optional)sourceDbNameOnRemote
- the name of the source database on the remote CM server (optional)targetDbNameOnRemote
- the name of the target database on the remote CM server (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<Boolean> isHive3ReverseDirectionEnabledWithHttpInfo(String clusterName, String serviceName, String clusterUuidOnRemote, String serviceNameOnRemote, String sourceDbNameOnRemote, String targetDbNameOnRemote) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)clusterUuidOnRemote
- the uuid of the cluster on the remote CM server (optional)serviceNameOnRemote
- the Hive3 service name on the remote CM server, more specifically on the cluster specified by clusterUuidOnRemote (optional)sourceDbNameOnRemote
- the name of the source database on the remote CM server (optional)targetDbNameOnRemote
- the name of the target database on the remote CM server (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call isHive3ReverseDirectionEnabledAsync(String clusterName, String serviceName, String clusterUuidOnRemote, String serviceNameOnRemote, String sourceDbNameOnRemote, String targetDbNameOnRemote, ApiCallback<Boolean> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)clusterUuidOnRemote
- the uuid of the cluster on the remote CM server (optional)serviceNameOnRemote
- the Hive3 service name on the remote CM server, more specifically on the cluster specified by clusterUuidOnRemote (optional)sourceDbNameOnRemote
- the name of the source database on the remote CM server (optional)targetDbNameOnRemote
- the name of the target database on the remote CM server (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call listHBaseNamespacesCall(String clusterName, String serviceName, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand listHBaseNamespaces(String clusterName, String serviceName) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> listHBaseNamespacesWithHttpInfo(String clusterName, String serviceName) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call listHBaseNamespacesAsync(String clusterName, String serviceName, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call listHBasePeersCall(String clusterName, String serviceName, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand listHBasePeers(String clusterName, String serviceName) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> listHBasePeersWithHttpInfo(String clusterName, String serviceName) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call listHBasePeersAsync(String clusterName, String serviceName, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call listHBaseTablesCall(String clusterName, String serviceName, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand listHBaseTables(String clusterName, String serviceName) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> listHBaseTablesWithHttpInfo(String clusterName, String serviceName) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call listHBaseTablesAsync(String clusterName, String serviceName, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call readHistoryCall(String clusterName, BigDecimal scheduleId, String serviceName, BigDecimal limit, BigDecimal offset, String view, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)limit
- Maximum number of commands to retrieve. (optional, default to 20)offset
- Index of first command to retrieve. (optional, default to 0)view
- The view to materialize. (optional, default to summary)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiReplicationCommandList readHistory(String clusterName, BigDecimal scheduleId, String serviceName, BigDecimal limit, BigDecimal offset, String view) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)limit
- Maximum number of commands to retrieve. (optional, default to 20)offset
- Index of first command to retrieve. (optional, default to 0)view
- The view to materialize. (optional, default to summary)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiReplicationCommandList> readHistoryWithHttpInfo(String clusterName, BigDecimal scheduleId, String serviceName, BigDecimal limit, BigDecimal offset, String view) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)limit
- Maximum number of commands to retrieve. (optional, default to 20)offset
- Index of first command to retrieve. (optional, default to 0)view
- The view to materialize. (optional, default to summary)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call readHistoryAsync(String clusterName, BigDecimal scheduleId, String serviceName, BigDecimal limit, BigDecimal offset, String view, ApiCallback<ApiReplicationCommandList> callback) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)limit
- Maximum number of commands to retrieve. (optional, default to 20)offset
- Index of first command to retrieve. (optional, default to 0)view
- The view to materialize. (optional, default to summary)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call readScheduleCall(String clusterName, BigDecimal scheduleId, String serviceName, String view, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)view
- The view to materialize. (optional, default to summary)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiReplicationSchedule readSchedule(String clusterName, BigDecimal scheduleId, String serviceName, String view) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)view
- The view to materialize. (optional, default to summary)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiReplicationSchedule> readScheduleWithHttpInfo(String clusterName, BigDecimal scheduleId, String serviceName, String view) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)view
- The view to materialize. (optional, default to summary)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call readScheduleAsync(String clusterName, BigDecimal scheduleId, String serviceName, String view, ApiCallback<ApiReplicationSchedule> callback) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)view
- The view to materialize. (optional, default to summary)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call readSchedulesCall(String clusterName, String serviceName, BigDecimal maxCommands, BigDecimal maxErrors, BigDecimal maxSchedules, BigDecimal maxTables, String view, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)maxCommands
- Maximum number of commands to include in the history of replication schedules. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)maxErrors
- Maximum number of errors per Hive replication command. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)maxSchedules
- Maximum number of replication schedules to be included in the response. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)maxTables
- Maximum number of tables per Hive replication command. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)view
- The view to materialize. (optional, default to summary)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiReplicationScheduleList readSchedules(String clusterName, String serviceName, BigDecimal maxCommands, BigDecimal maxErrors, BigDecimal maxSchedules, BigDecimal maxTables, String view) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)maxCommands
- Maximum number of commands to include in the history of replication schedules. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)maxErrors
- Maximum number of errors per Hive replication command. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)maxSchedules
- Maximum number of replication schedules to be included in the response. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)maxTables
- Maximum number of tables per Hive replication command. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)view
- The view to materialize. (optional, default to summary)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiReplicationScheduleList> readSchedulesWithHttpInfo(String clusterName, String serviceName, BigDecimal maxCommands, BigDecimal maxErrors, BigDecimal maxSchedules, BigDecimal maxTables, String view) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)maxCommands
- Maximum number of commands to include in the history of replication schedules. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)maxErrors
- Maximum number of errors per Hive replication command. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)maxSchedules
- Maximum number of replication schedules to be included in the response. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)maxTables
- Maximum number of tables per Hive replication command. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)view
- The view to materialize. (optional, default to summary)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call readSchedulesAsync(String clusterName, String serviceName, BigDecimal maxCommands, BigDecimal maxErrors, BigDecimal maxSchedules, BigDecimal maxTables, String view, ApiCallback<ApiReplicationScheduleList> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)maxCommands
- Maximum number of commands to include in the history of replication schedules. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)maxErrors
- Maximum number of errors per Hive replication command. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)maxSchedules
- Maximum number of replication schedules to be included in the response. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)maxTables
- Maximum number of tables per Hive replication command. By default, it has no limit. Pass 0 to explicitly set to unlimited. (optional, default to 0)view
- The view to materialize. (optional, default to summary)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call recreateCloudCredstoresOnHdfsCall(String clusterName, String serviceName, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand recreateCloudCredstoresOnHdfs(String clusterName, String serviceName) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> recreateCloudCredstoresOnHdfsWithHttpInfo(String clusterName, String serviceName) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call recreateCloudCredstoresOnHdfsAsync(String clusterName, String serviceName, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call removeHBasePeerCall(String clusterName, String serviceName, ApiHBasePeerId body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- ID of the peer to be removed. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand removeHBasePeer(String clusterName, String serviceName, ApiHBasePeerId body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- ID of the peer to be removed. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> removeHBasePeerWithHttpInfo(String clusterName, String serviceName, ApiHBasePeerId body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- ID of the peer to be removed. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call removeHBasePeerAsync(String clusterName, String serviceName, ApiHBasePeerId body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- ID of the peer to be removed. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call removeTablesFromHBasePeerCall(String clusterName, String serviceName, ApiHBasePeerIdWithTableCFs body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for removing tables from HBase replication peer. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand removeTablesFromHBasePeer(String clusterName, String serviceName, ApiHBasePeerIdWithTableCFs body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for removing tables from HBase replication peer. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> removeTablesFromHBasePeerWithHttpInfo(String clusterName, String serviceName, ApiHBasePeerIdWithTableCFs body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for removing tables from HBase replication peer. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call removeTablesFromHBasePeerAsync(String clusterName, String serviceName, ApiHBasePeerIdWithTableCFs body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for removing tables from HBase replication peer. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call rescheduleHive3ReplicationMetricsGetterCall(String clusterName, String serviceName, BigDecimal nextStartMins, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)nextStartMins
- (optional, default to 5)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic Boolean rescheduleHive3ReplicationMetricsGetter(String clusterName, String serviceName, BigDecimal nextStartMins) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)nextStartMins
- (optional, default to 5)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<Boolean> rescheduleHive3ReplicationMetricsGetterWithHttpInfo(String clusterName, String serviceName, BigDecimal nextStartMins) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)nextStartMins
- (optional, default to 5)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call rescheduleHive3ReplicationMetricsGetterAsync(String clusterName, String serviceName, BigDecimal nextStartMins, ApiCallback<Boolean> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)nextStartMins
- (optional, default to 5)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call runCopyListingCall(String clusterName, String serviceName, String body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand runCopyListing(String clusterName, String serviceName, String body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> runCopyListingWithHttpInfo(String clusterName, String serviceName, String body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call runCopyListingAsync(String clusterName, String serviceName, String body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call runHBaseReplicationRetryFailedSnapshotsCall(String clusterName, BigDecimal scheduleId, String serviceName, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)scheduleId
- The HBase schedule ID to retry on (required)serviceName
- The service name. (required)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand runHBaseReplicationRetryFailedSnapshots(String clusterName, BigDecimal scheduleId, String serviceName) throws ApiException
clusterName
- (required)scheduleId
- The HBase schedule ID to retry on (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> runHBaseReplicationRetryFailedSnapshotsWithHttpInfo(String clusterName, BigDecimal scheduleId, String serviceName) throws ApiException
clusterName
- (required)scheduleId
- The HBase schedule ID to retry on (required)serviceName
- The service name. (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call runHBaseReplicationRetryFailedSnapshotsAsync(String clusterName, BigDecimal scheduleId, String serviceName, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)scheduleId
- The HBase schedule ID to retry on (required)serviceName
- The service name. (required)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call runHBaseReplicationSecurityToolCall(String clusterName, String serviceName, Object body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand runHBaseReplicationSecurityTool(String clusterName, String serviceName, Object body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> runHBaseReplicationSecurityToolWithHttpInfo(String clusterName, String serviceName, Object body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call runHBaseReplicationSecurityToolAsync(String clusterName, String serviceName, Object body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call runHBaseReplicationValidationToolCall(String clusterName, String serviceName, String hbasePeerId, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)hbasePeerId
- The HBase peer ID to be validated (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand runHBaseReplicationValidationTool(String clusterName, String serviceName, String hbasePeerId) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)hbasePeerId
- The HBase peer ID to be validated (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> runHBaseReplicationValidationToolWithHttpInfo(String clusterName, String serviceName, String hbasePeerId) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)hbasePeerId
- The HBase peer ID to be validated (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call runHBaseReplicationValidationToolAsync(String clusterName, String serviceName, String hbasePeerId, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)hbasePeerId
- The HBase peer ID to be validated (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call runHiveReplicationQueryCall(String clusterName, String serviceName, ApiHive3ReplicationArguments body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand runHiveReplicationQuery(String clusterName, String serviceName, ApiHive3ReplicationArguments body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> runHiveReplicationQueryWithHttpInfo(String clusterName, String serviceName, ApiHive3ReplicationArguments body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call runHiveReplicationQueryAsync(String clusterName, String serviceName, ApiHive3ReplicationArguments body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call runScheduleCall(String clusterName, BigDecimal scheduleId, String serviceName, Boolean dryRun, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)dryRun
- Whether to execute a dry run. (optional, default to false)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand runSchedule(String clusterName, BigDecimal scheduleId, String serviceName, Boolean dryRun) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)dryRun
- Whether to execute a dry run. (optional, default to false)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> runScheduleWithHttpInfo(String clusterName, BigDecimal scheduleId, String serviceName, Boolean dryRun) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)dryRun
- Whether to execute a dry run. (optional, default to false)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call runScheduleAsync(String clusterName, BigDecimal scheduleId, String serviceName, Boolean dryRun, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)dryRun
- Whether to execute a dry run. (optional, default to false)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call setCFsReplicationScopeCall(String clusterName, String serviceName, ApiHBaseSetCFsReplicationScope body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for setting the replication scope. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand setCFsReplicationScope(String clusterName, String serviceName, ApiHBaseSetCFsReplicationScope body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for setting the replication scope. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> setCFsReplicationScopeWithHttpInfo(String clusterName, String serviceName, ApiHBaseSetCFsReplicationScope body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for setting the replication scope. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call setCFsReplicationScopeAsync(String clusterName, String serviceName, ApiHBaseSetCFsReplicationScope body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for setting the replication scope. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call updateHBasePeerStateCall(String clusterName, String serviceName, ApiHBaseReplicationUpdatePeerStateArgs body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- ApiHBaseReplicationUpdatePeerStateArgs (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand updateHBasePeerState(String clusterName, String serviceName, ApiHBaseReplicationUpdatePeerStateArgs body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- ApiHBaseReplicationUpdatePeerStateArgs (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> updateHBasePeerStateWithHttpInfo(String clusterName, String serviceName, ApiHBaseReplicationUpdatePeerStateArgs body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- ApiHBaseReplicationUpdatePeerStateArgs (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call updateHBasePeerStateAsync(String clusterName, String serviceName, ApiHBaseReplicationUpdatePeerStateArgs body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- ApiHBaseReplicationUpdatePeerStateArgs (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call updateHBaseReplicationPeerStateCall(String clusterName, String serviceName, ApiHBaseUpdateReplicationPeerState body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for operation. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiCommand updateHBaseReplicationPeerState(String clusterName, String serviceName, ApiHBaseUpdateReplicationPeerState body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for operation. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiCommand> updateHBaseReplicationPeerStateWithHttpInfo(String clusterName, String serviceName, ApiHBaseUpdateReplicationPeerState body) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for operation. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call updateHBaseReplicationPeerStateAsync(String clusterName, String serviceName, ApiHBaseUpdateReplicationPeerState body, ApiCallback<ApiCommand> callback) throws ApiException
clusterName
- (required)serviceName
- The service name. (required)body
- Arguments for operation. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic com.squareup.okhttp.Call updateScheduleCall(String clusterName, BigDecimal scheduleId, String serviceName, ApiReplicationSchedule body, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)body
- (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ApiReplicationSchedule updateSchedule(String clusterName, BigDecimal scheduleId, String serviceName, ApiReplicationSchedule body) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)body
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ApiReplicationSchedule> updateScheduleWithHttpInfo(String clusterName, BigDecimal scheduleId, String serviceName, ApiReplicationSchedule body) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)body
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic com.squareup.okhttp.Call updateScheduleAsync(String clusterName, BigDecimal scheduleId, String serviceName, ApiReplicationSchedule body, ApiCallback<ApiReplicationSchedule> callback) throws ApiException
clusterName
- (required)scheduleId
- Id of an existing replication schedule. (required)serviceName
- The service name. (required)body
- (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectCopyright © 2022. All rights reserved.