From 359da62d9e96f3b97cfb7e245b167b5dd329588b Mon Sep 17 00:00:00 2001
From: evenyag <realevenyag@gmail.com>
Date: Mon, 10 Mar 2025 13:35:56 +0800
Subject: [PATCH] feat: use parquet

---
 src/sst-convert/src/reader/remote_write.rs | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/sst-convert/src/reader/remote_write.rs b/src/sst-convert/src/reader/remote_write.rs
index e6104e1191..9fec7a12ca 100644
--- a/src/sst-convert/src/reader/remote_write.rs
+++ b/src/sst-convert/src/reader/remote_write.rs
@@ -92,8 +92,7 @@ impl RemoteWriteReader {
         };
         let mut sorter = TimeSeriesSorter::new(encoder);
 
-        let reader = operator.reader(path).await.context(ObjectStoreSnafu)?;
-        let mut reader = TimeSeriesReader::new(reader).await?;
+        let mut reader = TimeSeriesParquetReader::new(operator, path).await?;
         while let Some(series) = reader.next_series().await? {
             sorter.push(series).await?;
         }