query::range_select::plan

Function produce_align_time

source 
fn produce_align_time(
    align_to: i64,
    range: <TimestampMillisecondType as ArrowPrimitiveType>::Native,
    align: <TimestampMillisecondType as ArrowPrimitiveType>::Native,
    ts_column: &TimestampMillisecondArray,
    by_columns_hash: &[u64],
    modify_map: &mut HashMap<(u64, <TimestampMillisecondType as ArrowPrimitiveType>::Native), Vec<u32>>,
)
Expand description

Use align_to as time origin. According to align as time interval, produces aligned time. Combining the parameters related to the range query, determine for each Accumulator (hash, align_ts) define, which rows of data will be applied to it.