etl-unit 0.1.0

Semantic data model for ETL units — qualities and measurements over subjects and time. Built on Polars.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

#![doc = include_str!("../README.md")]
// Lint suppressions for `dead_code`, `unused_imports`, and polars-related
// glob ambiguities live in `Cargo.toml` under `[lints.rust]`.

pub mod aggregation;
pub mod binder;
pub mod chart_hints;
pub mod column;
pub mod component_filter;
pub mod composition;
pub mod error;
pub mod expr;
pub mod group;
pub mod interval;
pub mod pipeline;
pub mod plan;
pub(crate) mod polars_fns;
pub mod request;
pub mod schema;
pub mod signal_policy;
pub mod source;
pub mod subject;
pub mod subset;
pub mod time_range;
pub mod unit;
pub mod unit_ref;
pub mod universe;
pub mod unpivot;

// Re-export primary types
pub use aggregation::{Aggregate, SyntheticSubject};
pub use chart_hints::{AxisId, ChartHints, ChartSeries, ChartType, Index};
pub use column::{CanonicalColumnName, ColumnNameExt, DomainSignature, SourceColumnName};
pub use component_filter::*;
pub use composition::{ComponentReduction, CompositionPlan, CompositionStrategy};
pub use error::{EtlError, EtlResult};
pub use expr::{ColumnExpr, EpochUnit};
pub use request::{EtlUnitSubsetRequest, Interval, QualityFilter, SubjectFilter, TimeRange};
pub use schema::{EtlSchema, EtlSchemaBuilder};
pub use signal_policy::{SignalPolicy, WindowStrategy};
pub use source::{
    BindingRule, BoundSource, DedupStrategy, EtlUniverseBuildPlan, SignalPolicyMode, StackConfig,
};
// Plan layer — primitives, stage plans, and top-level plans.
pub use plan::{
    BuildPlan, BuildSink, CodomainBinding, ColumnBinding, DerivationPlan, ExtractionCore,
    ProcessingPlan, RuntimePlan, SourceContext, SourceKey, SourceMember,
};
pub use subset::{MeasurementMeta, QualityMeta, SubsetExecutor, SubsetInfo, SubsetUniverse};
pub use time_range::EtlTimeRange;
// Re-export derivation types
pub use unit::{Computation, Derivation, OverSubjectExpr, PointwiseExpr, TimeExpr, TimeUnit};
// Re-export unit types
pub use binder::SourceBinder;
pub use subject::{SubjectType, SubjectValue};
pub use unit::{
    DataTemporality, MeasurementKind, MeasurementUnit, NullValue, QualityDerivation, QualityUnit,
    ResampleStrategy, TruthMapping, UnmappedPolicy, compute_derived_quality,
};
pub use unit_ref::EtlUnitRef;
pub use universe::{
    AlignAction, AlignmentSpec, CompositionSummary, MeasurementAlignment, MemorySummary, Universe,
    UniverseBuildInfo, UniverseBuilder, extract_all_fragments,
};
// Re-export unpivot types
pub use unpivot::UnpivotConfig;