Skip to content

Commit

Permalink
chore: fix some style problems.
Browse files Browse the repository at this point in the history
  • Loading branch information
Rachelint committed May 9, 2023
1 parent b056310 commit f80557c
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 8 deletions.
4 changes: 2 additions & 2 deletions analytic_engine/src/instance/open.rs
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ impl Instance {
store_picker.default_store().clone(),
));

let table_snapshot_provider = Arc::new(TableMetaSetImpl {
let table_meta_set_impl = Arc::new(TableMetaSetImpl {
spaces: spaces.clone(),
file_purger: file_purger.clone(),
preflush_write_buffer_size_ratio: ctx.config.preflush_write_buffer_size_ratio,
Expand All @@ -74,7 +74,7 @@ impl Instance {
ctx.config.manifest.clone(),
manifest_storages.wal_manager,
manifest_storages.oss_storage,
table_snapshot_provider,
table_meta_set_impl,
)
.await
.context(OpenManifest)?;
Expand Down
10 changes: 5 additions & 5 deletions analytic_engine/src/manifest/details.rs
Original file line number Diff line number Diff line change
Expand Up @@ -35,10 +35,11 @@ use wal::{
},
};

use super::meta_edit::{MetaEdit, Snapshot};
use crate::{
manifest::{
meta_edit::{MetaEditRequest, MetaUpdate, MetaUpdateDecoder, MetaUpdatePayload},
meta_edit::{
MetaEdit, MetaEditRequest, MetaUpdate, MetaUpdateDecoder, MetaUpdatePayload, Snapshot,
},
meta_snapshot::{MetaSnapshot, MetaSnapshotBuilder},
LoadRequest, Manifest, SnapshotRequest,
},
Expand Down Expand Up @@ -178,9 +179,9 @@ impl MetaUpdateLogEntryIterator for MetaUpdateReaderImpl {
}
}

/// Table snapshot provider
/// Table meta set
///
/// Mainly for getting the [TableManifestData] from memory.
/// Get snapshot of or modify table's metadata through it.
pub(crate) trait TableMetaSet: fmt::Debug + Send + Sync {
fn get_table_snapshot(
&self,
Expand Down Expand Up @@ -462,7 +463,6 @@ impl Manifest for ManifestImpl {
let shard_id = shard_info.shard_id;
let location = WalLocation::new(shard_id as u64, table_id.as_u64());
let space_id = meta_update.space_id();
let table_id = meta_update.table_id();

self.maybe_do_snapshot(space_id, table_id, location, false)
.await?;
Expand Down
2 changes: 1 addition & 1 deletion analytic_engine/src/manifest/meta_edit.rs
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,8 @@ use snafu::{Backtrace, OptionExt, ResultExt, Snafu};
use table_engine::table::TableId;
use wal::log_batch::{Payload, PayloadDecoder};

use super::meta_snapshot::MetaSnapshot;
use crate::{
manifest::meta_snapshot::MetaSnapshot,
space::SpaceId,
table::{
data::{MemTableId, TableShardInfo},
Expand Down

0 comments on commit f80557c

Please sign in to comment.