apache / flink-connector-jdbc
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 139 files with 11,906 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 0 files changed 6-20 times (0 lines of code)
    • 139 files changed 1-5 times (11,906 lines of code)
0% | 0% | 0% | 0% | 100%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 139 files with 11,906 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 0 files changed by 6-10 contributors (0 lines of code)
    • 18 files changed by 2-5 contributors (2,891 lines of code)
    • 121 files changed by 1 contributor (9,015 lines of code)
0% | 0% | 0% | 24% | 75%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, xml, properties, yaml, md, gitignore, txt, gitmodules
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 0%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
flink-connector-jdbc-core0% | 0% | 0% | 0% | 100%
flink-connector-jdbc-postgres0% | 0% | 0% | 0% | 100%
flink-connector-jdbc-oceanbase0% | 0% | 0% | 0% | 100%
flink-connector-jdbc-mysql0% | 0% | 0% | 0% | 100%
flink-connector-jdbc-oracle0% | 0% | 0% | 0% | 100%
flink-connector-jdbc-cratedb0% | 0% | 0% | 0% | 100%
flink-connector-jdbc-sqlserver0% | 0% | 0% | 0% | 100%
flink-connector-jdbc-db20% | 0% | 0% | 0% | 100%
flink-connector-jdbc-trino0% | 0% | 0% | 0% | 100%
tools0% | 0% | 0% | 0% | 0%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
InternalJdbcConnectionOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options
 157 19 2024-04-26 2024-07-12 4 1 boto@boto.pro boto@boto.pro
AbstractJdbcCatalog.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog
 484 53 2024-05-30 2025-03-25 4 3 boto@boto.pro lvyanquan.lyq@alibaba-inc.com
TableSimpleStatementExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 38 5 2024-04-26 2024-05-30 3 1 boto@boto.pro boto@boto.pro
TableInsertOrUpdateStatementExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 81 7 2024-04-26 2024-05-30 3 1 boto@boto.pro boto@boto.pro
JdbcDmlOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options
 109 15 2024-04-26 2024-05-30 3 1 boto@boto.pro boto@boto.pro
JdbcUtils.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/utils
 138 4 2024-05-07 2024-05-30 3 1 boto@boto.pro boto@boto.pro
CompatiblePostgresDialectConverter.java
in flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect
 15 2 2024-05-30 2025-01-12 2 1 boto@boto.pro boto@boto.pro
EmptyTransactionXaException.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions
 17 2 2024-05-18 2024-07-08 2 1 boto@boto.pro boto@boto.pro
JdbcCatalogFactoryOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/factory
 22 1 2024-05-30 2024-07-08 2 1 boto@boto.pro boto@boto.pro
GenericJdbcSinkFunction.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal
 50 7 2024-05-18 2025-03-25 2 2 boto@boto.pro lvyanquan.lyq@alibaba-inc.com
OceanBaseFactory.java
in flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database
 52 5 2024-05-30 2024-08-02 2 2 boto@boto.pro wanghechn@qq.com
JdbcSourceSplitState.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split
 61 8 2024-07-08 2024-10-10 2 2 boto@boto.pro 2356672992@qq.com
OceanBaseDialect.java
in flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect
 78 11 2024-05-30 2024-08-02 2 2 boto@boto.pro wanghechn@qq.com
JdbcDynamicTableSink.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/sink
 87 8 2024-07-08 2025-03-25 2 2 boto@boto.pro lvyanquan.lyq@alibaba-inc.com
JdbcSink.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink
 90 7 2024-07-08 2025-03-25 2 2 boto@boto.pro lvyanquan.lyq@alibaba-inc.com
PostgresDialect.java
in flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect
 91 9 2024-05-30 2025-02-07 2 2 boto@boto.pro roseduan520@gmail.com
OceanBaseDialectConverter.java
in flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect
 105 3 2024-05-30 2024-08-02 2 2 boto@boto.pro wanghechn@qq.com
CrateDBCatalog.java
in flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/catalog
 120 9 2024-05-30 2024-08-02 2 2 boto@boto.pro wanghechn@qq.com
JdbcConnectorOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table
 133 1 2024-01-25 2024-07-08 2 2 jiabao.sun@xtransfer.cn boto@boto.pro
MySqlCatalog.java
in flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/catalog
 147 11 2024-05-30 2024-08-02 2 2 boto@boto.pro wanghechn@qq.com
JdbcSource.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source
 156 11 2024-07-08 2025-01-12 2 1 boto@boto.pro boto@boto.pro
JdbcWriter.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/writer
 157 7 2024-07-08 2025-03-25 2 2 boto@boto.pro lvyanquan.lyq@alibaba-inc.com
JdbcSourceEnumerator.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator
 162 12 2024-07-08 2025-01-12 2 1 boto@boto.pro boto@boto.pro
PostgresCatalog.java
in flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog
 181 13 2024-05-30 2024-08-02 2 2 boto@boto.pro wanghechn@qq.com
JdbcOutputFormat.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal
 190 14 2024-05-18 2024-09-03 2 2 boto@boto.pro morozov@tut.by
JdbcSourceBuilder.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source
 207 20 2024-07-08 2025-01-12 2 1 boto@boto.pro boto@boto.pro
XaTransaction.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa
 253 17 2024-05-18 2024-07-08 2 1 boto@boto.pro boto@boto.pro
JdbcDynamicTableSource.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source
 264 13 2024-01-25 2024-07-08 2 2 jiabao.sun@xtransfer.cn boto@boto.pro
JdbcInputFormat.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc
 284 27 2024-05-18 2024-07-08 2 1 boto@boto.pro boto@boto.pro
JdbcSourceSplitReader.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader
 296 20 2024-07-08 2025-03-25 2 2 boto@boto.pro lvyanquan.lyq@alibaba-inc.com
JdbcDynamicTableFactory.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table
 305 11 2024-01-25 2024-07-08 2 2 jiabao.sun@xtransfer.cn boto@boto.pro
StatementFactory.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/statement
 6 - 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcCatalog.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog
 6 - 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
TransientXaException.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions
 10 1 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcQueryStatement.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/statements
 10 - 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcStatementBuilder.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc
 10 - 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcCatalogTypeMapper.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog
 11 - 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
JdbcParameterValuesProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split
 12 2 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcDialectConverter.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect
 13 - 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
MySQLDialectConverter.java
in flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/dialect
 15 2 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
JdbcGenericParameterValuesProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split
 15 1 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
Jdbc.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream
 15 2 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
DerbyDialectConverter.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/derby/database/dialect
 15 2 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
CrateDBDialectConverter.java
in flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/dialect
 15 2 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
ResultExtractor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/extractor
 16 2 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
RowResultExtractor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/extractor
 17 1 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcRecordEmitter.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader
 17 1 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
XaConnectionProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa
 18 - 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
Db2DialectConverter.java
in flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect
 20 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
JdbcBatchStatementExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 21 2 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
AbstractJdbcCatalog.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog
 484 53 2024-05-30 2025-03-25 4 3 boto@boto.pro lvyanquan.lyq@alibaba-inc.com
OceanBaseDialectConverter.java
in flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect
 105 3 2024-05-30 2024-08-02 2 2 boto@boto.pro wanghechn@qq.com
OceanBaseDialect.java
in flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect
 78 11 2024-05-30 2024-08-02 2 2 boto@boto.pro wanghechn@qq.com
OceanBaseFactory.java
in flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database
 52 5 2024-05-30 2024-08-02 2 2 boto@boto.pro wanghechn@qq.com
CrateDBCatalog.java
in flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/catalog
 120 9 2024-05-30 2024-08-02 2 2 boto@boto.pro wanghechn@qq.com
JdbcSink.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink
 90 7 2024-07-08 2025-03-25 2 2 boto@boto.pro lvyanquan.lyq@alibaba-inc.com
JdbcWriter.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/writer
 157 7 2024-07-08 2025-03-25 2 2 boto@boto.pro lvyanquan.lyq@alibaba-inc.com
JdbcSourceSplitState.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split
 61 8 2024-07-08 2024-10-10 2 2 boto@boto.pro 2356672992@qq.com
JdbcSourceSplitReader.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader
 296 20 2024-07-08 2025-03-25 2 2 boto@boto.pro lvyanquan.lyq@alibaba-inc.com
JdbcDynamicTableFactory.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table
 305 11 2024-01-25 2024-07-08 2 2 jiabao.sun@xtransfer.cn boto@boto.pro
JdbcDynamicTableSink.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/sink
 87 8 2024-07-08 2025-03-25 2 2 boto@boto.pro lvyanquan.lyq@alibaba-inc.com
JdbcDynamicTableSource.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source
 264 13 2024-01-25 2024-07-08 2 2 jiabao.sun@xtransfer.cn boto@boto.pro
JdbcConnectorOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table
 133 1 2024-01-25 2024-07-08 2 2 jiabao.sun@xtransfer.cn boto@boto.pro
JdbcOutputFormat.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal
 190 14 2024-05-18 2024-09-03 2 2 boto@boto.pro morozov@tut.by
GenericJdbcSinkFunction.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal
 50 7 2024-05-18 2025-03-25 2 2 boto@boto.pro lvyanquan.lyq@alibaba-inc.com
PostgresDialect.java
in flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect
 91 9 2024-05-30 2025-02-07 2 2 boto@boto.pro roseduan520@gmail.com
PostgresCatalog.java
in flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog
 181 13 2024-05-30 2024-08-02 2 2 boto@boto.pro wanghechn@qq.com
MySqlCatalog.java
in flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/catalog
 147 11 2024-05-30 2024-08-02 2 2 boto@boto.pro wanghechn@qq.com
InternalJdbcConnectionOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options
 157 19 2024-04-26 2024-07-12 4 1 boto@boto.pro boto@boto.pro
JdbcUtils.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/utils
 138 4 2024-05-07 2024-05-30 3 1 boto@boto.pro boto@boto.pro
JdbcDmlOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options
 109 15 2024-04-26 2024-05-30 3 1 boto@boto.pro boto@boto.pro
TableInsertOrUpdateStatementExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 81 7 2024-04-26 2024-05-30 3 1 boto@boto.pro boto@boto.pro
TableSimpleStatementExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 38 5 2024-04-26 2024-05-30 3 1 boto@boto.pro boto@boto.pro
JdbcInputFormat.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc
 284 27 2024-05-18 2024-07-08 2 1 boto@boto.pro boto@boto.pro
JdbcSourceBuilder.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source
 207 20 2024-07-08 2025-01-12 2 1 boto@boto.pro boto@boto.pro
JdbcSourceEnumerator.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator
 162 12 2024-07-08 2025-01-12 2 1 boto@boto.pro boto@boto.pro
JdbcSource.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source
 156 11 2024-07-08 2025-01-12 2 1 boto@boto.pro boto@boto.pro
JdbcCatalogFactoryOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/factory
 22 1 2024-05-30 2024-07-08 2 1 boto@boto.pro boto@boto.pro
EmptyTransactionXaException.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions
 17 2 2024-05-18 2024-07-08 2 1 boto@boto.pro boto@boto.pro
XaTransaction.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa
 253 17 2024-05-18 2024-07-08 2 1 boto@boto.pro boto@boto.pro
CompatiblePostgresDialectConverter.java
in flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect
 15 2 2024-05-30 2025-01-12 2 1 boto@boto.pro boto@boto.pro
OracleDialect.java
in flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database/dialect
 113 9 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
OracleDialectConverter.java
in flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database/dialect
 154 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
OracleFactory.java
in flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database
 27 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
Db2Factory.java
in flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database
 27 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
Db2DialectConverter.java
in flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect
 20 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
Db2Dialect.java
in flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect
 114 9 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
TrinoFactory.java
in flink-connector-jdbc-trino/src/main/java/org/apache/flink/connector/jdbc/trino/database
 27 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
TrinoDialect.java
in flink-connector-jdbc-trino/src/main/java/org/apache/flink/connector/jdbc/trino/database/dialect
 73 9 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
TrinoDialectConverter.java
in flink-connector-jdbc-trino/src/main/java/org/apache/flink/connector/jdbc/trino/database/dialect
 38 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
OceanBaseCompatibleMode.java
in flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect
 25 3 2024-08-02 2024-08-02 1 1 wanghechn@qq.com wanghechn@qq.com
OceanBaseTypeMapper.java
in flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog
 123 6 2024-08-02 2024-08-02 1 1 wanghechn@qq.com wanghechn@qq.com
OceanBaseCatalog.java
in flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog
 139 11 2024-08-02 2024-08-02 1 1 wanghechn@qq.com wanghechn@qq.com
CrateDBDialect.java
in flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/dialect
 21 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
CrateDBDialectConverter.java
in flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/dialect
 15 2 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
CrateDBFactory.java
in flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database
 29 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
CrateDBTablePath.java
in flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/catalog
 30 4 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
CrateDBTypeMapper.java
in flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/catalog
 31 2 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
JdbcExactlyOnceOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc
 90 14 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
DerbyDialect.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/derby/database/dialect
 68 9 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
suppressions.xml
in tools/maven
 6 -
JdbcRowDataInputFormat.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source
 304 26 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcInputFormat.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc
 284 27 2024-05-18 2024-07-08 2 1 boto@boto.pro boto@boto.pro
XaTransaction.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa
 253 17 2024-05-18 2024-07-08 2 1 boto@boto.pro boto@boto.pro
SimpleXaConnectionProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa
 233 26 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
TransactionId.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/domain
 222 22 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
AbstractDialectConverter.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect
 211 9 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
JdbcSourceBuilder.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source
 207 20 2024-07-08 2025-01-12 2 1 boto@boto.pro boto@boto.pro
FieldNamedPreparedStatementImpl.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/statement
 198 22 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcOutputFormatBuilder.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/sink
 183 14 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcRowDataLookupFunction.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source
 183 7 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
MySqlTypeMapper.java
in flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/catalog
 172 4 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
JdbcFilterPushdownPreparedStatementVisitor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source
 167 7 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcSourceEnumerator.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator
 162 12 2024-07-08 2025-01-12 2 1 boto@boto.pro boto@boto.pro
TableJdbcUpsertOutputFormat.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal
 162 10 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
AbstractDialect.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect
 160 10 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
InternalJdbcConnectionOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options
 157 19 2024-04-26 2024-07-12 4 1 boto@boto.pro boto@boto.pro
JdbcSource.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source
 156 11 2024-07-08 2025-01-12 2 1 boto@boto.pro boto@boto.pro
OracleDialectConverter.java
in flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database/dialect
 154 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
PoolingXaConnectionProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa
 149 19 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
XaError.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions
 146 12 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
PostgresTypeMapper.java
in flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog
 143 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
OceanBaseCatalog.java
in flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog
 139 11 2024-08-02 2024-08-02 1 1 wanghechn@qq.com wanghechn@qq.com
JdbcUtils.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/utils
 138 4 2024-05-07 2024-05-30 3 1 boto@boto.pro boto@boto.pro
OceanBaseTypeMapper.java
in flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog
 123 6 2024-08-02 2024-08-02 1 1 wanghechn@qq.com wanghechn@qq.com
SqlServerDialect.java
in flink-connector-jdbc-sqlserver/src/main/java/org/apache/flink/connector/jdbc/sqlserver/database/dialect
 118 9 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
JdbcReadOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options
 115 18 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
Db2Dialect.java
in flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect
 114 9 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
OracleDialect.java
in flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database/dialect
 113 9 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
JdbcDmlOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options
 109 15 2024-04-26 2024-05-30 3 1 boto@boto.pro boto@boto.pro
JdbcConnectionOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc
 105 15 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcTypeUtil.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/utils
 104 4 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
SqlTemplateSplitEnumerator.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator
 102 9 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
SimpleJdbcConnectionProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections
 102 10 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcFactoryLoader.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database
 101 7 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
XaCommand.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa
 96 9 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
XidSerializer.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid
 96 17 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
InsertOrUpdateJdbcExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 95 7 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcRowOutputFormat.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc
 93 13 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
MySqlDialect.java
in flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/dialect
 91 10 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
JdbcExactlyOnceOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc
 90 14 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcSourceSplit.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split
 90 10 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcSourceEnumStateSerializer.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator
 88 5 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
RowJdbcOutputFormat.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal
 88 11 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
TableInsertOrUpdateStatementExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 81 7 2024-04-26 2024-05-30 3 1 boto@boto.pro boto@boto.pro
JdbcSinkBuilder.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink
 80 9 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
TrinoDialect.java
in flink-connector-jdbc-trino/src/main/java/org/apache/flink/connector/jdbc/trino/database/dialect
 73 9 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
JdbcExecutionOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc
 73 12 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcSourceSplitSerializer.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split
 73 4 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
TableBufferReducedStatementExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 71 6 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
Correlations

File Size vs. Number of Changes: 139 points

flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/AbstractJdbcCatalog.java x: 484 lines of code y: 4 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/JdbcSink.java x: 90 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/writer/JdbcWriter.java x: 157 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/JdbcSourceSplitReader.java x: 296 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/sink/JdbcDynamicTableSink.java x: 87 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/GenericJdbcSinkFunction.java x: 50 lines of code y: 2 # changes flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialect.java x: 91 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/JdbcSource.java x: 156 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/JdbcSourceBuilder.java x: 207 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/config/ContinuousUnBoundingSettings.java x: 48 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/JdbcSourceEnumerator.java x: 162 lines of code y: 2 # changes flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/CompatiblePostgresDialectConverter.java x: 15 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split/JdbcSourceSplitState.java x: 61 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcOutputFormat.java x: 190 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/FilterHandlingPolicy.java x: 24 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/JdbcConnectorOptions.java x: 133 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/JdbcDynamicTableFactory.java x: 305 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/JdbcDynamicTableSource.java x: 264 lines of code y: 2 # changes flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/catalog/CrateDBCatalog.java x: 120 lines of code y: 2 # changes flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/catalog/MySqlCatalog.java x: 147 lines of code y: 2 # changes flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/OceanBaseFactory.java x: 52 lines of code y: 2 # changes flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog/OceanBaseCatalog.java x: 139 lines of code y: 1 # changes flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog/OceanBaseTypeMapper.java x: 123 lines of code y: 1 # changes flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect/OceanBaseCompatibleMode.java x: 25 lines of code y: 1 # changes flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect/OceanBaseDialect.java x: 78 lines of code y: 2 # changes flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect/OceanBaseDialectConverter.java x: 105 lines of code y: 2 # changes flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresCatalog.java x: 181 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/InternalJdbcConnectionOptions.java x: 157 lines of code y: 4 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/factory/JdbcCatalogFactoryOptions.java x: 22 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/sink/JdbcOutputFormatBuilder.java x: 183 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/JdbcFilterPushdownPreparedStatementVisitor.java x: 167 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/JdbcRowDataInputFormat.java x: 304 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/ParameterizedPredicate.java x: 30 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/committer/JdbcCommitableSerializer.java x: 28 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/EmptyTransactionXaException.java x: 17 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid/XidImpl.java x: 63 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid/XidSerializer.java x: 96 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/JdbcInputFormat.java x: 284 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/Jdbc.java x: 15 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/JdbcSourceEnumStateSerializer.java x: 88 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/JdbcSourceEnumeratorState.java x: 62 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/JdbcSqlSplitEnumeratorBase.java x: 40 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/SqlTemplateSplitEnumerator.java x: 102 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/JdbcRecordEmitter.java x: 17 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/JdbcSourceReader.java x: 39 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/RecordAndOffset.java x: 26 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/extractor/ResultExtractor.java x: 16 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split/CheckpointedOffset.java x: 47 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split/JdbcSourceSplit.java x: 90 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split/JdbcSourceSplitSerializer.java x: 73 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/JdbcSinkBuilder.java x: 80 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/committer/JdbcCommitter.java x: 49 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/writer/JdbcWriterState.java x: 64 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/XaTransaction.java x: 253 lines of code y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/JdbcFactory.java x: 38 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/JdbcFactoryLoader.java x: 101 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/JdbcCatalog.java x: 6 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/JdbcCatalogTypeMapper.java x: 11 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/factory/JdbcCatalogFactory.java x: 54 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect/AbstractDialect.java x: 160 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect/AbstractDialectConverter.java x: 211 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect/JdbcDialect.java x: 29 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect/JdbcDialectConverter.java x: 13 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/derby/database/DerbyFactory.java x: 27 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/derby/database/dialect/DerbyDialect.java x: 68 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableInsertOrUpdateStatementExecutor.java x: 81 lines of code y: 3 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableSimpleStatementExecutor.java x: 38 lines of code y: 3 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java x: 109 lines of code y: 3 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcUtils.java x: 138 lines of code y: 3 # changes flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/catalog/CrateDBTypeMapper.java x: 31 lines of code y: 1 # changes flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/dialect/CrateDBDialect.java x: 21 lines of code y: 1 # changes flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2Dialect.java x: 114 lines of code y: 1 # changes flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2DialectConverter.java x: 20 lines of code y: 1 # changes flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/catalog/MySqlTypeMapper.java x: 172 lines of code y: 1 # changes flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/dialect/MySqlDialect.java x: 91 lines of code y: 1 # changes flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database/dialect/OracleDialect.java x: 113 lines of code y: 1 # changes flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database/dialect/OracleDialectConverter.java x: 154 lines of code y: 1 # changes flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresTablePath.java x: 69 lines of code y: 1 # changes flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresTypeMapper.java x: 143 lines of code y: 1 # changes flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/CompatiblePostgresDialect.java x: 23 lines of code y: 1 # changes flink-connector-jdbc-sqlserver/src/main/java/org/apache/flink/connector/jdbc/sqlserver/database/dialect/SqlServerDialect.java x: 118 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java x: 105 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/JdbcRowOutputFormat.java x: 93 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/JdbcStatementBuilder.java x: 10 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/PoolingXaConnectionProvider.java x: 149 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/SimpleXaConnectionProvider.java x: 233 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/XaConnectionProvider.java x: 18 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/SimpleJdbcQueryStatement.java x: 22 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/XaTransactionResult.java x: 55 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/domain/TransactionId.java x: 222 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/XaError.java x: 146 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/TableJdbcUpsertOutputFormat.java x: 162 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/InsertOrUpdateJdbcExecutor.java x: 95 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/KeyedBatchStatementExecutor.java x: 51 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferReducedStatementExecutor.java x: 71 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferedStatementExecutor.java x: 36 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcReadOptions.java x: 115 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split/CompositeJdbcParameterValuesProvider.java x: 32 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split/JdbcNumericBetweenParametersProvider.java x: 70 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split/JdbcParameterValuesProvider.java x: 12 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatementImpl.java x: 198 lines of code y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcTypeUtil.java x: 104 lines of code y: 1 # changes
4.0
# changes
  min: 1.0
  average: 1.28
  25th percentile: 1.0
  median: 1.0
  75th percentile: 1.0
  max: 4.0
0 484.0
lines of code
min: 6.0 | average: 85.65 | 25th percentile: 27.0 | median: 63.0 | 75th percentile: 118.0 | max: 484.0

Number of Contributors vs. Number of Changes: 139 points

flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/AbstractJdbcCatalog.java x: 3 # contributors y: 4 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/JdbcSink.java x: 2 # contributors y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/JdbcSource.java x: 1 # contributors y: 2 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/config/ContinuousUnBoundingSettings.java x: 1 # contributors y: 1 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/InternalJdbcConnectionOptions.java x: 1 # contributors y: 4 # changes flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableInsertOrUpdateStatementExecutor.java x: 1 # contributors y: 3 # changes
4.0
# changes
  min: 1.0
  average: 1.28
  25th percentile: 1.0
  median: 1.0
  75th percentile: 1.0
  max: 4.0
0 3.0
# contributors
min: 1.0 | average: 1.14 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 3.0

Number of Contributors vs. File Size: 139 points

flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/AbstractJdbcCatalog.java x: 3 # contributors y: 484 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/JdbcSink.java x: 2 # contributors y: 90 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/writer/JdbcWriter.java x: 2 # contributors y: 157 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/JdbcSourceSplitReader.java x: 2 # contributors y: 296 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/sink/JdbcDynamicTableSink.java x: 2 # contributors y: 87 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/GenericJdbcSinkFunction.java x: 2 # contributors y: 50 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/JdbcSource.java x: 1 # contributors y: 156 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/JdbcSourceBuilder.java x: 1 # contributors y: 207 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/config/ContinuousUnBoundingSettings.java x: 1 # contributors y: 48 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/JdbcSourceEnumerator.java x: 1 # contributors y: 162 lines of code flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/CompatiblePostgresDialectConverter.java x: 1 # contributors y: 15 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split/JdbcSourceSplitState.java x: 2 # contributors y: 61 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcOutputFormat.java x: 2 # contributors y: 190 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/FilterHandlingPolicy.java x: 1 # contributors y: 24 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/JdbcConnectorOptions.java x: 2 # contributors y: 133 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/JdbcDynamicTableFactory.java x: 2 # contributors y: 305 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/JdbcDynamicTableSource.java x: 2 # contributors y: 264 lines of code flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/catalog/CrateDBCatalog.java x: 2 # contributors y: 120 lines of code flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/catalog/MySqlCatalog.java x: 2 # contributors y: 147 lines of code flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/OceanBaseFactory.java x: 2 # contributors y: 52 lines of code flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog/OceanBaseCatalog.java x: 1 # contributors y: 139 lines of code flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog/OceanBaseTypeMapper.java x: 1 # contributors y: 123 lines of code flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect/OceanBaseCompatibleMode.java x: 1 # contributors y: 25 lines of code flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect/OceanBaseDialect.java x: 2 # contributors y: 78 lines of code flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect/OceanBaseDialectConverter.java x: 2 # contributors y: 105 lines of code flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresCatalog.java x: 2 # contributors y: 181 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/InternalJdbcConnectionOptions.java x: 1 # contributors y: 157 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/factory/JdbcCatalogFactoryOptions.java x: 1 # contributors y: 22 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/sink/JdbcOutputFormatBuilder.java x: 1 # contributors y: 183 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/JdbcFilterPushdownPreparedStatementVisitor.java x: 1 # contributors y: 167 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/JdbcRowDataInputFormat.java x: 1 # contributors y: 304 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/ParameterizedPredicate.java x: 1 # contributors y: 30 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/committer/JdbcCommitableSerializer.java x: 1 # contributors y: 28 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/EmptyTransactionXaException.java x: 1 # contributors y: 17 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid/XidImpl.java x: 1 # contributors y: 63 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid/XidSerializer.java x: 1 # contributors y: 96 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/JdbcInputFormat.java x: 1 # contributors y: 284 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/JdbcSourceEnumStateSerializer.java x: 1 # contributors y: 88 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/JdbcSourceEnumeratorState.java x: 1 # contributors y: 62 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/JdbcSqlSplitEnumeratorBase.java x: 1 # contributors y: 40 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/SqlTemplateSplitEnumerator.java x: 1 # contributors y: 102 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split/CheckpointedOffset.java x: 1 # contributors y: 47 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split/JdbcSourceSplit.java x: 1 # contributors y: 90 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split/JdbcSourceSplitSerializer.java x: 1 # contributors y: 73 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/JdbcSinkBuilder.java x: 1 # contributors y: 80 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/XaTransaction.java x: 1 # contributors y: 253 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/JdbcFactory.java x: 1 # contributors y: 38 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/JdbcCatalog.java x: 1 # contributors y: 6 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/JdbcCatalogTypeMapper.java x: 1 # contributors y: 11 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/factory/JdbcCatalogFactory.java x: 1 # contributors y: 54 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect/AbstractDialect.java x: 1 # contributors y: 160 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect/AbstractDialectConverter.java x: 1 # contributors y: 211 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect/JdbcDialectConverter.java x: 1 # contributors y: 13 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/derby/database/dialect/DerbyDialect.java x: 1 # contributors y: 68 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableInsertOrUpdateStatementExecutor.java x: 1 # contributors y: 81 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java x: 1 # contributors y: 109 lines of code flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/catalog/CrateDBTypeMapper.java x: 1 # contributors y: 31 lines of code flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2Dialect.java x: 1 # contributors y: 114 lines of code flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2DialectConverter.java x: 1 # contributors y: 20 lines of code flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/catalog/MySqlTypeMapper.java x: 1 # contributors y: 172 lines of code flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database/dialect/OracleDialectConverter.java x: 1 # contributors y: 154 lines of code flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresTablePath.java x: 1 # contributors y: 69 lines of code flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresTypeMapper.java x: 1 # contributors y: 143 lines of code flink-connector-jdbc-sqlserver/src/main/java/org/apache/flink/connector/jdbc/sqlserver/database/dialect/SqlServerDialect.java x: 1 # contributors y: 118 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java x: 1 # contributors y: 105 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/JdbcRowOutputFormat.java x: 1 # contributors y: 93 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/PoolingXaConnectionProvider.java x: 1 # contributors y: 149 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/SimpleXaConnectionProvider.java x: 1 # contributors y: 233 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/XaConnectionProvider.java x: 1 # contributors y: 18 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/domain/TransactionId.java x: 1 # contributors y: 222 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/XaError.java x: 1 # contributors y: 146 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/InsertOrUpdateJdbcExecutor.java x: 1 # contributors y: 95 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/KeyedBatchStatementExecutor.java x: 1 # contributors y: 51 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferReducedStatementExecutor.java x: 1 # contributors y: 71 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferedStatementExecutor.java x: 1 # contributors y: 36 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcReadOptions.java x: 1 # contributors y: 115 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatementImpl.java x: 1 # contributors y: 198 lines of code flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcTypeUtil.java x: 1 # contributors y: 104 lines of code
484.0
lines of code
  min: 6.0
  average: 85.65
  25th percentile: 27.0
  median: 63.0
  75th percentile: 118.0
  max: 484.0
0 3.0
# contributors
min: 1.0 | average: 1.14 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 3.0