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-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/ConfigurationUtils.java 51 6 428 42 6 5 2024-03-06 2025-03-27 ruanhang1993@hotmail.com 18814118038@163.com flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/YamlParserUtils.java 195 2 380 379 2 2 2024-04-23 2024-04-24 1063410652@qq.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/FlinkEnvironmentUtils.java 29 6 428 42 6 5 2024-03-06 2025-03-27 ruanhang1993@hotmail.com 18814118038@163.com flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontend.java 197 7 428 42 7 7 2024-03-06 2025-03-27 ruanhang1993@hotmail.com 18814118038@163.com flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliExecutor.java 107 5 428 42 5 5 2024-03-06 2025-03-27 ruanhang1993@hotmail.com 18814118038@163.com flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java 286 11 428 42 12 7 2024-03-06 2025-03-27 ruanhang1993@hotmail.com 18814118038@163.com flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/PipelineDefinitionParser.java 8 3 428 42 3 3 2024-03-06 2025-03-27 ruanhang1993@hotmail.com 18814118038@163.com flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontendOptions.java 91 5 428 31 5 5 2024-03-06 2025-04-07 ruanhang1993@hotmail.com 56642952+lidoudou1993@users.noreply.github.com flink-cdc-pipeline-model/src/main/java/org/apache/flink/cdc/runtime/model/ModelOptions.java 25 1 163 163 1 1 2024-11-26 2024-11-26 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-pipeline-model/src/main/java/org/apache/flink/cdc/runtime/model/OpenAIChatModel.java 61 1 163 163 1 1 2024-11-26 2024-11-26 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-pipeline-model/src/main/java/org/apache/flink/cdc/runtime/model/OpenAIEmbeddingModel.java 71 1 163 163 1 1 2024-11-26 2024-11-26 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineExecution.java 23 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslator.java 179 8 428 16 8 5 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/SchemaOperatorTranslator.java 159 9 428 16 9 6 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/PartitioningTranslator.java 73 6 428 16 6 6 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSourceTranslator.java 69 7 428 16 7 5 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/TransformTranslator.java 111 12 414 15 13 7 2024-03-20 2025-04-23 32723967+wenmo@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposer.java 194 18 428 15 20 11 2024-03-06 2025-04-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/ComposeDeployment.java 36 1 42 42 1 1 2025-03-27 2025-03-27 18814118038@163.com 18814118038@163.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/YarnApplicationDeploymentExecutor.java 122 2 42 9 2 2 2025-03-27 2025-04-29 18814118038@163.com 149778446+joycurry30@users.noreply.github.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/K8SApplicationDeploymentExecutor.java 66 2 273 42 2 2 2024-08-08 2025-03-27 jam.gzczy@gmail.com 18814118038@163.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/coordination/OperatorIDGenerator.java 21 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkEnvironmentUtils.java 41 3 428 289 3 3 2024-03-06 2024-07-23 ruanhang1993@hotmail.com gongzhongqiang@apache.org flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/PipelineComposer.java 5 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/PipelineExecution.java 18 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/utils/FactoryDiscoveryUtils.java 83 4 428 269 4 3 2024-03-06 2024-08-12 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java 111 4 428 112 4 3 2024-03-06 2025-01-16 ruanhang1993@hotmail.com 18814118038@163.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java 79 2 428 273 2 2 2024-03-06 2024-08-08 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java 64 2 428 300 2 2 2024-03-06 2024-07-12 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java 52 1 163 163 1 1 2024-11-26 2024-11-26 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java 54 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java 143 6 428 16 6 4 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java 35 1 272 272 1 1 2024-08-09 2024-08-09 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/PipelineDeploymentExecutor.java 13 2 273 42 2 2 2024-08-08 2025-03-27 jam.gzczy@gmail.com 18814118038@163.com tools/ci/license_check.rb 84 3 379 175 3 2 2024-04-24 2024-11-14 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com tools/maven/suppressions.xml 11 10 1531 43 10 6 2021-02-27 2025-03-26 jark@apache.org 34335406+yuxiqian@users.noreply.github.com tools/cdcup/src/download_libs.rb 97 1 114 114 1 1 2025-01-14 2025-01-14 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com tools/cdcup/src/sink/doris.rb 27 1 114 114 1 1 2025-01-14 2025-01-14 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com tools/cdcup/src/sink/star_rocks.rb 25 1 114 114 1 1 2025-01-14 2025-01-14 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com tools/cdcup/src/sink/kafka.rb 38 1 114 114 1 1 2025-01-14 2025-01-14 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com tools/cdcup/src/sink/paimon.rb 15 1 114 114 1 1 2025-01-14 2025-01-14 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com tools/cdcup/src/sink/values_sink.rb 13 1 114 114 1 1 2025-01-14 2025-01-14 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com tools/cdcup/src/source/my_sql.rb 31 1 114 114 1 1 2025-01-14 2025-01-14 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com tools/cdcup/src/source/values_source.rb 14 1 114 114 1 1 2025-01-14 2025-01-14 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com tools/cdcup/src/app.rb 87 2 114 64 2 2 2025-01-14 2025-03-05 34335406+yuxiqian@users.noreply.github.com fcsaky@apache.org flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/ByteSerializer.java 57 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/IntSerializer.java 57 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/StringDataSerializer.java 74 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java 257 1 122 122 1 1 2025-01-06 2025-01-06 umeshdangat@users.noreply.github.com umeshdangat@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java 226 2 428 122 2 2 2024-03-06 2025-01-06 ruanhang1993@hotmail.com umeshdangat@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/util/MapDataUtil.java 22 1 122 122 1 1 2025-01-06 2025-01-06 umeshdangat@users.noreply.github.com umeshdangat@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/LocalZonedTimestampDataSerializer.java 138 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ZonedTimestampDataSerializer.java 141 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryWriter.java 111 2 428 122 2 2 2024-03-06 2025-01-06 ruanhang1993@hotmail.com umeshdangat@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/AbstractBinaryWriter.java 270 5 428 78 5 4 2024-03-06 2025-02-19 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriter.java 194 1 122 122 1 1 2025-01-06 2025-01-06 umeshdangat@users.noreply.github.com umeshdangat@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryRecordDataWriter.java 83 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/TimestampDataSerializer.java 133 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java 145 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/RecordDataSerializer.java 61 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/binary/BinaryRecordDataSerializer.java 117 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/binary/BinaryRecordDataDataUtil.java 34 1 122 122 1 1 2025-01-06 2025-01-06 umeshdangat@users.noreply.github.com umeshdangat@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/InternalSerializers.java 67 2 428 122 2 2 2024-03-06 2025-01-06 ruanhang1993@hotmail.com umeshdangat@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NestedSerializersSnapshotDelegate.java 102 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/TableIdSerializer.java 88 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/BooleanSerializer.java 58 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/LinkedListSerializer.java 190 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java 141 2 428 122 2 2 2024-03-06 2025-01-06 ruanhang1993@hotmail.com umeshdangat@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/FloatSerializer.java 57 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/DropTableEventSerializer.java 70 1 262 262 1 1 2024-08-19 2024-08-19 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/SchemaChangeEventSerializer.java 150 4 428 136 4 2 2024-03-06 2024-12-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/AddColumnEventSerializer.java 71 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/PartitioningEventSerializer.java 71 2 428 136 2 2 2024-03-06 2024-12-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/EventSerializer.java 121 3 428 119 3 3 2024-03-06 2025-01-09 ruanhang1993@hotmail.com 5797454@qq.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/AlterColumnTypeEventSerializer.java 80 2 428 262 2 2 2024-03-06 2024-08-19 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/RenameColumnEventSerializer.java 71 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/DropColumnEventSerializer.java 72 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/CreateTableEventSerializer.java 69 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/TruncateTableEventSerializer.java 70 1 262 262 1 1 2024-08-19 2024-08-19 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/DataChangeEventSerializer.java 135 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/BytePrimitiveArraySerializer.java 70 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/ColumnWithPositionSerializer.java 83 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/DataFieldSerializer.java 79 2 428 122 2 2 2024-03-06 2025-01-06 ruanhang1993@hotmail.com umeshdangat@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/RowTypeSerializer.java 76 2 428 122 2 2 2024-03-06 2025-01-06 ruanhang1993@hotmail.com umeshdangat@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/DataTypeSerializer.java 267 3 428 122 3 3 2024-03-06 2025-01-06 ruanhang1993@hotmail.com umeshdangat@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/ColumnSerializer.java 103 2 497 428 2 2 2023-12-28 2024-03-06 decq12ybhl@gmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/SchemaSerializer.java 107 4 497 336 4 4 2023-12-28 2024-06-06 decq12ybhl@gmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/PhysicalColumnSerializer.java 99 2 497 428 2 2 2023-12-28 2024-03-06 decq12ybhl@gmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/MetadataColumnSerializer.java 78 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/ListSerializer.java 120 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/EnumSerializer.java 201 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/StringSerializer.java 59 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/ShortSerializer.java 57 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/TypeSerializerSingleton.java 17 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/MapSerializer.java 154 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/DoubleSerializer.java 58 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/LongSerializer.java 57 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformFilterProcessor.java 168 8 414 15 9 5 2024-03-20 2025-04-23 32723967+wenmo@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java 84 3 414 42 3 3 2024-03-20 2025-03-27 32723967+wenmo@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformChangeInfo.java 95 2 273 15 2 1 2024-08-08 2025-04-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformProjectionProcessor.java 73 7 414 15 8 4 2024-03-20 2025-04-23 32723967+wenmo@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/ProjectionColumn.java 112 5 414 42 5 3 2024-03-20 2025-03-27 32723967+wenmo@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperator.java 398 15 273 15 16 5 2024-08-08 2025-04-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/exceptions/TransformException.java 68 1 42 42 1 1 2025-03-27 2025-03-27 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/ProjectionColumnProcessor.java 133 10 414 15 11 5 2024-03-20 2025-04-23 32723967+wenmo@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperatorBuilder.java 66 1 15 15 1 1 2025-04-23 2025-04-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformProcessor.java 35 3 273 114 3 3 2024-08-08 2025-01-14 34335406+yuxiqian@users.noreply.github.com 72908278+chaomingzhangcn@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/SchemaMetadataTransform.java 53 1 414 414 1 1 2024-03-20 2024-03-20 32723967+wenmo@users.noreply.github.com 32723967+wenmo@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperator.java 390 15 273 15 15 4 2024-08-08 2025-04-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperatorBuilder.java 61 1 15 15 1 1 2025-04-23 2025-04-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformContext.java 45 1 15 15 1 1 2025-04-23 2025-04-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformChangeInfo.java 130 2 273 114 2 2 2024-08-08 2025-01-14 34335406+yuxiqian@users.noreply.github.com 72908278+chaomingzhangcn@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/converter/PostTransformConverter.java 9 1 140 140 1 1 2024-12-19 2024-12-19 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/converter/PostTransformConverters.java 20 1 140 140 1 1 2024-12-19 2024-12-19 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/converter/SoftDeleteConverter.java 17 1 140 140 1 1 2024-12-19 2024-12-19 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformer.java 26 1 273 273 1 1 2024-08-08 2024-08-08 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformFilter.java 72 5 414 15 5 3 2024-03-20 2025-04-23 32723967+wenmo@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionCompiler.java 50 5 414 42 5 3 2024-03-20 2025-03-27 32723967+wenmo@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformer.java 40 4 273 15 4 2 2024-08-08 2025-04-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformRule.java 61 5 273 15 5 3 2024-08-08 2025-04-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformProjection.java 40 3 414 15 3 3 2024-03-20 2025-04-23 32723967+wenmo@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java 134 3 272 15 3 2 2024-08-09 2025-04-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed/SchemaCoordinator.java 362 2 136 17 2 1 2024-12-23 2025-04-21 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed/event/SchemaChangeRequest.java 46 2 136 17 2 1 2024-12-23 2025-04-21 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed/event/SchemaChangeResponse.java 47 2 136 17 2 1 2024-12-23 2025-04-21 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed/SchemaOperator.java 176 4 136 17 4 3 2024-12-23 2025-04-21 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed/SchemaOperatorFactory.java 47 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed/SchemaCoordinatorProvider.java 56 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/metrics/SchemaOperatorMetrics.java 49 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/CoordinatorExecutorThreadFactory.java 34 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaDerivator.java 321 3 136 16 3 3 2024-12-23 2025-04-22 34335406+yuxiqian@users.noreply.github.com 809097465@qq.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java 290 2 136 16 2 2 2024-12-23 2025-04-22 34335406+yuxiqian@users.noreply.github.com 809097465@qq.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/event/SinkWriterRegisterEvent.java 29 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/event/GetEvolvedSchemaRequest.java 33 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/event/GetOriginalSchemaRequest.java 33 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/event/GetEvolvedSchemaResponse.java 17 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/event/FlushSuccessEvent.java 43 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/event/GetOriginalSchemaResponse.java 17 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaRegistry.java 285 3 136 14 4 4 2024-12-23 2025-04-24 34335406+yuxiqian@users.noreply.github.com lvyanquan.lyq@alibaba-inc.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/TableIdRouter.java 86 2 136 16 2 2 2024-12-23 2025-04-22 34335406+yuxiqian@users.noreply.github.com 809097465@qq.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/CoordinationResponseUtils.java 122 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaCoordinator.java 367 4 136 9 4 2 2024-12-23 2025-04-29 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/BatchSchemaOperator.java 134 1 16 16 1 1 2025-04-22 2025-04-22 809097465@qq.com 809097465@qq.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/event/SchemaChangeRequest.java 56 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/event/SchemaChangeResponse.java 52 2 136 64 2 1 2024-12-23 2025-03-05 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaOperator.java 185 6 136 9 6 4 2024-12-23 2025-04-29 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaOperatorFactory.java 45 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaCoordinatorProvider.java 56 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/SchemaEvolutionClient.java 56 3 428 136 3 2 2024-03-06 2024-12-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkWriterOperatorFactory.java 57 2 428 16 2 2 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkFunctionOperator.java 103 5 394 42 5 3 2024-04-09 2025-03-27 125648852+loserwang1024@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/exception/SinkWrapperException.java 7 1 42 42 1 1 2025-03-27 2025-03-27 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/BatchDataSinkFunctionOperator.java 24 1 16 16 1 1 2025-04-22 2025-04-22 809097465@qq.com 809097465@qq.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkWriterOperator.java 207 7 428 42 7 5 2024-03-06 2025-03-27 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/BatchDataSinkWriterOperator.java 141 1 16 16 1 1 2025-04-22 2025-04-22 809097465@qq.com 809097465@qq.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/DistributedPrePartitionOperator.java 86 2 136 112 2 2 2024-12-23 2025-01-16 34335406+yuxiqian@users.noreply.github.com 72908278+chaomingzhangcn@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEventKeySelector.java 10 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java 59 2 428 136 2 2 2024-03-06 2024-12-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PostPartitionProcessor.java 11 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/BatchRegularPrePartitionOperator.java 93 1 16 16 1 1 2025-04-22 2025-04-22 809097465@qq.com 809097465@qq.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/EventPartitioner.java 16 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/RegularPrePartitionOperator.java 115 1 136 136 1 1 2024-12-23 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/BuiltInTimestampFunction.java 25 1 414 414 1 1 2024-03-20 2024-03-20 32723967+wenmo@users.noreply.github.com 32723967+wenmo@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/SystemFunctionUtils.java 902 11 414 13 13 5 2024-03-20 2025-04-25 32723967+wenmo@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/BuiltInScalarFunction.java 136 2 414 269 2 2 2024-03-20 2024-08-12 32723967+wenmo@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/metadata/TransformSqlOperatorTable.java 309 6 414 115 7 6 2024-03-20 2025-01-13 32723967+wenmo@users.noreply.github.com 809097465@qq.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/metadata/TransformSqlReturnTypes.java 134 2 414 182 2 2 2024-03-20 2024-11-07 32723967+wenmo@users.noreply.github.com 32723967+aiwenmo@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/metadata/TransformSchema.java 18 1 414 414 1 1 2024-03-20 2024-03-20 32723967+wenmo@users.noreply.github.com 32723967+wenmo@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/metadata/TransformNumericExceptFirstOperandChecker.java 60 1 414 414 1 1 2024-03-20 2024-03-20 32723967+wenmo@users.noreply.github.com 32723967+wenmo@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/metadata/TransformSchemaFactory.java 23 1 414 414 1 1 2024-03-20 2024-03-20 32723967+wenmo@users.noreply.github.com 32723967+wenmo@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/metadata/MetadataColumns.java 18 1 268 268 1 1 2024-08-13 2024-08-13 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/metadata/TransformTable.java 22 3 414 113 3 3 2024-03-20 2025-01-15 32723967+wenmo@users.noreply.github.com 809097465@qq.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/TransformParser.java 512 17 414 15 17 8 2024-03-20 2025-04-23 32723967+wenmo@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/JaninoCompiler.java 544 12 414 13 12 5 2024-03-20 2025-04-25 32723967+wenmo@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/EventTypeInfo.java 53 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/BinaryRecordDataExtractor.java 104 1 42 42 1 1 2025-03-27 2025-03-27 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/DataTypeConverter.java 791 5 414 113 5 4 2024-03-20 2025-01-15 32723967+wenmo@users.noreply.github.com 809097465@qq.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/BinaryRecordDataGenerator.java 57 3 428 122 3 3 2024-03-06 2025-01-06 ruanhang1993@hotmail.com umeshdangat@users.noreply.github.com flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/PartitioningEventTypeInfo.java 54 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/DecimalData.java 113 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ZonedTimestampData.java 110 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/TimestampData.java 85 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java 108 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/LocalZonedTimestampData.java 94 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/StringData.java 9 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/MapData.java 9 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericMapData.java 74 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java 118 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryMapData.java 73 1 122 122 1 1 2025-01-06 2025-01-06 umeshdangat@users.noreply.github.com umeshdangat@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java 433 1 122 122 1 1 2025-01-06 2025-01-06 umeshdangat@users.noreply.github.com umeshdangat@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java 52 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryRecordData.java 205 3 428 122 3 2 2024-03-06 2025-01-06 ruanhang1993@hotmail.com umeshdangat@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/MurmurHashUtils.java 107 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/NullAwareGetters.java 7 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java 779 2 428 122 2 2 2024-03-06 2025-01-06 ruanhang1993@hotmail.com umeshdangat@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryFormat.java 12 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java 615 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/LazyBinaryFormat.java 66 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java 230 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/RuntimeExecutionMode.java 7 1 16 16 1 1 2025-04-22 2025-04-22 809097465@qq.com 809097465@qq.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/SchemaChangeBehavior.java 10 2 428 273 2 2 2024-03-06 2024-08-08 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java 76 6 428 16 6 4 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/TimeUtils.java 139 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/Preconditions.java 75 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/TypeCheckUtils.java 94 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/StringUtf8Utils.java 195 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/DateTimeUtils.java 181 4 414 115 4 3 2024-03-20 2025-01-13 32723967+wenmo@users.noreply.github.com 809097465@qq.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/ChangeEventUtils.java 88 4 387 255 4 2 2024-04-16 2024-08-26 renqschn@gmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaMergingUtils.java 818 3 136 15 3 2 2024-12-23 2025-04-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/Predicates.java 143 2 428 331 2 2 2024-03-06 2024-06-11 ruanhang1993@hotmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaUtils.java 488 12 428 15 12 4 2024-03-06 2025-04-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/ThreadLocalCache.java 50 1 414 414 1 1 2024-03-20 2024-03-20 32723967+wenmo@users.noreply.github.com 32723967+wenmo@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/StringUtils.java 34 2 428 414 2 2 2024-03-06 2024-03-20 ruanhang1993@hotmail.com 32723967+wenmo@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/EncodingUtils.java 14 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/InstantiationUtil.java 185 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/TestCaseUtils.java 58 1 115 115 1 1 2025-01-13 2025-01-13 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java 357 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/ParsingException.java 20 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/Position.java 48 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/exceptions/UnsupportedSchemaChangeEventException.java 29 2 273 259 2 2 2024-08-08 2024-08-22 34335406+yuxiqian@users.noreply.github.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/exceptions/SchemaEvolveException.java 42 2 273 259 2 2 2024-08-08 2024-08-22 34335406+yuxiqian@users.noreply.github.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/Internal.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/VisibleForTesting.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/Experimental.java 19 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/PublicEvolving.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/Public.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/FactoryHelper.java 131 3 428 42 3 3 2024-03-06 2025-03-27 ruanhang1993@hotmail.com hx0698@gmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/DataSourceFactory.java 7 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/DataSinkFactory.java 7 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/Factory.java 17 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeFamily.java 20 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java 67 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java 61 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java 83 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java 83 2 428 392 2 2 2024-03-06 2024-04-11 ruanhang1993@hotmail.com zhongqishang@gmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java 74 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java 71 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/utils/runtime/DataInputViewStream.java 38 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/utils/runtime/DataOutputViewStream.java 18 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/utils/DataTypeUtils.java 168 4 428 176 4 4 2024-03-06 2024-11-13 ruanhang1993@hotmail.com hx0698@gmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BigIntType.java 31 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DateType.java 31 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java 83 2 428 402 2 2 2024-03-06 2024-04-01 ruanhang1993@hotmail.com zhongqishang@gmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeRoot.java 57 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TinyIntType.java 31 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/FloatType.java 31 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java 67 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java 74 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java 74 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DoubleType.java 31 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/SmallIntType.java 31 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java 174 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeVisitor.java 25 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java 71 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeDefaultVisitor.java 86 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/IntType.java 31 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java 164 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java 83 2 428 392 2 2 2024-03-06 2024-04-11 ruanhang1993@hotmail.com zhongqishang@gmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java 72 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BooleanType.java 31 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeChecks.java 158 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/route/RouteRule.java 16 2 300 136 2 1 2024-07-12 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/udf/UserDefinedFunctionContext.java 5 1 163 163 1 1 2024-11-26 2024-11-26 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/udf/UserDefinedFunction.java 15 2 272 163 2 2 2024-08-09 2024-11-26 34335406+yuxiqian@users.noreply.github.com lvyanquan.lyq@alibaba-inc.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/function/HashFunctionProvider.java 12 1 293 293 1 1 2024-07-19 2024-07-19 xbjtdcq@gmail.com xbjtdcq@gmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/function/HashFunction.java 6 1 293 293 1 1 2024-07-19 2024-07-19 xbjtdcq@gmail.com xbjtdcq@gmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/SchemaChangeEventWithPreSchema.java 11 1 262 262 1 1 2024-08-19 2024-08-19 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/SchemaChangeEvent.java 8 3 428 136 3 2 2024-03-06 2024-12-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/SchemaChangeEventType.java 58 3 273 255 3 1 2024-08-08 2024-08-26 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AddColumnEvent.java 126 4 428 136 4 3 2024-03-06 2024-12-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DataChangeEvent.java 183 5 428 15 5 3 2024-03-06 2025-04-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/ChangeEvent.java 6 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/RenameColumnEventVisitor.java 8 1 262 262 1 1 2024-08-19 2024-08-19 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/SchemaChangeEventVisitor.java 63 1 262 262 1 1 2024-08-19 2024-08-19 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/DropColumnEventVisitor.java 8 1 262 262 1 1 2024-08-19 2024-08-19 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/CreateTableEventVisitor.java 8 1 262 262 1 1 2024-08-19 2024-08-19 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/AlterColumnTypeEventVisitor.java 8 1 262 262 1 1 2024-08-19 2024-08-19 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/AddColumnEventVisitor.java 8 1 262 262 1 1 2024-08-19 2024-08-19 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/TruncateTableEventVisitor.java 8 1 262 262 1 1 2024-08-19 2024-08-19 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/DropTableEventVisitor.java 8 1 262 262 1 1 2024-08-19 2024-08-19 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/OperationType.java 9 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DropTableEvent.java 43 2 262 136 2 1 2024-08-19 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/RenameColumnEvent.java 49 4 428 136 4 2 2024-03-06 2024-12-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/CreateTableEvent.java 49 3 428 136 3 2 2024-03-06 2024-12-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java 82 2 428 136 2 2 2024-03-06 2024-12-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/FlushEvent.java 53 3 428 119 3 3 2024-03-06 2025-01-09 ruanhang1993@hotmail.com 5797454@qq.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DropColumnEvent.java 54 3 428 136 3 2 2024-03-06 2024-12-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/Event.java 4 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AlterColumnTypeEvent.java 109 4 428 136 4 2 2024-03-06 2024-12-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/EventDeserializer.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TruncateTableEvent.java 43 2 262 136 2 1 2024-08-19 2024-12-23 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/SchemaChangeEventTypeFamily.java 53 2 273 262 2 1 2024-08-08 2024-08-19 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Selectors.java 85 2 428 331 2 2 2024-03-06 2024-06-11 ruanhang1993@hotmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/TableFilter.java 13 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java 291 7 497 9 7 6 2023-12-28 2025-04-29 decq12ybhl@gmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/MetadataColumn.java 49 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Column.java 134 2 497 428 2 2 2023-12-28 2024-03-06 decq12ybhl@gmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/PhysicalColumn.java 27 2 497 428 2 2 2023-12-28 2024-03-06 decq12ybhl@gmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/MetadataApplier.java 26 3 428 112 3 3 2024-03-06 2025-01-16 ruanhang1993@hotmail.com morozov@tut.by flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/FlinkSinkProvider.java 11 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/EventSinkProvider.java 6 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DefaultDataChangeEventHashFunctionProvider.java 66 1 293 293 1 1 2024-07-19 2024-07-19 xbjtdcq@gmail.com xbjtdcq@gmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/FlinkSinkFunctionProvider.java 11 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DataSink.java 16 4 428 269 4 4 2024-03-06 2024-08-12 ruanhang1993@hotmail.com lvyanquan.lyq@alibaba-inc.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/FlinkSourceProvider.java 11 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/SupportedMetadataColumn.java 13 1 139 139 1 1 2024-12-20 2024-12-20 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/DataSource.java 15 3 428 136 3 2 2024-03-06 2024-12-23 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/FlinkSourceFunctionProvider.java 11 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/MetadataAccessor.java 13 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/EventSourceProvider.java 6 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/FallbackKey.java 40 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigurationUtils.java 240 2 428 275 2 2 2024-03-06 2024-08-06 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOptions.java 86 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOption.java 109 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/LineBreakElement.java 13 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/TextElement.java 48 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/LinkElement.java 27 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/Formatter.java 67 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/Description.java 45 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/ListElement.java 21 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/DescriptionElement.java 6 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/HtmlFormatter.java 44 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/BlockElement.java 4 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/InlineElement.java 4 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java 214 2 428 328 2 2 2024-03-06 2024-06-14 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/StructuredOptionsSplitter.java 131 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkOptions.java 49 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSink.java 44 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/TableSchemaWrapper.java 20 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/WriteResultWrapper.java 41 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergWriter.java 143 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/compaction/CompactionOptions.java 48 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/compaction/CompactionOperator.java 115 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/WriteResultWrapperSerializer.java 37 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/TableMetric.java 13 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergSink.java 121 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergCommitter.java 115 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/OptionUtils.java 16 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/IcebergTypeUtils.java 169 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/RowDataUtils.java 38 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergMetadataApplier.java 244 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactory.java 92 1 17 17 1 1 2025-04-21 2025-04-21 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplier.java 271 5 497 114 5 3 2023-12-28 2025-01-14 decq12ybhl@gmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.java 294 3 497 392 4 3 2023-12-28 2024-04-11 decq12ybhl@gmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksEnrichedCatalog.java 75 1 114 114 1 1 2025-01-14 2025-01-14 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/EventRecordSerializationSchema.java 109 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSinkOptions.java 106 2 428 57 2 2 2024-03-06 2025-03-12 ruanhang1993@hotmail.com 72908278+chaomingzhangcn@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSinkFactory.java 146 4 428 57 4 4 2024-03-06 2025-03-12 ruanhang1993@hotmail.com 72908278+chaomingzhangcn@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/TableCreateConfig.java 46 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/SchemaChangeConfig.java 24 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSink.java 49 3 428 114 3 3 2024-03-06 2025-01-14 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/ValuesDatabase.java 422 5 428 259 5 4 2024-03-06 2024-08-22 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/sink/ValuesDataSinkFunction.java 64 1 394 394 1 1 2024-04-09 2024-04-09 125648852+loserwang1024@users.noreply.github.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/sink/ValuesDataSinkHelper.java 56 3 428 113 3 3 2024-03-06 2025-01-15 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/sink/ValuesDataSink.java 130 3 428 273 3 3 2024-03-06 2024-08-08 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/sink/ValuesDataSinkOptions.java 28 3 428 273 3 3 2024-03-06 2024-08-08 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/ValuesDataSource.java 267 4 428 58 4 3 2024-03-06 2025-03-11 ruanhang1993@hotmail.com hx0698@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/OpTsMetadataColumn.java 26 1 139 139 1 1 2024-12-20 2024-12-20 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/ValuesDataSourceOptions.java 41 3 428 16 3 3 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/ValuesDataSourceHelper.java 937 7 428 16 7 6 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/TimestampTypeMetadataColumn.java 23 1 58 58 1 1 2025-03-11 2025-03-11 hx0698@gmail.com hx0698@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/factory/ValuesDataFactory.java 90 5 428 16 5 4 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/utils/KafkaSinkUtils.java 27 1 112 112 1 1 2025-01-16 2025-01-16 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/utils/JsonRowDataSerializationSchemaUtils.java 101 2 115 31 2 1 2025-01-13 2025-04-07 18814118038@163.com 18814118038@163.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/TableSchemaInfo.java 159 3 380 178 3 1 2024-04-23 2024-11-11 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/ChangeLogJsonFormatFactory.java 66 5 380 29 5 3 2024-04-23 2025-04-09 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/canal/CanalJsonSerializationSchema.java 190 6 380 115 6 3 2024-04-23 2025-01-13 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java 106 1 31 31 1 1 2025-04-07 2025-04-07 18814118038@163.com 18814118038@163.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonStruct.java 53 1 31 31 1 1 2025-04-07 2025-04-07 18814118038@163.com 18814118038@163.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonSerializationSchema.java 343 6 380 31 6 3 2024-04-23 2025-04-07 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/JsonSerializationType.java 17 1 380 380 1 1 2024-04-23 2024-04-23 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSink.java 73 5 380 112 5 2 2024-04-23 2025-01-16 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/PartitionStrategy.java 14 1 272 272 1 1 2024-08-09 2024-08-09 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSinkOptions.java 76 5 380 29 5 2 2024-04-23 2025-04-09 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSinkFactory.java 109 8 380 29 8 5 2024-04-23 2025-04-09 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/PipelineKafkaRecordSerializationSchema.java 120 3 380 112 3 1 2024-04-23 2025-01-16 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KeyFormat.java 15 1 272 272 1 1 2024-08-09 2024-08-09 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KeySerializationFactory.java 48 2 272 115 2 2 2024-08-09 2025-01-13 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaMetaDataApplier.java 29 1 262 262 1 1 2024-08-19 2024-08-19 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/serialization/CsvSerializationSchema.java 84 1 272 272 1 1 2024-08-09 2024-08-09 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/serialization/JsonSerializationSchema.java 109 2 272 115 2 2 2024-08-09 2025-01-13 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/utils/ListUtils.java 12 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/utils/OptionUtils.java 16 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseDataSink.java 38 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseEventSerializationSchema.java 126 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseDataSinkOptions.java 78 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseRowConvert.java 149 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseUtils.java 250 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseMetadataApplier.java 152 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/factory/OceanBaseDataSinkFactory.java 59 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java 179 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseCatalogFactory.java 23 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseCatalogException.java 12 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java 155 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseCatalog.java 68 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseMySQLCatalog.java 417 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseOracleCatalog.java 68 1 122 122 1 1 2025-01-06 2025-01-06 zhao137578346@gmail.com zhao137578346@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonDataSink.java 55 2 379 269 2 1 2024-04-24 2024-08-12 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonRecordEventSerializer.java 62 4 379 59 4 1 2024-04-24 2025-03-10 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/StoreSinkWriteImpl.java 178 4 379 119 4 1 2024-04-24 2025-01-09 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonRecordSerializer.java 6 1 379 379 1 1 2024-04-24 2024-04-24 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/TableSchemaInfo.java 19 1 379 379 1 1 2024-04-24 2024-04-24 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSink.java 66 5 379 115 5 2 2024-04-24 2025-01-13 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/MultiTableCommittableChannelComputer.java 33 2 379 261 2 2 2024-04-24 2024-08-20 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonCommitter.java 59 4 379 119 4 2 2024-04-24 2025-01-09 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriter.java 171 8 379 35 8 2 2024-04-24 2025-04-03 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/OperatorIDGenerator.java 21 1 269 269 1 1 2024-08-12 2024-08-12 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonEvent.java 55 3 379 59 3 1 2024-04-24 2025-03-10 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriterHelper.java 293 4 379 59 4 2 2024-04-24 2025-03-10 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonEventSink.java 58 3 269 35 3 1 2024-08-12 2025-04-03 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PreCommitOperator.java 98 3 379 43 3 1 2024-04-24 2025-03-26 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperEventTypeInfo.java 53 1 269 269 1 1 2024-08-12 2024-08-12 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperEventSerializer.java 101 4 269 115 4 3 2024-08-12 2025-01-13 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperChangeEvent.java 48 1 269 269 1 1 2024-08-12 2024-08-12 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapper.java 6 1 269 269 1 1 2024-08-12 2024-08-12 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketAssignOperator.java 191 5 269 115 6 3 2024-08-12 2025-01-13 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/FlushEventAlignmentOperator.java 60 1 115 115 1 1 2025-01-13 2025-01-13 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java 57 4 269 115 4 3 2024-08-12 2025-01-13 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/SchemaChangeProvider.java 95 2 337 114 2 2 2024-06-05 2025-01-14 149778446+joycurry30@users.noreply.github.com 39675622+hiliuxg@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java 316 9 379 64 13 8 2024-04-24 2025-03-05 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonHashFunctionProvider.java 23 1 269 269 1 1 2024-08-12 2024-08-12 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonDataSinkOptions.java 36 2 379 328 2 2 2024-04-24 2024-06-14 lvyanquan.lyq@alibaba-inc.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonDataSinkFactory.java 104 5 379 115 5 2 2024-04-24 2025-01-13 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonHashFunction.java 54 2 269 57 2 1 2024-08-12 2025-03-12 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/options/MaxComputeOptions.java 102 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/options/CompressAlgorithm.java 19 1 114 114 1 1 2025-01-14 2025-01-14 72908278+chaomingzhangcn@users.noreply.github.com 72908278+chaomingzhangcn@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/options/MaxComputeWriteOptions.java 65 2 120 114 2 2 2025-01-08 2025-01-14 50667759+dingxin-tech@users.noreply.github.com 72908278+chaomingzhangcn@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/MaxComputeDataSinkOptions.java 75 2 120 114 2 2 2025-01-08 2025-01-14 50667759+dingxin-tech@users.noreply.github.com 72908278+chaomingzhangcn@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java 447 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/MaxComputeUtils.java 225 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/RetryUtils.java 80 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/SchemaEvolutionUtils.java 209 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/SessionCommitCoordinateHelper.java 92 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java 84 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/UncheckedOdpsException.java 18 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/FlinkOdpsException.java 13 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/Constant.java 9 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/MaxComputeDataSink.java 31 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/MaxComputeDataSinkFactory.java 96 2 120 114 2 2 2025-01-08 2025-01-14 50667759+dingxin-tech@users.noreply.github.com 72908278+chaomingzhangcn@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/sink/MaxComputeEventSink.java 37 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/sink/MaxComputeEventWriter.java 145 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/sink/MaxComputeHashFunctionProvider.java 74 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageCoordinator.java 232 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageOperator.java 238 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageCoordinatedOperatorFactory.java 58 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/message/CommitSessionResponse.java 12 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/message/CreateSessionRequest.java 16 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/message/SyncRequest.java 12 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/message/CommitSessionRequest.java 27 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/message/CreateSessionResponse.java 12 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/message/WaitForFlushSuccessRequest.java 17 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/writer/BatchUpsertWriter.java 132 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/writer/MaxComputeWriter.java 27 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/writer/BatchAppendWriter.java 98 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/MaxComputeMetadataApplier.java 95 1 120 120 1 1 2025-01-08 2025-01-08 50667759+dingxin-tech@users.noreply.github.com 50667759+dingxin-tech@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/utils/DorisSchemaUtils.java 90 1 16 16 1 1 2025-04-22 2025-04-22 37775475+qg-lin@users.noreply.github.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisDataSinkOptions.java 153 3 428 16 3 2 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisEventSerializer.java 129 3 428 16 3 3 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisSchemaChangeManager.java 23 3 114 31 3 3 2025-01-14 2025-04-07 34335406+yuxiqian@users.noreply.github.com 2795267041@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisDataSink.java 54 2 428 16 2 2 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisRowConverter.java 145 2 428 112 2 2 2024-03-06 2025-01-16 ruanhang1993@hotmail.com xiaowenli@selectdb.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java 273 9 497 16 9 5 2023-12-28 2025-04-22 decq12ybhl@gmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/factory/DorisDataSinkFactory.java 136 4 428 16 4 3 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/serializer/ElasticsearchEventSerializer.java 208 3 300 90 3 2 2024-07-12 2025-02-07 1027914152@qq.com beryllwang@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/serializer/ElasticsearchRowConverter.java 149 2 300 279 2 1 2024-07-12 2024-08-02 1027914152@qq.com 1027914152@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/serializer/Elasticsearch6RequestCreator.java 27 1 279 279 1 1 2024-08-02 2024-08-02 1027914152@qq.com 1027914152@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Elasticsearch8AsyncSink.java 67 2 300 279 2 1 2024-07-12 2024-08-02 1027914152@qq.com 1027914152@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Operation.java 22 2 300 279 2 1 2024-07-12 2024-08-02 1027914152@qq.com 1027914152@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/NetworkConfig.java 78 2 300 279 2 1 2024-07-12 2024-08-02 1027914152@qq.com 1027914152@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/OperationSerializer.java 44 2 300 279 2 1 2024-07-12 2024-08-02 1027914152@qq.com 1027914152@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Elasticsearch8AsyncWriter.java 157 2 300 279 2 1 2024-07-12 2024-08-02 1027914152@qq.com 1027914152@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Elasticsearch8AsyncSinkBuilder.java 132 2 300 279 2 1 2024-07-12 2024-08-02 1027914152@qq.com 1027914152@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Elasticsearch8AsyncSinkSerializer.java 18 2 300 279 2 1 2024-07-12 2024-08-02 1027914152@qq.com 1027914152@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/config/ElasticsearchSinkOptions.java 113 3 300 90 3 2 2024-07-12 2025-02-07 1027914152@qq.com beryllwang@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkFactory.java 159 3 300 90 3 2 2024-07-12 2025-02-07 1027914152@qq.com beryllwang@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSink.java 108 4 300 90 4 2 2024-07-12 2025-02-07 1027914152@qq.com beryllwang@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkOptions.java 74 3 300 90 3 2 2024-07-12 2025-02-07 1027914152@qq.com beryllwang@gmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/utils/MySqlTypeUtils.java 211 4 428 112 4 4 2024-03-06 2025-01-16 ruanhang1993@hotmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/utils/MySqlSchemaUtils.java 113 2 428 112 2 2 2024-03-06 2025-01-16 ruanhang1993@hotmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java 267 13 428 57 14 10 2024-03-06 2025-03-12 ruanhang1993@hotmail.com 1365976815@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/OpTsMetadataColumn.java 26 1 139 139 1 1 2024-12-20 2024-12-20 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSchemaDataTypeInference.java 20 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSource.java 73 4 428 112 5 3 2024-03-06 2025-01-16 ruanhang1993@hotmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomMySqlAntlrDdlParserListener.java 92 2 428 112 2 2 2024-03-06 2025-01-16 ruanhang1993@hotmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomColumnDefinitionParserListener.java 267 2 428 253 2 2 2024-03-06 2024-08-28 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomMySqlAntlrDdlParser.java 260 2 428 112 3 2 2024-03-06 2025-01-16 ruanhang1993@hotmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomAlterTableParserListener.java 380 8 497 111 8 6 2023-12-28 2025-01-17 decq12ybhl@gmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlPipelineRecordEmitter.java 231 7 497 16 8 7 2023-12-28 2025-04-22 decq12ybhl@gmail.com 809097465@qq.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlEventDeserializer.java 152 3 428 112 4 2 2024-03-06 2025-01-16 ruanhang1993@hotmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlMetadataAccessor.java 36 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java 461 18 428 16 19 11 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/WatermarkDispatcher.java 15 1 114 114 1 1 2025-01-14 2025-01-14 125648852+loserwang1024@users.noreply.github.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupMode.java 10 2 428 13 2 2 2024-03-06 2025-04-25 ruanhang1993@hotmail.com vinh.pham@shopback.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java 89 2 428 13 2 2 2024-03-06 2025-04-25 ruanhang1993@hotmail.com vinh.pham@shopback.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/SourceOptions.java 116 4 428 57 4 4 2024-03-06 2025-03-12 ruanhang1993@hotmail.com 1365976815@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/JdbcSourceOptions.java 80 2 428 288 2 2 2024-03-06 2024-07-24 ruanhang1993@hotmail.com semicpu@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/relational/connection/ConnectionPoolId.java 59 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/relational/connection/ConnectionPools.java 7 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/relational/connection/JdbcConnectionPools.java 65 2 428 275 2 2 2024-03-06 2024-08-06 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/relational/connection/JdbcConnectionFactory.java 52 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/relational/connection/JdbcConnectionPoolFactory.java 40 2 428 346 2 2 2024-03-06 2024-05-27 ruanhang1993@hotmail.com hx0698@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/relational/handler/SchemaChangeEventHandler.java 8 2 428 380 2 2 2024-03-06 2024-04-23 ruanhang1993@hotmail.com @users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/relational/JdbcSourceEventDispatcher.java 210 3 428 114 3 3 2024-03-06 2025-01-14 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/VersionComparable.java 76 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/OptionUtils.java 16 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/EnvironmentUtils.java 19 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/SourceRecordUtils.java 151 2 428 153 2 2 2024-03-06 2024-12-06 ruanhang1993@hotmail.com 754089893@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/ObjectUtils.java 75 2 428 289 2 2 2024-03-06 2024-07-23 ruanhang1993@hotmail.com gongzhongqiang@apache.org flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/SerializerUtils.java 59 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/dialect/DataSourceDialect.java 35 4 428 13 4 3 2024-03-06 2025-04-25 ruanhang1993@hotmail.com vinh.pham@shopback.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/dialect/JdbcDataSourceDialect.java 29 2 428 275 2 2 2024-03-06 2024-08-06 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/SourceConfig.java 19 3 428 63 3 3 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/JdbcSourceConfig.java 127 3 428 63 3 3 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/JdbcSourceConfigFactory.java 147 5 428 13 5 5 2024-03-06 2025-04-25 ruanhang1993@hotmail.com vinh.pham@shopback.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/BaseSourceConfig.java 86 3 428 63 3 3 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceReaderMetrics.java 177 3 428 153 3 3 2024-03-06 2024-12-06 ruanhang1993@hotmail.com 754089893@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceEnumeratorMetrics.java 189 1 153 153 1 1 2024-12-06 2024-12-06 754089893@qq.com 754089893@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/StreamSplitAssigner.java 156 5 428 13 5 5 2024-03-06 2025-04-25 ruanhang1993@hotmail.com vinh.pham@shopback.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/HybridSplitAssigner.java 235 4 428 107 4 4 2024-03-06 2025-01-21 ruanhang1993@hotmail.com gongzhongqiang@apache.org flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/HybridPendingSplitsState.java 42 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/StreamPendingSplitsState.java 30 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/ChunkSplitterState.java 108 1 142 142 1 1 2024-12-17 2024-12-17 125648852+loserwang1024@users.noreply.github.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/PendingSplitsState.java 5 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/SnapshotPendingSplitsState.java 140 3 428 142 3 3 2024-03-06 2024-12-17 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/PendingSplitsStateSerializer.java 395 5 428 142 5 5 2024-03-06 2024-12-17 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java 585 8 428 30 8 4 2024-03-06 2025-04-08 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SplitAssigner.java 29 2 428 275 2 2 2024-03-06 2024-08-06 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java 398 10 428 16 11 8 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 131222468+linjianchang@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkSplitter.java 15 2 428 142 2 2 2024-03-06 2024-12-17 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/ChunkRange.java 53 2 428 30 2 2 2024-03-06 2025-04-08 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/AssignerStatus.java 135 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/EmbeddedFlinkDatabaseHistory.java 113 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/JdbcChunkUtils.java 80 2 279 20 2 2 2024-08-02 2025-04-18 125648852+loserwang1024@users.noreply.github.com semicpu@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/hooks/SnapshotPhaseHook.java 11 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/hooks/SnapshotPhaseHooks.java 41 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/enumerator/IncrementalSourceEnumerator.java 281 4 428 146 4 3 2024-03-06 2024-12-13 ruanhang1993@hotmail.com genzhedangdang@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceReaderContext.java 30 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceReader.java 431 3 428 14 3 3 2024-03-06 2025-04-24 ruanhang1993@hotmail.com genzhedangdang@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceSplitReader.java 234 2 428 13 2 2 2024-03-06 2025-04-25 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceRecordEmitter.java 146 3 428 153 3 3 2024-03-06 2024-12-06 ruanhang1993@hotmail.com 754089893@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceReaderWithCommit.java 71 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/IncrementalSource.java 191 2 428 153 2 2 2024-03-06 2024-12-06 ruanhang1993@hotmail.com 754089893@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/jdbc/JdbcIncrementalSource.java 16 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/offset/OffsetDeserializerSerializer.java 95 2 428 107 2 2 2024-03-06 2025-01-21 ruanhang1993@hotmail.com gongzhongqiang@apache.org flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/offset/Offset.java 64 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/offset/OffsetFactory.java 13 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/wartermark/WatermarkKind.java 15 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/wartermark/WatermarkEvent.java 82 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceRecords.java 22 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplitState.java 33 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/FinishedSnapshotSplitInfo.java 115 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/StreamSplitState.java 59 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/StreamSplit.java 247 4 428 107 4 3 2024-03-06 2025-01-21 ruanhang1993@hotmail.com gongzhongqiang@apache.org flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitSerializer.java 234 4 428 16 5 4 2024-03-06 2025-04-22 ruanhang1993@hotmail.com loserwang1024@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/ChangeEventRecords.java 57 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java 139 2 428 157 2 1 2024-03-06 2024-12-02 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SchemalessSnapshotSplit.java 37 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitState.java 20 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitBase.java 46 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/events/FinishedSnapshotSplitsReportEvent.java 20 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/events/StreamSplitAssignedEvent.java 9 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/events/StreamSplitUpdateRequestEvent.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/events/FinishedSnapshotSplitsAckEvent.java 19 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/events/StreamSplitMetaRequestEvent.java 25 2 428 391 2 2 2024-03-06 2024-04-12 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/events/LatestFinishedSplitsNumberRequestEvent.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/events/FinishedSnapshotSplitsRequestEvent.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/events/StreamSplitUpdateAckEvent.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/events/StreamSplitMetaEvent.java 36 2 428 391 2 2 2024-03-06 2024-04-12 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/events/LatestFinishedSplitsNumberEvent.java 21 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/metrics/TiDBSourceMetrics.java 42 1 366 366 1 1 2024-05-07 2024-05-07 105206850+xieyi888@users.noreply.github.com 105206850+xieyi888@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupMode.java 5 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/RowDataTiKVChangeEventDeserializationSchema.java 79 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/utils/UriHostMapping.java 59 1 303 303 1 1 2024-07-09 2024-07-09 mr.artboy@gmail.com mr.artboy@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/utils/OptionUtils.java 16 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/utils/TableKeyRangeUtils.java 47 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/RowDataTiKVEventDeserializationSchemaBase.java 459 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java 171 2 428 303 2 2 2024-03-06 2024-07-09 ruanhang1993@hotmail.com mr.artboy@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiKVMetadataConverter.java 23 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/StartupOptions.java 36 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiKVReadableMetadata.java 74 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/RowDataTiKVSnapshotEventDeserializationSchema.java 46 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiKVAppendMetadataCollector.java 28 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiKVDeserializationRuntimeConverter.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSourceFactory.java 110 2 428 303 2 2 2024-03-06 2024-07-09 ruanhang1993@hotmail.com mr.artboy@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/TiKVRichParallelSourceFunction.java 339 2 428 366 2 2 2024-03-06 2024-05-07 ruanhang1993@hotmail.com 105206850+xieyi888@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/TiKVSnapshotEventDeserializationSchema.java 11 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/TDBSourceOptions.java 75 2 428 303 2 2 2024-03-06 2024-07-09 ruanhang1993@hotmail.com mr.artboy@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/TiDBSource.java 52 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/TiKVChangeEventDeserializationSchema.java 11 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/common/operation/iterator/ScanIterator.java 79 2 552 430 2 2 2023-11-03 2024-03-04 leonard@apache.org ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/common/util/ChannelFactory.java 153 2 552 430 2 2 2023-11-03 2024-03-04 leonard@apache.org ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/CDCClient.java 200 3 552 430 3 3 2023-11-03 2024-03-04 leonard@apache.org ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/RegionCDCClient.java 193 3 552 430 3 3 2023-11-03 2024-03-04 leonard@apache.org ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/CDCEvent.java 55 2 552 430 2 2 2023-11-03 2024-03-04 leonard@apache.org ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/DummyDocs.java 2 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/DummyDocs.java 2 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java 820 2 552 468 2 2 2023-11-03 2024-01-26 leonard@apache.org 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/LogMinerChangeRecordEmitter.java 80 2 552 468 2 2 2023-11-03 2024-01-26 leonard@apache.org 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java 729 5 552 181 5 5 2023-11-03 2024-11-08 leonard@apache.org 676366545@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/LogMinerAdapter.java 363 3 552 430 3 3 2023-11-03 2024-03-04 leonard@apache.org ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleReadableMetaData.java 81 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSourceFactory.java 204 5 428 57 5 5 2024-03-06 2025-03-12 ruanhang1993@hotmail.com 1365976815@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java 310 5 428 57 5 5 2024-03-06 2025-03-12 ruanhang1993@hotmail.com 1365976815@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleDeserializationConverterFactory.java 212 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/util/ChunkUtils.java 48 2 428 20 2 2 2024-03-06 2025-04-18 ruanhang1993@hotmail.com semicpu@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/util/OracleJdbcUrlUtils.java 16 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/OracleSource.java 117 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/handler/OracleSchemaChangeEventHandler.java 17 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/assigner/splitter/OracleChunkSplitter.java 132 7 428 16 7 6 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 131222468+linjianchang@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleSchema.java 51 2 428 289 2 2 2024-03-06 2024-07-23 ruanhang1993@hotmail.com 18033291053@163.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleUtils.java 289 2 428 279 2 2 2024-03-06 2024-08-02 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleTypeUtils.java 63 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleConnectionUtils.java 88 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/OracleDialect.java 126 2 428 142 2 2 2024-03-06 2024-12-17 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/OracleSourceBuilder.java 140 4 428 63 4 4 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/config/OracleSourceConfigFactory.java 89 4 428 63 4 4 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/config/OracleSourceOptions.java 17 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/config/OracleSourceConfig.java 80 4 428 63 4 4 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/OraclePooledDataSourceFactory.java 20 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/EventProcessorFactory.java 244 2 428 114 2 2 2024-03-06 2025-01-14 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/OracleStreamFetchTask.java 127 2 428 114 2 2 2024-03-06 2025-01-14 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/OracleSourceFetchTaskContext.java 264 2 428 114 2 2 2024-03-06 2025-01-14 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/OracleScanFetchTask.java 276 2 428 114 2 2 2024-03-06 2025-01-14 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/StoppableChangeEventSourceContext.java 13 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/meta/offset/RedoLogOffset.java 74 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/meta/offset/RedoLogOffsetFactory.java 35 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/OracleValidator.java 45 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/DummyDocs.java 2 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2StreamingChangeEventSource.java 398 1 512 512 1 1 2023-12-13 2023-12-13 genzhedangdang@gmail.com genzhedangdang@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2Connection.java 413 2 512 367 2 1 2023-12-13 2024-05-06 genzhedangdang@gmail.com genzhedangdang@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/utils/OptionUtils.java 16 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/Db2ReadableMetaData.java 81 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/Db2TableSource.java 289 5 512 57 5 5 2023-12-13 2025-03-12 genzhedangdang@gmail.com 1365976815@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java 37 4 512 112 4 4 2023-12-13 2025-01-16 genzhedangdang@gmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/Db2TableSourceFactory.java 227 5 512 57 5 5 2023-12-13 2025-03-12 genzhedangdang@gmail.com 1365976815@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/handler/Db2SchemaChangeEventHandler.java 20 2 512 380 2 2 2023-12-13 2024-04-23 genzhedangdang@gmail.com @users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/utils/Db2Utils.java 334 2 512 279 2 2 2023-12-13 2024-08-02 genzhedangdang@gmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/utils/Db2ConnectionUtils.java 57 2 512 380 2 2 2023-12-13 2024-04-23 genzhedangdang@gmail.com @users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/utils/Db2TypeUtils.java 54 2 512 380 2 2 2023-12-13 2024-04-23 genzhedangdang@gmail.com @users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/dialect/Db2PooledDataSourceFactory.java 13 1 512 512 1 1 2023-12-13 2023-12-13 genzhedangdang@gmail.com genzhedangdang@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/dialect/Db2Schema.java 49 1 512 512 1 1 2023-12-13 2023-12-13 genzhedangdang@gmail.com genzhedangdang@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/dialect/Db2ChunkSplitter.java 42 4 512 142 4 3 2023-12-13 2024-12-17 genzhedangdang@gmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/dialect/Db2Dialect.java 131 2 512 142 2 2 2023-12-13 2024-12-17 genzhedangdang@gmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/config/Db2SourceConfig.java 67 3 512 63 3 3 2023-12-13 2025-03-06 genzhedangdang@gmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/config/Db2SourceConfigFactory.java 71 3 512 63 3 3 2023-12-13 2025-03-06 genzhedangdang@gmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/Db2SourceBuilder.java 128 4 512 63 4 4 2023-12-13 2025-03-06 genzhedangdang@gmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/offset/LsnOffset.java 64 1 512 512 1 1 2023-12-13 2023-12-13 genzhedangdang@gmail.com genzhedangdang@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/offset/LsnFactory.java 41 1 512 512 1 1 2023-12-13 2023-12-13 genzhedangdang@gmail.com genzhedangdang@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch/Db2StreamFetchTask.java 134 2 512 114 2 2 2023-12-13 2025-01-14 genzhedangdang@gmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch/Db2ScanFetchTask.java 282 2 512 114 2 2 2023-12-13 2025-01-14 genzhedangdang@gmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch/Db2SourceFetchTaskContext.java 251 3 512 114 3 3 2023-12-13 2025-01-14 genzhedangdang@gmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/Db2Source.java 90 2 512 428 2 2 2023-12-13 2024-03-06 genzhedangdang@gmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/DummyDocs.java 2 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/DummyDocs.java 2 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/io/debezium/connector/sqlserver/SqlServerStreamingChangeEventSource.java 504 2 552 468 2 2 2023-11-03 2024-01-26 leonard@apache.org 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/io/debezium/connector/sqlserver/SqlServerOffsetContext.java 192 1 107 107 1 1 2025-01-21 2025-01-21 gongzhongqiang@apache.org gongzhongqiang@apache.org flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerReadableMetadata.java 81 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java 296 4 428 57 4 4 2024-03-06 2025-03-12 ruanhang1993@hotmail.com 1365976815@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableFactory.java 229 4 428 57 4 4 2024-03-06 2025-03-12 ruanhang1993@hotmail.com 1365976815@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerDeserializationConverterFactory.java 48 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/SqlServerSource.java 90 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/SqlServerValidator.java 61 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/handler/SqlServerSchemaChangeEventHandler.java 23 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/utils/SqlServerTypeUtils.java 55 3 428 259 3 3 2024-03-06 2024-08-22 ruanhang1993@hotmail.com morozov@tut.by flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/utils/SqlServerConnectionUtils.java 80 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/utils/SqlServerUtils.java 369 3 428 275 3 3 2024-03-06 2024-08-06 ruanhang1993@hotmail.com 33644226+lipl2017@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/dialect/SqlServerPooledDataSourceFactory.java 13 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/dialect/SqlServerSchema.java 50 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/dialect/SqlServerChunkSplitter.java 50 6 428 16 6 5 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 131222468+linjianchang@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/dialect/SqlServerDialect.java 134 2 428 142 2 2 2024-03-06 2024-12-17 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/config/SqlServerSourceConfig.java 67 3 428 63 3 3 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/config/SqlServerSourceConfigFactory.java 71 3 428 63 3 3 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/offset/LsnOffset.java 63 2 428 107 2 2 2024-03-06 2025-01-21 ruanhang1993@hotmail.com gongzhongqiang@apache.org flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/offset/LsnFactory.java 40 2 428 107 2 2 2024-03-06 2025-01-21 ruanhang1993@hotmail.com gongzhongqiang@apache.org flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/reader/fetch/SqlServerSourceFetchTaskContext.java 257 2 428 114 2 2 2024-03-06 2025-01-14 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/reader/fetch/SqlServerStreamFetchTask.java 137 4 428 107 4 4 2024-03-06 2025-01-21 ruanhang1993@hotmail.com gongzhongqiang@apache.org flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/reader/fetch/SqlServerScanFetchTask.java 286 3 428 114 3 3 2024-03-06 2025-01-14 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/SqlServerSourceBuilder.java 126 3 428 63 3 3 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/DummyDocs.java 2 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/DummyDocs.java 2 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/VitessSource.java 161 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableFactory.java 165 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table/VitessTableSource.java 225 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/config/TabletType.java 15 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/config/SchemaAdjustmentMode.java 11 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/VitessValidator.java 19 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/DummyDocs.java 2 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSourceFactory.java 208 5 428 16 5 5 2024-03-06 2025-04-22 ruanhang1993@hotmail.com hrunker@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBConnectorDeserializationSchema.java 678 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java 353 5 428 16 5 5 2024-03-06 2025-04-22 ruanhang1993@hotmail.com hrunker@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBConnectorFullChangelogDeserializationSchema.java 89 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBReadableMetadata.java 86 2 428 31 2 2 2024-03-06 2025-04-07 ruanhang1993@hotmail.com hrunker@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/MongoDBSource.java 264 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/connection/MongoClientPool.java 30 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/CollectionDiscoveryUtils.java 198 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/MongoUtils.java 362 2 428 386 2 2 2024-03-06 2024-04-17 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/MongoRecordUtils.java 153 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/BsonUtils.java 258 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/ChunkUtils.java 19 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/ResumeTokenUtils.java 44 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/dialect/MongoDBDialect.java 167 2 428 142 2 2 2024-03-06 2024-12-17 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java 212 3 428 63 3 3 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceOptions.java 141 2 428 16 2 2 2024-03-06 2025-04-22 ruanhang1993@hotmail.com hrunker@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfigFactory.java 175 3 428 63 3 3 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamDescriptor.java 94 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamOffsetFactory.java 33 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/offset/ChangeStreamOffset.java 68 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/MongoDBSource.java 40 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/MongoDBRecordEmitter.java 88 2 428 153 2 2 2024-03-06 2024-12-06 ruanhang1993@hotmail.com 754089893@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBScanFetchTask.java 171 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBFetchTaskContext.java 152 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java 333 2 428 386 2 2 2024-03-06 2024-04-17 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/MongoDBChunkSplitter.java 39 2 428 142 2 2 2024-03-06 2024-12-17 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SplitVectorSplitStrategy.java 99 4 428 63 4 3 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SplitContext.java 70 3 428 63 3 3 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SingleSplitStrategy.java 34 2 428 157 2 1 2024-03-06 2024-12-02 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/ShardedSplitStrategy.java 93 2 428 157 2 1 2024-03-06 2024-12-02 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SplitStrategy.java 21 2 428 157 2 1 2024-03-06 2024-12-02 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SampleBucketSplitStrategy.java 118 4 428 63 4 3 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/MongoDBSourceBuilder.java 115 3 428 63 3 3 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/internal/MongoDBConnectorSourceConnector.java 9 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/internal/MongoDBConnectorSourceTask.java 280 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/internal/MongoDBEnvelope.java 97 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java 714 2 521 468 2 2 2023-12-04 2024-01-26 jiabao.sun@xtransfer.cn 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/util/ErrorMessageUtils.java 33 2 552 430 2 2 2023-11-03 2024-03-04 leonard@apache.org ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/GtidUtils.java 55 2 552 430 2 2 2023-11-03 2024-03-04 leonard@apache.org ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java 1193 3 552 393 3 3 2023-11-03 2024-04-10 leonard@apache.org nsk93@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlDefaultValueConverter.java 352 2 552 468 2 2 2023-11-03 2024-01-26 leonard@apache.org 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlConnection.java 571 3 552 346 3 3 2023-11-03 2024-05-27 leonard@apache.org hx0698@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/antlr/listener/DefaultValueParserListener.java 83 2 552 468 2 2 2023-11-03 2024-01-26 leonard@apache.org 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/converters/MysqlDebeziumTimeConverter.java 282 4 377 112 4 3 2024-04-26 2025-01-16 jam.gzczy@gmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/io/BufferedSocketInputStream.java 46 2 552 430 2 2 2023-11-03 2024-03-04 leonard@apache.org ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonStringFormatter.java 244 1 198 198 1 1 2024-10-22 2024-10-22 louis.sml@kakaocorp.com louis.sml@kakaocorp.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventMetadataDeserializer.java 178 2 520 430 2 2 2023-12-05 2024-03-04 qidian990107@163.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/ColumnType.java 55 3 552 142 3 3 2023-11-03 2024-12-17 leonard@apache.org 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventDataDeserializer.java 106 4 552 142 4 4 2023-11-03 2024-12-17 leonard@apache.org 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/utils/OptionUtils.java 16 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupMode.java 9 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSource.java 385 9 428 21 9 8 2024-03-06 2025-04-17 ruanhang1993@hotmail.com hrunker@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlReadableMetadata.java 85 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/StartupOptions.java 70 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactory.java 334 7 428 21 7 7 2024-03-06 2025-04-17 ruanhang1993@hotmail.com hrunker@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlDeserializationConverterFactory.java 132 2 428 169 2 2 2024-03-06 2024-11-20 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/SeekBinlogToTimestampFilter.java 54 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/schema/Selectors.java 71 1 254 254 1 1 2024-08-27 2024-08-27 125648852+loserwang1024@users.noreply.github.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/schema/MySqlTableDefinition.java 42 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/schema/MySqlFieldDefinition.java 64 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/schema/MySqlTypeUtils.java 200 2 428 112 2 2 2024-03-06 2025-01-16 ruanhang1993@hotmail.com 37775475+qg-lin@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/schema/MySqlSchema.java 139 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/MySqlSource.java 150 2 428 198 2 2 2024-03-06 2024-10-22 ruanhang1993@hotmail.com louis.sml@kakaocorp.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/metrics/MySqlSourceReaderMetrics.java 23 2 428 349 2 2 2024-03-06 2024-05-24 ruanhang1993@hotmail.com hx0698@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/connection/ConnectionPoolId.java 35 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/connection/ConnectionPools.java 9 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/connection/JdbcConnectionPools.java 34 2 428 275 2 2 2024-03-06 2024-08-06 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/connection/JdbcConnectionFactory.java 51 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/connection/PooledDataSourceFactory.java 66 2 428 346 3 2 2024-03-06 2024-05-27 ruanhang1993@hotmail.com hx0698@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/VersionComparable.java 76 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/RecordUtils.java 465 3 428 115 3 3 2024-03-06 2025-01-13 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/TableDiscoveryUtils.java 122 2 428 254 2 2 2024-03-06 2024-08-27 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/StatementUtils.java 277 2 428 181 2 2 2024-03-06 2024-11-08 ruanhang1993@hotmail.com genzhedangdang@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/EnvironmentUtils.java 19 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/ObjectUtils.java 59 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/ChunkUtils.java 75 4 428 20 4 3 2024-03-06 2025-04-18 ruanhang1993@hotmail.com semicpu@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/hooks/SnapshotPhaseHook.java 11 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/hooks/SnapshotPhaseHooks.java 41 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/SerializerUtils.java 88 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/ServerIdRange.java 70 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java 239 8 428 21 8 8 2024-03-06 2025-04-17 ruanhang1993@hotmail.com hrunker@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceConfig.java 226 8 428 14 8 8 2024-03-06 2025-04-24 ruanhang1993@hotmail.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceConfigFactory.java 253 7 428 63 7 7 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffset.java 183 3 428 86 3 3 2024-03-06 2025-02-11 ruanhang1993@hotmail.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetKind.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetBuilder.java 84 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetUtils.java 25 2 428 275 2 2 2024-03-06 2024-08-06 ruanhang1993@hotmail.com 46524102+shiyiky@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetSerializer.java 18 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/enumerator/MySqlSourceEnumerator.java 273 5 428 146 5 4 2024-03-06 2024-12-13 ruanhang1993@hotmail.com genzhedangdang@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSource.java 209 3 428 16 3 3 2024-03-06 2025-04-22 ruanhang1993@hotmail.com 809097465@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlBinlogSplitState.java 59 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/SourceRecords.java 22 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplitState.java 37 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/FinishedSnapshotSplitInfo.java 117 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplitSerializer.java 216 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSchemalessSnapshotSplit.java 37 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplit.java 45 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplitState.java 20 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlRecords.java 53 2 428 13 2 2 2024-03-06 2025-04-25 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSnapshotSplit.java 139 2 428 157 2 1 2024-03-06 2024-12-02 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlBinlogSplit.java 254 4 428 44 4 4 2024-03-06 2025-03-25 ruanhang1993@hotmail.com hrunker@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceBuilder.java 133 5 428 63 5 5 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSourceReaderContext.java 30 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSplitReader.java 205 3 428 13 3 3 2024-03-06 2025-04-25 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlRecordEmitter.java 111 2 428 349 2 2 2024-03-06 2024-05-24 ruanhang1993@hotmail.com hx0698@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSourceReader.java 456 5 428 44 5 4 2024-03-06 2025-03-25 ruanhang1993@hotmail.com hrunker@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlHybridSplitAssigner.java 190 2 428 115 2 2 2024-03-06 2025-01-13 ruanhang1993@hotmail.com hx0698@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/HybridPendingSplitsState.java 42 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/ChunkSplitterState.java 109 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java 30 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/PendingSplitsState.java 5 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/SnapshotPendingSplitsState.java 131 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/PendingSplitsStateSerializer.java 357 2 428 145 2 2 2024-03-06 2024-12-14 ruanhang1993@hotmail.com morozov@tut.by flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkSplitter.java 16 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSplitAssigner.java 29 2 428 275 2 2 2024-03-06 2024-08-06 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlChunkSplitter.java 378 6 428 30 6 5 2024-03-06 2025-04-08 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlBinlogSplitAssigner.java 95 2 428 275 2 2 2024-03-06 2024-08-06 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/ChunkRange.java 53 2 428 30 2 2 2024-03-06 2025-04-08 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java 517 8 428 30 8 4 2024-03-06 2025-04-08 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/AssignerStatus.java 132 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/FinishedSnapshotSplitsReportEvent.java 20 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/BinlogSplitUpdateRequestEvent.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/BinlogSplitAssignedEvent.java 9 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/BinlogSplitMetaEvent.java 36 2 428 391 2 2 2024-03-06 2024-04-12 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/BinlogSplitUpdateAckEvent.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/FinishedSnapshotSplitsAckEvent.java 19 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/LatestFinishedSplitsNumberRequestEvent.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/FinishedSnapshotSplitsRequestEvent.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/BinlogSplitMetaRequestEvent.java 25 2 428 391 2 2 2024-03-06 2024-04-12 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/LatestFinishedSplitsNumberEvent.java 21 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/dispatcher/EventDispatcherImpl.java 234 2 428 86 2 2 2024-03-06 2025-02-11 ruanhang1993@hotmail.com yoheimuta@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/dispatcher/SignalEventDispatcher.java 88 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/EmbeddedFlinkDatabaseHistory.java 117 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/context/MySqlTaskContextImpl.java 19 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/context/StatefulTaskContext.java 347 3 428 112 3 3 2024-03-06 2025-01-16 ruanhang1993@hotmail.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/context/exception/SchemaOutOfSyncException.java 6 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/context/MySqlErrorHandler.java 76 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/MySqlBinlogSplitReadTask.java 92 2 428 346 2 2 2024-03-06 2024-05-27 ruanhang1993@hotmail.com hx0698@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/MySqlSnapshotSplitReadTask.java 319 3 428 86 3 3 2024-03-06 2025-02-11 ruanhang1993@hotmail.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java 381 3 428 13 3 3 2024-03-06 2025-04-25 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/DebeziumReader.java 10 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/StoppableChangeEventSourceContext.java 13 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReader.java 303 8 428 64 9 7 2024-03-06 2025-03-05 ruanhang1993@hotmail.com hx0698@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java 275 3 428 254 3 3 2024-03-06 2024-08-27 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/MySqlValidator.java 190 3 428 346 3 3 2024-03-06 2024-05-27 ruanhang1993@hotmail.com hx0698@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnectionUtils.java 47 1 13 13 1 1 2025-04-25 2025-04-25 vinh.pham@shopback.com vinh.pham@shopback.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java 620 4 552 468 4 2 2023-11-03 2024-01-26 leonard@apache.org 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java 749 2 552 468 2 2 2023-11-03 2024-01-26 leonard@apache.org 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/Lsn.java 88 2 552 468 2 2 2023-11-03 2024-01-26 leonard@apache.org 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/Utils.java 51 3 552 428 3 2 2023-11-03 2024-03-06 leonard@apache.org ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java 392 2 552 468 2 2 2023-11-03 2024-01-26 leonard@apache.org 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/PostgresObjectUtils.java 108 2 552 430 2 2 2023-11-03 2024-03-04 leonard@apache.org ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/utils/OptionUtils.java 16 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/PostgreSQLSource.java 96 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLReadableMetadata.java 98 2 428 112 2 2 2024-03-06 2025-01-16 ruanhang1993@hotmail.com o.valenduc@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgresValueValidator.java 23 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java 346 5 428 57 5 5 2024-03-06 2025-03-12 ruanhang1993@hotmail.com 1365976815@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableFactory.java 237 6 428 13 6 6 2024-03-06 2025-04-25 ruanhang1993@hotmail.com vinh.pham@shopback.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLDeserializationConverterFactory.java 67 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresConnectionPoolFactory.java 26 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/handler/PostgresSchemaChangeEventHandler.java 11 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java 265 6 428 63 6 6 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/CustomPostgresSchema.java 105 2 428 185 2 2 2024-03-06 2024-11-04 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/TableDiscoveryUtils.java 28 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/PostgresQueryUtils.java 318 4 428 42 4 4 2024-03-06 2025-03-27 ruanhang1993@hotmail.com morozov@tut.by flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/PostgresTypeUtils.java 133 2 428 296 2 2 2024-03-06 2024-07-16 ruanhang1993@hotmail.com boto@boto.pro flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/ChunkUtils.java 46 2 428 20 2 2 2024-03-06 2025-04-18 ruanhang1993@hotmail.com semicpu@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/config/PostgresSourceConfigFactory.java 103 4 428 63 4 4 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/config/PostgresSourceOptions.java 63 2 428 338 2 2 2024-03-06 2024-06-04 ruanhang1993@hotmail.com 916295+morazow@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/config/PostgresSourceConfig.java 87 4 428 63 4 4 2024-03-06 2025-03-06 ruanhang1993@hotmail.com xbjtdcq@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/offset/PostgresOffsetUtils.java 22 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/offset/PostgresOffset.java 89 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/offset/PostgresOffsetFactory.java 32 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/enumerator/PostgresSourceEnumerator.java 100 2 428 57 2 2 2024-03-06 2025-03-12 ruanhang1993@hotmail.com genzhedangdang@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDialect.java 200 6 428 13 6 5 2024-03-06 2025-04-25 ruanhang1993@hotmail.com vinh.pham@shopback.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresChunkSplitter.java 53 4 428 142 4 3 2024-03-06 2024-12-17 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresSourceReader.java 96 3 428 57 3 3 2024-03-06 2025-03-12 ruanhang1993@hotmail.com genzhedangdang@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresScanFetchTask.java 309 4 428 13 4 3 2024-03-06 2025-04-25 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresSourceFetchTaskContext.java 300 2 428 114 2 2 2024-03-06 2025-01-14 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresStreamFetchTask.java 188 2 428 114 2 2 2024-03-06 2025-01-14 ruanhang1993@hotmail.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/CDCPostgresDispatcher.java 60 1 114 114 1 1 2025-01-14 2025-01-14 125648852+loserwang1024@users.noreply.github.com 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/StoppableChangeEventSourceContext.java 13 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/events/OffsetCommitEvent.java 14 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/events/OffsetCommitAckEvent.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational/RelationalTableFilters.java 104 1 14 14 1 1 2025-04-24 2025-04-24 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational/HistorizedRelationalDatabaseConnectorConfig.java 134 1 552 552 1 1 2023-11-03 2023-11-03 leonard@apache.org leonard@apache.org flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational/RelationalChangeRecordEmitter.java 223 2 552 468 2 2 2023-11-03 2024-01-26 leonard@apache.org 125648852+loserwang1024@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/embedded/EmbeddedEngineChangeEvent.java 44 2 552 428 2 2 2023-11-03 2024-03-06 leonard@apache.org ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/DebeziumDeserializationSchema.java 10 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/StringDebeziumDeserializationSchema.java 16 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/DebeziumSourceFunction.java 400 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/utils/JdbcUrlUtils.java 23 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/utils/TemporalConversions.java 184 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/utils/ConvertTimeBceUtil.java 32 1 377 377 1 1 2024-04-26 2024-04-26 jam.gzczy@gmail.com jam.gzczy@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/utils/ResolvedSchemaUtils.java 17 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/utils/DatabaseHistoryUtil.java 39 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/AppendMetadataCollector.java 48 2 428 21 2 2 2024-03-06 2025-04-17 ruanhang1993@hotmail.com hrunker@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/RowDataMetadataConverter.java 7 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/DebeziumChangelogMode.java 13 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/MetadataConverter.java 9 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java 529 3 428 21 3 3 2024-03-06 2025-04-17 ruanhang1993@hotmail.com hrunker@gmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/DeserializationRuntimeConverter.java 7 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/DeserializationRuntimeConverterFactory.java 11 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/DebeziumOptions.java 30 2 428 14 2 2 2024-03-06 2025-04-24 ruanhang1993@hotmail.com lvyanquan.lyq@alibaba-inc.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/history/FlinkJsonTableChangeSerializer.java 166 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/DebeziumSchemaDataTypeInference.java 169 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/SourceRecordEventDeserializer.java 47 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/DebeziumEventDeserializationSchema.java 353 2 428 30 2 2 2024-03-06 2025-04-08 ruanhang1993@hotmail.com 34335406+yuxiqian@users.noreply.github.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/SchemaDataTypeInference.java 8 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/Validator.java 9 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/JsonDebeziumDeserializationSchema.java 51 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/Handover.java 110 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/DebeziumChangeFetcher.java 185 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/FlinkDatabaseSchemaHistory.java 155 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/DebeziumOffset.java 25 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/DebeziumChangeConsumer.java 65 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/SchemaRecord.java 56 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/FlinkOffsetBackingStore.java 147 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/FlinkDatabaseHistory.java 68 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/DebeziumOffsetSerializer.java 16 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/DummyDocs.java 2 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/utils/OptionUtils.java 16 1 428 428 1 1 2024-03-06 2024-03-06 ruanhang1993@hotmail.com ruanhang1993@hotmail.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/utils/OceanBaseUtils.java 7 1 378 378 1 1 2024-04-25 2024-04-25 wanghechn@qq.com wanghechn@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/OceanBaseSource.java 244 2 428 378 2 2 2024-03-06 2024-04-25 ruanhang1993@hotmail.com wanghechn@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSourceFactory.java 284 2 428 378 2 2 2024-03-06 2024-04-25 ruanhang1993@hotmail.com wanghechn@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseReadableMetadata.java 94 2 428 378 2 2 2024-03-06 2024-04-25 ruanhang1993@hotmail.com wanghechn@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java 286 2 428 378 2 2 2024-03-06 2024-04-25 ruanhang1993@hotmail.com wanghechn@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/connection/OceanBaseConnection.java 268 1 378 378 1 1 2024-04-25 2024-04-25 wanghechn@qq.com wanghechn@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/config/OceanBaseConnectorConfig.java 58 1 378 378 1 1 2024-04-25 2024-04-25 wanghechn@qq.com wanghechn@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/offset/OceanBaseSourceInfo.java 65 1 378 378 1 1 2024-04-25 2024-04-25 wanghechn@qq.com wanghechn@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/offset/OceanBaseSourceInfoStructMaker.java 48 1 378 378 1 1 2024-04-25 2024-04-25 wanghechn@qq.com wanghechn@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/OceanBaseRichSourceFunction.java 517 2 428 378 2 2 2024-03-06 2024-04-25 ruanhang1993@hotmail.com wanghechn@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/schema/OceanBaseSchema.java 51 1 378 378 1 1 2024-04-25 2024-04-25 wanghechn@qq.com wanghechn@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/schema/OceanBaseDatabaseSchema.java 31 1 378 378 1 1 2024-04-25 2024-04-25 wanghechn@qq.com wanghechn@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/converter/OceanBaseDeserializationConverterFactory.java 47 1 378 378 1 1 2024-04-25 2024-04-25 wanghechn@qq.com wanghechn@qq.com flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/converter/OceanBaseValueConverters.java 457 1 378 378 1 1 2024-04-25 2024-04-25 wanghechn@qq.com wanghechn@qq.com flink-cdc-dist/src/main/flink-cdc-bin/conf/flink-cdc.yaml 2 3 524 430 3 3 2023-12-01 2024-03-04 gongzhongqiang@apache.org ruanhang1993@hotmail.com