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: MirScalarExprDeserializeContextcatalog: &'a TestCatalogscope: Scope

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

Implementations

source

impl<'a> MirRelationExprDeserializeContext<'a>

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

Trait Implementations

source

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

source

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

Override the way that first_arg is resolved to JSON. Read more

source

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

Converts json back to the extended syntax specified by TestDeserializeContext::override_syntax. Read more

Auto Trait Implementations

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

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> Borrow<T> for T where
T: ?Sized,

const: unstable · source
fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

const: unstable · source
fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source
impl<T> From<T> for T

const: unstable · source
fn from(t: T) -> T

Returns the argument unchanged.

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 for T where
U: From<T>,

const: unstable · 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<P, R> ProtoType<R> for P where
R: RustType,

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

See RustType::from_proto.

source
fn from_rust(rust: &R) -> P

See RustType::into_proto.

source
impl<T> Same<T> for T

type Output = T

Should always be Self

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

type Error = Infallible

The type returned in the event of a conversion error.

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

Performs the conversion.

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

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source
fn try_into(self) -> Result<U, >::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

Struct mz_expr_test_util::MirRelationExprDeserializeContext

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( &mut 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> 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 T where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

fn borrow_mut(&mut self) -> &mut 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 T where U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

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

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

fn from_rust(rust: &R) -> P

impl<T> Same<T> for T

type Output = T

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

type Error = Infallible

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

impl<T, U> TryInto<U> for T where 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 T where 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>

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(
&mut 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>,

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>

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> Into<U> for T where
U: From<T>,

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

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>,