Struct TimeSeriesTable 

pub struct TimeSeriesTable {
    pub def: Arc<TimeSeriesTableDef>,
    pub partitions: Arc<Mutex<PartitionManager>>,
    pub index: Arc<TimeSeriesIndex>,
    pub lifecycle: LifecycleManager,
    pub pre_aggregation: Arc<Mutex<PreAggregationStore>>,
}

时序表结构

Fields

def: Arc<TimeSeriesTableDef>

表定义

partitions: Arc<Mutex<PartitionManager>>

分区管理器

index: Arc<TimeSeriesIndex>

时序索引

lifecycle: LifecycleManager

生命周期管理器

pre_aggregation: Arc<Mutex<PreAggregationStore>>

预聚合数据存储

Implementations

impl TimeSeriesTable

pub fn new( def: Arc<TimeSeriesTableDef>, index: Arc<TimeSeriesIndex>, ) -> Result<Self>

创建新的时序表

pub fn add_pre_aggregation( &self, interval_seconds: u64, aggregation: &str, ) -> Result<()>

添加预聚合配置

pub fn query_pre_aggregated( &self, start_time: u64, end_time: u64, interval_seconds: u64, aggregation: &str, ) -> Result<Vec<TimeSeriesRecord>>

使用预聚合数据执行查询

pub unsafe fn batch_write( &mut self, records: *const TimeSeriesRecord, count: usize, ) -> Result<usize>

批量写入时序数据

pub fn write_timeseries_batch( &mut self, data_points: &[TimeSeriesRecord], ) -> Result<usize>

事务化批量写入时序数据 确保一批数据要么全部成功插入并立即可见，要么全部回滚

pub fn query_time_range( &self, start_time: u64, end_time: u64, ) -> Result<Vec<TimeSeriesRecord>>

时间范围查询