Struct ArrowRecordBatchIpcStreamFormat

pub struct ArrowRecordBatchIpcStreamFormat { /* private fields */ }

Implementations

impl ArrowRecordBatchIpcStreamFormat

pub fn new(schema: Arc<Schema>) -> Self

pub fn with_options(schema: Arc<Schema>, options: IpcWriteOptions) -> Self

Trait Implementations

impl StreamingFormat<RecordBatch> for ArrowRecordBatchIpcStreamFormat

fn to_bytes_stream<'a, 'b>( &'a self, stream: BoxStream<'b, Result<RecordBatch, Error>>, _: &'a StreamBodyAsOptions, ) -> BoxStream<'b, Result<Bytes, Error>>

fn http_response_headers( &self, options: &StreamBodyAsOptions, ) -> Option<HeaderMap>