Enum SerializedRecordBatchResult 

pub(crate) enum SerializedRecordBatchResult {
    Success {
        writer: Box<dyn AsyncWrite + Send + Unpin>,
        row_count: usize,
    },
    Failure {
        writer: Option<Box<dyn AsyncWrite + Send + Unpin>>,
        err: DataFusionError,
    },
}

Result of calling serialize_rb_stream_to_object_store

Variants

Success

Fields

writer: Box<dyn AsyncWrite + Send + Unpin>

the writer

row_count: usize

the number of rows successfully written

Failure

Fields

writer: Option<Box<dyn AsyncWrite + Send + Unpin>>

As explained in serialize_rb_stream_to_object_store:

• If an IO error occurred that involved the ObjectStore writer, then the writer will not be returned to the caller
• Otherwise, the writer is returned to the caller

err: DataFusionError

the actual error that occurred

Implementations

impl SerializedRecordBatchResult

pub fn success( writer: Box<dyn AsyncWrite + Send + Unpin>, row_count: usize, ) -> Self

Create the success variant

pub fn failure( writer: Option<Box<dyn AsyncWrite + Send + Unpin>>, err: DataFusionError, ) -> Self