1#[allow(missing_docs)]
3#[derive(Clone, Copy, PartialEq, ::prost::Message)]
4pub struct ProtoColumnOrder {
5 #[prost(uint64, tag = "1")]
6 pub column: u64,
7 #[prost(bool, tag = "2")]
8 pub desc: bool,
9 #[prost(bool, tag = "3")]
10 pub nulls_last: bool,
11}
12#[allow(missing_docs)]
13#[derive(Clone, Copy, PartialEq, ::prost::Message)]
14pub struct ProtoWindowFrame {
15 #[prost(message, optional, tag = "1")]
16 pub units: ::core::option::Option<proto_window_frame::ProtoWindowFrameUnits>,
17 #[prost(message, optional, tag = "2")]
18 pub start_bound: ::core::option::Option<proto_window_frame::ProtoWindowFrameBound>,
19 #[prost(message, optional, tag = "3")]
20 pub end_bound: ::core::option::Option<proto_window_frame::ProtoWindowFrameBound>,
21}
22pub mod proto_window_frame {
24 #[allow(missing_docs)]
25 #[derive(Clone, Copy, PartialEq, ::prost::Message)]
26 pub struct ProtoWindowFrameBound {
27 #[prost(oneof = "proto_window_frame_bound::Kind", tags = "1, 2, 3, 4, 5")]
28 pub kind: ::core::option::Option<proto_window_frame_bound::Kind>,
29 }
30 pub mod proto_window_frame_bound {
32 #[allow(missing_docs)]
33 #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
34 pub enum Kind {
35 #[prost(message, tag = "1")]
36 UnboundedPreceding(()),
37 #[prost(uint64, tag = "2")]
38 OffsetPreceding(u64),
39 #[prost(message, tag = "3")]
40 CurrentRow(()),
41 #[prost(uint64, tag = "4")]
42 OffsetFollowing(u64),
43 #[prost(message, tag = "5")]
44 UnboundedFollowing(()),
45 }
46 }
47 #[allow(missing_docs)]
48 #[derive(Clone, Copy, PartialEq, ::prost::Message)]
49 pub struct ProtoWindowFrameUnits {
50 #[prost(oneof = "proto_window_frame_units::Kind", tags = "1, 2, 3")]
51 pub kind: ::core::option::Option<proto_window_frame_units::Kind>,
52 }
53 pub mod proto_window_frame_units {
55 #[allow(missing_docs)]
56 #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
57 pub enum Kind {
58 #[prost(message, tag = "1")]
59 Rows(()),
60 #[prost(message, tag = "2")]
61 Range(()),
62 #[prost(message, tag = "3")]
63 Groups(()),
64 }
65 }
66}
67#[allow(missing_docs)]
68#[derive(Clone, PartialEq, ::prost::Message)]
69pub struct ProtoAggregateExpr {
70 #[prost(message, optional, tag = "1")]
71 pub func: ::core::option::Option<ProtoAggregateFunc>,
72 #[prost(message, optional, tag = "2")]
73 pub expr: ::core::option::Option<super::scalar::ProtoMirScalarExpr>,
74 #[prost(bool, tag = "3")]
75 pub distinct: bool,
76}
77#[allow(missing_docs)]
78#[derive(Clone, PartialEq, ::prost::Message)]
79pub struct ProtoAggregateFunc {
80 #[prost(
81 oneof = "proto_aggregate_func::Kind",
82 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, 68, 43, 44, 45, 46, 47, 48, 49, 50, 51, 52, 53, 56, 66, 67"
83 )]
84 pub kind: ::core::option::Option<proto_aggregate_func::Kind>,
85}
86pub mod proto_aggregate_func {
88 #[allow(missing_docs)]
89 #[derive(Clone, PartialEq, ::prost::Message)]
90 pub struct ProtoColumnOrders {
91 #[prost(message, repeated, tag = "1")]
92 pub orders: ::prost::alloc::vec::Vec<super::ProtoColumnOrder>,
93 }
94 #[allow(missing_docs)]
95 #[derive(Clone, PartialEq, ::prost::Message)]
96 pub struct ProtoLagLead {
97 #[prost(message, optional, tag = "1")]
98 pub order_by: ::core::option::Option<ProtoColumnOrders>,
99 #[prost(bool, tag = "4")]
100 pub ignore_nulls: bool,
101 #[prost(oneof = "proto_lag_lead::LagLead", tags = "2, 3")]
102 pub lag_lead: ::core::option::Option<proto_lag_lead::LagLead>,
103 }
104 pub mod proto_lag_lead {
106 #[allow(missing_docs)]
107 #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
108 pub enum LagLead {
109 #[prost(message, tag = "2")]
110 Lag(()),
111 #[prost(message, tag = "3")]
112 Lead(()),
113 }
114 }
115 #[allow(missing_docs)]
116 #[derive(Clone, PartialEq, ::prost::Message)]
117 pub struct ProtoFramedWindowFunc {
118 #[prost(message, optional, tag = "1")]
119 pub order_by: ::core::option::Option<ProtoColumnOrders>,
120 #[prost(message, optional, tag = "2")]
121 pub window_frame: ::core::option::Option<super::ProtoWindowFrame>,
122 }
123 #[allow(missing_docs)]
124 #[derive(Clone, PartialEq, ::prost::Message)]
125 pub struct ProtoWindowAggregate {
126 #[prost(message, optional, boxed, tag = "1")]
127 pub wrapped_aggregate: ::core::option::Option<
128 ::prost::alloc::boxed::Box<super::ProtoAggregateFunc>,
129 >,
130 #[prost(message, optional, tag = "2")]
131 pub order_by: ::core::option::Option<ProtoColumnOrders>,
132 #[prost(message, optional, tag = "3")]
133 pub window_frame: ::core::option::Option<super::ProtoWindowFrame>,
134 }
135 #[allow(missing_docs)]
136 #[derive(Clone, PartialEq, ::prost::Message)]
137 pub struct ProtoFusedWindowAggregate {
138 #[prost(message, repeated, tag = "1")]
139 pub wrapped_aggregates: ::prost::alloc::vec::Vec<super::ProtoAggregateFunc>,
140 #[prost(message, optional, tag = "2")]
141 pub order_by: ::core::option::Option<ProtoColumnOrders>,
142 #[prost(message, optional, tag = "3")]
143 pub window_frame: ::core::option::Option<super::ProtoWindowFrame>,
144 }
145 #[allow(missing_docs)]
146 #[derive(Clone, PartialEq, ::prost::Message)]
147 pub struct ProtoFusedValueWindowFunc {
148 #[prost(message, repeated, tag = "1")]
149 pub funcs: ::prost::alloc::vec::Vec<super::ProtoAggregateFunc>,
150 #[prost(message, optional, tag = "2")]
151 pub order_by: ::core::option::Option<ProtoColumnOrders>,
152 }
153 #[allow(missing_docs)]
154 #[derive(Clone, PartialEq, ::prost::Message)]
155 pub struct ProtoMapAgg {
156 #[prost(message, optional, tag = "1")]
157 pub order_by: ::core::option::Option<ProtoColumnOrders>,
158 #[prost(message, optional, tag = "2")]
159 pub value_type: ::core::option::Option<::mz_repr::ProtoScalarType>,
160 }
161 #[allow(missing_docs)]
162 #[derive(Clone, PartialEq, ::prost::Oneof)]
163 pub enum Kind {
164 #[prost(message, tag = "1")]
165 MaxNumeric(()),
166 #[prost(message, tag = "2")]
167 MaxInt16(()),
168 #[prost(message, tag = "3")]
169 MaxInt32(()),
170 #[prost(message, tag = "4")]
171 MaxInt64(()),
172 #[prost(message, tag = "5")]
173 MaxFloat32(()),
174 #[prost(message, tag = "6")]
175 MaxFloat64(()),
176 #[prost(message, tag = "7")]
177 MaxBool(()),
178 #[prost(message, tag = "8")]
179 MaxString(()),
180 #[prost(message, tag = "9")]
181 MaxDate(()),
182 #[prost(message, tag = "10")]
183 MaxTimestamp(()),
184 #[prost(message, tag = "11")]
185 MaxTimestampTz(()),
186 #[prost(message, tag = "64")]
187 MaxInterval(()),
188 #[prost(message, tag = "12")]
189 MinNumeric(()),
190 #[prost(message, tag = "13")]
191 MinInt16(()),
192 #[prost(message, tag = "14")]
193 MinInt32(()),
194 #[prost(message, tag = "15")]
195 MinInt64(()),
196 #[prost(message, tag = "16")]
197 MinFloat32(()),
198 #[prost(message, tag = "17")]
199 MinFloat64(()),
200 #[prost(message, tag = "18")]
201 MinBool(()),
202 #[prost(message, tag = "19")]
203 MinString(()),
204 #[prost(message, tag = "20")]
205 MinDate(()),
206 #[prost(message, tag = "21")]
207 MinTimestamp(()),
208 #[prost(message, tag = "22")]
209 MinTimestampTz(()),
210 #[prost(message, tag = "65")]
211 MinInterval(()),
212 #[prost(message, tag = "23")]
213 SumInt16(()),
214 #[prost(message, tag = "24")]
215 SumInt32(()),
216 #[prost(message, tag = "25")]
217 SumInt64(()),
218 #[prost(message, tag = "26")]
219 SumFloat32(()),
220 #[prost(message, tag = "27")]
221 SumFloat64(()),
222 #[prost(message, tag = "28")]
223 SumNumeric(()),
224 #[prost(message, tag = "29")]
225 Count(()),
226 #[prost(message, tag = "30")]
227 Any(()),
228 #[prost(message, tag = "31")]
229 All(()),
230 #[prost(message, tag = "32")]
231 JsonbAgg(ProtoColumnOrders),
232 #[prost(message, tag = "33")]
233 JsonbObjectAgg(ProtoColumnOrders),
234 #[prost(message, tag = "34")]
235 ArrayConcat(ProtoColumnOrders),
236 #[prost(message, tag = "35")]
237 ListConcat(ProtoColumnOrders),
238 #[prost(message, tag = "36")]
239 StringAgg(ProtoColumnOrders),
240 #[prost(message, tag = "37")]
241 RowNumber(ProtoColumnOrders),
242 #[prost(message, tag = "54")]
243 Rank(ProtoColumnOrders),
244 #[prost(message, tag = "38")]
245 DenseRank(ProtoColumnOrders),
246 #[prost(message, tag = "39")]
247 LagLead(ProtoLagLead),
248 #[prost(message, tag = "40")]
249 Dummy(()),
250 #[prost(message, tag = "41")]
251 FirstValue(ProtoFramedWindowFunc),
252 #[prost(message, tag = "42")]
253 LastValue(ProtoFramedWindowFunc),
254 #[prost(message, tag = "55")]
255 WindowAggregate(::prost::alloc::boxed::Box<ProtoWindowAggregate>),
256 #[prost(message, tag = "57")]
257 FusedValueWindowFunc(ProtoFusedValueWindowFunc),
258 #[prost(message, tag = "68")]
259 FusedWindowAggregate(ProtoFusedWindowAggregate),
260 #[prost(message, tag = "43")]
261 MaxUint16(()),
262 #[prost(message, tag = "44")]
263 MaxUint32(()),
264 #[prost(message, tag = "45")]
265 MaxUint64(()),
266 #[prost(message, tag = "46")]
267 MinUint16(()),
268 #[prost(message, tag = "47")]
269 MinUint32(()),
270 #[prost(message, tag = "48")]
271 MinUint64(()),
272 #[prost(message, tag = "49")]
273 SumUint16(()),
274 #[prost(message, tag = "50")]
275 SumUint32(()),
276 #[prost(message, tag = "51")]
277 SumUint64(()),
278 #[prost(message, tag = "52")]
279 MaxMzTimestamp(()),
280 #[prost(message, tag = "53")]
281 MinMzTimestamp(()),
282 #[prost(message, tag = "56")]
283 MapAgg(ProtoMapAgg),
284 #[prost(message, tag = "66")]
285 MinTime(()),
286 #[prost(message, tag = "67")]
287 MaxTime(()),
288 }
289}
290#[allow(missing_docs)]
291#[derive(Clone, PartialEq, ::prost::Message)]
292pub struct ProtoRowSetFinishing {
293 #[prost(message, repeated, tag = "1")]
294 pub order_by: ::prost::alloc::vec::Vec<ProtoColumnOrder>,
295 #[prost(int64, optional, tag = "5")]
296 pub limit: ::core::option::Option<i64>,
297 #[prost(uint64, tag = "3")]
298 pub offset: u64,
299 #[prost(uint64, repeated, tag = "4")]
300 pub project: ::prost::alloc::vec::Vec<u64>,
301}
302#[allow(missing_docs)]
303#[derive(Clone, PartialEq, ::prost::Message)]
304pub struct ProtoTableFunc {
305 #[prost(
306 oneof = "proto_table_func::Kind",
307 tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19"
308 )]
309 pub kind: ::core::option::Option<proto_table_func::Kind>,
310}
311pub mod proto_table_func {
313 #[allow(missing_docs)]
314 #[derive(Clone, PartialEq, ::prost::Message)]
315 pub struct ProtoWrap {
316 #[prost(message, repeated, tag = "1")]
317 pub types: ::prost::alloc::vec::Vec<::mz_repr::ProtoColumnType>,
318 #[prost(uint64, tag = "2")]
319 pub width: u64,
320 }
321 #[allow(missing_docs)]
322 #[derive(Clone, PartialEq, ::prost::Message)]
323 pub struct ProtoTabletizedScalar {
324 #[prost(string, tag = "1")]
325 pub name: ::prost::alloc::string::String,
326 #[prost(message, optional, tag = "2")]
327 pub relation: ::core::option::Option<::mz_repr::ProtoRelationType>,
328 }
329 #[allow(missing_docs)]
330 #[derive(Clone, PartialEq, ::prost::Oneof)]
331 pub enum Kind {
332 #[prost(bool, tag = "1")]
333 JsonbEach(bool),
334 #[prost(message, tag = "2")]
335 JsonbObjectKeys(()),
336 #[prost(bool, tag = "3")]
337 JsonbArrayElements(bool),
338 #[prost(message, tag = "4")]
339 RegexpExtract(super::func::ProtoAnalyzedRegex),
340 #[prost(uint64, tag = "5")]
341 CsvExtract(u64),
342 #[prost(message, tag = "6")]
343 GenerateSeriesInt32(()),
344 #[prost(message, tag = "7")]
345 GenerateSeriesInt64(()),
346 #[prost(message, tag = "8")]
347 GenerateSeriesTimestamp(()),
348 #[prost(message, tag = "9")]
349 GenerateSeriesTimestampTz(()),
350 #[prost(message, tag = "10")]
351 Repeat(()),
352 #[prost(message, tag = "11")]
353 UnnestArray(::mz_repr::ProtoScalarType),
354 #[prost(message, tag = "12")]
355 UnnestList(::mz_repr::ProtoScalarType),
356 #[prost(message, tag = "13")]
357 Wrap(ProtoWrap),
358 #[prost(message, tag = "14")]
359 GenerateSubscriptsArray(()),
360 #[prost(message, tag = "15")]
361 TabletizedScalar(ProtoTabletizedScalar),
362 #[prost(message, tag = "16")]
363 AclExplode(()),
364 #[prost(message, tag = "17")]
365 MzAclExplode(()),
366 #[prost(message, tag = "18")]
367 UnnestMap(::mz_repr::ProtoScalarType),
368 #[prost(message, tag = "19")]
369 RegexpMatches(()),
370 }
371}