path	# lines of code
custom_env.sh.tpl	2
tools/maven/suppressions.xml	7
flink-doris-connector/src/main/java/org/apache/flink/table/runtime/arrow/serializers/ArrowSerializer.java	84
flink-doris-connector/src/main/java/org/apache/doris/flink/connection/JdbcConnectionProvider.java	6
flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java	51
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisStreamOptions.java	106
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java	104
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java	127
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisConnectionOptions.java	88
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java	274
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java	35
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java	339
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Record.java	43
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisJdbcLookupReader.java	106
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisLookupReader.java	10
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/LookupSchema.java	69
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java	187
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java	208
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Get.java	19
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java	109
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/GetAction.java	19
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/LookupMetrics.java	26
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/deserialize/DorisJsonDebeziumDeserializationSchema.java	165
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Type.java	71
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java	208
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DateConverter.java	104
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Schema.java	31
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/JdbcSourceSchema.java	93
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java	30
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java	63
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java	95
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java	23
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java	116
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java	186
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java	209
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/ChangeStreamConstant.java	21
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDateConverter.java	17
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java	130
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java	105
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java	205
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java	57
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java	141
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java	17
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java	227
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java	184
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSyncConfig.java	66
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerSchema.java	22
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDateConverter.java	85
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java	93
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java	193
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DorisTableConfig.java	78
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java	475
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceConnector.java	16
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleSchema.java	31
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java	220
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java	89
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java	118
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter/TableNameConverter.java	37
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java	196
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDateConverter.java	104
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java	213
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresSchema.java	22
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java	118
flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java	85
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java	223
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java	146
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java	129
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java	279
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java	240
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java	108
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java	26
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisExpressionVisitor.java	126
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java	159
flink-doris-connector/src/main/java/org/apache/doris/flink/util/ErrorMessages.java	13
flink-doris-connector/src/main/java/org/apache/doris/flink/util/IPUtils.java	126
flink-doris-connector/src/main/java/org/apache/doris/flink/util/FastDateUtil.java	63
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java	2
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/CopyLoadException.java	22
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/CreateTableException.java	9
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisSchemaChangeException.java	22
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisException.java	22
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/StreamLoadException.java	9
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ConnectedFailedException.java	9
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java	22
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisInternalException.java	14
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java	15
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisRuntimeException.java	22
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/IllegalArgumentException.java	12
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisSystemException.java	12
flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/RowDataDeserializationSchema.java	25
flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java	355
flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java	10
flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/SimpleListDeserializationSchema.java	17
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java	101
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpPutBuilder.java	93
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/models/CopyIntoResp.java	18
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/models/BaseResponse.java	18
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyWriter.java	164
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommittable.java	43
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommitter.java	136
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchRecordBuffer.java	113
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/CopySQLBuilder.java	68
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/CopyCommittableSerializer.java	40
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java	367
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BackoffAndRetryUtils.java	43
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/HttpPostBuilder.java	43
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/LoadStatus.java	7
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java	520
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java	98
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/RecordWithMeta.java	47
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java	142
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchBufferHttpEntity.java	48
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchBufferStream.java	47
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java	80
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java	143
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittableSerializer.java	34
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisAbstractCommittable.java	2
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/util/DeleteOperation.java	12
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/ResponseUtil.java	23
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java	51
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SQLParserSchemaManager.java	343
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeManager.java	311
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeHelper.java	177
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeMode.java	12
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisSink.java	148
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java	26
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/CdcSchemaChange.java	9
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImpl.java	115
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/CdcDataChange.java	12
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java	156
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumDataChange.java	95
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java	289
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java	130
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java	98
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeUtils.java	71
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecord.java	55
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RecordWithMetaSerializer.java	29
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecordSerializer.java	13
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/SimpleStringSerializer.java	11
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowDataSerializer.java	203
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java	269
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowSerializer.java	74
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/WriteMode.java	13
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterStateSerializer.java	41
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisAbstractWriter.java	6
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java	63
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/ChangeEvent.java	3
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java	63
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriteMetrics.java	275
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/CacheRecordBuffer.java	87
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java	42
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/EventType.java	5
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java	355
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java	103
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java	482
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpGetWithEntity.java	14
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java	75
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/EscapeHandler.java	39
flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java	599
flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/Routing.java	38
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/RespContent.java	112
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java	87
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java	68
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java	34
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java	31
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/BackendV2.java	52
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java	132
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java	639
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/SchemaUtils.java	45
flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/PendingSplitsCheckpoint.java	14
flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumerator.java	58
flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/PendingSplitsCheckpointSerializer.java	80
flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSplitRecords.java	48
flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java	42
flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplitSerializer.java	85
flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplitState.java	10
flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisFlightValueReader.java	184
flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/ValueReader.java	35
flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisRecordEmitter.java	31
flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceReader.java	50
flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceSplitReader.java	80
flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisValueReader.java	246
flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners/SimpleSplitAssigner.java	35
flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners/DorisSplitAssigner.java	11
flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSource.java	147
flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java	222
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java	99
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogOptions.java	23
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/TableSchema.java	105
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java	7
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/FieldSchema.java	60
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactory.java	207
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java	151
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisType.java	31
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java	230
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java	478