From b099abc3a32e87f7b894d6037cb24b673669726e Mon Sep 17 00:00:00 2001 From: LFC <990479+MichaelScofield@users.noreply.github.com> Date: Mon, 24 Nov 2025 19:29:08 +0800 Subject: [PATCH] refactor: pub `HttpOutputWriter` for external use (#7287) Signed-off-by: luofucong --- src/servers/src/http/result.rs | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/src/servers/src/http/result.rs b/src/servers/src/http/result.rs index f4466ead8d..ec3f6120d0 100644 --- a/src/servers/src/http/result.rs +++ b/src/servers/src/http/result.rs @@ -43,17 +43,14 @@ pub(crate) mod null_result; pub(crate) mod prometheus_resp; pub(crate) mod table_result; -pub(super) struct HttpOutputWriter { +pub struct HttpOutputWriter { columns: usize, value_transformer: Option Value>>, current: Option>, } impl HttpOutputWriter { - pub(super) fn new( - columns: usize, - value_transformer: Option Value>>, - ) -> Self { + pub fn new(columns: usize, value_transformer: Option Value>>) -> Self { Self { columns, value_transformer, @@ -101,7 +98,7 @@ impl HttpOutputWriter { self.current.take().unwrap_or_default() } - pub(super) fn write( + pub fn write( &mut self, record_batch: RecordBatch, rows: &mut Vec>,