rhei-datafusion 1.5.0

DataFusion OLAP backend for Rhei HTAP engine
Documentation 
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

//! Error types for the DataFusion OLAP backend.

use datafusion::error::DataFusionError;

/// Errors that can occur in the DataFusion OLAP backend.
///
/// This enum consolidates errors from DataFusion, Arrow, Parquet, I/O, and
/// (when the `cloud-storage` feature is enabled) the `object_store` crate.
#[derive(Debug, thiserror::Error)]
pub enum DfOlapError {
    /// An error originating inside the DataFusion query engine.
    #[error("DataFusion error: {0}")]
    DataFusion(#[from] DataFusionError),

    /// An Arrow-level error (e.g. schema mismatch during array construction).
    #[error("Arrow error: {0}")]
    Arrow(#[from] arrow::error::ArrowError),

    /// A Parquet serialisation or deserialisation error.
    #[error("Parquet error: {0}")]
    Parquet(#[from] parquet::errors::ParquetError),

    /// A query or DML statement referenced a table that has not been registered.
    #[error("table not found: {0}")]
    TableNotFound(String),

    /// The supplied data schema does not match the registered table schema.
    #[error("schema mismatch: {0}")]
    SchemaMismatch(String),

    /// A file-system I/O error (e.g. creating the table directory or writing a file).
    #[error("I/O error: {0}")]
    Io(#[from] std::io::Error),

    /// A `tokio::task::JoinError` from a `spawn_blocking` call.
    #[error("task join error: {0}")]
    Join(String),

    /// An error from the `object_store` crate (cloud storage operations).
    ///
    /// Available on crate feature `cloud-storage` only.
    #[cfg(feature = "cloud-storage")]
    #[error("object store error: {0}")]
    ObjectStore(#[from] object_store::Error),

    /// A URL parse error encountered when constructing cloud storage URLs.
    ///
    /// Available on crate feature `cloud-storage` only.
    #[cfg(feature = "cloud-storage")]
    #[error("invalid URL: {0}")]
    UrlParse(#[from] url::ParseError),

    /// A catch-all error for situations not covered by the other variants.
    #[error("{0}")]
    Other(String),
}

impl DfOlapError {
    /// Wrap a `tokio::task::JoinError` from `spawn_blocking`.
    pub(crate) fn from_join(e: tokio::task::JoinError) -> Self {
        Self::Join(e.to_string())
    }
}