Skip to main content

build_series_partition_range

Function build_series_partition_range 

Source
async fn build_series_partition_range(
    stream_ctx: Arc<StreamContext>,
    part_range: PartitionRange,
    range: SeriesRange,
    filter: MetricSeriesFilter,
    codec: SparsePrimaryKeyCodec,
    partition_pruner: Arc<PartitionPruner>,
    part_metrics: PartitionMetrics,
) -> Result<(BoxedRecordBatchStream, usize)>