rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-26 01:40:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: update fs object build

Browse Source
This commit is contained in:
evenyag
2025-03-09 20:37:49 +08:00
parent 371afc458f
commit 142dacb2c8
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/sst-convert/src/converter.rs
View File

@@ -16,19 +16,19 @@
use std::sync::Arc;
use datanode::config::{FileConfig, StorageConfig};
use datanode::config::StorageConfig;
use datanode::datanode::DatanodeBuilder;
use datanode::store::fs::new_fs_object_store;
use meta_client::MetaClientOptions;
use mito2::access_layer::SstInfoArray;
use mito2::config::MitoConfig;
use mito2::read::Source;
use mito2::sst::parquet::WriteOptions;
use object_store::manager::ObjectStoreManagerRef;
use object_store::services::Fs;
use object_store::ObjectStore;
use snafu::ResultExt;
use crate::error::{DatanodeSnafu, MitoSnafu, Result};
use crate::error::{DatanodeSnafu, MitoSnafu, ObjectStoreSnafu, Result};
use crate::reader::InputReaderBuilder;
use crate::table::TableMetadataHelper;
use crate::writer::RegionWriterBuilder;
@@ -191,7 +191,10 @@ pub async fn new_object_store_manager(config: &StorageConfig) -> Result<ObjectSt
/// Creates a input store from a path.
pub async fn new_input_store(path: &str) -> Result<ObjectStore> {
new_fs_object_store(path, &FileConfig::default())
.await
.context(DatanodeSnafu)
let builder = Fs::default().root(path);
let object_store = ObjectStore::new(builder)
.context(ObjectStoreSnafu)?
.finish();
Ok(object_store)
}