Struct mz_expr_test_util::MirRelationExprDeserializeContext

source ·

pub struct MirRelationExprDeserializeContext<'a> {
    pub(crate) inner_ctx: MirScalarExprDeserializeContext,
    pub(crate) catalog: &'a TestCatalog,
    pub(crate) scope: Scope,
}

Expand description

Extends the test case syntax to support MirRelationExprs

A new context should be created for the deserialization of each MirRelationExpr because the context stores state local to each MirRelationExpr.

Includes all the test case syntax extensions to support MirScalarExprs.

The following variants of MirRelationExpr have non-standard syntax: Let -> the syntax is (let x <value> <body>) where x is an ident that should not match any existing ident in any Let statement in <value>. Get -> the syntax is (get x), where x is an ident that refers to a pre-defined source or an ident defined in a let. Union -> the syntax is (union <input1> .. <inputn>). Constant -> the syntax is

(constant
   [[<row1literal1>..<row1literaln>]..[<rowiliteral1>..<rowiliteraln>]]
   <RelationType>
)

For convenience, a usize can be alternately specified as #n. We recommend specifying a usize as #n instead of n when the usize is a column reference.

Fields§

§inner_ctx: MirScalarExprDeserializeContext§catalog: &'a TestCatalog§scope: Scope

Tracks local references when converting spec to JSON. Tracks global references not found in the catalog when converting from JSON to spec.

Struct mz_expr_test_util::MirRelationExprDeserializeContextCopy item path

Fields§

Implementations§

impl<'a> MirRelationExprDeserializeContext<'a>

pub fn new(catalog: &'a TestCatalog) -> Self

pub fn list_scope_references( &self, ) -> impl Iterator<Item = (&String, &RelationType)>

pub(crate) fn build_constant<I>( &mut self, stream_iter: &mut I, ) -> Result<MirRelationExpr, String>where I: Iterator<Item = TokenTree>,

pub(crate) fn build_constant_err<I>( &mut self, stream_iter: &mut I, ) -> Result<MirRelationExpr, String>where I: Iterator<Item = TokenTree>,

pub(crate) fn build_get( &self, token: Option<TokenTree>, ) -> Result<MirRelationExpr, String>

pub(crate) fn build_let<I>( &mut self, stream_iter: &mut I, ) -> Result<MirRelationExpr, String>where I: Iterator<Item = TokenTree>,

pub(crate) fn build_union<I>( &mut self, stream_iter: &mut I, ) -> Result<MirRelationExpr, String>where I: Iterator<Item = TokenTree>,

pub(crate) fn build_special_mir_if_able<I>( &mut self, first_arg: TokenTree, rest_of_stream: &mut I, ) -> Result<Option<MirRelationExpr>, String>where I: Iterator<Item = TokenTree>,

Trait Implementations§

impl<'a> TestDeserializeContext for MirRelationExprDeserializeContext<'a>

fn override_syntax<I>( &mut self, first_arg: TokenTree, rest_of_stream: &mut I, type_name: &str, ) -> Result<Option<String>, String>where I: Iterator<Item = TokenTree>,

fn reverse_syntax_override( &mut self, json: &Value, type_name: &str, ) -> Option<String>

Auto Trait Implementations§

impl<'a> Freeze for MirRelationExprDeserializeContext<'a>

impl<'a> RefUnwindSafe for MirRelationExprDeserializeContext<'a>

impl<'a> Send for MirRelationExprDeserializeContext<'a>

impl<'a> Sync for MirRelationExprDeserializeContext<'a>

impl<'a> Unpin for MirRelationExprDeserializeContext<'a>

impl<'a> UnwindSafe for MirRelationExprDeserializeContext<'a>

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

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

fn cast_into(self) -> U

impl<T> CopyAs<T> for T

fn copy_as(self) -> T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

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

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

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

fn in_current_span(self) -> Instrumented<Self>

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

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

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

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

impl<T> Pointable for T

const ALIGN: usize = _

type Init = T

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

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

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

unsafe fn drop(ptr: usize)

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

fn into_rust(self) -> Result<R, TryFromProtoError>

fn from_rust(rust: &R) -> P

impl<T> Same for T

type Output = T

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

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

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

type Error = Infallible

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

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

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

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

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

fn vzip(self) -> V

impl<T> WithSubscriber for T

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

fn with_current_subscriber(self) -> WithDispatch<Self>

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

Struct mz_expr_test_util::MirRelationExprDeserializeContext

pub(crate) fn build_constant<I>( &mut self, stream_iter: &mut I, ) -> Result<MirRelationExpr, String>
where I: Iterator<Item = TokenTree>,

pub(crate) fn build_constant_err<I>( &mut self, stream_iter: &mut I, ) -> Result<MirRelationExpr, String>
where I: Iterator<Item = TokenTree>,

pub(crate) fn build_let<I>( &mut self, stream_iter: &mut I, ) -> Result<MirRelationExpr, String>
where I: Iterator<Item = TokenTree>,

pub(crate) fn build_union<I>( &mut self, stream_iter: &mut I, ) -> Result<MirRelationExpr, String>
where I: Iterator<Item = TokenTree>,

pub(crate) fn build_special_mir_if_able<I>( &mut self, first_arg: TokenTree, rest_of_stream: &mut I, ) -> Result<Option<MirRelationExpr>, String>
where I: Iterator<Item = TokenTree>,

fn override_syntax<I>( &mut self, first_arg: TokenTree, rest_of_stream: &mut I, type_name: &str, ) -> Result<Option<String>, String>
where I: Iterator<Item = TokenTree>,

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

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

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

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

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

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

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

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

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

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

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

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

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