{"type":"doc","content":[{"type":"paragraph","content":[{"text":"Use the CDAP Replication Microservices to manage replication jobs.","type":"text"}]},{"type":"paragraph","content":[{"text":"All methods or endpoints described in this API have a base URL (typically ","type":"text"},{"text":"http://:11015","type":"text","marks":[{"type":"code"}]},{"text":" or ","type":"text"},{"text":"https://:10443","type":"text","marks":[{"type":"code"}]},{"text":") that precedes the resource identifier, as described in the ","type":"text"},{"text":"Microservices Conventions","type":"text","marks":[{"type":"link","attrs":{"href":"https://cdap.atlassian.net/wiki/spaces/DOCS/pages/477692124/API+Introduction#Microservices-Conventions"}}]},{"text":". These methods return a status code, as listed in the ","type":"text"},{"text":"Microservices Status Codes","type":"text","marks":[{"type":"link","attrs":{"href":"https://cdap.atlassian.net/wiki/spaces/DOCS/pages/477692124/API+Introduction#Status-Codes"}}]},{"text":".","type":"text"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Assess a Draft Replication Job","type":"text"}]},{"type":"paragraph","content":[{"text":"To assess a replication job in draft mode based on the source and target tables, submit an HTTP POST request:","type":"text"}]},{"type":"codeBlock","content":[{"text":"POST /v3/namespaces/system/apps/delta/services/assessor/methods/v1/contexts//drafts//assessPipeline","type":"text"}]},{"type":"table","attrs":{"layout":"default","localId":"29a2830e-a8bc-4251-9725-6926a54096b3"},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[206.0]},"content":[{"type":"paragraph","content":[{"text":"Parameter","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[552.0]},"content":[{"type":"paragraph","content":[{"text":"Description","type":"text","marks":[{"type":"strong"}]}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[206.0]},"content":[{"type":"paragraph","content":[{"text":"namespace","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[552.0]},"content":[{"type":"paragraph","content":[{"text":"The namespace for the draft replication jobs.","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[206.0]},"content":[{"type":"paragraph","content":[{"text":"draft-id","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[552.0]},"content":[{"type":"paragraph","content":[{"text":"The Draft ID of the replication job. The Draft ID can be any alphanumeric string. It must be unique in the namespace.","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Assess a Table in a Draft Replication Job","type":"text"}]},{"type":"paragraph","content":[{"text":"To assess a specific table in a replication job in draft mode, submit an HTTP POST request:","type":"text"}]},{"type":"codeBlock","content":[{"text":"POST /v3/namespaces/system/apps/delta/services/assessor/methods/v1/contexts//drafts//assessPipeline","type":"text"}]},{"type":"table","attrs":{"layout":"default","localId":"30582cae-eb96-4114-8717-32ddb11cc662"},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[206.0]},"content":[{"type":"paragraph","content":[{"text":"Parameter","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[552.0]},"content":[{"type":"paragraph","content":[{"text":"Description","type":"text","marks":[{"type":"strong"}]}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[206.0]},"content":[{"type":"paragraph","content":[{"text":"namespace","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[552.0]},"content":[{"type":"paragraph","content":[{"text":"The namespace for the draft replication jobs.","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[206.0]},"content":[{"type":"paragraph","content":[{"text":"draft-","type":"text","marks":[{"type":"code"}]},{"text":"id","type":"text","marks":[{"type":"annotation","attrs":{"annotationType":"inlineComment","id":"6eb9fcc1-e479-452f-b28b-a2cb115737e2"}},{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[552.0]},"content":[{"type":"paragraph","content":[{"text":"The Draft ID of the replication job. The Draft ID can be any alphanumeric string. It must be unique in the namespace.","type":"text"}]}]}]}]},{"type":"paragraph","content":[{"text":"The request body is a JSON object specifying the database and table name in the draft replication job. ","type":"text"}]},{"type":"paragraph","content":[{"text":"For example:","type":"text"}]},{"type":"codeBlock","content":[{"text":"{\n \"database\": \"db1\",\n \"table\": \"table1\"\n}","type":"text"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Create or Update a Draft Replication Job","type":"text"}]},{"type":"paragraph","content":[{"text":"To add a new replication job in draft mode or overwrite an existing one, submit an HTTP PUT request:","type":"text"}]},{"type":"codeBlock","content":[{"text":"PUT /v3/namespaces/system/apps/delta/services/assessor/methods/v1/contexts//drafts/","type":"text"}]},{"type":"table","attrs":{"layout":"default","localId":"01575b25-e327-4a28-b6b3-782280fa3afb"},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[206.0]},"content":[{"type":"paragraph","content":[{"text":"Parameter","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[552.0]},"content":[{"type":"paragraph","content":[{"text":"Description","type":"text","marks":[{"type":"strong"}]}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[206.0]},"content":[{"type":"paragraph","content":[{"text":"namespace","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[552.0]},"content":[{"type":"paragraph","content":[{"text":"The namespace for the draft replication jobs.","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[206.0]},"content":[{"type":"paragraph","content":[{"text":"draft-id","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[552.0]},"content":[{"type":"paragraph","content":[{"text":"The Draft ID of the replication job. The Draft ID can be any alphanumeric string. It must be unique in the namespace.","type":"text"}]}]}]}]},{"type":"paragraph","content":[{"text":"The request body is a JSON object specifying the draft replication job configuration. ","type":"text"}]},{"type":"paragraph","content":[{"text":"For example:","type":"text","marks":[{"type":"annotation","attrs":{"annotationType":"inlineComment","id":"4ca7a060-97e5-49c9-a4c0-9e9438ab6a71"}}]}]},{"type":"codeBlock","content":[{"text":"{\n \"name\": \"\",\n \"artifact\": {\n \"name\": \"delta-app\",\n \"version\": \"0.6.1\",\n \"scope\": \"SYSTEM\"\n },\n \"config\": {\n \"tables\": [\n {\n \"database\": \"testreplication\",\n \"table\": \"persons\",\n \"schema\": \"dbo\"\n }\n ],\n \"stages\": [\n {\n \"name\": \"Microsoft SQLServer\",\n \"plugin\": {\n \"name\": \"sqlserver\",\n \"type\": \"cdcSource\",\n \"properties\": {\n \"port\": \"1433\",\n \"serverTimezone\": \"UTC\",\n \"replicateExistingData\": \"true\",\n \"user\": \"<>\",\n \"password\": \"<>\",\n \"host\": \"1.2.3.4\",\n \"jdbcPluginName\": \"sqlserver42\",\n \"database\": \"testreplication\"\n },\n \"artifact\": {\n \"name\": \"sqlserver-delta-plugins\",\n \"version\": \"0.6.1\",\n \"scope\": \"SYSTEM\"\n }\n }\n },\n {\n \"name\": \"BigQuery\",\n \"plugin\": {\n \"name\": \"bigquery\",\n \"type\": \"cdcTarget\",\n \"properties\": {\n \"project\": \"auto-detect\",\n \"serviceAccountKey\": \"auto-detect\",\n \"stagingBucketLocation\": \"us\",\n \"loadInterval\": \"90\",\n \"stagingTablePrefix\": \"staging\",\n \"requireManualDrops\": \"false\",\n \"datasetName\": \"testreplication1\"\n },\n \"artifact\": {\n \"name\": \"bigquery-delta-plugins\",\n \"version\": \"0.6.1\",\n \"scope\": \"SYSTEM\"\n }\n }\n }\n ],\n \"tableTransformations\": [],\n \"parallelism\": {\n \"numInstances\": 1\n },\n \"description\": \"<>\"\n }\n}","type":"text"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Delete a Draft Replication Job","type":"text"}]},{"type":"paragraph","content":[{"text":"To delete an existing replication job in draft mode, submit an HTTP DELETE request:","type":"text"}]},{"type":"codeBlock","content":[{"text":"DELETE /v3/namespaces/system/apps/delta/services/assessor/methods/v1/contexts//drafts/","type":"text"}]},{"type":"table","attrs":{"layout":"default","localId":"f149e35e-713d-4dca-b3bf-a7839b1d59e5"},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[210.0]},"content":[{"type":"paragraph","content":[{"text":"Parameter","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[548.0]},"content":[{"type":"paragraph","content":[{"text":"Description","type":"text","marks":[{"type":"strong"}]}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[210.0]},"content":[{"type":"paragraph","content":[{"text":"namespace","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[548.0]},"content":[{"type":"paragraph","content":[{"text":"The namespace for the draft replication jobs.","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[210.0]},"content":[{"type":"paragraph","content":[{"text":"draft-id","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[548.0]},"content":[{"type":"paragraph","content":[{"text":"The Draft ID of the replication job. The Draft ID can be any alphanumeric string. It must be unique in the namespace.","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Details of a Source Table in a Replication Job Draft","type":"text"}]},{"type":"paragraph","content":[{"text":"To list the details of a source table in replication job draft, submit an HTTP POST request:","type":"text"}]},{"type":"codeBlock","content":[{"text":"POST /v3/namespaces/system/apps/delta/services/assessor/methods/v1/contexts//drafts//describeTable","type":"text"}]},{"type":"table","attrs":{"layout":"default","localId":"7a3b10e9-bd8b-45f0-bbba-a5566071736a"},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[210.0]},"content":[{"type":"paragraph","content":[{"text":"Parameter","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[548.0]},"content":[{"type":"paragraph","content":[{"text":"Description","type":"text","marks":[{"type":"strong"}]}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[210.0]},"content":[{"type":"paragraph","content":[{"text":"namespace","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[548.0]},"content":[{"type":"paragraph","content":[{"text":"The namespace for the draft replication jobs.","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[210.0]},"content":[{"type":"paragraph","content":[{"text":"draft-id","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[548.0]},"content":[{"type":"paragraph","content":[{"text":"The Draft ID of the replication job. The Draft ID can be any alphanumeric string. It must be unique in the namespace.","type":"text"}]}]}]}]},{"type":"paragraph","content":[{"text":"The request body is a JSON object specifying the database and table name in the draft replication job. ","type":"text"}]},{"type":"paragraph","content":[{"text":"For example:","type":"text"}]},{"type":"codeBlock","content":[{"text":"{\n \"database\": \"db1\",\n \"table\": \"table1\"\n}","type":"text"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Details of a Replication Job Draft","type":"text"}]},{"type":"paragraph","content":[{"text":"To list the details of a replication job draft, submit an HTTP GET request:","type":"text"}]},{"type":"codeBlock","content":[{"text":"GET /v3/namespaces/system/apps/delta/services/assessor/methods/v1/contexts//drafts/","type":"text"}]},{"type":"table","attrs":{"layout":"default","localId":"daea1bcd-c0c2-4c86-9bfa-46ef8b06869d"},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[206.0]},"content":[{"type":"paragraph","content":[{"text":"Parameter","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[552.0]},"content":[{"type":"paragraph","content":[{"text":"Description","type":"text","marks":[{"type":"strong"}]}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[206.0]},"content":[{"type":"paragraph","content":[{"text":"namespace","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[552.0]},"content":[{"type":"paragraph","content":[{"text":"The namespace for the draft replication jobs.","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[206.0]},"content":[{"type":"paragraph","content":[{"text":"draft-id","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[552.0]},"content":[{"type":"paragraph","content":[{"text":"The Draft ID of the replication job. The Draft ID can be any alphanumeric string. It must be unique in the namespace.","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Draft Replication Jobs","type":"text"}]},{"type":"paragraph","content":[{"text":"To list all replication jobs in Draft mode in a namespace, submit an HTTP GET request:","type":"text"}]},{"type":"codeBlock","content":[{"text":"GET /v3/namespaces/system/apps/delta/services/assessor/methods/v1/contexts//drafts","type":"text"}]},{"type":"table","attrs":{"layout":"default","localId":"1e6cac45-13e6-4f6a-9e1a-369a3319f1ee"},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[215.0]},"content":[{"type":"paragraph","content":[{"text":"Parameter","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[543.0]},"content":[{"type":"paragraph","content":[{"text":"Description","type":"text","marks":[{"type":"strong"}]}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[215.0]},"content":[{"type":"paragraph","content":[{"text":"namespace","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[543.0]},"content":[{"type":"paragraph","content":[{"text":"The namespace for the draft replication jobs.","type":"text"}]}]}]}]},{"type":"paragraph","content":[{"text":"The information will be returned in the body of the response. It list the draft objects, where a draft contains the full job configuration. ","type":"text"},{"text":"For example:","type":"text","marks":[{"type":"annotation","attrs":{"annotationType":"inlineComment","id":"05df7292-79fe-49e5-a80b-31fd2d00b368"}}]}]},{"type":"codeBlock","content":[{"text":"[\n {\n \"name\": \"Draft1\",\n \"created\": timestamp\n \"config\": {\n \"stages\": [\n {\n \"name\": \"source\",\n \"plugin\": {\n \"name\": \"oracle\",\n \"type\": \"cdcSource\",\n \"properties\": {\n \"host\": \"[hostname]\",\n \"port\": \"1433\",\n \"user\": \"repluser\",\n \"password\": \"${secure(kms-key)}\"\n }\n }\n },\n ...\n ]\n },\n }\n]","type":"text"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"G","type":"text","marks":[{"type":"annotation","attrs":{"annotationType":"inlineComment","id":"7438a824-ecab-41d4-9b56-015b2833dc66"}}]},{"text":"eneration Number for the Replication Job (CDAP 6.7+)","type":"text"}]},{"type":"paragraph","content":[{"text":"To get the generation number for a replication job, submit an HTTP GET request:","type":"text"}]},{"type":"codeBlock","content":[{"text":"GET /v3/namespaces/system/apps/delta/services/assessor/methods/v1/contexts/{namespace}/apps/{app_name}/maxgeneration","type":"text"}]},{"type":"table","attrs":{"layout":"default","localId":"9c9d9803-8f89-481c-bbb0-e1bca4214a1b"},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"background":"var(--ds-background-neutral, #F4F5F7)","rowspan":1,"colwidth":[226.0]},"content":[{"type":"paragraph","content":[{"text":"Parameter","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"tableHeader","attrs":{"colspan":1,"background":"var(--ds-background-neutral, #F4F5F7)","rowspan":1,"colwidth":[533.0]},"content":[{"type":"paragraph","content":[{"text":"Description","type":"text","marks":[{"type":"strong"}]}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[226.0]},"content":[{"type":"paragraph","content":[{"text":"namespace","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[533.0]},"content":[{"type":"paragraph","content":[{"text":"The namespace for your application. ","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[226.0]},"content":[{"type":"paragraph","content":[{"text":"app_name","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[533.0]},"content":[{"type":"paragraph","content":[{"text":"The name of the replication job.","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Offset Information for each Task Instance (CDAP 6.7+)","type":"text"}]},{"type":"paragraph","content":[{"text":"The offset is maintained at for every task instance. When you configure a replication job, there is an option to set the number of tasks and each task has its own offset information. ","type":"text"}]},{"type":"paragraph","content":[{"text":"To get the offset information for each task instance for a replication job, submit an HTTP GET request:","type":"text"}]},{"type":"codeBlock","content":[{"text":"GET /v3/namespaces/system/apps/delta/services/assessor/methods/v1/contexts/{namespace}/apps/{app_name}/generations/{generation_num}/instances/{instance_id}/offset","type":"text"}]},{"type":"table","attrs":{"layout":"default","localId":"1bef4332-524b-44a2-8985-0b9e8615b35e"},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"background":"var(--ds-background-neutral, #F4F5F7)","rowspan":1,"colwidth":[226.0]},"content":[{"type":"paragraph","content":[{"text":"Parameter","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"tableHeader","attrs":{"colspan":1,"background":"var(--ds-background-neutral, #F4F5F7)","rowspan":1,"colwidth":[533.0]},"content":[{"type":"paragraph","content":[{"text":"Description","type":"text","marks":[{"type":"strong"}]}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[226.0]},"content":[{"type":"paragraph","content":[{"text":"namespace","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[533.0]},"content":[{"type":"paragraph","content":[{"text":"The namespace for the deployed replication job. ","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[226.0]},"content":[{"type":"paragraph","content":[{"text":"app_name","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[533.0]},"content":[{"type":"paragraph","content":[{"text":"The name of the deployed replication job.","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[226.0]},"content":[{"type":"paragraph","content":[{"text":"generation_num","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[533.0]},"content":[{"type":"paragraph","content":[{"text":"The generation number for the deployed replication job. It’s generally a LONG type value. ","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[226.0]},"content":[{"type":"paragraph","content":[{"text":"instance_id","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[533.0]},"content":[{"type":"paragraph","content":[{"text":"The ID of the task. ","type":"text"},{"type":"hardBreak"},{"text":"The tasks are given monotonically, increasing value starting from 0. ","type":"text"},{"type":"hardBreak"},{"text":"Depending on the number of tasks, you might have to make multiple API call","type":"text"},{"text":"s.","type":"text","marks":[{"type":"annotation","attrs":{"annotationType":"inlineComment","id":"0d20dfe9-5039-4a3f-9d33-11dd9e589f67"}}]},{"text":" ","type":"text"}]}]}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Replication Tables Mapped to each Task / Instance_id (CDAP 6.7+)","type":"text"}]},{"type":"paragraph","content":[{"text":"Each Task/instance handles a particular set of tables. It is responsible to snapshot and replication process for those tables. ","type":"text"}]},{"type":"paragraph","content":[{"text":"To list the replication tables mapped to an ","type":"text"},{"text":"Instance_id","type":"text","marks":[{"type":"code"}]},{"text":" for a deployed replication job, submit an HTTP GET request: ","type":"text"}]},{"type":"codeBlock","content":[{"text":"GET v3/namespaces/system/apps/{app_name}/workers/DeltaWorker","type":"text"}]},{"type":"table","attrs":{"layout":"default","localId":"9349bc72-d2cd-4431-a925-6b45bff116f2"},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[215.0]},"content":[{"type":"paragraph","content":[{"text":"Parameter","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[543.0]},"content":[{"type":"paragraph","content":[{"text":"Description","type":"text","marks":[{"type":"strong"}]}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[215.0]},"content":[{"type":"paragraph","content":[{"text":"app_name","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[543.0]},"content":[{"type":"paragraph","content":[{"text":"The name of the deployed replication job.","type":"text"}]}]}]}]},{"type":"paragraph","content":[{"text":"In the Response body, look for ","type":"text"},{"text":"properties","type":"text","marks":[{"type":"code"}]},{"text":" . ","type":"text"},{"text":"table.assignments","type":"text","marks":[{"type":"code"}]},{"text":".","type":"text"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Source Tables for a Draft Replication Job ","type":"text"}]},{"type":"paragraph","content":[{"text":"To list the source tables in a replication job in draft mode, submit an HTTP POST request:","type":"text"}]},{"type":"codeBlock","content":[{"text":"POST /v3/namespaces/system/apps/delta/services/assessor/methods/v1/contexts//drafts//listTables","type":"text"}]},{"type":"table","attrs":{"layout":"default","localId":"34350e7f-f6db-4a16-9826-8fcc718f9a56"},"content":[{"type":"tableRow","content":[{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[210.0]},"content":[{"type":"paragraph","content":[{"text":"Parameter","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"tableHeader","attrs":{"colspan":1,"rowspan":1,"colwidth":[548.0]},"content":[{"type":"paragraph","content":[{"text":"Description","type":"text","marks":[{"type":"strong"}]}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[210.0]},"content":[{"type":"paragraph","content":[{"text":"namespace","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[548.0]},"content":[{"type":"paragraph","content":[{"text":"The namespace for the draft replication jobs.","type":"text"}]}]}]},{"type":"tableRow","content":[{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[210.0]},"content":[{"type":"paragraph","content":[{"text":"draft-id","type":"text","marks":[{"type":"code"}]}]}]},{"type":"tableCell","attrs":{"colspan":1,"rowspan":1,"colwidth":[548.0]},"content":[{"type":"paragraph","content":[{"text":"The Draft ID of the replication job. The Draft ID can be any alphanumeric string. It must be unique in the namespace.","type":"text"}]}]}]}]}],"version":1}

Browser not supported