apache / flink-connector-jdbc
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 139 files with 11,906 lines of code in files.
    • 9 files that are 366+ days old (1,249 lines of code)
    • 129 files that are 181-365 days old (10,609 lines of code)
    • 1 files that are 91-180 days old (48 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
10% | 89% | <1% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 139 files with 11,906 lines of code in files.
    • 1 files have been last changed 366+ days ago (24 lines of code)
    • 126 files have been last changed 181-365 days ago (10,039 lines of code)
    • 5 files have been last changed 91-180 days ago (588 lines of code)
    • 7 files have been last changed 31-90 days ago (1,255 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
<1% | 84% | 4% | 10% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, xml, properties, yaml, md, gitignore, txt, gitmodules
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java10% | 89% | <1% | 0% | 0%
xml0% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java<1% | 84% | 4% | 10% | 0%
xml0% | 0% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
flink-connector-jdbc-core13% | 86% | <1% | 0% | 0%
flink-connector-jdbc-postgres0% | 100% | 0% | 0% | 0%
flink-connector-jdbc-oceanbase0% | 100% | 0% | 0% | 0%
flink-connector-jdbc-mysql0% | 100% | 0% | 0% | 0%
flink-connector-jdbc-oracle0% | 100% | 0% | 0% | 0%
flink-connector-jdbc-cratedb0% | 100% | 0% | 0% | 0%
flink-connector-jdbc-sqlserver0% | 100% | 0% | 0% | 0%
flink-connector-jdbc-db20% | 100% | 0% | 0% | 0%
flink-connector-jdbc-trino0% | 100% | 0% | 0% | 0%
tools0% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
flink-connector-jdbc-core<1% | 81% | 6% | 12% | 0%
flink-connector-jdbc-oceanbase0% | 100% | 0% | 0% | 0%
flink-connector-jdbc-postgres0% | 82% | 2% | 14% | 0%
flink-connector-jdbc-mysql0% | 100% | 0% | 0% | 0%
flink-connector-jdbc-oracle0% | 100% | 0% | 0% | 0%
flink-connector-jdbc-cratedb0% | 100% | 0% | 0% | 0%
flink-connector-jdbc-sqlserver0% | 100% | 0% | 0% | 0%
flink-connector-jdbc-db20% | 100% | 0% | 0% | 0%
flink-connector-jdbc-trino0% | 100% | 0% | 0% | 0%
tools0% | 0% | 0% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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
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
FilterHandlingPolicy.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table
 24 2 2024-01-25 2024-01-25 1 1 jiabao.sun@xtransfer.cn jiabao.sun@xtransfer.cn
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
JdbcNumericBetweenParametersProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split
 70 5 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcSlideTimingParameterProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split
 63 5 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
XaTransactionResult.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa
 55 9 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
KeyedBatchStatementExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 51 4 2024-05-18 2024-05-18 1 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
FieldNamedPreparedStatement.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/statement
 47 2 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
SimpleBatchStatementExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 47 4 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
TableBufferedStatementExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 36 5 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
CompositeJdbcParameterValuesProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split
 32 1 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcOutputSerializer.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal
 27 5 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcConnectionProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections
 24 2 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcInsertOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options
 24 3 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
SimpleJdbcQueryStatement.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/statements
 22 3 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcTypedQueryOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options
 21 1 2024-05-18 2024-05-18 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
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
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
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
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
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
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
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
FilterHandlingPolicy.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table
 24 2 2024-01-25 2024-01-25 1 1 jiabao.sun@xtransfer.cn jiabao.sun@xtransfer.cn
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
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
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
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
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
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
JdbcTypedQueryOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options
 21 1 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
SimpleJdbcQueryStatement.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/statements
 22 3 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcInsertOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options
 24 3 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcConnectionProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections
 24 2 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcOutputSerializer.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal
 27 5 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
CompositeJdbcParameterValuesProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split
 32 1 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
TableBufferedStatementExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 36 5 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
SimpleBatchStatementExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 47 4 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
FieldNamedPreparedStatement.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/statement
 47 2 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
KeyedBatchStatementExecutor.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor
 51 4 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
XaTransactionResult.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa
 55 9 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcSlideTimingParameterProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split
 63 5 2024-05-18 2024-05-18 1 1 boto@boto.pro boto@boto.pro
JdbcNumericBetweenParametersProvider.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split
 70 5 2024-05-18 2024-05-18 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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
CompatiblePostgresDialect.java
in flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect
 23 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
SqlServerDialectConverter.java
in flink-connector-jdbc-sqlserver/src/main/java/org/apache/flink/connector/jdbc/sqlserver/database/dialect
 25 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
SqlServerFactory.java
in flink-connector-jdbc-sqlserver/src/main/java/org/apache/flink/connector/jdbc/sqlserver/database
 27 3 2024-05-30 2024-05-30 1 1 boto@boto.pro boto@boto.pro
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
suppressions.xml
in tools/maven
 6 -
ContinuousUnBoundingSettings.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/config
 48 6 2025-01-12 2025-01-12 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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
JdbcWriterState.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/writer
 64 8 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcWriterStateSerializer.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/writer
 64 3 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
XidImpl.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid
 63 5 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcSourceEnumeratorState.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator
 62 3 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
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
JdbcCommitter.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/committer
 49 3 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
CheckpointedOffset.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split
 47 7 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcSqlSplitEnumeratorBase.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator
 40 6 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcSourceReader.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader
 39 5 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
ParameterizedPredicate.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source
 30 5 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcCommitable.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/committer
 28 5 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcCommitableSerializer.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/committer
 28 2 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcSourceOptions.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source
 28 1 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
RecordAndOffset.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader
 26 5 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
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
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
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
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
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
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
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
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
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
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
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
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
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
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
suppressions.xml
in tools/maven
 6 -
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
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
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
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
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
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
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
ContinuousUnBoundingSettings.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/config
 48 6 2025-01-12 2025-01-12 1 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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
JdbcWriterState.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/writer
 64 8 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcWriterStateSerializer.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/writer
 64 3 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
XidImpl.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid
 63 5 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcSourceEnumeratorState.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator
 62 3 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcCommitter.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/committer
 49 3 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
CheckpointedOffset.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split
 47 7 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcSqlSplitEnumeratorBase.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator
 40 6 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcSourceReader.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader
 39 5 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
ParameterizedPredicate.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source
 30 5 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro
JdbcCommitable.java
in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/committer
 28 5 2024-07-08 2024-07-08 1 1 boto@boto.pro boto@boto.pro