Struct ConsolidationQuery 

pub struct ConsolidationQuery {
    pub query_start: u64,
    pub query_end: u64,
    pub use_period_boundaries: bool,
}

Information about a consolidation query to be executed.

This struct encapsulates all the information needed to execute a single consolidation operation, including the data range to query and file naming strategy.

Fields

• query_start: Start timestamp for the data query range (inclusive, in nanoseconds).
• query_end: End timestamp for the data query range (inclusive, in nanoseconds).
• use_period_boundaries: If true, uses period boundaries for file naming; if false, uses actual data timestamps.

Usage

This struct is used internally by the consolidation system to plan and execute data consolidation operations. It allows the system to:

• Separate query planning from execution.
• Handle complex scenarios like data splitting.
• Optimize file naming strategies.
• Batch multiple operations efficiently.
• Maintain file contiguity across periods.

Examples

use nautilus_persistence::backend::catalog_operations::ConsolidationQuery;

// Regular consolidation query
let query = ConsolidationQuery {
    query_start: 1609459200000000000,
    query_end: 1609545600000000000,
    use_period_boundaries: true,
};

// Split operation to preserve data
let split_query = ConsolidationQuery {
    query_start: 1609459200000000000,
    query_end: 1609462800000000000,
    use_period_boundaries: false,
};

Fields

query_start: u64

Start timestamp for the query range (inclusive, in nanoseconds)

query_end: u64

End timestamp for the query range (inclusive, in nanoseconds)

use_period_boundaries: bool

Whether to use period boundaries for file naming (true) or actual data timestamps (false)

Trait Implementations

impl Clone for ConsolidationQuery

fn clone(&self) -> ConsolidationQuery

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConsolidationQuery

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

Formats the value using the given formatter.