diff --git a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/DataInterpretProcessor.java b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/DataInterpretProcessor.java index 34dc9fb01..8debff21a 100644 --- a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/DataInterpretProcessor.java +++ b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/DataInterpretProcessor.java @@ -20,6 +20,9 @@ import java.util.HashMap; import java.util.Map; import java.util.Objects; +/** + * DataInterpretProcessor interprets query result to make it more readable to the users. + */ public class DataInterpretProcessor implements ExecuteResultProcessor { private static final Logger keyPipelineLog = LoggerFactory.getLogger("keyPipeline"); diff --git a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/MetricRatioProcessor.java b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/MetricRatioCalcProcessor.java similarity index 99% rename from chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/MetricRatioProcessor.java rename to chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/MetricRatioCalcProcessor.java index c456d49f0..3ee9cd8eb 100644 --- a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/MetricRatioProcessor.java +++ b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/MetricRatioCalcProcessor.java @@ -56,7 +56,7 @@ import static com.tencent.supersonic.common.pojo.Constants.TIME_FORMAT; * Add ratio queries for metric queries. */ @Slf4j -public class MetricRatioProcessor implements ExecuteResultProcessor { +public class MetricRatioCalcProcessor implements ExecuteResultProcessor { @Override public void process(ExecuteContext executeContext, QueryResult queryResult) { diff --git a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/MetricRecommendProcessor.java b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/MetricRecommendProcessor.java index a108c86b6..cd2176b64 100644 --- a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/MetricRecommendProcessor.java +++ b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/execute/MetricRecommendProcessor.java @@ -26,7 +26,9 @@ import java.util.Objects; import java.util.Set; import java.util.stream.Collectors; -/** MetricRecommendProcessor fills recommended metrics based on embedding similarity. */ +/** + * MetricRecommendProcessor fills recommended metrics based on embedding similarity. + **/ public class MetricRecommendProcessor implements ExecuteResultProcessor { private static final int METRIC_RECOMMEND_SIZE = 5; diff --git a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/ErrorMessageProcessor.java b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/ErrorMsgRewriteProcessor.java similarity index 94% rename from chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/ErrorMessageProcessor.java rename to chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/ErrorMsgRewriteProcessor.java index c6f05980d..39bf1a233 100644 --- a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/ErrorMessageProcessor.java +++ b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/ErrorMsgRewriteProcessor.java @@ -19,7 +19,10 @@ import java.util.HashMap; import java.util.Map; import java.util.Objects; -public class ErrorMessageProcessor implements ParseResultProcessor { +/** + * ErrorMsgRewriteProcessor rewrites error message to make it more readable to the users. + **/ +public class ErrorMsgRewriteProcessor implements ParseResultProcessor { private static final Logger keyPipelineLog = LoggerFactory.getLogger("keyPipeline"); @@ -33,7 +36,7 @@ public class ErrorMessageProcessor implements ParseResultProcessor { + "#Input: {{user_question}}\n" + "#Output: {{system_message}}\n" + "#Examples: {{examples}}\n" + "#Response: "; - public ErrorMessageProcessor() { + public ErrorMsgRewriteProcessor() { ChatAppManager.register(APP_KEY_ERROR_MESSAGE, ChatApp.builder().prompt(REWRITE_ERROR_MESSAGE_INSTRUCTION).name("异常提示改写") .appModule(AppModule.CHAT).description("通过大模型将异常信息改写为更友好和引导性的提示用语") diff --git a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/TextInfoProcessor.java b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/ParseInfoFormatProcessor.java similarity index 94% rename from chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/TextInfoProcessor.java rename to chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/ParseInfoFormatProcessor.java index d921a78b2..238275d44 100644 --- a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/TextInfoProcessor.java +++ b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/ParseInfoFormatProcessor.java @@ -13,7 +13,10 @@ import java.util.Optional; import java.util.Set; import java.util.stream.Collectors; -public class TextInfoProcessor implements ParseResultProcessor { +/** + * ParseInfoFormatProcessor formats parse info to make it more readable to the users. + **/ +public class ParseInfoFormatProcessor implements ParseResultProcessor { @Override public void process(ParseContext parseContext) { parseContext.getResponse().getSelectedParses().forEach(p -> { diff --git a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/ParseInfoSortProcessor.java b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/ParseInfoSortProcessor.java new file mode 100644 index 000000000..f8f864893 --- /dev/null +++ b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/ParseInfoSortProcessor.java @@ -0,0 +1,14 @@ +package com.tencent.supersonic.chat.server.processor.parse; + +import com.tencent.supersonic.chat.server.pojo.ParseContext; + +/** + * ParseInfoSortProcessor sorts candidate parse info based on certain algorithm. \ + **/ +public class ParseInfoSortProcessor implements ParseResultProcessor { + + @Override + public void process(ParseContext parseContext) { + + } +} diff --git a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/QueryRecommendProcessor.java b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/QueryRecommendProcessor.java index a302e1bab..8a0ac855e 100644 --- a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/QueryRecommendProcessor.java +++ b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/QueryRecommendProcessor.java @@ -17,7 +17,9 @@ import java.util.List; import java.util.concurrent.CompletableFuture; import java.util.stream.Collectors; -/** MetricRecommendProcessor fills recommended query based on embedding similarity. */ +/** + * MetricRecommendProcessor fills recommended query based on embedding similarity. + **/ @Slf4j public class QueryRecommendProcessor implements ParseResultProcessor { diff --git a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/TimeCostProcessor.java b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/TimeCostCalcProcessor.java similarity index 76% rename from chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/TimeCostProcessor.java rename to chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/TimeCostCalcProcessor.java index 672017bf9..5c05a03fd 100644 --- a/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/TimeCostProcessor.java +++ b/chat/server/src/main/java/com/tencent/supersonic/chat/server/processor/parse/TimeCostCalcProcessor.java @@ -2,12 +2,13 @@ package com.tencent.supersonic.chat.server.processor.parse; import com.tencent.supersonic.chat.api.pojo.response.ChatParseResp; import com.tencent.supersonic.chat.server.pojo.ParseContext; -import com.tencent.supersonic.headless.api.pojo.response.ParseResp; import lombok.extern.slf4j.Slf4j; -/** TimeCostProcessor adds time cost of parsing. */ +/** + * TimeCostProcessor adds time cost of parsing. + **/ @Slf4j -public class TimeCostProcessor implements ParseResultProcessor { +public class TimeCostCalcProcessor implements ParseResultProcessor { @Override public void process(ParseContext parseContext) { diff --git a/launchers/chat/src/main/resources/META-INF/spring.factories b/launchers/chat/src/main/resources/META-INF/spring.factories index ed6e5b11c..4b0a855db 100644 --- a/launchers/chat/src/main/resources/META-INF/spring.factories +++ b/launchers/chat/src/main/resources/META-INF/spring.factories @@ -15,12 +15,12 @@ com.tencent.supersonic.chat.server.plugin.recognize.PluginRecognizer=\ com.tencent.supersonic.chat.server.processor.parse.ParseResultProcessor=\ com.tencent.supersonic.chat.server.processor.parse.QueryRecommendProcessor,\ - com.tencent.supersonic.chat.server.processor.parse.TimeCostProcessor + com.tencent.supersonic.chat.server.processor.parse.TimeCostCalcProcessor com.tencent.supersonic.chat.server.processor.execute.ExecuteResultProcessor=\ com.tencent.supersonic.chat.server.processor.execute.MetricRecommendProcessor,\ com.tencent.supersonic.chat.server.processor.execute.DimensionRecommendProcessor,\ - com.tencent.supersonic.chat.server.processor.execute.MetricRatioProcessor,\ + com.tencent.supersonic.chat.server.processor.execute.MetricRatioCalcProcessor,\ com.tencent.supersonic.chat.server.processor.execute.DataInterpretProcessor ### auth-authentication SPIs diff --git a/launchers/standalone/src/main/resources/META-INF/spring.factories b/launchers/standalone/src/main/resources/META-INF/spring.factories index 30f262855..2a5caf958 100644 --- a/launchers/standalone/src/main/resources/META-INF/spring.factories +++ b/launchers/standalone/src/main/resources/META-INF/spring.factories @@ -67,14 +67,14 @@ com.tencent.supersonic.chat.server.plugin.recognize.PluginRecognizer=\ com.tencent.supersonic.chat.server.processor.parse.ParseResultProcessor=\ com.tencent.supersonic.chat.server.processor.parse.QueryRecommendProcessor,\ - com.tencent.supersonic.chat.server.processor.parse.TimeCostProcessor,\ - com.tencent.supersonic.chat.server.processor.parse.ErrorMessageProcessor,\ - com.tencent.supersonic.chat.server.processor.parse.TextInfoProcessor + com.tencent.supersonic.chat.server.processor.parse.TimeCostCalcProcessor,\ + com.tencent.supersonic.chat.server.processor.parse.ErrorMsgRewriteProcessor,\ + com.tencent.supersonic.chat.server.processor.parse.ParseInfoFormatProcessor com.tencent.supersonic.chat.server.processor.execute.ExecuteResultProcessor=\ com.tencent.supersonic.chat.server.processor.execute.MetricRecommendProcessor,\ com.tencent.supersonic.chat.server.processor.execute.DimensionRecommendProcessor,\ - com.tencent.supersonic.chat.server.processor.execute.MetricRatioProcessor,\ + com.tencent.supersonic.chat.server.processor.execute.MetricRatioCalcProcessor,\ com.tencent.supersonic.chat.server.processor.execute.DataInterpretProcessor ### auth-authentication SPIs