pub struct AvroSoeFormat {}展开描述
每条记录使用单对象编码的原始 Avro 二进制流式传输格式。
流写入器写入的每条记录都带有一个由 schema 指纹算法确定的前缀。
请参阅:https://avro.apache.org/docs/1.11.1/specification/#single-object-encoding 请参阅:https://docs.confluent.io/platform/current/schema-registry/fundamentals/serdes-develop/index.html#wire-format
Trait 实现§
源代码§impl AvroFormat for AvroSoeFormat
impl AvroFormat for AvroSoeFormat
源代码§const NEEDS_PREFIX: bool = true
const NEEDS_PREFIX: bool = true
如果为
true,此格式的写入器将查询 single_object_prefix() 并在每个记录之前写入前缀。如果为 false,写入器可以跳过此步骤。这是对写入器的性能提示。源代码§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>
在输出流的最开始(文件头等)写入任何必需的字节。实现 不得 写入任何记录数据。
源代码§impl Debug for AvroSoeFormat
impl Debug for AvroSoeFormat
源代码§impl Default for AvroSoeFormat
impl Default for AvroSoeFormat
源代码§fn default() -> AvroSoeFormat
fn default() -> AvroSoeFormat
返回某个类型的“默认值”。阅读更多