Enum mz_testdrive::format::avro::SchemaPiece

source ·
pub enum SchemaPiece {
Show 34 variants Null, Boolean, Int, Long, Float, Double, Date, TimestampMilli, TimestampMicro, Decimal { precision: usize, scale: usize, fixed_size: Option<usize>, }, Bytes, String, Json, Uuid, Array(Box<SchemaPieceOrNamed>), Map(Box<SchemaPieceOrNamed>), Union(UnionSchema), ResolveIntTsMilli, ResolveIntTsMicro, ResolveDateTimestamp, ResolveIntLong, ResolveIntFloat, ResolveIntDouble, ResolveLongFloat, ResolveLongDouble, ResolveFloatDouble, ResolveConcreteUnion { index: usize, inner: Box<SchemaPieceOrNamed>, n_reader_variants: usize, reader_null_variant: Option<usize>, }, ResolveUnionUnion { permutation: Vec<Result<(usize, SchemaPieceOrNamed), Error>>, n_reader_variants: usize, reader_null_variant: Option<usize>, }, ResolveUnionConcrete { index: usize, inner: Box<SchemaPieceOrNamed>, }, Record { doc: Option<String>, fields: Vec<RecordField>, lookup: BTreeMap<String, usize>, }, Enum { doc: Option<String>, symbols: Vec<String>, default_idx: Option<usize>, }, Fixed { size: usize, }, ResolveRecord { defaults: Vec<ResolvedDefaultValueField>, fields: Vec<ResolvedRecordField>, n_reader_fields: usize, }, ResolveEnum { doc: Option<String>, symbols: Vec<Result<(usize, String), String>>, default: Option<(usize, String)>, },
}

Variants§

§

Null

A null Avro schema.

§

Boolean

A boolean Avro schema.

§

Int

An int Avro schema.

§

Long

A long Avro schema.

§

Float

A float Avro schema.

§

Double

A double Avro schema.

§

Date

An Int Avro schema with a semantic type being days since the unix epoch.

§

TimestampMilli

An Int64 Avro schema with a semantic type being milliseconds since the unix epoch.

https://avro.apache.org/docs/current/spec.html#Timestamp+%28millisecond+precision%29

§

TimestampMicro

An Int64 Avro schema with a semantic type being microseconds since the unix epoch.

https://avro.apache.org/docs/current/spec.html#Timestamp+%28microsecond+precision%29

§

Decimal

A bytes or fixed Avro schema with a logical type of decimal and the specified precision and scale.

If the underlying type is fixed, the fixed_size field specifies the size.

Fields

§precision: usize
§scale: usize
§fixed_size: Option<usize>
§

Bytes

A bytes Avro schema. Bytes represents a sequence of 8-bit unsigned bytes.

§

String

A string Avro schema. String represents a unicode character sequence.

§

Json

A string Avro schema that is tagged as representing JSON data

§

Uuid

A string Avro schema with a logical type of uuid.

§

Array(Box<SchemaPieceOrNamed>)

A array Avro schema. Avro arrays are required to have the same type for each element. This variant holds the Schema for the array element type.

§

Map(Box<SchemaPieceOrNamed>)

A map Avro schema. Map holds a pointer to the Schema of its values, which must all be the same schema. Map keys are assumed to be string.

§

Union(UnionSchema)

A union Avro schema.

§

ResolveIntTsMilli

A value written as int and read as long, for the timestamp-millis logicalType.

§

ResolveIntTsMicro

A value written as int and read as long, for the timestamp-micros logicalType.

§

ResolveDateTimestamp

A value written as an int with date logical type, and read as any timestamp type

§

ResolveIntLong

A value written as int and read as long

§

ResolveIntFloat

A value written as int and read as float

§

ResolveIntDouble

A value written as int and read as double

§

ResolveLongFloat

A value written as long and read as float

§

ResolveLongDouble

A value written as long and read as double

§

ResolveFloatDouble

A value written as float and read as double

§

ResolveConcreteUnion

A concrete (i.e., non-union) type in the writer, resolved against one specific variant of a union in the reader.

Fields

§index: usize

The index of the variant in the reader

§inner: Box<SchemaPieceOrNamed>

The concrete type

§n_reader_variants: usize
§reader_null_variant: Option<usize>
§

ResolveUnionUnion

A union in the writer, resolved against a union in the reader. The two schemas may have different variants and the variants may be in a different order.

Fields

§permutation: Vec<Result<(usize, SchemaPieceOrNamed), Error>>

A mapping of the fields in the writer to those in the reader. If the ith element is Err(e), the ith field in the writer did not match any field in the reader (or even if it matched by name, resolution failed). If the ith element is Ok((j, piece)), then the ith field of the writer matched the jth field of the reader, and piece is their resolved node.

§n_reader_variants: usize
§reader_null_variant: Option<usize>
§

ResolveUnionConcrete

The inverse of ResolveConcreteUnion

Fields

§index: usize
§

Record

A record Avro schema.

The lookup table maps field names to their position in the Vec of fields.

Fields

§

Enum

An enum Avro schema.

Fields

§symbols: Vec<String>
§default_idx: Option<usize>

The index of the default value.

This is only used in schema resolution: it is the value that will be read by a reader when a writer writes a value that the reader does not expect.

§

Fixed

A fixed Avro schema.

Fields

§size: usize
§

ResolveRecord

A record in the writer, resolved against a record in the reader. The two schemas may have different fields and the fields may be in a different order.

Fields

§defaults: Vec<ResolvedDefaultValueField>

Fields that do not exist in the writer schema, but had a default value specified in the reader schema, which we use.

§fields: Vec<ResolvedRecordField>

Fields in the order of their appearance in the writer schema. Present if they could be resolved against a field in the reader schema; Absent otherwise.

§n_reader_fields: usize

The size of defaults, plus the number of Present values in fields.

§

ResolveEnum

An enum in the writer, resolved against an enum in the reader. The two schemas may have different values and the values may be in a different order.

Fields

§symbols: Vec<Result<(usize, String), String>>

Symbols in order of the writer schema along with their index in the reader schema, or Err(symbol_name) if they don’t exist in the reader schema.

§default: Option<(usize, String)>

The value to decode if the writer writes some value not expected by the reader.

Implementations§

source§

impl SchemaPiece

source

pub fn is_underlying_int(&self) -> bool

Returns whether the schema node is “underlyingly” an Int (but possibly a logicalType typedef)

source

pub fn is_underlying_long(&self) -> bool

Returns whether the schema node is “underlyingly” an Int64 (but possibly a logicalType typedef)

source

pub fn try_make_int_value(&self, int: i32) -> Option<Result<Value, Error>>

Constructs an avro::Value if this is of underlying int type. Guaranteed to be Some when is_underlying_int is true.

source

pub fn try_make_long_value(&self, long: i64) -> Option<Result<Value, Error>>

Constructs an avro::Value if this is of underlying long type. Guaranteed to be Some when is_underlying_long is true.

Trait Implementations§

source§

impl Clone for SchemaPiece

source§

fn clone(&self) -> SchemaPiece

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl Debug for SchemaPiece

source§

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

Formats the value using the given formatter. Read more
source§

impl<'a> From<&'a SchemaPiece> for SchemaKind

source§

fn from(piece: &'a SchemaPiece) -> SchemaKind

Converts to this type from the input type.
source§

impl From<SchemaPiece> for SchemaPieceOrNamed

source§

fn from(piece: SchemaPiece) -> SchemaPieceOrNamed

Converts to this type from the input type.
source§

impl PartialEq for SchemaPiece

source§

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

Tests for self and other values to be equal, and is used by ==.
1.0.0 · source§

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
source§

impl StructuralPartialEq for SchemaPiece

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> AsAny for T
where T: Any,

source§

fn as_any(&self) -> &(dyn Any + 'static)

source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T, U> CastInto<U> for T
where U: CastFrom<T>,

source§

fn cast_into(self) -> U

Performs the cast.
source§

impl<T> CloneToUninit for T
where T: Clone,

source§

default unsafe fn clone_to_uninit(&self, dst: *mut T)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dst. Read more
source§

impl<T> Conv for T

source§

fn conv<T>(self) -> T
where Self: Into<T>,

Converts self into T using Into<T>. Read more
source§

impl<T> DynClone for T
where T: Clone,

source§

impl<T> FmtForward for T

source§

fn fmt_binary(self) -> FmtBinary<Self>
where Self: Binary,

Causes self to use its Binary implementation when Debug-formatted.
source§

fn fmt_display(self) -> FmtDisplay<Self>
where Self: Display,

Causes self to use its Display implementation when Debug-formatted.
source§

fn fmt_lower_exp(self) -> FmtLowerExp<Self>
where Self: LowerExp,

Causes self to use its LowerExp implementation when Debug-formatted.
source§

fn fmt_lower_hex(self) -> FmtLowerHex<Self>
where Self: LowerHex,

Causes self to use its LowerHex implementation when Debug-formatted.
source§

fn fmt_octal(self) -> FmtOctal<Self>
where Self: Octal,

Causes self to use its Octal implementation when Debug-formatted.
source§

fn fmt_pointer(self) -> FmtPointer<Self>
where Self: Pointer,

Causes self to use its Pointer implementation when Debug-formatted.
source§

fn fmt_upper_exp(self) -> FmtUpperExp<Self>
where Self: UpperExp,

Causes self to use its UpperExp implementation when Debug-formatted.
source§

fn fmt_upper_hex(self) -> FmtUpperHex<Self>
where Self: UpperHex,

Causes self to use its UpperHex implementation when Debug-formatted.
source§

fn fmt_list(self) -> FmtList<Self>
where &'a Self: for<'a> IntoIterator,

Formats each item in a sequence. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> FromRef<T> for T
where T: Clone,

source§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
source§

impl<T> FutureExt for T

source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoRequest<T> for T

source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
source§

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

source§

fn into_shared(self) -> Shared

Creates a shared type from an unshared type.
source§

impl<T, U> OverrideFrom<Option<&T>> for U
where U: OverrideFrom<T>,

source§

fn override_from(self, layer: &Option<&T>) -> U

Override the configuration represented by Self with values from the given layer.
source§

impl<T> Pipe for T
where T: ?Sized,

source§

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

Pipes by value. This is generally the method you want to use. Read more
source§

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

Borrows self and passes that borrow into the pipe function. Read more
source§

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

Mutably borrows self and passes that borrow into the pipe function. Read more
source§

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

Borrows self, then passes self.borrow() into the pipe function. Read more
source§

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.borrow_mut() into the pipe function. Read more
source§

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

Borrows self, then passes self.as_ref() into the pipe function.
source§

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.as_mut() into the pipe function.
source§

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

Borrows self, then passes self.deref() into the pipe function.
source§

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.deref_mut() into the pipe function.
source§

impl<T> Pointable for T

source§

const ALIGN: usize = _

The alignment of pointer.
§

type Init = T

The type for initializers.
source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
source§

impl<T> ProgressEventTimestamp for T
where T: Data + Debug + Any,

source§

fn as_any(&self) -> &(dyn Any + 'static)

Upcasts this ProgressEventTimestamp to Any. Read more
source§

fn type_name(&self) -> &'static str

Returns the name of the concrete type of this object. Read more
source§

impl<P, R> ProtoType<R> for P
where R: RustType<P>,

source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<'a, S, T> Semigroup<&'a S> for T
where T: Semigroup<S>,

source§

fn plus_equals(&mut self, rhs: &&'a S)

The method of std::ops::AddAssign, for types that do not implement AddAssign.
source§

impl<T> Tap for T

source§

fn tap(self, func: impl FnOnce(&Self)) -> Self

Immutable access to a value. Read more
source§

fn tap_mut(self, func: impl FnOnce(&mut Self)) -> Self

Mutable access to a value. Read more
source§

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Immutable access to the Borrow<B> of a value. Read more
source§

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Mutable access to the BorrowMut<B> of a value. Read more
source§

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Immutable access to the AsRef<R> view of a value. Read more
source§

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Mutable access to the AsMut<R> view of a value. Read more
source§

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Immutable access to the Deref::Target of a value. Read more
source§

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Mutable access to the Deref::Target of a value. Read more
source§

fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self

Calls .tap() only in debug builds, and is erased in release builds.
source§

fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self

Calls .tap_mut() only in debug builds, and is erased in release builds.
source§

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Calls .tap_borrow() only in debug builds, and is erased in release builds.
source§

fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Calls .tap_borrow_mut() only in debug builds, and is erased in release builds.
source§

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Calls .tap_ref() only in debug builds, and is erased in release builds.
source§

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Calls .tap_ref_mut() only in debug builds, and is erased in release builds.
source§

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Calls .tap_deref() only in debug builds, and is erased in release builds.
source§

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Calls .tap_deref_mut() only in debug builds, and is erased in release builds.
source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T> TryConv for T

source§

fn try_conv<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

Attempts to convert self into T using TryInto<T>. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

source§

impl<T> Data for T
where T: Clone + 'static,