Sign in

    zhaoyuanjuns/moonbit_extractor/data does not have a README file

    AggregateBin

    pub(all) struct AggregateBin {
    index : Int
    lower : Double
    upper : Double
    count : Int
    mean : Double
    minimum : Double
    maximum : Double
    standard_deviation : Double
    } derive(Eq, ToJson,
    Debug
    )

    ColumnStatistics

    pub(all) struct ColumnStatistics {
    count : Int
    minimum : Double
    maximum : Double
    mean : Double
    standard_deviation : Double
    missing_count : Int
    } derive(Eq, ToJson,
    Debug
    )

    CsvOptions

    pub(all) struct CsvOptions {
    delimiter : String
    has_header : Bool
    comment_prefix : String
    } derive(Eq,
    Debug
    )

    CsvOptions::default

    fn CsvOptions::default() -> CsvOptions

    DataQuality

    pub(all) enum DataQuality {
    Accepted
    Suspect(reason~ : String)
    Rejected(reason~ : String)
    } derive(Eq, ToJson,
    Debug
    )

    DataRule

    pub(all) enum DataRule {
    XRange(lower~ : Double, upper~ : Double)
    YRange(lower~ : Double, upper~ : Double)
    XStrictlyIncreasing
    NoRejectedRows
    MaximumAbsoluteSlope(value~ : Double)
    MaximumRelativeJump(value~ : Double)
    MinimumRows(count~ : Int)
    } derive(Eq, ToJson,
    Debug
    )

    A reusable validation rule for measured equilibrium data.

    FeatureVector

    pub(all) struct FeatureVector {
    id : String
    features : Array[Double]
    target : Double
    } derive(Eq, ToJson,
    Debug
    )

    GroupSummary

    pub(all) struct GroupSummary {
    key : String
    count : Int
    mean : Double
    weighted_mean : Double
    minimum : Double
    maximum : Double
    total : Double
    } derive(Eq, ToJson,
    Debug
    )

    Histogram

    pub(all) struct Histogram {
    bins : Array[AggregateBin]
    total_count : Int
    underflow : Int
    overflow : Int
    } derive(Eq, ToJson,
    Debug
    )

    MeasurementRow

    pub(all) struct MeasurementRow {
    id : String
    x : Double
    y : Double
    temperature_kelvin : Double
    pressure_pascal : Double
    replicate : Int
    quality : DataQuality
    } derive(Eq, ToJson,
    Debug
    )

    A row of measured process data with optional operating metadata.

    MeasurementRow::is_usable

    fn MeasurementRow::is_usable(self : MeasurementRow) -> Bool

    MeasurementRow::mark

    MeasurementRow::new

    fn MeasurementRow::new(id~ : String, x~ : Double, y~ : Double, temperature_kelvin~ : Double, pressure_pascal~ : Double, replicate? : Int) -> MeasurementRow raise
    ExtractionError

    MeasurementRow::relative_volatility

    fn MeasurementRow::relative_volatility(self : MeasurementRow) -> Double

    MeasurementRow::temperature_celsius

    fn MeasurementRow::temperature_celsius(self : MeasurementRow) -> Double

    MeasurementTable

    pub(all) struct MeasurementTable {
    name : String
    rows : Array[MeasurementRow]
    x_label : String
    y_label : String
    } derive(Eq, ToJson,
    Debug
    )

    MeasurementTable::accepted_count

    fn MeasurementTable::accepted_count(self : MeasurementTable) -> Int

    MeasurementTable::correlation

    MeasurementTable::deduplicate_x

    MeasurementTable::filter_x

    MeasurementTable::mark_outliers

    MeasurementTable::moving_average

    MeasurementTable::name

    fn MeasurementTable::name(self : MeasurementTable) -> String

    MeasurementTable::new

    fn MeasurementTable::new(name~ : String, rows~ : ArrayView[MeasurementRow], x_label? : String, y_label? : String) -> MeasurementTable raise
    ExtractionError

    MeasurementTable::quality_report

    fn MeasurementTable::quality_report(self : MeasurementTable) -> TableQuality

    MeasurementTable::rejected_count

    fn MeasurementTable::rejected_count(self : MeasurementTable) -> Int

    MeasurementTable::rows

    MeasurementTable::to_csv

    fn MeasurementTable::to_csv(self : MeasurementTable) -> String

    MeasurementTable::usable_rows

    MeasurementTable::x_values

    fn MeasurementTable::x_values(self : MeasurementTable) -> Array[Double]

    MeasurementTable::y_values

    fn MeasurementTable::y_values(self : MeasurementTable) -> Array[Double]

    QualityControlSummary

    pub(all) struct QualityControlSummary {
    results : Array[RuleResult]
    passed : Bool
    total_violations : Int
    failed_rules : Int
    } derive(Eq, ToJson,
    Debug
    )

    QualityControlSummary::to_markdown

    fn QualityControlSummary::to_markdown(self : QualityControlSummary) -> String

    RuleResult

    pub(all) struct RuleResult {
    rule_name : String
    passed : Bool
    violations : Int
    first_row : Int
    message : String
    } derive(Eq, ToJson,
    Debug
    )

    TableQuality

    pub(all) struct TableQuality {
    rows : Int
    usable_rows : Int
    rejected_rows : Int
    duplicate_x_groups : Int
    monotone_x : Bool
    finite_values : Bool
    message : String
    } derive(Eq, ToJson,
    Debug
    )

    TimePoint

    pub(all) struct TimePoint {
    timestamp : Double
    value : Double
    quality : DataQuality
    } derive(Eq, ToJson,
    Debug
    )

    Time-series utilities for sampled process measurements.

    TimeSeries

    pub(all) struct TimeSeries {
    name : String
    unit : String
    points : Array[TimePoint]
    sampling_interval : Double
    } derive(Eq, ToJson,
    Debug
    )

    TimeSeries::linear_trend

    fn TimeSeries::linear_trend(self : TimeSeries) -> TrendResult

    TimeSeries::mark_quality

    fn TimeSeries::mark_quality(self : TimeSeries, predicate : (Double) -> DataQuality) -> TimeSeries

    TimeSeries::maximum

    fn TimeSeries::maximum(self : TimeSeries) -> Double

    TimeSeries::mean

    fn TimeSeries::mean(self : TimeSeries) -> Double

    TimeSeries::minimum

    fn TimeSeries::minimum(self : TimeSeries) -> Double

    TimeSeries::new

    fn TimeSeries::new(name~ : String, unit~ : String, timestamps : ArrayView[Double], values : ArrayView[Double], interval? : Double) -> TimeSeries raise
    ExtractionError

    TimeSeries::slice

    TimeSeries::standard_deviation

    fn TimeSeries::standard_deviation(self : TimeSeries) -> Double

    TimeSeries::timestamps

    fn TimeSeries::timestamps(self : TimeSeries) -> Array[Double]

    TimeSeries::valid_points

    fn TimeSeries::valid_points(self : TimeSeries) -> Array[TimePoint]

    TimeSeries::values

    fn TimeSeries::values(self : TimeSeries) -> Array[Double]

    TimeSeries::variance

    fn TimeSeries::variance(self : TimeSeries) -> Double

    TrendResult

    pub(all) struct TrendResult {
    slope : Double
    intercept : Double
    r_squared : Double
    first_value : Double
    last_value : Double
    direction : String
    } derive(Eq, ToJson,
    Debug
    )

    WindowSummary

    pub(all) struct WindowSummary {
    start : Double
    end : Double
    count : Int
    mean : Double
    minimum : Double
    maximum : Double
    standard_deviation : Double
    } derive(Eq, ToJson,
    Debug
    )

    aggregate_correlation

    fn aggregate_correlation(first : ArrayView[Double], second : ArrayView[Double]) -> Double raise
    ExtractionError

    aggregate_covariance

    fn aggregate_covariance(first : ArrayView[Double], second : ArrayView[Double]) -> Double raise
    ExtractionError

    aggregate_cv

    fn aggregate_cv(values : ArrayView[Double]) -> Double

    aggregate_mad

    fn aggregate_mad(values : ArrayView[Double]) -> Double

    aggregate_maximum

    fn aggregate_maximum(values : ArrayView[Double]) -> Double

    aggregate_mean

    fn aggregate_mean(values : ArrayView[Double]) -> Double

    aggregate_median

    fn aggregate_median(values : ArrayView[Double]) -> Double

    aggregate_minimum

    fn aggregate_minimum(values : ArrayView[Double]) -> Double

    aggregate_range

    fn aggregate_range(values : ArrayView[Double]) -> (Double, Double)

    aggregate_rank

    fn aggregate_rank(values : ArrayView[Double]) -> Array[Int]

    aggregate_sort_indices

    fn aggregate_sort_indices(values : ArrayView[Double]) -> Array[Int]

    aggregate_standard_deviation

    fn aggregate_standard_deviation(values : ArrayView[Double]) -> Double

    aggregate_trimmed_mean

    fn aggregate_trimmed_mean(values : ArrayView[Double], trim_fraction : Double) -> Double raise
    ExtractionError

    aggregate_variance

    fn aggregate_variance(values : ArrayView[Double]) -> Double

    aggregate_winsorized_mean

    fn aggregate_winsorized_mean(values : ArrayView[Double], fraction : Double) -> Double raise
    ExtractionError

    aggregate_z_scores

    fn aggregate_z_scores(values : ArrayView[Double]) -> Array[Double]

    autocorrelation

    fn autocorrelation(series : TimeSeries, lag : Int) -> Double raise
    ExtractionError

    bin_index

    fn bin_index(value : Double, lower : Double, upper : Double, bins : Int) -> Int

    cumulative_counts

    fn cumulative_counts(histogram : Histogram) -> Array[Int]

    detect_plateau

    fn detect_plateau(values : ArrayView[Double], tolerance~ : Double) -> Array[Bool]

    detect_spikes

    fn detect_spikes(series : TimeSeries, threshold : Double) -> Array[TimePoint]

    detect_step_changes

    fn detect_step_changes(series : TimeSeries, threshold : Double) -> Array[TimePoint]

    feature_matrix

    fn feature_matrix(table : MeasurementTable) -> Array[Array[Double]]

    first_difference

    fn first_difference(values : ArrayView[Double]) -> Array[Double]

    group_by_label

    group_summary_csv

    fn group_summary_csv(groups : ArrayView[GroupSummary]) -> String

    group_summary_markdown

    fn group_summary_markdown(groups : ArrayView[GroupSummary]) -> String

    histogram

    fn histogram(values : ArrayView[Double], lower : Double, upper : Double, bins : Int) -> Histogram raise
    ExtractionError

    histogram_density

    fn histogram_density(histogram : Histogram) -> Array[Double]

    histogram_quantile

    fn histogram_quantile(histogram : Histogram, probability : Double) -> Double raise
    ExtractionError

    monotone_direction

    fn monotone_direction(values : ArrayView[Double]) -> Int

    moving_average

    normalize_column

    fn normalize_column(values : ArrayView[Double]) -> Array[Double] raise
    ExtractionError

    Normalize a measured column to the unit interval.

    parse_equilibrium_csv

    Parse a two-column equilibrium table (x,y) from CSV text.

    parse_tie_lines_csv

    Parse tie lines with columns r_carrier,r_solute,r_solvent,e_carrier,e_solute,e_solvent.

    relative_difference

    fn relative_difference(values : ArrayView[Double]) -> Array[Double]

    resample_linear

    fn resample_linear(table : MeasurementTable, lower~ : Double, upper~ : Double, count~ : Int) -> Array[MeasurementRow] raise
    ExtractionError

    Resample a monotone table onto evenly spaced x coordinates.

    resample_uniform

    fn resample_uniform(series : TimeSeries, interval : Double) -> TimeSeries raise
    ExtractionError

    rescale_column

    fn rescale_column(values : ArrayView[Double], source_lower~ : Double, source_upper~ : Double, target_lower~ : Double, target_upper~ : Double) -> Array[Double] raise
    ExtractionError

    rolling_summaries

    rolling_variance

    fn rolling_variance(values : ArrayView[Double], window~ : Int) -> Array[Double] raise
    ExtractionError

    standardize_column

    fn standardize_column(values : ArrayView[Double]) -> Array[Double] raise
    ExtractionError

    table_features

    fn table_features(table : MeasurementTable) -> Array[FeatureVector]

    time_series_csv

    fn time_series_csv(series : TimeSeries) -> String

    time_series_markdown

    fn time_series_markdown(series : TimeSeries) -> String

    weighted_group_by_label

    fn weighted_group_by_label(labels : ArrayView[String], values : ArrayView[Double], weights : ArrayView[Double]) -> Array[GroupSummary] raise
    ExtractionError

    winsorize_column

    fn winsorize_column(values : ArrayView[Double], lower_probability~ : Double, upper_probability~ : Double) -> Array[Double] raise
    ExtractionError