JingsongLi commented on code in PR #2117:
URL: https://github.com/apache/incubator-paimon/pull/2117#discussion_r1354524362
##########
docs/content/how-to/cdc-ingestion.md:
##########
@@ -377,6 +377,40 @@ Example
--table-conf changelog-producer=input \
--table-conf sink.parallelism=4
```
+
+If the kafka topic doesn't contain message when you start the synchronization
job, you must manually create the table
+before submitting the job. You can define the partition keys and primary keys
only, and the left columns will be added
+by the synchronization job.
+
+NOTE: In this case you shouldn't use --partition-keys or --primary-keys,
because those keys are defined when creating
+the table and can not be modified. Additionally, if you specified computed
columns, you should also define all the argument
+columns used for computed columns.
+
+Example 2:
+If you want to synchronize a table which has primary key 'id INT', and you
want to compute a partition key '_year=year(age)',
+you can create a such table first (the other columns can be omitted):
+```sql
+CREATE TABLE test_db.test_table (
+ id INT, -- primary key
+ year DATE, -- the argument of computed column _year
Review Comment:
Year to year? Change an example for computed column?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
