path # lines of code # active days days since first update days since last update # commits # contributors first updated last updated first contributor last contributor flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database/dialect/OracleDialect.java 113 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database/dialect/OracleDialectConverter.java 154 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-oracle/src/main/java/org/apache/flink/connector/jdbc/oracle/database/OracleFactory.java 27 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/Db2Factory.java 27 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2DialectConverter.java 20 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2Dialect.java 114 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-trino/src/main/java/org/apache/flink/connector/jdbc/trino/database/TrinoFactory.java 27 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-trino/src/main/java/org/apache/flink/connector/jdbc/trino/database/dialect/TrinoDialect.java 73 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-trino/src/main/java/org/apache/flink/connector/jdbc/trino/database/dialect/TrinoDialectConverter.java 38 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect/OceanBaseCompatibleMode.java 25 1 279 279 1 1 2024-08-02 2024-08-02 wanghechn@qq.com wanghechn@qq.com flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect/OceanBaseDialectConverter.java 105 2 343 279 2 2 2024-05-30 2024-08-02 boto@boto.pro wanghechn@qq.com flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect/OceanBaseDialect.java 78 2 343 279 2 2 2024-05-30 2024-08-02 boto@boto.pro wanghechn@qq.com flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/OceanBaseFactory.java 52 2 343 279 2 2 2024-05-30 2024-08-02 boto@boto.pro wanghechn@qq.com flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog/OceanBaseTypeMapper.java 123 1 279 279 1 1 2024-08-02 2024-08-02 wanghechn@qq.com wanghechn@qq.com flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog/OceanBaseCatalog.java 139 1 279 279 1 1 2024-08-02 2024-08-02 wanghechn@qq.com wanghechn@qq.com flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/dialect/CrateDBDialect.java 21 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/dialect/CrateDBDialectConverter.java 15 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/CrateDBFactory.java 29 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/catalog/CrateDBTablePath.java 30 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/catalog/CrateDBCatalog.java 120 2 343 279 2 2 2024-05-30 2024-08-02 boto@boto.pro wanghechn@qq.com flink-connector-jdbc-cratedb/src/main/java/org/apache/flink/connector/jdbc/cratedb/database/catalog/CrateDBTypeMapper.java 31 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/JdbcExactlyOnceOptions.java 90 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/derby/database/dialect/DerbyDialect.java 68 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/derby/database/dialect/DerbyDialectConverter.java 15 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/derby/database/DerbyFactory.java 27 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/JdbcInputFormat.java 284 2 355 304 2 1 2024-05-18 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/JdbcRowOutputFormat.java 93 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcUtils.java 138 3 366 343 3 1 2024-05-07 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcTypeUtil.java 104 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java 73 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/JdbcStatementBuilder.java 10 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java 105 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/Jdbc.java 15 1 304 304 2 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/JdbcSink.java 90 2 304 44 2 2 2024-07-08 2025-03-25 boto@boto.pro lvyanquan.lyq@alibaba-inc.com flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/JdbcSinkBuilder.java 80 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/committer/JdbcCommitable.java 28 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/committer/JdbcCommitableSerializer.java 28 1 304 304 2 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/committer/JdbcCommitter.java 49 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/writer/JdbcWriter.java 157 2 304 44 2 2 2024-07-08 2025-03-25 boto@boto.pro lvyanquan.lyq@alibaba-inc.com flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/writer/JdbcWriterState.java 64 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/sink/writer/JdbcWriterStateSerializer.java 64 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/JdbcSourceBuilder.java 207 2 304 116 2 1 2024-07-08 2025-01-12 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/config/ContinuousUnBoundingSettings.java 48 1 116 116 1 1 2025-01-12 2025-01-12 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/SqlTemplateSplitEnumerator.java 102 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/JdbcSourceEnumStateSerializer.java 88 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/JdbcSourceEnumerator.java 162 2 304 116 2 1 2024-07-08 2025-01-12 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/JdbcSourceEnumeratorState.java 62 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/JdbcSqlSplitEnumeratorBase.java 40 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split/JdbcSourceSplitSerializer.java 73 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split/JdbcSourceSplitState.java 61 2 304 210 2 2 2024-07-08 2024-10-10 boto@boto.pro 2356672992@qq.com flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split/JdbcSourceSplit.java 90 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split/CheckpointedOffset.java 47 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/JdbcRecordEmitter.java 17 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/RecordAndOffset.java 26 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/JdbcSourceSplitReader.java 296 2 304 44 2 2 2024-07-08 2025-03-25 boto@boto.pro lvyanquan.lyq@alibaba-inc.com flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/JdbcSourceReader.java 39 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/extractor/ResultExtractor.java 16 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/extractor/RowResultExtractor.java 17 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/JdbcSourceOptions.java 28 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/JdbcSource.java 156 2 304 116 2 1 2024-07-08 2025-01-12 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/JdbcDynamicTableFactory.java 305 2 469 304 2 2 2024-01-25 2024-07-08 jiabao.sun@xtransfer.cn boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/FilterHandlingPolicy.java 24 1 469 469 1 1 2024-01-25 2024-01-25 jiabao.sun@xtransfer.cn jiabao.sun@xtransfer.cn flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/sink/JdbcDynamicTableSink.java 87 2 304 44 2 2 2024-07-08 2025-03-25 boto@boto.pro lvyanquan.lyq@alibaba-inc.com flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/sink/JdbcOutputFormatBuilder.java 183 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/JdbcRowDataInputFormat.java 304 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/ParameterizedPredicate.java 30 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/JdbcFilterPushdownPreparedStatementVisitor.java 167 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/JdbcDynamicTableSource.java 264 2 469 304 2 2 2024-01-25 2024-07-08 jiabao.sun@xtransfer.cn boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/source/JdbcRowDataLookupFunction.java 183 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/JdbcConnectorOptions.java 133 2 469 304 2 2 2024-01-25 2024-07-08 jiabao.sun@xtransfer.cn boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect/JdbcDialect.java 29 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect/JdbcDialectConverter.java 13 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect/AbstractDialectConverter.java 211 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/dialect/AbstractDialect.java 160 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/JdbcFactory.java 38 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/JdbcFactoryLoader.java 101 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/JdbcCatalogTypeMapper.java 11 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/AbstractJdbcCatalog.java 484 4 343 44 4 3 2024-05-30 2025-03-25 boto@boto.pro lvyanquan.lyq@alibaba-inc.com flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/JdbcCatalog.java 6 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/factory/JdbcCatalogFactory.java 54 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/factory/JdbcCatalogFactoryOptions.java 22 2 343 304 2 1 2024-05-30 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split/JdbcSlideTimingParameterProvider.java 63 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split/JdbcParameterValuesProvider.java 12 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split/JdbcGenericParameterValuesProvider.java 15 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split/JdbcNumericBetweenParametersProvider.java 70 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/split/CompositeJdbcParameterValuesProvider.java 32 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatement.java 47 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/statement/StatementFactory.java 6 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatementImpl.java 198 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/JdbcQueryStatement.java 10 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/SimpleJdbcQueryStatement.java 22 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/PoolingXaConnectionProvider.java 149 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/XaConnectionProvider.java 18 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/SimpleXaConnectionProvider.java 233 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/xa/XaCommand.java 96 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/JdbcConnectionProvider.java 24 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/connections/SimpleJdbcConnectionProvider.java 102 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/XaError.java 146 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/TransientXaException.java 10 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/exceptions/EmptyTransactionXaException.java 17 2 355 304 2 1 2024-05-18 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/XaTransactionResult.java 55 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid/XidImpl.java 63 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/xid/XidSerializer.java 96 1 304 304 1 1 2024-07-08 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/domain/TransactionId.java 222 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/XaTransaction.java 253 2 355 304 2 1 2024-05-18 2024-07-08 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java 109 3 377 343 3 1 2024-04-26 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcTypedQueryOptions.java 21 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/InternalJdbcConnectionOptions.java 157 4 377 300 4 1 2024-04-26 2024-07-12 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcReadOptions.java 115 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcInsertOptions.java 24 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcOutputFormat.java 190 2 355 247 2 2 2024-05-18 2024-09-03 boto@boto.pro morozov@tut.by flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcOutputSerializer.java 27 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/RowJdbcOutputFormat.java 88 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/GenericJdbcSinkFunction.java 50 2 355 44 2 2 2024-05-18 2025-03-25 boto@boto.pro lvyanquan.lyq@alibaba-inc.com flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferedStatementExecutor.java 36 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferReducedStatementExecutor.java 71 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableInsertOrUpdateStatementExecutor.java 81 3 377 343 3 1 2024-04-26 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/JdbcBatchStatementExecutor.java 21 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/KeyedBatchStatementExecutor.java 51 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/SimpleBatchStatementExecutor.java 47 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableSimpleStatementExecutor.java 38 3 377 343 3 1 2024-04-26 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/executor/InsertOrUpdateJdbcExecutor.java 95 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/TableJdbcUpsertOutputFormat.java 162 1 355 355 1 1 2024-05-18 2024-05-18 boto@boto.pro boto@boto.pro flink-connector-jdbc-sqlserver/src/main/java/org/apache/flink/connector/jdbc/sqlserver/database/dialect/SqlServerDialect.java 118 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-sqlserver/src/main/java/org/apache/flink/connector/jdbc/sqlserver/database/dialect/SqlServerDialectConverter.java 25 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-sqlserver/src/main/java/org/apache/flink/connector/jdbc/sqlserver/database/SqlServerFactory.java 27 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/CompatiblePostgresDialect.java 23 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialectConverter.java 63 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialect.java 91 2 343 90 2 2 2024-05-30 2025-02-07 boto@boto.pro roseduan520@gmail.com flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/CompatiblePostgresDialectConverter.java 15 2 343 116 2 1 2024-05-30 2025-01-12 boto@boto.pro boto@boto.pro flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/PostgresFactory.java 29 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresTypeMapper.java 143 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresTablePath.java 69 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresCatalog.java 181 2 343 279 2 2 2024-05-30 2024-08-02 boto@boto.pro wanghechn@qq.com flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/MySqlFactory.java 28 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/dialect/MySqlDialect.java 91 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/dialect/MySQLDialectConverter.java 15 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/catalog/MySqlCatalog.java 147 2 343 279 2 2 2024-05-30 2024-08-02 boto@boto.pro wanghechn@qq.com flink-connector-jdbc-mysql/src/main/java/org/apache/flink/connector/jdbc/mysql/database/catalog/MySqlTypeMapper.java 172 1 343 343 1 1 2024-05-30 2024-05-30 boto@boto.pro boto@boto.pro