结构体 AvroSchema 

pub struct AvroSchema {
    pub json_string: String,
}

Avro schema 的 JSON 字符串表示的包装器。

字段

json_string: String

Avro schema 的 JSON 字符串。

实现

impl AvroSchema

pub fn new(json_string: String) -> Self

从 JSON 字符串创建一个新的 AvroSchema。

pub(crate) fn schema(&self) -> Result<Schema<'_>, ArrowError>

pub fn fingerprint( &self, hash_type: FingerprintAlgorithm, ) -> Result<Fingerprint, ArrowError>

返回 schema 的指纹，使用指定的 FingerprintAlgorithm 计算。

指纹是根据 Avro 规范定义的 schema 的“解析规范形式”计算的。根据 hash_type，这将返回其中一个受支持的 Fingerprint 变体

• 对于 FingerprintAlgorithm::Rabin 返回 Fingerprint::Rabin
• 对于 FingerprintAlgorithm::MD5 返回 Fingerprint::MD5
• 对于 FingerprintAlgorithm::SHA256 返回 Fingerprint::SHA256

注意：FingerprintAlgorithm::Id 或 FingerprintAlgorithm::Id64 不能用于生成指纹，否则将导致错误。如果您打算使用基于 Schema Registry ID 的线路格式，请使用 SchemaStore::set 或通过 Fingerprint::load_fingerprint_id 直接加载 Fingerprint::Id，或者对于 Fingerprint::Id64 通过 Fingerprint::load_fingerprint_id64 加载。

另请参阅：https://avro.apache.org/docs/1.11.1/specification/#schema-fingerprints

错误

如果 schema 反序列化失败、生成 schema 的规范形式失败，或者 hash_type 是 FingerprintAlgorithm::Id，则返回错误。

示例

use arrow_avro::schema::{AvroSchema, FingerprintAlgorithm};

let avro = AvroSchema::new("\"string\"".to_string());
let fp = avro.fingerprint(FingerprintAlgorithm::Rabin).unwrap();

pub(crate) fn generate_fingerprint( schema: &Schema<'_>, hash_type: FingerprintAlgorithm, ) -> Result<Fingerprint, ArrowError>

pub(crate) fn generate_canonical_form( schema: &Schema<'_>, ) -> Result<String, ArrowError>

为给定的 Schema 生成“解析规范形式”。

规范形式是 schema 的标准化 JSON 表示，主要用于生成 schema 指纹以进行相等性检查。

此形式会剥离不影响 schema 身份的属性，例如 doc 字段、aliases 以及 Avro 规范中未定义的任何属性。

https://avro.apache.org/docs/1.11.1/specification/#parsing-canonical-form-for-schemas

pub(crate) fn from_arrow_with_options( schema: &ArrowSchema, options: Option<AvroSchemaOptions>, ) -> Result<AvroSchema, ArrowError>

从 Arrow [`ArrowSchema`] 构建 Avro JSON，应用给定的空联合顺序，并可选地剥离内部 Arrow 元数据。

如果输入 Arrow schema 在 SCHEMA_METADATA_KEY 中已包含 Avro JSON，则按原样返回该 JSON 以保留精确的头部编码对齐；否则，将生成一个新的 JSON，该 JSON 在**所有可空位置**都遵循 null_union_order。

Trait 实现

impl Clone for AvroSchema

fn clone(&self) -> AvroSchema

返回值的副本。 阅读更多

fn clone_from(&mut self, source: &Self)

执行从 source 的复制赋值。 阅读更多

impl Debug for AvroSchema

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

使用给定的格式化程序格式化值。 阅读更多

impl<'de> Deserialize<'de> for AvroSchema

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

从给定的 Serde 反序列化器反序列化此值。 阅读更多

impl PartialEq for AvroSchema

fn eq(&self, other: &AvroSchema) -> bool

测试 self 和 other 值是否相等，并由 == 使用。

fn ne(&self, other: &Rhs) -> bool

测试 !=。默认实现几乎总是足够的，不应在没有充分理由的情况下重写。

impl Serialize for AvroSchema

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

将此值序列化到给定的 Serde 序列化器中。 阅读更多

impl TryFrom<&Schema> for AvroSchema

fn try_from(schema: &ArrowSchema) -> Result<Self, Self::Error>

将 ArrowSchema 转换为 AvroSchema，委托给 AvroSchema::from_arrow_with_options 并使用 None，以便联合空排序由 Nullability::default() 决定。

type Error = ArrowError

转换错误时返回的类型。

impl Eq for AvroSchema

impl StructuralPartialEq for AvroSchema