File tree
88 files changed
+9787
-2611
lines changed- docs/en/connector-v2/source
- seatunnel-api/src
- main/java/org/apache/seatunnel/api/table
- catalog
- converter
- event
- handler
- test/java/org/apache/seatunnel/api/table/catalog
- seatunnel-connectors-v2
- connector-cdc
- connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/debezium/utils
- connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils
- connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils
- connector-cdc-postgres/src/main/java
- io/debezium/connector/postgresql
- org/apache/seatunnel/connectors/seatunnel/cdc/postgres
- source
- reader
- utils
- connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/utils
- connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source
- connector-doris/src
- main/java/org/apache/seatunnel/connectors/doris/util
- test/java/org/apache/seatunnel/connectors/doris/catalog
- connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/catalog
- connector-iceberg/src
- main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/catalog
- test/java/org/apache/seatunnel/connectors/seatunnel/iceberg/catalog
- connector-jdbc/src
- main/java/org/apache/seatunnel/connectors/seatunnel/jdbc
- catalog
- dm
- mysql
- oracle
- psql
- sqlserver
- tidb
- utils
- internal
- converter
- dialect
- dm
- mysql
- oracle
- psql
- sqlserver
- utils
- test/java/org/apache/seatunnel/connectors/seatunnel/jdbc
- catalog/sql
- internal/dialect
- dm
- mysql
- oracle
- psql
- sqlserver
- connector-starrocks/src
- main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink
- test/java/org/apache/seatunnel/connectors/seatunnel/starrocks/catalog
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
88 files changed
+9787
-2611
lines changedLines changed: 16 additions & 16 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
133 | 133 |
| |
134 | 134 |
| |
135 | 135 |
| |
136 |
| - | |
137 |
| - | |
138 |
| - | |
139 |
| - | |
140 |
| - | |
141 |
| - | |
142 |
| - | |
143 |
| - | |
144 |
| - | |
145 |
| - | |
146 |
| - | |
147 |
| - | |
148 |
| - | |
149 |
| - | |
150 |
| - | |
151 |
| - | |
| 136 | + | |
| 137 | + | |
| 138 | + | |
| 139 | + | |
| 140 | + | |
| 141 | + | |
| 142 | + | |
| 143 | + | |
| 144 | + | |
| 145 | + | |
| 146 | + | |
| 147 | + | |
| 148 | + | |
| 149 | + | |
| 150 | + | |
| 151 | + | |
152 | 152 |
| |
153 | 153 |
| |
154 | 154 |
| |
|
Lines changed: 18 additions & 17 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
51 | 51 |
| |
52 | 52 |
| |
53 | 53 |
| |
54 |
| - | |
55 |
| - | |
56 |
| - | |
57 |
| - | |
58 |
| - | |
59 |
| - | |
60 |
| - | |
61 |
| - | |
62 |
| - | |
63 |
| - | |
64 |
| - | |
65 |
| - | |
66 |
| - | |
67 |
| - | |
68 |
| - | |
69 |
| - | |
70 |
| - | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
71 | 72 |
| |
72 | 73 |
| |
73 | 74 |
| |
|
0 commit comments