-
ZackYoung authored
* 优化 cdc SQLSinkBuilder KafkaSinkBuilder, filter to process * change "_" to "." * change "db" to config.getSchemaFieldName() * change "tableMap key" to table.getSchemaTableName()
| Name |
Last commit
|
Last update |
|---|---|---|
| .. | ||
| doris | ||
| kafka | ||
| mysql | ||
| oracle | ||
| sql | ||
| AbstractCDCBuilder.java | ||
| AbstractSinkBuilder.java | ||
| CDCBuilder.java | ||
| CDCBuilderFactory.java | ||
| SinkBuilder.java | ||
| SinkBuilderFactory.java |