Struct ColumnarExport 

pub struct ColumnarExport {
    pub timestamps: Vec<i64>,
    pub metrics: Vec<String>,
    pub values: Vec<f64>,
}

A flat, owned columnar representation of exported time-series data.

ColumnarExport stores three parallel vectors:

• timestamps: Unix epoch milliseconds.
• metrics: series / metric names.
• values: observed measurement values.

It is independent of the arrow-export feature and is always compiled. Use it as a lightweight bridge to CSV, TSV, or JSON exports for small to medium datasets, or as a staging area before Arrow conversion.

Fields

timestamps: Vec<i64>

Parallel array of Unix epoch milliseconds.

metrics: Vec<String>

Parallel array of metric / series names.

values: Vec<f64>

Parallel array of observed values.

Implementations

impl ColumnarExport

pub fn new() -> Self

Create an empty ColumnarExport.

pub fn with_capacity(capacity: usize) -> Self

Create a ColumnarExport pre-allocated for capacity rows.

pub fn from_points(points: &[ExportedPoint]) -> Self

Populate from a slice of ExportedPoints.

pub fn len(&self) -> usize

Return the number of rows in this export.

pub fn is_empty(&self) -> bool

Return true if the export contains no rows.

pub fn push(&mut self, timestamp_ms: i64, metric: impl Into<String>, value: f64)

Append a single row.

pub fn to_points(&self) -> Vec<ExportedPoint>

Convert to a Vec<ExportedPoint>.

pub fn to_csv(&self, path: &Path) -> TsdbResult<()>

Write this export as CSV to the file at path.

The header row is timestamp_ms,metric,value.

pub fn to_tsv(&self, path: &Path) -> TsdbResult<()>

Write this export as TSV (tab-separated values) to the file at path.

The header row is timestamp_ms\tmetric\tvalue.

pub fn to_json(&self) -> TsdbResult<Value>

Serialize this export to a JSON array.

Each element is {"timestamp_ms": <i64>, "metric": <str>, "value": <f64>}.

pub fn to_json_string(&self) -> TsdbResult<String>

Serialize this export to a JSON string.

pub fn filter_metric(&self, metric: &str) -> Self

Filter rows to only those matching the given metric name, returning a new ColumnarExport.

pub fn filter_time_range(&self, start_ms: i64, end_ms: i64) -> Self

Filter rows to the given time range [start_ms, end_ms] inclusive.

pub fn sort_by_timestamp(&mut self)

Sort rows by timestamp in ascending order (in-place).

pub fn value_stats(&self) -> ColumnarStats

Compute basic descriptive statistics over the value column.

pub fn from_csv(path: &Path) -> TsdbResult<Self>

Read a CSV file previously written by to_csv back into a ColumnarExport.

Trait Implementations

impl Clone for ColumnarExport

fn clone(&self) -> ColumnarExport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ColumnarExport

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

Formats the value using the given formatter.

impl Default for ColumnarExport

fn default() -> ColumnarExport

Returns the “default value” for a type.