Enum BatchHandoffError 

pub enum BatchHandoffError {
    QueryOutputSetup {
        source: DataFusionError,
        stats: BatchHandoffStats,
    },
    Upstream {
        source: DataFusionError,
        stats: BatchHandoffStats,
    },
    Downstream {
        source: DeltaFunnelError,
        stats: BatchHandoffStats,
    },
}

Terminal failure from a query-output handoff.

Upstream errors come from the DataFusion stream. Downstream errors come from the batch consumer, which will later be backed by arrow-tiberius.

Variants

QueryOutputSetup

The selected DataFusion query output could not be exposed as a stream.

Fields

source: DataFusionError

Original DataFusion setup error.

stats: BatchHandoffStats

Handoff counters for batches accepted before the failure.

Upstream

The upstream DataFusion stream failed before producing the next batch.

Fields

source: DataFusionError

Original DataFusion error with its existing provider/query context.

stats: BatchHandoffStats

Handoff counters for batches accepted before the failure.

Downstream

The downstream consumer rejected the current batch.

Fields

source: DeltaFunnelError

Original downstream writer error.

stats: BatchHandoffStats

Handoff counters for batches accepted before the failure.

Implementations

impl BatchHandoffError

pub fn stats(&self) -> BatchHandoffStats

Returns counters for batches accepted before the terminal failure.

Trait Implementations

impl Debug for BatchHandoffError

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

Formats the value using the given formatter.

impl Display for BatchHandoffError

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

Formats the value using the given formatter.

impl Error for BatchHandoffError

where Self: Debug + Display,

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl ErrorCompat for BatchHandoffError

fn backtrace(&self) -> Option<&Backtrace>

Returns a Backtrace that may be printed.

fn iter_chain(&self) -> ChainCompat<'_, '_>

where Self: AsErrorSource,

Returns an iterator for traversing the chain of errors, starting with the current error and continuing with recursive calls to Error::source.