#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoAvailableCollections {
#[prost(bool, tag = "1")]
pub raw: bool,
#[prost(message, repeated, tag = "2")]
pub arranged: ::prost::alloc::vec::Vec<threshold::ProtoArrangement>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoGetPlan {
#[prost(oneof = "proto_get_plan::Kind", tags = "1, 2, 3")]
pub kind: ::core::option::Option<proto_get_plan::Kind>,
}
pub mod proto_get_plan {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoGetPlanArrangement {
#[prost(message, repeated, tag = "1")]
pub key: ::prost::alloc::vec::Vec<::mz_expr::ProtoMirScalarExpr>,
#[prost(message, optional, tag = "2")]
pub seek: ::core::option::Option<::mz_repr::ProtoRow>,
#[prost(message, optional, tag = "3")]
pub mfp: ::core::option::Option<::mz_expr::ProtoMapFilterProject>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Kind {
#[prost(message, tag = "1")]
PassArrangements(()),
#[prost(message, tag = "2")]
Arrangement(ProtoGetPlanArrangement),
#[prost(message, tag = "3")]
Collection(::mz_expr::ProtoMapFilterProject),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoLetRecLimit {
#[prost(uint64, tag = "1")]
pub max_iters: u64,
#[prost(bool, tag = "2")]
pub return_at_limit: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlan {
#[prost(
oneof = "proto_plan::Kind",
tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13"
)]
pub kind: ::core::option::Option<proto_plan::Kind>,
}
pub mod proto_plan {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoRowDiff {
#[prost(message, optional, tag = "1")]
pub row: ::core::option::Option<::mz_repr::ProtoRow>,
#[prost(uint64, tag = "2")]
pub timestamp: u64,
#[prost(int64, tag = "3")]
pub diff: i64,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoRowDiffVec {
#[prost(message, repeated, tag = "1")]
pub rows: ::prost::alloc::vec::Vec<ProtoRowDiff>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanConstant {
#[prost(oneof = "proto_plan_constant::Result", tags = "1, 2")]
pub result: ::core::option::Option<proto_plan_constant::Result>,
}
pub mod proto_plan_constant {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Result {
#[prost(message, tag = "1")]
Rows(super::ProtoRowDiffVec),
#[prost(message, tag = "2")]
Err(::mz_expr::ProtoEvalError),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanGet {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<::mz_expr::ProtoId>,
#[prost(message, optional, tag = "2")]
pub keys: ::core::option::Option<super::ProtoAvailableCollections>,
#[prost(message, optional, tag = "3")]
pub plan: ::core::option::Option<super::ProtoGetPlan>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanLet {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<::mz_expr::ProtoLocalId>,
#[prost(message, optional, boxed, tag = "2")]
pub value: ::core::option::Option<::prost::alloc::boxed::Box<super::ProtoPlan>>,
#[prost(message, optional, boxed, tag = "3")]
pub body: ::core::option::Option<::prost::alloc::boxed::Box<super::ProtoPlan>>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanLetRec {
#[prost(message, repeated, tag = "1")]
pub ids: ::prost::alloc::vec::Vec<::mz_expr::ProtoLocalId>,
#[prost(message, repeated, tag = "2")]
pub values: ::prost::alloc::vec::Vec<super::ProtoPlan>,
#[prost(message, repeated, tag = "4")]
pub limits: ::prost::alloc::vec::Vec<super::ProtoLetRecLimit>,
#[prost(bool, repeated, tag = "5")]
pub limit_is_some: ::prost::alloc::vec::Vec<bool>,
#[prost(message, optional, boxed, tag = "3")]
pub body: ::core::option::Option<::prost::alloc::boxed::Box<super::ProtoPlan>>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanInputKeyVal {
#[prost(message, repeated, tag = "1")]
pub key: ::prost::alloc::vec::Vec<::mz_expr::ProtoMirScalarExpr>,
#[prost(message, optional, tag = "2")]
pub val: ::core::option::Option<::mz_repr::ProtoRow>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanMfp {
#[prost(message, optional, boxed, tag = "1")]
pub input: ::core::option::Option<::prost::alloc::boxed::Box<super::ProtoPlan>>,
#[prost(message, optional, tag = "2")]
pub mfp: ::core::option::Option<::mz_expr::ProtoMapFilterProject>,
#[prost(message, optional, tag = "3")]
pub input_key_val: ::core::option::Option<ProtoPlanInputKeyVal>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanInputKey {
#[prost(message, repeated, tag = "1")]
pub key: ::prost::alloc::vec::Vec<::mz_expr::ProtoMirScalarExpr>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanFlatMap {
#[prost(message, optional, boxed, tag = "1")]
pub input: ::core::option::Option<::prost::alloc::boxed::Box<super::ProtoPlan>>,
#[prost(message, optional, tag = "2")]
pub func: ::core::option::Option<::mz_expr::ProtoTableFunc>,
#[prost(message, repeated, tag = "3")]
pub exprs: ::prost::alloc::vec::Vec<::mz_expr::ProtoMirScalarExpr>,
#[prost(message, optional, tag = "4")]
pub mfp: ::core::option::Option<::mz_expr::ProtoMapFilterProject>,
#[prost(message, optional, tag = "5")]
pub input_key: ::core::option::Option<ProtoPlanInputKey>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanJoin {
#[prost(message, repeated, tag = "1")]
pub inputs: ::prost::alloc::vec::Vec<super::ProtoPlan>,
#[prost(message, optional, tag = "2")]
pub plan: ::core::option::Option<super::join::ProtoJoinPlan>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanReduce {
#[prost(message, optional, boxed, tag = "1")]
pub input: ::core::option::Option<::prost::alloc::boxed::Box<super::ProtoPlan>>,
#[prost(message, optional, tag = "2")]
pub key_val_plan: ::core::option::Option<super::reduce::ProtoKeyValPlan>,
#[prost(message, optional, tag = "3")]
pub plan: ::core::option::Option<super::reduce::ProtoReducePlan>,
#[prost(message, optional, tag = "4")]
pub input_key: ::core::option::Option<ProtoPlanInputKey>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanTopK {
#[prost(message, optional, boxed, tag = "1")]
pub input: ::core::option::Option<::prost::alloc::boxed::Box<super::ProtoPlan>>,
#[prost(message, optional, tag = "2")]
pub top_k_plan: ::core::option::Option<super::top_k::ProtoTopKPlan>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanThreshold {
#[prost(message, optional, boxed, tag = "1")]
pub input: ::core::option::Option<::prost::alloc::boxed::Box<super::ProtoPlan>>,
#[prost(message, optional, tag = "2")]
pub threshold_plan: ::core::option::Option<super::threshold::ProtoThresholdPlan>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanUnion {
#[prost(message, repeated, tag = "1")]
pub inputs: ::prost::alloc::vec::Vec<super::ProtoPlan>,
#[prost(bool, tag = "2")]
pub consolidate_output: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPlanArrangeBy {
#[prost(message, optional, boxed, tag = "1")]
pub input: ::core::option::Option<::prost::alloc::boxed::Box<super::ProtoPlan>>,
#[prost(message, optional, tag = "2")]
pub forms: ::core::option::Option<super::ProtoAvailableCollections>,
#[prost(message, optional, tag = "3")]
pub input_key: ::core::option::Option<ProtoPlanInputKey>,
#[prost(message, optional, tag = "4")]
pub input_mfp: ::core::option::Option<::mz_expr::ProtoMapFilterProject>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Kind {
#[prost(message, tag = "1")]
Constant(ProtoPlanConstant),
#[prost(message, tag = "2")]
Get(ProtoPlanGet),
#[prost(message, tag = "3")]
Let(::prost::alloc::boxed::Box<ProtoPlanLet>),
#[prost(message, tag = "4")]
Mfp(::prost::alloc::boxed::Box<ProtoPlanMfp>),
#[prost(message, tag = "5")]
FlatMap(::prost::alloc::boxed::Box<ProtoPlanFlatMap>),
#[prost(message, tag = "6")]
Join(ProtoPlanJoin),
#[prost(message, tag = "7")]
Reduce(::prost::alloc::boxed::Box<ProtoPlanReduce>),
#[prost(message, tag = "8")]
TopK(::prost::alloc::boxed::Box<ProtoPlanTopK>),
#[prost(message, tag = "9")]
Negate(::prost::alloc::boxed::Box<super::ProtoPlan>),
#[prost(message, tag = "10")]
Threshold(::prost::alloc::boxed::Box<ProtoPlanThreshold>),
#[prost(message, tag = "11")]
Union(ProtoPlanUnion),
#[prost(message, tag = "12")]
ArrangeBy(::prost::alloc::boxed::Box<ProtoPlanArrangeBy>),
#[prost(message, tag = "13")]
LetRec(::prost::alloc::boxed::Box<ProtoPlanLetRec>),
}
}