#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ProtoColumnOrder {
#[prost(uint64, tag = "1")]
pub column: u64,
#[prost(bool, tag = "2")]
pub desc: bool,
#[prost(bool, tag = "3")]
pub nulls_last: bool,
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ProtoWindowFrame {
#[prost(message, optional, tag = "1")]
pub units: ::core::option::Option<proto_window_frame::ProtoWindowFrameUnits>,
#[prost(message, optional, tag = "2")]
pub start_bound: ::core::option::Option<proto_window_frame::ProtoWindowFrameBound>,
#[prost(message, optional, tag = "3")]
pub end_bound: ::core::option::Option<proto_window_frame::ProtoWindowFrameBound>,
}
pub mod proto_window_frame {
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ProtoWindowFrameBound {
#[prost(oneof = "proto_window_frame_bound::Kind", tags = "1, 2, 3, 4, 5")]
pub kind: ::core::option::Option<proto_window_frame_bound::Kind>,
}
pub mod proto_window_frame_bound {
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
pub enum Kind {
#[prost(message, tag = "1")]
UnboundedPreceding(()),
#[prost(uint64, tag = "2")]
OffsetPreceding(u64),
#[prost(message, tag = "3")]
CurrentRow(()),
#[prost(uint64, tag = "4")]
OffsetFollowing(u64),
#[prost(message, tag = "5")]
UnboundedFollowing(()),
}
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ProtoWindowFrameUnits {
#[prost(oneof = "proto_window_frame_units::Kind", tags = "1, 2, 3")]
pub kind: ::core::option::Option<proto_window_frame_units::Kind>,
}
pub mod proto_window_frame_units {
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
pub enum Kind {
#[prost(message, tag = "1")]
Rows(()),
#[prost(message, tag = "2")]
Range(()),
#[prost(message, tag = "3")]
Groups(()),
}
}
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoAggregateExpr {
#[prost(message, optional, tag = "1")]
pub func: ::core::option::Option<ProtoAggregateFunc>,
#[prost(message, optional, tag = "2")]
pub expr: ::core::option::Option<super::scalar::ProtoMirScalarExpr>,
#[prost(bool, tag = "3")]
pub distinct: bool,
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoAggregateFunc {
#[prost(
oneof = "proto_aggregate_func::Kind",
tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 64, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 65, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 54, 38, 39, 40, 41, 42, 55, 57, 43, 44, 45, 46, 47, 48, 49, 50, 51, 52, 53, 56, 66, 67"
)]
pub kind: ::core::option::Option<proto_aggregate_func::Kind>,
}
pub mod proto_aggregate_func {
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoColumnOrders {
#[prost(message, repeated, tag = "1")]
pub orders: ::prost::alloc::vec::Vec<super::ProtoColumnOrder>,
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoLagLead {
#[prost(message, optional, tag = "1")]
pub order_by: ::core::option::Option<ProtoColumnOrders>,
#[prost(bool, tag = "4")]
pub ignore_nulls: bool,
#[prost(oneof = "proto_lag_lead::LagLead", tags = "2, 3")]
pub lag_lead: ::core::option::Option<proto_lag_lead::LagLead>,
}
pub mod proto_lag_lead {
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
pub enum LagLead {
#[prost(message, tag = "2")]
Lag(()),
#[prost(message, tag = "3")]
Lead(()),
}
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoFramedWindowFunc {
#[prost(message, optional, tag = "1")]
pub order_by: ::core::option::Option<ProtoColumnOrders>,
#[prost(message, optional, tag = "2")]
pub window_frame: ::core::option::Option<super::ProtoWindowFrame>,
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoWindowAggregate {
#[prost(message, optional, boxed, tag = "1")]
pub wrapped_aggregate: ::core::option::Option<
::prost::alloc::boxed::Box<super::ProtoAggregateFunc>,
>,
#[prost(message, optional, tag = "2")]
pub order_by: ::core::option::Option<ProtoColumnOrders>,
#[prost(message, optional, tag = "3")]
pub window_frame: ::core::option::Option<super::ProtoWindowFrame>,
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoFusedValueWindowFunc {
#[prost(message, repeated, tag = "1")]
pub funcs: ::prost::alloc::vec::Vec<super::ProtoAggregateFunc>,
#[prost(message, optional, tag = "2")]
pub order_by: ::core::option::Option<ProtoColumnOrders>,
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoMapAgg {
#[prost(message, optional, tag = "1")]
pub order_by: ::core::option::Option<ProtoColumnOrders>,
#[prost(message, optional, tag = "2")]
pub value_type: ::core::option::Option<::mz_repr::ProtoScalarType>,
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Kind {
#[prost(message, tag = "1")]
MaxNumeric(()),
#[prost(message, tag = "2")]
MaxInt16(()),
#[prost(message, tag = "3")]
MaxInt32(()),
#[prost(message, tag = "4")]
MaxInt64(()),
#[prost(message, tag = "5")]
MaxFloat32(()),
#[prost(message, tag = "6")]
MaxFloat64(()),
#[prost(message, tag = "7")]
MaxBool(()),
#[prost(message, tag = "8")]
MaxString(()),
#[prost(message, tag = "9")]
MaxDate(()),
#[prost(message, tag = "10")]
MaxTimestamp(()),
#[prost(message, tag = "11")]
MaxTimestampTz(()),
#[prost(message, tag = "64")]
MaxInterval(()),
#[prost(message, tag = "12")]
MinNumeric(()),
#[prost(message, tag = "13")]
MinInt16(()),
#[prost(message, tag = "14")]
MinInt32(()),
#[prost(message, tag = "15")]
MinInt64(()),
#[prost(message, tag = "16")]
MinFloat32(()),
#[prost(message, tag = "17")]
MinFloat64(()),
#[prost(message, tag = "18")]
MinBool(()),
#[prost(message, tag = "19")]
MinString(()),
#[prost(message, tag = "20")]
MinDate(()),
#[prost(message, tag = "21")]
MinTimestamp(()),
#[prost(message, tag = "22")]
MinTimestampTz(()),
#[prost(message, tag = "65")]
MinInterval(()),
#[prost(message, tag = "23")]
SumInt16(()),
#[prost(message, tag = "24")]
SumInt32(()),
#[prost(message, tag = "25")]
SumInt64(()),
#[prost(message, tag = "26")]
SumFloat32(()),
#[prost(message, tag = "27")]
SumFloat64(()),
#[prost(message, tag = "28")]
SumNumeric(()),
#[prost(message, tag = "29")]
Count(()),
#[prost(message, tag = "30")]
Any(()),
#[prost(message, tag = "31")]
All(()),
#[prost(message, tag = "32")]
JsonbAgg(ProtoColumnOrders),
#[prost(message, tag = "33")]
JsonbObjectAgg(ProtoColumnOrders),
#[prost(message, tag = "34")]
ArrayConcat(ProtoColumnOrders),
#[prost(message, tag = "35")]
ListConcat(ProtoColumnOrders),
#[prost(message, tag = "36")]
StringAgg(ProtoColumnOrders),
#[prost(message, tag = "37")]
RowNumber(ProtoColumnOrders),
#[prost(message, tag = "54")]
Rank(ProtoColumnOrders),
#[prost(message, tag = "38")]
DenseRank(ProtoColumnOrders),
#[prost(message, tag = "39")]
LagLead(ProtoLagLead),
#[prost(message, tag = "40")]
Dummy(()),
#[prost(message, tag = "41")]
FirstValue(ProtoFramedWindowFunc),
#[prost(message, tag = "42")]
LastValue(ProtoFramedWindowFunc),
#[prost(message, tag = "55")]
WindowAggregate(::prost::alloc::boxed::Box<ProtoWindowAggregate>),
#[prost(message, tag = "57")]
FusedValueWindowFunc(ProtoFusedValueWindowFunc),
#[prost(message, tag = "43")]
MaxUint16(()),
#[prost(message, tag = "44")]
MaxUint32(()),
#[prost(message, tag = "45")]
MaxUint64(()),
#[prost(message, tag = "46")]
MinUint16(()),
#[prost(message, tag = "47")]
MinUint32(()),
#[prost(message, tag = "48")]
MinUint64(()),
#[prost(message, tag = "49")]
SumUint16(()),
#[prost(message, tag = "50")]
SumUint32(()),
#[prost(message, tag = "51")]
SumUint64(()),
#[prost(message, tag = "52")]
MaxMzTimestamp(()),
#[prost(message, tag = "53")]
MinMzTimestamp(()),
#[prost(message, tag = "56")]
MapAgg(ProtoMapAgg),
#[prost(message, tag = "66")]
MinTime(()),
#[prost(message, tag = "67")]
MaxTime(()),
}
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoRowSetFinishing {
#[prost(message, repeated, tag = "1")]
pub order_by: ::prost::alloc::vec::Vec<ProtoColumnOrder>,
#[prost(int64, optional, tag = "5")]
pub limit: ::core::option::Option<i64>,
#[prost(uint64, tag = "3")]
pub offset: u64,
#[prost(uint64, repeated, tag = "4")]
pub project: ::prost::alloc::vec::Vec<u64>,
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoTableFunc {
#[prost(
oneof = "proto_table_func::Kind",
tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18"
)]
pub kind: ::core::option::Option<proto_table_func::Kind>,
}
pub mod proto_table_func {
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoWrap {
#[prost(message, repeated, tag = "1")]
pub types: ::prost::alloc::vec::Vec<::mz_repr::ProtoColumnType>,
#[prost(uint64, tag = "2")]
pub width: u64,
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoTabletizedScalar {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub relation: ::core::option::Option<::mz_repr::ProtoRelationType>,
}
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Kind {
#[prost(bool, tag = "1")]
JsonbEach(bool),
#[prost(message, tag = "2")]
JsonbObjectKeys(()),
#[prost(bool, tag = "3")]
JsonbArrayElements(bool),
#[prost(message, tag = "4")]
RegexpExtract(super::func::ProtoAnalyzedRegex),
#[prost(uint64, tag = "5")]
CsvExtract(u64),
#[prost(message, tag = "6")]
GenerateSeriesInt32(()),
#[prost(message, tag = "7")]
GenerateSeriesInt64(()),
#[prost(message, tag = "8")]
GenerateSeriesTimestamp(()),
#[prost(message, tag = "9")]
GenerateSeriesTimestampTz(()),
#[prost(message, tag = "10")]
Repeat(()),
#[prost(message, tag = "11")]
UnnestArray(::mz_repr::ProtoScalarType),
#[prost(message, tag = "12")]
UnnestList(::mz_repr::ProtoScalarType),
#[prost(message, tag = "13")]
Wrap(ProtoWrap),
#[prost(message, tag = "14")]
GenerateSubscriptsArray(()),
#[prost(message, tag = "15")]
TabletizedScalar(ProtoTabletizedScalar),
#[prost(message, tag = "16")]
AclExplode(()),
#[prost(message, tag = "17")]
MzAclExplode(()),
#[prost(message, tag = "18")]
UnnestMap(::mz_repr::ProtoScalarType),
}
}