HTTPResponse |
CR8Impl.deleteConnector(String pipelineName) |
HTTPResponse |
Connector.deleteConnector(String pipelineName) |
static HTTPResponse |
Consumer.deleteConsumer(String url) |
HTTPResponse |
CR8Impl.getConfiguration(String pipelineName) |
HTTPResponse |
Connector.getConfiguration(String pipelineName) |
HTTPResponse |
CR8Impl.getFullSyncStatus(String pipelineName) |
HTTPResponse |
Connector.getFullSyncStatus(String pipelineName) |
static HTTPResponse |
Consumer.getHasKafkaDelta(String url) |
static HTTPResponse |
Consumer.getStatus(String url) |
HTTPResponse |
CR8Impl.getStatusConnector(String pipelineName) |
HTTPResponse |
Connector.getStatusConnector(String pipelineName) |
HTTPResponse |
CR8Impl.getTableMetadata(String pipeline,
String db,
String schema,
String table) |
HTTPResponse |
Connector.getTableMetadata(String pipeline,
String db,
String schema,
String table) |
static HTTPResponse |
Consumer.getThreadStatus(String url) |
static HTTPResponse |
Consumer.getTotalOperation(String url) |
HTTPResponse |
CR8Impl.startConnector(String pipelineName) |
HTTPResponse |
Connector.startConnector(String pipelineName) |
static HTTPResponse |
Consumer.startConsumer(String url,
String offset,
Boolean cleanStart,
Integer parallelism) |
HTTPResponse |
CR8Impl.startFullSync(String pipelineName) |
HTTPResponse |
Connector.startFullSync(String pipelineName) |
static HTTPResponse |
Consumer.startPopulationOfDeletedTables(String url) |
HTTPResponse |
CR8Impl.stopConnector(String pipelineName) |
HTTPResponse |
Connector.stopConnector(String pipelineName) |
static HTTPResponse |
Consumer.stopConsumer(String url) |
HTTPResponse |
CR8Impl.stopFullSync(String pipelineName) |
HTTPResponse |
Connector.stopFullSync(String pipelineName) |
static HTTPResponse |
Consumer.stopPopulationOfDeletedTables(String url) |
HTTPResponse |
CR8Impl.validateConnection(String pipelineName,
String jsonConfiguration) |
HTTPResponse |
Connector.validateConnection(String pipelineName,
String jsonLocation) |