path # lines of code # active days days since first update days since last update # commits # contributors first updated last updated first contributor last contributor custom_env.sh.tpl 2 2 1182 721 2 2 2022-02-11 2023-05-18 chenmingyu@baidu.com 46414265+dongliang-0@users.noreply.github.com tools/maven/suppressions.xml 7 2 511 510 2 1 2023-12-14 2023-12-15 46414265+dongliang-0@users.noreply.github.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/flink/table/runtime/arrow/serializers/ArrowSerializer.java 84 1 498 498 1 1 2023-12-27 2023-12-27 wuwenchihdu@hotmail.com wuwenchihdu@hotmail.com flink-doris-connector/src/main/java/org/apache/doris/flink/connection/JdbcConnectionProvider.java 6 2 842 510 2 2 2023-01-17 2023-12-15 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java 51 4 842 251 4 2 2023-01-17 2024-08-30 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisStreamOptions.java 106 4 1182 269 4 4 2022-02-11 2024-08-12 chenmingyu@baidu.com xyws5566@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java 104 11 1182 209 11 3 2022-02-11 2024-10-11 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java 127 4 966 343 4 2 2022-09-15 2024-05-30 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisConnectionOptions.java 88 7 1182 337 7 3 2022-02-11 2024-06-05 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java 274 12 1182 56 12 4 2022-02-11 2025-03-13 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java 35 8 1182 56 8 4 2022-02-11 2025-03-13 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java 339 23 1182 51 24 7 2022-02-11 2025-03-18 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Record.java 43 2 842 510 2 2 2023-01-17 2023-12-15 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisJdbcLookupReader.java 106 3 842 510 3 2 2023-01-17 2023-12-15 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisLookupReader.java 10 2 842 661 2 1 2023-01-17 2023-07-17 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/LookupSchema.java 69 2 842 510 2 2 2023-01-17 2023-12-15 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java 187 4 842 510 4 2 2023-01-17 2023-12-15 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java 208 7 842 57 7 3 2023-01-17 2025-03-12 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Get.java 19 1 842 842 1 1 2023-01-17 2023-01-17 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java 109 2 842 510 2 2 2023-01-17 2023-12-15 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/GetAction.java 19 1 842 842 1 1 2023-01-17 2023-01-17 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/LookupMetrics.java 26 1 365 365 1 1 2024-05-08 2024-05-08 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/deserialize/DorisJsonDebeziumDeserializationSchema.java 165 2 343 288 2 1 2024-05-30 2024-07-24 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Type.java 71 1 286 286 1 1 2024-07-26 2024-07-26 31833513+vinlee19@users.noreply.github.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java 208 2 286 269 2 1 2024-07-26 2024-08-12 31833513+vinlee19@users.noreply.github.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DateConverter.java 104 1 286 286 1 1 2024-07-26 2024-07-26 31833513+vinlee19@users.noreply.github.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Schema.java 31 2 286 275 2 1 2024-07-26 2024-08-06 31833513+vinlee19@users.noreply.github.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/JdbcSourceSchema.java 93 5 434 153 5 3 2024-02-29 2024-12-06 bingquan_zhao@icloud.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java 30 1 42 42 1 1 2025-03-27 2025-03-27 76644839+kwonder0926@users.noreply.github.com 76644839+kwonder0926@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java 63 1 42 42 1 1 2025-03-27 2025-03-27 76644839+kwonder0926@users.noreply.github.com 76644839+kwonder0926@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java 95 12 703 153 12 4 2023-06-05 2024-12-06 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java 23 3 365 71 3 2 2024-05-08 2025-02-26 bingquan_zhao@icloud.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java 116 4 343 42 4 4 2024-05-30 2025-03-27 676366545@qq.com 76644839+kwonder0926@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java 186 5 343 42 5 4 2024-05-30 2025-03-27 676366545@qq.com 76644839+kwonder0926@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java 209 4 343 42 4 3 2024-05-30 2025-03-27 676366545@qq.com 76644839+kwonder0926@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/ChangeStreamConstant.java 21 2 365 87 2 2 2024-05-08 2025-02-10 bingquan_zhao@icloud.com 781240052@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDateConverter.java 17 2 365 287 2 2 2024-05-08 2024-07-25 bingquan_zhao@icloud.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java 130 5 365 42 5 3 2024-05-08 2025-03-27 bingquan_zhao@icloud.com 76644839+kwonder0926@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java 105 4 365 17 4 3 2024-05-08 2025-04-21 bingquan_zhao@icloud.com 76644839+kwonder0926@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java 205 10 365 42 10 7 2024-05-08 2025-03-27 bingquan_zhao@icloud.com 76644839+kwonder0926@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java 57 5 526 71 5 3 2023-11-29 2025-02-26 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java 141 4 601 287 4 2 2023-09-15 2024-07-25 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java 17 4 659 429 4 3 2023-07-19 2024-03-05 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java 227 17 703 269 18 5 2023-06-05 2024-08-12 676366545@qq.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java 184 9 703 258 9 5 2023-06-05 2024-08-23 676366545@qq.com tmc9031@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSyncConfig.java 66 3 287 239 3 3 2024-07-25 2024-09-11 46414265+dongliang-0@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerSchema.java 22 4 623 429 4 3 2023-08-24 2024-03-05 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDateConverter.java 85 4 623 287 4 2 2023-08-24 2024-07-25 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java 93 7 623 394 7 4 2023-08-24 2024-04-09 676366545@qq.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java 193 11 623 269 11 4 2023-08-24 2024-08-12 676366545@qq.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DorisTableConfig.java 78 4 282 153 4 2 2024-07-30 2024-12-06 46414265+dongliang-0@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java 475 47 703 42 51 10 2023-06-05 2025-03-27 676366545@qq.com 76644839+kwonder0926@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceConnector.java 16 4 575 286 4 2 2023-10-11 2024-07-26 46414265+dongliang-0@users.noreply.github.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleSchema.java 31 5 659 395 5 4 2023-07-19 2024-04-08 676366545@qq.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java 220 18 659 126 18 4 2023-07-19 2025-01-02 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java 89 4 659 401 4 4 2023-07-19 2024-04-02 676366545@qq.com 71004656+caoliang-web@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java 118 4 659 287 4 2 2023-07-19 2024-07-25 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter/TableNameConverter.java 37 1 71 71 1 1 2025-02-26 2025-02-26 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java 196 23 703 157 24 6 2023-06-05 2024-12-02 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDateConverter.java 104 4 632 287 4 2 2023-08-15 2024-07-25 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java 213 11 632 155 11 4 2023-08-15 2024-12-04 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresSchema.java 22 4 632 429 4 3 2023-08-15 2024-03-05 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java 118 6 632 37 7 5 2023-08-15 2025-04-01 676366545@qq.com 48339061+aalron@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java 85 6 1182 337 6 4 2022-02-11 2024-06-05 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java 223 19 1182 85 20 7 2022-02-11 2025-02-12 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java 146 7 1182 510 7 5 2022-02-11 2023-12-15 chenmingyu@baidu.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java 129 5 842 365 5 2 2023-01-17 2024-05-08 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java 279 25 975 51 26 6 2022-09-06 2025-03-18 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java 240 25 1182 269 26 8 2022-02-11 2024-08-12 chenmingyu@baidu.com xyws5566@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java 108 5 842 365 5 2 2023-01-17 2024-05-08 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java 26 3 1182 195 3 3 2022-02-11 2024-10-25 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisExpressionVisitor.java 126 3 412 142 3 2 2024-03-22 2024-12-17 676366545@qq.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java 159 14 1182 108 15 7 2022-02-11 2025-01-20 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/util/ErrorMessages.java 13 2 1182 511 2 2 2022-02-11 2023-12-14 chenmingyu@baidu.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/util/IPUtils.java 126 1 388 388 1 1 2024-04-15 2024-04-15 31833513+vinlee19@users.noreply.github.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/util/FastDateUtil.java 63 1 269 269 1 1 2024-08-12 2024-08-12 xyws5566@qq.com xyws5566@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java 2 3 1182 511 3 3 2022-02-11 2023-12-14 chenmingyu@baidu.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/exception/CopyLoadException.java 22 1 462 462 1 1 2024-02-01 2024-02-01 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/exception/CreateTableException.java 9 3 703 343 3 2 2023-06-05 2024-05-30 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisSchemaChangeException.java 22 2 525 511 2 2 2023-11-30 2023-12-14 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisException.java 22 2 1182 511 2 2 2022-02-11 2023-12-14 chenmingyu@baidu.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/exception/StreamLoadException.java 9 3 1182 343 3 3 2022-02-11 2024-05-30 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ConnectedFailedException.java 9 3 1182 578 3 2 2022-02-11 2023-10-08 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java 22 2 388 51 2 1 2024-04-15 2025-03-18 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisInternalException.java 14 4 1182 511 4 3 2022-02-11 2023-12-14 chenmingyu@baidu.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java 15 3 640 343 3 2 2023-08-07 2024-05-30 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisRuntimeException.java 22 2 1157 511 2 2 2022-03-08 2023-12-14 44109015+madongz@users.noreply.github.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/exception/IllegalArgumentException.java 12 2 1182 230 2 2 2022-02-11 2024-09-20 chenmingyu@baidu.com 37775475+qg-lin@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisSystemException.java 12 3 682 343 3 2 2023-06-26 2024-05-30 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/RowDataDeserializationSchema.java 25 4 1113 337 4 3 2022-04-21 2024-06-05 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java 355 12 1113 421 12 5 2022-04-21 2024-03-13 676366545@qq.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java 10 5 1182 337 5 4 2022-02-11 2024-06-05 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/SimpleListDeserializationSchema.java 17 4 1182 337 4 3 2022-02-11 2024-06-05 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java 101 11 640 236 11 4 2023-08-07 2024-09-14 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpPutBuilder.java 93 6 1157 266 6 3 2022-03-08 2024-08-15 44109015+madongz@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/models/CopyIntoResp.java 18 1 462 462 1 1 2024-02-01 2024-02-01 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/models/BaseResponse.java 18 1 462 462 1 1 2024-02-01 2024-02-01 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyWriter.java 164 4 462 310 4 2 2024-02-01 2024-07-02 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java 43 1 462 462 1 1 2024-02-01 2024-02-01 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommitter.java 136 2 462 415 2 1 2024-02-01 2024-03-19 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchRecordBuffer.java 113 1 266 266 1 1 2024-08-15 2024-08-15 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/CopySQLBuilder.java 68 3 462 275 3 2 2024-02-01 2024-08-06 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/CopyCommittableSerializer.java 40 1 462 462 1 1 2024-02-01 2024-02-01 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java 367 5 462 266 5 1 2024-02-01 2024-08-15 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BackoffAndRetryUtils.java 43 1 462 462 1 1 2024-02-01 2024-02-01 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/HttpPostBuilder.java 43 1 462 462 1 1 2024-02-01 2024-02-01 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/LoadStatus.java 7 3 1157 510 3 2 2022-03-08 2023-12-15 44109015+madongz@users.noreply.github.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java 520 22 640 51 23 7 2023-08-07 2025-03-18 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java 98 6 640 266 6 3 2023-08-07 2024-08-15 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/RecordWithMeta.java 47 3 549 388 3 2 2023-11-06 2024-04-15 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java 142 10 640 78 10 4 2023-08-07 2025-02-19 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchBufferHttpEntity.java 48 1 266 266 1 1 2024-08-15 2024-08-15 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchBufferStream.java 47 1 266 266 1 1 2024-08-15 2024-08-15 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java 80 6 640 337 6 2 2023-08-07 2024-06-05 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java 143 13 1157 121 14 5 2022-03-08 2025-01-07 44109015+madongz@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittableSerializer.java 34 2 1157 510 2 2 2022-03-08 2023-12-15 44109015+madongz@users.noreply.github.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisAbstractCommittable.java 2 1 462 462 1 1 2024-02-01 2024-02-01 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/util/DeleteOperation.java 12 1 532 532 1 1 2023-11-23 2023-11-23 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/ResponseUtil.java 23 5 1157 388 5 3 2022-03-08 2024-04-15 44109015+madongz@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java 51 3 1157 462 3 3 2022-03-08 2024-02-01 44109015+madongz@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SQLParserSchemaManager.java 343 6 295 118 6 2 2024-07-17 2025-01-10 46414265+dongliang-0@users.noreply.github.com 781240052@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeManager.java 311 9 532 230 12 3 2023-11-23 2024-09-20 46414265+dongliang-0@users.noreply.github.com 37775475+qg-lin@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeHelper.java 177 10 532 164 10 3 2023-11-23 2024-11-25 676366545@qq.com 37775475+qg-lin@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeMode.java 12 1 295 295 1 1 2024-07-17 2024-07-17 46414265+dongliang-0@users.noreply.github.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisSink.java 148 13 1157 209 13 3 2022-03-08 2024-10-11 44109015+madongz@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java 26 8 1157 51 8 5 2022-03-08 2025-03-18 44109015+madongz@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/CdcSchemaChange.java 9 2 434 118 2 2 2024-02-29 2025-01-10 bingquan_zhao@icloud.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImpl.java 115 3 491 295 3 1 2024-01-03 2024-07-17 46414265+dongliang-0@users.noreply.github.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/CdcDataChange.java 12 2 434 365 2 1 2024-02-29 2024-05-08 bingquan_zhao@icloud.com bingquan_zhao@icloud.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java 156 8 491 50 8 3 2024-01-03 2025-03-19 46414265+dongliang-0@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumDataChange.java 95 4 491 276 4 3 2024-01-03 2024-08-05 46414265+dongliang-0@users.noreply.github.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java 289 15 491 50 15 3 2024-01-03 2025-03-19 46414265+dongliang-0@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java 130 6 491 71 6 3 2024-01-03 2025-02-26 46414265+dongliang-0@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java 98 7 295 50 7 2 2024-07-17 2025-03-19 46414265+dongliang-0@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeUtils.java 71 5 462 286 5 2 2024-02-01 2024-07-26 46414265+dongliang-0@users.noreply.github.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecord.java 55 3 526 498 4 3 2023-11-29 2023-12-27 676366545@qq.com wuwenchihdu@hotmail.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RecordWithMetaSerializer.java 29 4 534 337 4 2 2023-11-21 2024-06-05 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecordSerializer.java 13 5 534 337 5 3 2023-11-21 2024-06-05 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/SimpleStringSerializer.java 11 4 534 337 4 2 2023-11-21 2024-06-05 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowDataSerializer.java 203 5 534 337 5 3 2023-11-21 2024-06-05 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java 269 16 534 71 20 3 2023-11-21 2025-02-26 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowSerializer.java 74 4 534 337 4 2 2023-11-21 2024-06-05 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/WriteMode.java 13 1 465 465 1 1 2024-01-29 2024-01-29 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterStateSerializer.java 41 3 1157 510 3 3 2022-03-08 2023-12-15 44109015+madongz@users.noreply.github.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisAbstractWriter.java 6 1 465 465 1 1 2024-01-29 2024-01-29 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java 63 3 1157 510 3 3 2022-03-08 2023-12-15 44109015+madongz@users.noreply.github.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/ChangeEvent.java 3 1 491 491 1 1 2024-01-03 2024-01-03 46414265+dongliang-0@users.noreply.github.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java 63 11 1043 118 12 3 2022-06-30 2025-01-10 44109015+madongz@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriteMetrics.java 275 1 489 489 1 1 2024-01-05 2024-01-05 31833513+vinlee19@users.noreply.github.com 31833513+vinlee19@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/CacheRecordBuffer.java 87 2 590 510 2 2 2023-09-26 2023-12-15 82132356+gogowen@users.noreply.github.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java 42 4 1157 51 4 4 2022-03-08 2025-03-18 44109015+madongz@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/EventType.java 5 1 525 525 1 1 2023-11-30 2023-11-30 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java 355 29 1157 51 31 7 2022-03-08 2025-03-18 44109015+madongz@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java 103 4 1157 51 4 4 2022-03-08 2025-03-18 44109015+madongz@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java 482 28 1157 51 29 6 2022-03-08 2025-03-18 44109015+madongz@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpGetWithEntity.java 14 2 902 510 2 2 2022-11-18 2023-12-15 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java 75 10 1157 76 10 4 2022-03-08 2025-02-21 44109015+madongz@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/sink/EscapeHandler.java 39 3 1157 510 3 3 2022-03-08 2023-12-15 44109015+madongz@users.noreply.github.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java 599 25 1182 52 26 12 2022-02-11 2025-03-17 chenmingyu@baidu.com 1401597760@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/Routing.java 38 2 1182 511 2 2 2022-02-11 2023-12-14 chenmingyu@baidu.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/RespContent.java 112 6 1182 337 6 5 2022-02-11 2024-06-05 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java 87 4 1182 105 4 3 2022-02-11 2025-01-23 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java 68 4 1182 105 4 3 2022-02-11 2025-01-23 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java 34 4 1182 105 4 3 2022-02-11 2025-01-23 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java 31 4 1182 105 4 3 2022-02-11 2025-01-23 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/BackendV2.java 52 5 1182 105 5 3 2022-02-11 2025-01-23 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java 132 5 1182 133 5 3 2022-02-11 2024-12-26 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java 639 26 1182 56 27 11 2022-02-11 2025-03-13 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/rest/SchemaUtils.java 45 4 1182 269 4 3 2022-02-11 2024-08-12 chenmingyu@baidu.com xyws5566@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/PendingSplitsCheckpoint.java 14 2 1113 511 2 2 2022-04-21 2023-12-14 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumerator.java 58 4 1113 240 4 2 2022-04-21 2024-09-10 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/PendingSplitsCheckpointSerializer.java 80 2 1113 511 2 2 2022-04-21 2023-12-14 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSplitRecords.java 48 4 1113 269 4 3 2022-04-21 2024-08-12 676366545@qq.com xyws5566@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java 42 4 1113 133 4 2 2022-04-21 2024-12-26 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplitSerializer.java 85 4 1113 309 4 2 2022-04-21 2024-07-03 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplitState.java 10 2 1113 511 2 2 2022-04-21 2023-12-14 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisFlightValueReader.java 184 3 269 85 3 2 2024-08-12 2025-02-12 xyws5566@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/ValueReader.java 35 4 269 56 4 2 2024-08-12 2025-03-13 xyws5566@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisRecordEmitter.java 31 2 1113 511 2 2 2022-04-21 2023-12-14 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceReader.java 50 3 1113 240 3 2 2022-04-21 2024-09-10 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceSplitReader.java 80 6 1113 240 6 3 2022-04-21 2024-09-10 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisValueReader.java 246 8 1022 85 8 3 2022-07-21 2025-02-12 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners/SimpleSplitAssigner.java 35 5 1113 195 5 2 2022-04-21 2024-10-25 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners/DorisSplitAssigner.java 11 2 1113 511 2 2 2022-04-21 2023-12-14 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSource.java 147 9 1113 133 10 4 2022-04-21 2024-12-26 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java 222 6 1182 195 6 4 2022-02-11 2024-10-25 chenmingyu@baidu.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java 99 7 975 343 7 4 2022-09-06 2024-05-30 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogOptions.java 23 3 975 510 3 2 2022-09-06 2023-12-15 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/TableSchema.java 105 6 703 157 6 3 2023-06-05 2024-12-02 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java 7 3 703 57 3 2 2023-06-05 2025-03-12 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/FieldSchema.java 60 4 703 289 4 2 2023-06-05 2024-07-23 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactory.java 207 5 287 71 5 2 2024-07-25 2025-02-26 46414265+dongliang-0@users.noreply.github.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java 151 20 703 251 20 5 2023-06-05 2024-08-30 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisType.java 31 5 703 295 5 3 2023-06-05 2024-07-17 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java 230 15 975 295 15 6 2022-09-06 2024-07-17 676366545@qq.com 676366545@qq.com flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java 478 12 975 282 12 4 2022-09-06 2024-07-30 676366545@qq.com 46414265+dongliang-0@users.noreply.github.com