pub struct AvroSoeFormat {}Expand description
Raw Avro binary streaming format using Single-Object Encoding per record.
Each record written by the stream writer is framed with a prefix determined by the schema fingerprinting algorithm.
See: https://avro.apache.org/docs/1.11.1/specification/#single-object-encoding See: https://docs.confluent.io/platform/current/schema-registry/fundamentals/serdes-develop/index.html#wire-format
Trait Implementations§
Source§impl AvroFormat for AvroSoeFormat
impl AvroFormat for AvroSoeFormat
Source§const NEEDS_PREFIX: bool = true
const NEEDS_PREFIX: bool = true
If
true, the writer for this format will query single_object_prefix()
and write the prefix before each record. If false, the writer can
skip this step. This is a performance hint for the writer.Source§fn start_stream<W: Write>(
&mut self,
_writer: &mut W,
_schema: &Schema,
compression: Option<CompressionCodec>,
) -> Result<(), ArrowError>
fn start_stream<W: Write>( &mut self, _writer: &mut W, _schema: &Schema, compression: Option<CompressionCodec>, ) -> Result<(), ArrowError>
Write any bytes required at the very beginning of the output stream
(file header, etc.).
Implementations must not write any record data.
Source§impl Debug for AvroSoeFormat
impl Debug for AvroSoeFormat
Source§impl Default for AvroSoeFormat
impl Default for AvroSoeFormat
Source§fn default() -> AvroSoeFormat
fn default() -> AvroSoeFormat
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for AvroSoeFormat
impl RefUnwindSafe for AvroSoeFormat
impl Send for AvroSoeFormat
impl Sync for AvroSoeFormat
impl Unpin for AvroSoeFormat
impl UnwindSafe for AvroSoeFormat
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more