Enum StreamingError 

pub enum StreamingError {
    Core(OxiGdalError),
    StreamClosed,
    BufferFull,
    InvalidWindow(String),
    WatermarkError(String),
    StateError(String),
    CheckpointError(String),
    PartitionError(String),
    JoinError(String),
    SerializationError(String),
    DeserializationError(String),
    Io(Error),
    Arrow(ArrowError),
    SendError,
    RecvError,
    Timeout,
    InvalidState(String),
    ConfigError(String),
    InvalidOperation(String),
    NotImplemented(String),
    Other(String),
}

Errors that can occur during streaming operations.

Variants

Core(OxiGdalError)

Core OxiGDAL error

StreamClosed

Stream is closed

BufferFull

Stream buffer full

InvalidWindow(String)

Invalid window configuration

WatermarkError(String)

Watermark error

StateError(String)

State error

CheckpointError(String)

Checkpoint error

PartitionError(String)

Partition error

JoinError(String)

Join error

SerializationError(String)

Serialization error

DeserializationError(String)

Deserialization error

Io(Error)

IO error

Arrow(ArrowError)

Arrow error

SendError

Send error

RecvError

Receive error

Timeout

Timeout error

InvalidState(String)

Invalid state

ConfigError(String)

Configuration error

InvalidOperation(String)

Invalid operation

NotImplemented(String)

Not implemented

Other(String)

Other error

Trait Implementations

impl Debug for StreamingError

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

Formats the value using the given formatter.

impl Display for StreamingError

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

Formats the value using the given formatter.

impl Error for StreamingError

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 From<ArrowError> for StreamingError

fn from(source: ArrowError) -> Self

Converts to this type from the input type.

impl From<Error> for StreamingError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for StreamingError

Available on crate feature std only.

fn from(e: Error) -> Self

Converts to this type from the input type.

impl From<OxiGdalError> for StreamingError

fn from(source: OxiGdalError) -> Self

Converts to this type from the input type.

impl From<RecvError> for StreamingError

Available on crate feature std only.

fn from(_: RecvError) -> Self

Converts to this type from the input type.

impl<T> From<SendError<T>> for StreamingError

Available on crate feature std only.

fn from(_: SendError<T>) -> Self

Converts to this type from the input type.