rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-04 20:32:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: use parquet

Browse Source
This commit is contained in:
evenyag
2025-03-10 13:35:56 +08:00
parent c9f4b36360
commit 359da62d9e
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/sst-convert/src/reader/remote_write.rs
View File

@@ -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?;
}