pub struct SSTableDataManager { /* private fields */ }Expand description
Memory-efficient SSTable data manager
Implementations§
Source§impl SSTableDataManager
impl SSTableDataManager
Sourcepub async fn new(
config: SSTableDataManagerConfig,
platform: Arc<Platform>,
core_config: Config,
schema_manager: Arc<SchemaManager>,
) -> Result<Self>
pub async fn new( config: SSTableDataManagerConfig, platform: Arc<Platform>, core_config: Config, schema_manager: Arc<SchemaManager>, ) -> Result<Self>
Create a new SSTable data manager
Sourcepub async fn discover_tables(&self, data_dir: &Path) -> Result<TableDiscovery>
pub async fn discover_tables(&self, data_dir: &Path) -> Result<TableDiscovery>
Discover all available keyspaces and tables
Sourcepub async fn load_table_data(
&self,
keyspace: &str,
table: &str,
limit: Option<usize>,
) -> Result<Vec<DataRow>>
pub async fn load_table_data( &self, keyspace: &str, table: &str, limit: Option<usize>, ) -> Result<Vec<DataRow>>
Load data for a specific table with caching
Sourcepub async fn query_data(
&self,
keyspace: &str,
table: &str,
where_clause: Option<&str>,
limit: Option<usize>,
) -> Result<Vec<DataRow>>
pub async fn query_data( &self, keyspace: &str, table: &str, where_clause: Option<&str>, limit: Option<usize>, ) -> Result<Vec<DataRow>>
Query data with CQL-like filtering
Sourcepub async fn get_table_schema(
&self,
keyspace: &str,
table: &str,
) -> Result<Option<TableSchema>>
pub async fn get_table_schema( &self, keyspace: &str, table: &str, ) -> Result<Option<TableSchema>>
Get table schema information
Sourcepub async fn list_keyspaces(&self) -> Result<Vec<String>>
pub async fn list_keyspaces(&self) -> Result<Vec<String>>
List all discovered keyspaces
Sourcepub async fn list_tables(&self, keyspace: &str) -> Result<Vec<String>>
pub async fn list_tables(&self, keyspace: &str) -> Result<Vec<String>>
List tables in a keyspace
Sourcepub fn get_cache_stats(&self) -> CacheStatistics
pub fn get_cache_stats(&self) -> CacheStatistics
Get cache statistics
Sourcepub fn get_discovery_status(&self) -> (bool, Option<Duration>)
pub fn get_discovery_status(&self) -> (bool, Option<Duration>)
Get discovery status
Auto Trait Implementations§
impl !RefUnwindSafe for SSTableDataManager
impl !UnwindSafe for SSTableDataManager
impl Freeze for SSTableDataManager
impl Send for SSTableDataManager
impl Sync for SSTableDataManager
impl Unpin for SSTableDataManager
impl UnsafeUnpin for SSTableDataManager
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more