Path	Lines of Code
src/test/java/org/apache/doris/kafka/connector/DistributedTest.java	19
src/test/java/org/apache/doris/kafka/connector/StandaloneTest.java	26
src/test/java/org/apache/doris/kafka/connector/cfg/TestDorisOptions.java	65
src/test/java/org/apache/doris/kafka/connector/cfg/TestDorisSinkConnectorConfig.java	315
src/test/java/org/apache/doris/kafka/connector/decode/avro/DorisAvroConverterTest.java	68
src/test/java/org/apache/doris/kafka/connector/e2e/doris/DorisContainerService.java	6
src/test/java/org/apache/doris/kafka/connector/e2e/doris/DorisContainerServiceImpl.java	164
src/test/java/org/apache/doris/kafka/connector/e2e/kafka/KafkaContainerService.java	13
src/test/java/org/apache/doris/kafka/connector/e2e/kafka/KafkaContainerServiceImpl.java	274
src/test/java/org/apache/doris/kafka/connector/e2e/sink/AbstractKafka2DorisSink.java	212
src/test/java/org/apache/doris/kafka/connector/e2e/sink/avro/AbstractAvroE2ESinkTest.java	68
src/test/java/org/apache/doris/kafka/connector/e2e/sink/avro/AvroMsgE2ETest.java	154
src/test/java/org/apache/doris/kafka/connector/e2e/sink/stringconverter/AbstractStringE2ESinkTest.java	33
src/test/java/org/apache/doris/kafka/connector/e2e/sink/stringconverter/DorisSinkFailoverSinkTest.java	113
src/test/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtilsTest.java	26
src/test/java/org/apache/doris/kafka/connector/utils/FileNameConfigCheckUtilsTest.java	22
src/test/java/org/apache/doris/kafka/connector/utils/JdbcTest.java	75
src/test/java/org/apache/doris/kafka/connector/writer/HttpEntityMock.java	48
src/test/java/org/apache/doris/kafka/connector/writer/HttpTestUtil.java	30
src/test/java/org/apache/doris/kafka/connector/writer/TestCopyIntoWriter.java	106
src/test/java/org/apache/doris/kafka/connector/writer/TestCopyLoad.java	44
src/test/java/org/apache/doris/kafka/connector/writer/TestCopySQL.java	15
src/test/java/org/apache/doris/kafka/connector/writer/TestRecordBuffer.java	37
src/test/java/org/apache/doris/kafka/connector/writer/TestStreamLoadWriter.java	160
src/test/resources/decode/avro/product.avsc	18
src/test/resources/decode/avro/user.avsc	18
src/test/resources/doris-connector-sink.sh	26
src/test/resources/e2e/avro_converter/confluent_avro_tab.sql	11
src/test/resources/e2e/avro_converter/doris_avro_tab.sql	11
src/test/resources/e2e/string_converter/debezium_dml_event_tab.sql	11
src/test/resources/e2e/string_converter/full_types_debezium_ingestion.sql	59
src/test/resources/e2e/string_converter/group_commit_tab.sql	12
src/test/resources/e2e/string_converter/insert_partial_update_tab.sql	3
src/test/resources/e2e/string_converter/null_values_tab.sql	11
src/test/resources/e2e/string_converter/partial_update_tab.sql	14
src/test/resources/e2e/string_converter/string_msg_tab.sql	11
src/test/resources/e2e/string_converter/string_msg_tab_failover.sql	11
src/test/resources/e2e/string_converter/table_field_config1.sql	11
src/test/resources/e2e/string_converter/table_field_config2.sql	11
src/test/resources/e2e/string_converter/time_types.sql	15
src/test/resources/e2e/transforms/regex_router_transforms.sql	11
src/test/resources/e2e/transforms/rename_transforms.sql	11