File | # lines | # units | # long lines |
---|
|
|
97 |
5 |
35 |
MySqlDataSourceOptions.javain flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source |
267 |
- |
27 |
MySqlSourceOptions.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config |
239 |
- |
23 |
SourceOptions.javain flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options |
116 |
- |
17 |
|
1193 |
43 |
12 |
|
76 |
1 |
11 |
MySqlDataSourceFactory.javain flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory |
461 |
14 |
10 |
PostgreSQLTableFactory.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table |
237 |
6 |
8 |
PostgresSourceOptions.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/config |
63 |
- |
8 |
ValuesDataSourceOptions.javain flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source |
41 |
- |
7 |
KafkaDataSinkOptions.javain flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink |
76 |
- |
7 |
Db2Connection.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2 |
413 |
27 |
7 |
|
504 |
7 |
7 |
IcebergDataSinkOptions.javain flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink |
49 |
- |
6 |
MongoDBTableSourceFactory.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table |
208 |
4 |
6 |
MongoDBSourceOptions.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config |
141 |
- |
6 |
OceanBaseTableSourceFactory.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table |
284 |
5 |
6 |
|
398 |
7 |
5 |
MySqlSourceReader.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader |
456 |
19 |
5 |
MySqlValidator.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql |
190 |
11 |
5 |
PostgresConnection.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection |
620 |
31 |
5 |
|
749 |
34 |
5 |
|
729 |
29 |
4 |
MongoDBSource.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb |
264 |
24 |
4 |
ErrorMessageUtils.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/util |
33 |
1 |
4 |
MySqlSourceEnumerator.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/enumerator |
273 |
15 |
4 |
DebeziumSourceFunction.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium |
400 |
19 |
4 |
|
181 |
14 |
3 |
|
818 |
26 |
3 |
OceanBaseDataSinkOptions.javain flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink |
78 |
- |
3 |
JdbcSourceOptions.javain flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options |
80 |
- |
3 |
SnapshotSplitAssigner.javain flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner |
585 |
32 |
3 |
JdbcSourceChunkSplitter.javain flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter |
398 |
24 |
3 |
IncrementalSourceEnumerator.javain flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/enumerator |
281 |
15 |
3 |
IncrementalSourceReader.javain flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader |
431 |
20 |
3 |
RecordUtils.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils |
465 |
31 |
3 |
MySqlChunkSplitter.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners |
378 |
21 |
3 |
MySqlSnapshotSplitAssigner.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners |
517 |
32 |
3 |
SchemaCoordinator.javain flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed |
362 |
14 |
2 |
SchemaCoordinator.javain flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular |
367 |
15 |
2 |
|
101 |
3 |
2 |
PaimonDataSinkOptions.javain flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink |
36 |
- |
2 |
MaxComputeMetadataApplier.javain flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute |
95 |
2 |
2 |
ElasticsearchDataSinkOptions.javain flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsea... |
74 |
1 |
2 |
JdbcConnectionPools.javain flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/relational/connection |
65 |
5 |
2 |
|
820 |
33 |
2 |
OracleChunkSplitter.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/assigner/splitter |
132 |
9 |
2 |
VitessTableFactory.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table |
165 |
2 |
2 |
EventDispatcherImpl.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/dispatcher |
234 |
10 |
2 |
PostgresValueValidator.javain flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table |
23 |
2 |
2 |