Path	Lines of Code
flink-doris-connector/src/test/java/org/apache/doris/flink/backend/BackendClientTest.java	12
flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisCatalogFactoryTest.java	48
flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisCatalogITCase.java	345
flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisCatalogOptionsTest.java	36
flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisCatalogTest.java	31
flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisTypeMapperTest.java	175
flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactoryTest.java	140
flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/doris/DorisSystemTest.java	73
flink-doris-connector/src/test/java/org/apache/doris/flink/cfg/DorisExecutionOptionsTest.java	118
flink-doris-connector/src/test/java/org/apache/doris/flink/cfg/DorisLookupOptionsTest.java	51
flink-doris-connector/src/test/java/org/apache/doris/flink/cfg/DorisOptionsTest.java	50
flink-doris-connector/src/test/java/org/apache/doris/flink/cfg/DorisReadOptionsTest.java	76
flink-doris-connector/src/test/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProviderTest.java	37
flink-doris-connector/src/test/java/org/apache/doris/flink/container/AbstractContainerTestBase.java	77
flink-doris-connector/src/test/java/org/apache/doris/flink/container/AbstractE2EService.java	124
flink-doris-connector/src/test/java/org/apache/doris/flink/container/AbstractITCaseService.java	183
flink-doris-connector/src/test/java/org/apache/doris/flink/container/ContainerUtils.java	158
flink-doris-connector/src/test/java/org/apache/doris/flink/container/e2e/Doris2DorisE2ECase.java	142
flink-doris-connector/src/test/java/org/apache/doris/flink/container/e2e/Mysql2DorisE2ECase.java	469
flink-doris-connector/src/test/java/org/apache/doris/flink/container/instance/ContainerService.java	23
flink-doris-connector/src/test/java/org/apache/doris/flink/container/instance/DorisContainer.java	224
flink-doris-connector/src/test/java/org/apache/doris/flink/container/instance/DorisCustomerContainer.java	98
flink-doris-connector/src/test/java/org/apache/doris/flink/container/instance/MySQLContainer.java	75
flink-doris-connector/src/test/java/org/apache/doris/flink/deserialization/RowDataDeserializationSchemaTest.java	36
flink-doris-connector/src/test/java/org/apache/doris/flink/deserialization/convert/DorisRowConverterTest.java	329
flink-doris-connector/src/test/java/org/apache/doris/flink/example/CDCSchemaChangeExample.java	67
flink-doris-connector/src/test/java/org/apache/doris/flink/example/CatalogExample.java	27
flink-doris-connector/src/test/java/org/apache/doris/flink/example/DataGen2DorisExample.java	40
flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisDateAndTimestampSqlTest.java	49
flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisIntranetAccessSinkExample.java	72
flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkArraySQLExample.java	108
flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkBatchExample.java	121
flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkExample.java	92
flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkExampleRowData.java	73
flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkMultiTableExample.java	48
flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkSQLExample.java	39
flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSinkStreamMultiTableExample.java	85
flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSourceDataStream.java	72
flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSourceExample.java	36
flink-doris-connector/src/test/java/org/apache/doris/flink/example/DorisSourceSinkExample.java	118
flink-doris-connector/src/test/java/org/apache/doris/flink/example/LookupJoinCdcExample.java	58
flink-doris-connector/src/test/java/org/apache/doris/flink/example/LookupJoinExample.java	65
flink-doris-connector/src/test/java/org/apache/doris/flink/lookup/DorisLookupTableITCase.java	310
flink-doris-connector/src/test/java/org/apache/doris/flink/lookup/RecordTest.java	87
flink-doris-connector/src/test/java/org/apache/doris/flink/rest/SchemaUtilsTest.java	34
flink-doris-connector/src/test/java/org/apache/doris/flink/rest/TestPartitionDefinition.java	57
flink-doris-connector/src/test/java/org/apache/doris/flink/rest/models/TestSchema.java	18
flink-doris-connector/src/test/java/org/apache/doris/flink/serialization/TestRouting.java	23
flink-doris-connector/src/test/java/org/apache/doris/flink/serialization/TestRowBatch.java	1446
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/DorisSinkFailoverITCase.java	163
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/DorisSinkITCase.java	649
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/DorisSinkMultiTblFailoverITCase.java	321
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/DorisSinkTest.java	66
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/HttpEntityMock.java	48
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/HttpTestUtil.java	263
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/OptionUtils.java	64
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/TestBackendUtil.java	72
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/TestDorisCommittable.java	20
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/TestDorisCommittableSerializer.java	13
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/TestEscapeHandler.java	17
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/TestResponseUtil.java	46
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/TestUtil.java	20
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/batch/TestBatchBufferHttpEntity.java	23
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/batch/TestBatchBufferStream.java	64
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/batch/TestDorisBatchSink.java	28
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/batch/TestDorisBatchStreamLoad.java	184
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/batch/TestDorisBatchWriter.java	63
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/batch/TestRecordWithMeta.java	13
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/committer/MockCommitRequest.java	26
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/committer/TestDorisCommitter.java	144
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/copy/TestBatchRecordBuffer.java	61
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/copy/TestCopyCommittableSerializer.java	16
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/copy/TestDorisCopyCommitter.java	106
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/copy/TestDorisCopyWriter.java	97
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/schema/SchemaChangeHelperTest.java	43
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/schema/SchemaManagerITCase.java	251
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/schema/SchemaManagerTest.java	128
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/TestCacheRecordBuffer.java	51
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/TestDorisStreamLoad.java	340
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/TestDorisWriter.java	230
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/TestDorisWriterStateSerializer.java	28
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/TestLabelGenerator.java	41
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/TestRecordBuffer.java	58
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/TestRecordWithMetaSerializer.java	27
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/TestRowDataSerializer.java	157
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/TestRowSerializer.java	101
flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/TestJsonDebeziumChangeBase.java	32
flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceExampleTest.java	26
flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java	882
flink-doris-connector/src/test/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumeratorTest.java	75
flink-doris-connector/src/test/java/org/apache/doris/flink/source/enumerator/PendingSplitsCheckpointSerializerTest.java	25
flink-doris-connector/src/test/java/org/apache/doris/flink/source/reader/DorisSourceReaderTest.java	38
flink-doris-connector/src/test/java/org/apache/doris/flink/source/reader/TestingReaderContext.java	60
flink-doris-connector/src/test/java/org/apache/doris/flink/source/split/DorisSourceSplitSerializerTest.java	18
flink-doris-connector/src/test/java/org/apache/doris/flink/source/split/DorisSourceSplitTest.java	17
flink-doris-connector/src/test/java/org/apache/doris/flink/source/split/DorisSplitRecordsTest.java	12
flink-doris-connector/src/test/java/org/apache/doris/flink/table/DorisDynamicTableFactoryTest.java	220
flink-doris-connector/src/test/java/org/apache/doris/flink/table/DorisDynamicTableSourceTest.java	281
flink-doris-connector/src/test/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunctionITCase.java	153
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcDb2SyncDatabaseCase.java	72
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcMongoSyncDatabaseCase.java	68
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcMysqlSyncDatabaseCase.java	74
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcOraclelSyncDatabaseCase.java	68
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcPostgresSyncDatabaseCase.java	68
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcSqlServerSyncDatabaseCase.java	67
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcToolsTest.java	87
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/DatabaseSyncTest.java	220
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/DorisTableConfigTest.java	32
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/MockSourceSchema.java	15
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/db2/Db2TypeTest.java	29
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBCreateTableTest.java	85
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSyncTest.java	25
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBTypeTest.java	115
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDateConverterTest.java	11
flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunctionTest.java	14
flink-doris-connector/src/test/java/org/apache/doris/flink/utils/DateToStringConverter.java	123
flink-doris-connector/src/test/java/org/apache/doris/flink/utils/FactoryMocks.java	28
flink-doris-connector/src/test/java/org/apache/doris/flink/utils/FastDateUtilTest.java	29
flink-doris-connector/src/test/java/org/apache/doris/flink/utils/MockMultiTableSource.java	116
flink-doris-connector/src/test/java/org/apache/doris/flink/utils/MockSource.java	82
flink-doris-connector/src/test/resources/container/e2e/doris2doris/test_doris2doris_sink_test_tbl.sql	30
flink-doris-connector/src/test/resources/container/e2e/doris2doris/test_doris2doris_source_test_tbl.sql	46
flink-doris-connector/src/test/resources/container/e2e/mysql2doris/testAutoAddTable_init.sql	31
flink-doris-connector/src/test/resources/container/e2e/mysql2doris/testMySQL2DorisByDefault_init.sql	31
flink-doris-connector/src/test/resources/container/e2e/mysql2doris/testMySQL2DorisCreateTable_init.sql	53
flink-doris-connector/src/test/resources/container/e2e/mysql2doris/testMySQL2DorisEnableDelete_init.sql	31
flink-doris-connector/src/test/resources/container/e2e/mysql2doris/testMySQL2DorisMultiDb2One_init.sql	60
flink-doris-connector/src/test/resources/container/e2e/mysql2doris/testMySQL2DorisMultiDbSync_init.sql	44
flink-doris-connector/src/test/resources/container/e2e/mysql2doris/testMySQL2DorisSQLParse_init.sql	31
flink-doris-connector/src/test/resources/container/e2e/mysql2doris/testMySQL2Doris_init.sql	32