flink-cdc-connectors：更改Apache Flink的数据捕获（CDC）连接器-源码

[{"title":"（ 67 个子文件 157KB ） flink-cdc-connectors：更改Apache Flink的数据捕获（CDC）连接器-源码","children":[{"title":"flink-cdc-connectors-master","children":[{"title":".gitignore <span style='color:#111;'> 235B </span>","children":null,"spread":false},{"title":"flink-connector-mysql-cdc","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"META-INF","children":[{"title":"services","children":[{"title":"org.apache.flink.table.factories.Factory <span style='color:#111;'> 855B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"alibaba","children":[{"title":"ververica","children":[{"title":"cdc","children":[{"title":"connectors","children":[{"title":"mysql","children":[{"title":"table","children":[{"title":"MySQLTableSourceFactory.java <span style='color:#111;'> 5.15KB </span>","children":null,"spread":false},{"title":"MySQLTableSource.java <span style='color:#111;'> 5.37KB </span>","children":null,"spread":false}],"spread":true},{"title":"MySQLSource.java <span style='color:#111;'> 5.98KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"test","children":[{"title":"resources","children":[{"title":"ddl","children":[{"title":"inventory.sql <span style='color:#111;'> 3.59KB </span>","children":null,"spread":false},{"title":"column_type_test.sql <span style='color:#111;'> 1.97KB </span>","children":null,"spread":false}],"spread":true},{"title":"log4j2-test.properties <span style='color:#111;'> 1.32KB </span>","children":null,"spread":false},{"title":"docker","children":[{"title":"setup.sql <span style='color:#111;'> 1.69KB </span>","children":null,"spread":false},{"title":"my.cnf <span style='color:#111;'> 2.33KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"alibaba","children":[{"title":"ververica","children":[{"title":"cdc","children":[{"title":"connectors","children":[{"title":"mysql","children":[{"title":"MySQLSourceTest.java <span style='color:#111;'> 24.51KB </span>","children":null,"spread":false},{"title":"table","children":[{"title":"MySQLTableSourceFactoryTest.java <span style='color:#111;'> 5.82KB </span>","children":null,"spread":false},{"title":"MySQLConnectorITCase.java <span style='color:#111;'> 10.74KB </span>","children":null,"spread":false}],"spread":false},{"title":"utils","children":[{"title":"UniqueDatabase.java <span style='color:#111;'> 4.50KB </span>","children":null,"spread":false},{"title":"MySQLContainer.java <span style='color:#111;'> 4.72KB </span>","children":null,"spread":false}],"spread":false},{"title":"MySQLTestBase.java <span style='color:#111;'> 2.23KB </span>","children":null,"spread":false},{"title":"MySQLSourceITCase.java <span style='color:#111;'> 2.14KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 6.06KB </span>","children":null,"spread":false}],"spread":true},{"title":"flink-sql-connector-mysql-cdc","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"META-INF","children":[{"title":"NOTICE <span style='color:#111;'> 237B </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"alibaba","children":[{"title":"ververica","children":[{"title":"cdc","children":[{"title":"connectors","children":[{"title":"mysql","children":[{"title":"DummyDocs.java <span style='color:#111;'> 985B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 3.78KB </span>","children":null,"spread":false}],"spread":true},{"title":"LICENSE <span style='color:#111;'> 11.09KB </span>","children":null,"spread":false},{"title":"flink-format-changelog-json","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"META-INF","children":[{"title":"services","children":[{"title":"org.apache.flink.table.factories.Factory <span style='color:#111;'> 848B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"alibaba","children":[{"title":"ververica","children":[{"title":"cdc","children":[{"title":"formats","children":[{"title":"json","children":[{"title":"ChangelogJsonSerializationSchema.java <span style='color:#111;'> 3.87KB </span>","children":null,"spread":false},{"title":"ChangelogJsonDeserializationSchema.java <span style='color:#111;'> 4.89KB </span>","children":null,"spread":false},{"title":"ChangelogJsonFormatFactory.java <span style='color:#111;'> 5.05KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"test","children":[{"title":"resources","children":[{"title":"changelog-json-data.txt <span style='color:#111;'> 2.19KB </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"alibaba","children":[{"title":"ververica","children":[{"title":"cdc","children":[{"title":"formats","children":[{"title":"json","children":[{"title":"ChangelogJsonSerDeTest.java <span style='color:#111;'> 8.73KB </span>","children":null,"spread":false},{"title":"ChangelogJsonFormatFactoryTest.java <span style='color:#111;'> 5.99KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.84KB </span>","children":null,"spread":false}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 21.31KB </span>","children":null,"spread":false},{"title":"tools","children":[{"title":"maven","children":[{"title":"checkstyle.xml <span style='color:#111;'> 21.73KB </span>","children":null,"spread":false},{"title":"suppressions.xml <span style='color:#111;'> 2.76KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"README.md <span style='color:#111;'> 4.35KB </span>","children":null,"spread":false},{"title":"NOTICE <span style='color:#111;'> 50B </span>","children":null,"spread":false},{"title":"flink-connector-postgres-cdc","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"META-INF","children":[{"title":"services","children":[{"title":"org.apache.flink.table.factories.Factory <span style='color:#111;'> 857B </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"alibaba","children":[{"title":"ververica","children":[{"title":"cdc","children":[{"title":"connectors","children":[{"title":"postgres","children":[{"title":"table","children":[{"title":"PostgresValueValidator.java <span style='color:#111;'> 2.07KB </span>","children":null,"spread":false},{"title":"PostgreSQLTableSource.java <span style='color:#111;'> 5.22KB </span>","children":null,"spread":false},{"title":"PostgreSQLTableFactory.java <span style='color:#111;'> 5.11KB </span>","children":null,"spread":false}],"spread":false},{"title":"PostgreSQLSource.java <span style='color:#111;'> 5.51KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true},{"title":"test","children":[{"title":"resources","children":[{"title":"ddl","children":[{"title":"replica_identity.sql <span style='color:#111;'> 1.86KB </span>","children":null,"spread":false},{"title":"inventory.sql <span style='color:#111;'> 1.83KB </span>","children":null,"spread":false},{"title":"column_type_test.sql <span style='color:#111;'> 1.84KB </span>","children":null,"spread":false}],"spread":false},{"title":"log4j2-test.properties <span style='color:#111;'> 1.32KB </span>","children":null,"spread":false}],"spread":false},{"title":"java","children":[{"title":"com","children":[{"title":"alibaba","children":[{"title":"ververica","children":[{"title":"cdc","children":[{"title":"connectors","children":[{"title":"postgres","children":[{"title":"PostgresTestBase.java <span style='color:#111;'> 3.55KB </span>","children":null,"spread":false},{"title":"table","children":[{"title":"PostgreSQLConnectorITCase.java <span style='color:#111;'> 12.43KB </span>","children":null,"spread":false},{"title":"PostgreSQLTableFactoryTest.java <span style='color:#111;'> 5.51KB </span>","children":null,"spread":false}],"spread":false},{"title":"PostgreSQLSourceTest.java <span style='color:#111;'> 20.45KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 6.07KB </span>","children":null,"spread":false}],"spread":true},{"title":"flink-connector-test-util","children":[{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"alibaba","children":[{"title":"ververica","children":[{"title":"cdc","children":[{"title":"connectors","children":[{"title":"utils","children":[{"title":"AssertUtils.java <span style='color:#111;'> 7.70KB </span>","children":null,"spread":false},{"title":"TestSourceContext.java <span style='color:#111;'> 2.06KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.02KB </span>","children":null,"spread":false}],"spread":true},{"title":"flink-sql-connector-postgres-cdc","children":[{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"alibaba","children":[{"title":"ververica","children":[{"title":"cdc","children":[{"title":"connectors","children":[{"title":"postgres","children":[{"title":"DummyDocs.java <span style='color:#111;'> 988B </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 3.37KB </span>","children":null,"spread":false}],"spread":true},{"title":"flink-connector-debezium","children":[{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"alibaba","children":[{"title":"ververica","children":[{"title":"cdc","children":[{"title":"debezium","children":[{"title":"StringDebeziumDeserializationSchema.java <span style='color:#111;'> 1.59KB </span>","children":null,"spread":false},{"title":"table","children":[{"title":"DebeziumOptions.java <span style='color:#111;'> 1.81KB </span>","children":null,"spread":false},{"title":"RowDataDebeziumDeserializeSchema.java <span style='color:#111;'> 13.33KB </span>","children":null,"spread":false}],"spread":false},{"title":"DebeziumSourceFunction.java <span style='color:#111;'> 13.18KB </span>","children":null,"spread":false},{"title":"utils","children":[{"title":"TemporalConversions.java <span style='color:#111;'> 7.20KB </span>","children":null,"spread":false}],"spread":false},{"title":"DebeziumDeserializationSchema.java <span style='color:#111;'> 1.56KB </span>","children":null,"spread":false},{"title":"internal","children":[{"title":"DebeziumChangeConsumer.java <span style='color:#111;'> 6.48KB </span>","children":null,"spread":false},{"title":"ErrorReporter.java <span style='color:#111;'> 1.02KB </span>","children":null,"spread":false},{"title":"FlinkDatabaseHistory.java <span style='color:#111;'> 5.21KB </span>","children":null,"spread":false},{"title":"FlinkOffsetBackingStore.java <span style='color:#111;'> 6.70KB </span>","children":null,"spread":false},{"title":"DebeziumState.java <span style='color:#111;'> 2.26KB </span>","children":null,"spread":false},{"title":"DebeziumStateSerializer.java <span style='color:#111;'> 1.61KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false},{"title":"pom.xml <span style='color:#111;'> 2.23KB </span>","children":null,"spread":false}],"spread":true}],"spread":false}],"spread":true}]