Struct PartitionCache 

pub struct PartitionCache {
    pub partitions: Vec<Partition>,
    /* private fields */
}

PartitionCache allows to query partitions based on the insert_time range

Fields

partitions: Vec<Partition>

Implementations

impl PartitionCache

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn fetch_overlapping_insert_range( pool: &Pool<Postgres>, insert_range: TimeRange, ) -> impl Future<Output = Result<PartitionCache, Error>>

fetches the partitions of all views matching the specified insert range

pub fn fetch_overlapping_insert_range_for_view( pool: &Pool<Postgres>, view_set_name: Arc<String>, view_instance_id: Arc<String>, insert_range: TimeRange, ) -> impl Future<Output = Result<PartitionCache, Error>>

fetches the partitions of a single view instance matching the specified insert range

pub fn filter( &self, view_set_name: &str, view_instance_id: &str, file_schema_hash: &[u8], insert_range: TimeRange, ) -> PartitionCache

pub fn filter_insert_range(&self, insert_range: TimeRange) -> PartitionCache

pub fn filter_inside_range( &self, view_set_name: &str, view_instance_id: &str, insert_range: TimeRange, ) -> PartitionCache

Trait Implementations

impl Debug for PartitionCache

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Display for PartitionCache

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl QueryPartitionProvider for PartitionCache

fn fetch<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, view_set_name: &'life1 str, view_instance_id: &'life2 str, query_range: Option<TimeRange>, file_schema_hash: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Partition>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, PartitionCache: 'async_trait,

unlike LivePartitionProvider, the query_range is tested against the insertion time, not the event time