risingwave_pb/
expr.rs

1// This file is @generated by prost-build.
2#[derive(prost_helpers::AnyPB)]
3#[derive(Eq, Hash)]
4#[derive(Clone, PartialEq, ::prost::Message)]
5pub struct ExprNode {
6    /// Only use this field for function call. For other types of expression, it should be UNSPECIFIED.
7    #[prost(enumeration = "expr_node::Type", tag = "1")]
8    pub function_type: i32,
9    #[prost(message, optional, tag = "3")]
10    pub return_type: ::core::option::Option<super::data::DataType>,
11    #[prost(oneof = "expr_node::RexNode", tags = "4, 5, 6, 7, 8")]
12    pub rex_node: ::core::option::Option<expr_node::RexNode>,
13}
14/// Nested message and enum types in `ExprNode`.
15pub mod expr_node {
16    #[derive(prost_helpers::AnyPB)]
17    #[derive(Eq, Hash)]
18    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
19    pub struct NowRexNode {}
20    /// TODO: move this into `FunctionCall`.
21    #[derive(prost_helpers::AnyPB)]
22    #[derive(
23        Clone,
24        Copy,
25        Debug,
26        PartialEq,
27        Eq,
28        Hash,
29        PartialOrd,
30        Ord,
31        ::prost::Enumeration
32    )]
33    #[repr(i32)]
34    pub enum Type {
35        /// Used for `InputRef`, `Constant`, and `UserDefinedFunction`.
36        Unspecified = 0,
37        /// arithmetics operators
38        Add = 3,
39        Subtract = 4,
40        Multiply = 5,
41        Divide = 6,
42        Modulus = 7,
43        /// comparison operators
44        Equal = 8,
45        NotEqual = 9,
46        LessThan = 10,
47        LessThanOrEqual = 11,
48        GreaterThan = 12,
49        GreaterThanOrEqual = 13,
50        Greatest = 14,
51        Least = 15,
52        /// logical operators
53        And = 21,
54        Or = 22,
55        Not = 23,
56        In = 24,
57        Some = 25,
58        All = 26,
59        /// bitwise operators
60        BitwiseAnd = 31,
61        BitwiseOr = 32,
62        BitwiseXor = 33,
63        BitwiseNot = 34,
64        BitwiseShiftLeft = 35,
65        BitwiseShiftRight = 36,
66        /// date/time functions
67        Extract = 101,
68        DatePart = 102,
69        TumbleStart = 103,
70        MakeDate = 113,
71        MakeTime = 114,
72        MakeTimestamp = 115,
73        DateBin = 116,
74        /// From f64 to timestamp.
75        /// e.g. `select to_timestamp(1672044740.0)`
76        SecToTimestamptz = 104,
77        AtTimeZone = 105,
78        DateTrunc = 106,
79        /// Parse text to timestamp by format string.
80        /// e.g. `select to_timestamp('2022 08 21', 'YYYY MM DD')`
81        CharToTimestamptz = 107,
82        CharToDate = 111,
83        /// Performs a cast with additional timezone information.
84        CastWithTimeZone = 108,
85        AddWithTimeZone = 109,
86        SubtractWithTimeZone = 110,
87        MakeTimestamptz = 112,
88        /// other functions
89        Cast = 201,
90        Substr = 202,
91        Length = 203,
92        Like = 204,
93        ILike = 279,
94        SimilarToEscape = 284,
95        Upper = 205,
96        Lower = 206,
97        Trim = 207,
98        Replace = 208,
99        Position = 209,
100        Ltrim = 210,
101        Rtrim = 211,
102        Case = 212,
103        /// Optimize case-when expression to constant lookup
104        /// when arms are in a large scale with simple form
105        ConstantLookup = 624,
106        /// ROUND(numeric, integer) -> numeric
107        RoundDigit = 213,
108        /// ROUND(numeric) -> numeric
109        /// ROUND(double precision) -> double precision
110        Round = 214,
111        Ascii = 215,
112        Translate = 216,
113        Coalesce = 217,
114        ConcatWs = 218,
115        ConcatWsVariadic = 285,
116        Abs = 219,
117        SplitPart = 220,
118        Ceil = 221,
119        Floor = 222,
120        ToChar = 223,
121        Md5 = 224,
122        CharLength = 225,
123        Repeat = 226,
124        ConcatOp = 227,
125        ByteaConcatOp = 290,
126        Concat = 286,
127        ConcatVariadic = 287,
128        /// BOOL_OUT is different from CAST-bool-to-varchar in PostgreSQL.
129        BoolOut = 228,
130        OctetLength = 229,
131        BitLength = 230,
132        Overlay = 231,
133        RegexpMatch = 232,
134        RegexpReplace = 280,
135        RegexpCount = 281,
136        RegexpSplitToArray = 282,
137        RegexpEq = 283,
138        Pow = 233,
139        Exp = 234,
140        Chr = 235,
141        StartsWith = 236,
142        Initcap = 237,
143        Lpad = 238,
144        Rpad = 239,
145        Reverse = 240,
146        /// duplicated with POSITION
147        Strpos = 241,
148        ToAscii = 242,
149        ToHex = 243,
150        QuoteIdent = 244,
151        Sin = 245,
152        Cos = 246,
153        Tan = 247,
154        Cot = 248,
155        Asin = 249,
156        Acos = 250,
157        Atan = 251,
158        Atan2 = 252,
159        Sind = 253,
160        Cosd = 254,
161        Cotd = 255,
162        Tand = 256,
163        Asind = 257,
164        Sqrt = 258,
165        Degrees = 259,
166        Radians = 260,
167        Cosh = 261,
168        Tanh = 262,
169        Coth = 263,
170        Asinh = 264,
171        Acosh = 265,
172        Atanh = 266,
173        Sinh = 267,
174        Acosd = 268,
175        Atand = 269,
176        Atan2d = 270,
177        Trunc = 271,
178        Ln = 272,
179        Log10 = 273,
180        Cbrt = 274,
181        Sign = 275,
182        Scale = 276,
183        MinScale = 277,
184        TrimScale = 278,
185        /// Boolean comparison
186        IsTrue = 301,
187        IsNotTrue = 302,
188        IsFalse = 303,
189        IsNotFalse = 304,
190        IsNull = 305,
191        IsNotNull = 306,
192        IsDistinctFrom = 307,
193        IsNotDistinctFrom = 308,
194        /// string/bytea expressions
195        Encode = 310,
196        Decode = 311,
197        Sha1 = 312,
198        Sha224 = 313,
199        Sha256 = 314,
200        Sha384 = 315,
201        Sha512 = 316,
202        Left = 317,
203        Right = 318,
204        Format = 319,
205        FormatVariadic = 326,
206        PgwireSend = 320,
207        PgwireRecv = 321,
208        ConvertFrom = 322,
209        ConvertTo = 323,
210        Decrypt = 324,
211        Encrypt = 325,
212        InetAton = 328,
213        InetNtoa = 329,
214        QuoteLiteral = 330,
215        QuoteNullable = 331,
216        Hmac = 332,
217        SecureCompare = 333,
218        /// Constraints Check
219        CheckNotNull = 350,
220        /// Unary operators
221        Neg = 401,
222        /// Nested selection operators
223        Field = 501,
224        /// Array expression.
225        Array = 521,
226        ArrayAccess = 522,
227        Row = 523,
228        ArrayToString = 524,
229        ArrayRangeAccess = 525,
230        /// Array functions
231        ArrayCat = 531,
232        ArrayAppend = 532,
233        ArrayPrepend = 533,
234        FormatType = 534,
235        ArrayDistinct = 535,
236        ArrayLength = 536,
237        Cardinality = 537,
238        ArrayRemove = 538,
239        ArrayPositions = 539,
240        TrimArray = 540,
241        StringToArray = 541,
242        ArrayPosition = 542,
243        ArrayReplace = 543,
244        ArrayDims = 544,
245        ArrayTransform = 545,
246        ArrayMin = 546,
247        ArrayMax = 547,
248        ArraySum = 548,
249        ArraySort = 549,
250        ArrayContains = 550,
251        ArrayContained = 551,
252        ArrayFlatten = 552,
253        /// Int256 functions
254        HexToInt256 = 560,
255        /// jsonb -> int, jsonb -> text that returns jsonb
256        JsonbAccess = 600,
257        /// jsonb ->> int, jsonb ->> text that returns text
258        JsonbAccessStr = 601,
259        /// jsonb #> text\[\] -> jsonb
260        JsonbExtractPath = 627,
261        JsonbExtractPathVariadic = 613,
262        /// jsonb #>> text\[\] -> text
263        JsonbExtractPathText = 628,
264        JsonbExtractPathTextVariadic = 614,
265        JsonbTypeof = 602,
266        JsonbArrayLength = 603,
267        IsJson = 604,
268        JsonbConcat = 605,
269        JsonbObject = 606,
270        JsonbPretty = 607,
271        /// jsonb @> jsonb
272        JsonbContains = 608,
273        /// jsonb <@ jsonb
274        JsonbContained = 609,
275        /// jsonb ? text
276        JsonbExists = 610,
277        /// jsonb ?| text\[\]
278        JsonbExistsAny = 611,
279        /// jsonb ?& text\[\]
280        JsonbExistsAll = 612,
281        /// see SUBTRACT for:
282        /// jsonb - text -> jsonb
283        /// jsonb - text\[\] -> jsonb
284        /// jsonb - integer -> jsonb
285        ///
286        /// jsonb #- text\[\] -> jsonb
287        JsonbDeletePath = 615,
288        JsonbStripNulls = 616,
289        ToJsonb = 617,
290        JsonbBuildArray = 618,
291        JsonbBuildArrayVariadic = 625,
292        JsonbBuildObject = 619,
293        JsonbBuildObjectVariadic = 626,
294        JsonbPathExists = 620,
295        JsonbPathMatch = 621,
296        JsonbPathQueryArray = 622,
297        JsonbPathQueryFirst = 623,
298        JsonbPopulateRecord = 629,
299        JsonbToRecord = 630,
300        JsonbSet = 631,
301        JsonbPopulateMap = 632,
302        /// Map functions
303        MapFromEntries = 700,
304        MapAccess = 701,
305        MapKeys = 702,
306        MapValues = 703,
307        MapEntries = 704,
308        MapFromKeyValues = 705,
309        MapLength = 706,
310        MapContains = 707,
311        MapCat = 708,
312        MapInsert = 709,
313        MapDelete = 710,
314        MapFilter = 711,
315        /// Vector functions
316        L2Distance = 750,
317        /// Internal function for schema change
318        CompositeCast = 800,
319        /// Non-pure functions below (> 1000)
320        /// ------------------------
321        /// Internal functions
322        Vnode = 1101,
323        TestPaidTier = 1102,
324        VnodeUser = 1103,
325        License = 1104,
326        /// Non-deterministic functions
327        Proctime = 2023,
328        PgSleep = 2024,
329        PgSleepFor = 2025,
330        PgSleepUntil = 2026,
331        /// System administration functions
332        CastRegclass = 2100,
333        /// System information functions
334        PgGetIndexdef = 2400,
335        ColDescription = 2401,
336        PgGetViewdef = 2402,
337        PgGetUserbyid = 2403,
338        PgIndexesSize = 2404,
339        PgRelationSize = 2405,
340        PgGetSerialSequence = 2406,
341        PgIndexColumnHasProperty = 2410,
342        HasTablePrivilege = 2407,
343        HasAnyColumnPrivilege = 2408,
344        HasSchemaPrivilege = 2409,
345        PgIsInRecovery = 2411,
346        RwRecoveryStatus = 2412,
347        RwEpochToTs = 2413,
348        PgTableIsVisible = 2414,
349        HasFunctionPrivilege = 2415,
350        HasDatabasePrivilege = 2416,
351        /// EXTERNAL
352        IcebergTransform = 2201,
353        /// AI model functions
354        OpenaiEmbedding = 2501,
355    }
356    impl Type {
357        /// String value of the enum field names used in the ProtoBuf definition.
358        ///
359        /// The values are not transformed in any way and thus are considered stable
360        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
361        pub fn as_str_name(&self) -> &'static str {
362            match self {
363                Self::Unspecified => "UNSPECIFIED",
364                Self::Add => "ADD",
365                Self::Subtract => "SUBTRACT",
366                Self::Multiply => "MULTIPLY",
367                Self::Divide => "DIVIDE",
368                Self::Modulus => "MODULUS",
369                Self::Equal => "EQUAL",
370                Self::NotEqual => "NOT_EQUAL",
371                Self::LessThan => "LESS_THAN",
372                Self::LessThanOrEqual => "LESS_THAN_OR_EQUAL",
373                Self::GreaterThan => "GREATER_THAN",
374                Self::GreaterThanOrEqual => "GREATER_THAN_OR_EQUAL",
375                Self::Greatest => "GREATEST",
376                Self::Least => "LEAST",
377                Self::And => "AND",
378                Self::Or => "OR",
379                Self::Not => "NOT",
380                Self::In => "IN",
381                Self::Some => "SOME",
382                Self::All => "ALL",
383                Self::BitwiseAnd => "BITWISE_AND",
384                Self::BitwiseOr => "BITWISE_OR",
385                Self::BitwiseXor => "BITWISE_XOR",
386                Self::BitwiseNot => "BITWISE_NOT",
387                Self::BitwiseShiftLeft => "BITWISE_SHIFT_LEFT",
388                Self::BitwiseShiftRight => "BITWISE_SHIFT_RIGHT",
389                Self::Extract => "EXTRACT",
390                Self::DatePart => "DATE_PART",
391                Self::TumbleStart => "TUMBLE_START",
392                Self::MakeDate => "MAKE_DATE",
393                Self::MakeTime => "MAKE_TIME",
394                Self::MakeTimestamp => "MAKE_TIMESTAMP",
395                Self::DateBin => "DATE_BIN",
396                Self::SecToTimestamptz => "SEC_TO_TIMESTAMPTZ",
397                Self::AtTimeZone => "AT_TIME_ZONE",
398                Self::DateTrunc => "DATE_TRUNC",
399                Self::CharToTimestamptz => "CHAR_TO_TIMESTAMPTZ",
400                Self::CharToDate => "CHAR_TO_DATE",
401                Self::CastWithTimeZone => "CAST_WITH_TIME_ZONE",
402                Self::AddWithTimeZone => "ADD_WITH_TIME_ZONE",
403                Self::SubtractWithTimeZone => "SUBTRACT_WITH_TIME_ZONE",
404                Self::MakeTimestamptz => "MAKE_TIMESTAMPTZ",
405                Self::Cast => "CAST",
406                Self::Substr => "SUBSTR",
407                Self::Length => "LENGTH",
408                Self::Like => "LIKE",
409                Self::ILike => "I_LIKE",
410                Self::SimilarToEscape => "SIMILAR_TO_ESCAPE",
411                Self::Upper => "UPPER",
412                Self::Lower => "LOWER",
413                Self::Trim => "TRIM",
414                Self::Replace => "REPLACE",
415                Self::Position => "POSITION",
416                Self::Ltrim => "LTRIM",
417                Self::Rtrim => "RTRIM",
418                Self::Case => "CASE",
419                Self::ConstantLookup => "CONSTANT_LOOKUP",
420                Self::RoundDigit => "ROUND_DIGIT",
421                Self::Round => "ROUND",
422                Self::Ascii => "ASCII",
423                Self::Translate => "TRANSLATE",
424                Self::Coalesce => "COALESCE",
425                Self::ConcatWs => "CONCAT_WS",
426                Self::ConcatWsVariadic => "CONCAT_WS_VARIADIC",
427                Self::Abs => "ABS",
428                Self::SplitPart => "SPLIT_PART",
429                Self::Ceil => "CEIL",
430                Self::Floor => "FLOOR",
431                Self::ToChar => "TO_CHAR",
432                Self::Md5 => "MD5",
433                Self::CharLength => "CHAR_LENGTH",
434                Self::Repeat => "REPEAT",
435                Self::ConcatOp => "CONCAT_OP",
436                Self::ByteaConcatOp => "BYTEA_CONCAT_OP",
437                Self::Concat => "CONCAT",
438                Self::ConcatVariadic => "CONCAT_VARIADIC",
439                Self::BoolOut => "BOOL_OUT",
440                Self::OctetLength => "OCTET_LENGTH",
441                Self::BitLength => "BIT_LENGTH",
442                Self::Overlay => "OVERLAY",
443                Self::RegexpMatch => "REGEXP_MATCH",
444                Self::RegexpReplace => "REGEXP_REPLACE",
445                Self::RegexpCount => "REGEXP_COUNT",
446                Self::RegexpSplitToArray => "REGEXP_SPLIT_TO_ARRAY",
447                Self::RegexpEq => "REGEXP_EQ",
448                Self::Pow => "POW",
449                Self::Exp => "EXP",
450                Self::Chr => "CHR",
451                Self::StartsWith => "STARTS_WITH",
452                Self::Initcap => "INITCAP",
453                Self::Lpad => "LPAD",
454                Self::Rpad => "RPAD",
455                Self::Reverse => "REVERSE",
456                Self::Strpos => "STRPOS",
457                Self::ToAscii => "TO_ASCII",
458                Self::ToHex => "TO_HEX",
459                Self::QuoteIdent => "QUOTE_IDENT",
460                Self::Sin => "SIN",
461                Self::Cos => "COS",
462                Self::Tan => "TAN",
463                Self::Cot => "COT",
464                Self::Asin => "ASIN",
465                Self::Acos => "ACOS",
466                Self::Atan => "ATAN",
467                Self::Atan2 => "ATAN2",
468                Self::Sind => "SIND",
469                Self::Cosd => "COSD",
470                Self::Cotd => "COTD",
471                Self::Tand => "TAND",
472                Self::Asind => "ASIND",
473                Self::Sqrt => "SQRT",
474                Self::Degrees => "DEGREES",
475                Self::Radians => "RADIANS",
476                Self::Cosh => "COSH",
477                Self::Tanh => "TANH",
478                Self::Coth => "COTH",
479                Self::Asinh => "ASINH",
480                Self::Acosh => "ACOSH",
481                Self::Atanh => "ATANH",
482                Self::Sinh => "SINH",
483                Self::Acosd => "ACOSD",
484                Self::Atand => "ATAND",
485                Self::Atan2d => "ATAN2D",
486                Self::Trunc => "TRUNC",
487                Self::Ln => "LN",
488                Self::Log10 => "LOG10",
489                Self::Cbrt => "CBRT",
490                Self::Sign => "SIGN",
491                Self::Scale => "SCALE",
492                Self::MinScale => "MIN_SCALE",
493                Self::TrimScale => "TRIM_SCALE",
494                Self::IsTrue => "IS_TRUE",
495                Self::IsNotTrue => "IS_NOT_TRUE",
496                Self::IsFalse => "IS_FALSE",
497                Self::IsNotFalse => "IS_NOT_FALSE",
498                Self::IsNull => "IS_NULL",
499                Self::IsNotNull => "IS_NOT_NULL",
500                Self::IsDistinctFrom => "IS_DISTINCT_FROM",
501                Self::IsNotDistinctFrom => "IS_NOT_DISTINCT_FROM",
502                Self::Encode => "ENCODE",
503                Self::Decode => "DECODE",
504                Self::Sha1 => "SHA1",
505                Self::Sha224 => "SHA224",
506                Self::Sha256 => "SHA256",
507                Self::Sha384 => "SHA384",
508                Self::Sha512 => "SHA512",
509                Self::Left => "LEFT",
510                Self::Right => "RIGHT",
511                Self::Format => "FORMAT",
512                Self::FormatVariadic => "FORMAT_VARIADIC",
513                Self::PgwireSend => "PGWIRE_SEND",
514                Self::PgwireRecv => "PGWIRE_RECV",
515                Self::ConvertFrom => "CONVERT_FROM",
516                Self::ConvertTo => "CONVERT_TO",
517                Self::Decrypt => "DECRYPT",
518                Self::Encrypt => "ENCRYPT",
519                Self::InetAton => "INET_ATON",
520                Self::InetNtoa => "INET_NTOA",
521                Self::QuoteLiteral => "QUOTE_LITERAL",
522                Self::QuoteNullable => "QUOTE_NULLABLE",
523                Self::Hmac => "HMAC",
524                Self::SecureCompare => "SECURE_COMPARE",
525                Self::CheckNotNull => "CHECK_NOT_NULL",
526                Self::Neg => "NEG",
527                Self::Field => "FIELD",
528                Self::Array => "ARRAY",
529                Self::ArrayAccess => "ARRAY_ACCESS",
530                Self::Row => "ROW",
531                Self::ArrayToString => "ARRAY_TO_STRING",
532                Self::ArrayRangeAccess => "ARRAY_RANGE_ACCESS",
533                Self::ArrayCat => "ARRAY_CAT",
534                Self::ArrayAppend => "ARRAY_APPEND",
535                Self::ArrayPrepend => "ARRAY_PREPEND",
536                Self::FormatType => "FORMAT_TYPE",
537                Self::ArrayDistinct => "ARRAY_DISTINCT",
538                Self::ArrayLength => "ARRAY_LENGTH",
539                Self::Cardinality => "CARDINALITY",
540                Self::ArrayRemove => "ARRAY_REMOVE",
541                Self::ArrayPositions => "ARRAY_POSITIONS",
542                Self::TrimArray => "TRIM_ARRAY",
543                Self::StringToArray => "STRING_TO_ARRAY",
544                Self::ArrayPosition => "ARRAY_POSITION",
545                Self::ArrayReplace => "ARRAY_REPLACE",
546                Self::ArrayDims => "ARRAY_DIMS",
547                Self::ArrayTransform => "ARRAY_TRANSFORM",
548                Self::ArrayMin => "ARRAY_MIN",
549                Self::ArrayMax => "ARRAY_MAX",
550                Self::ArraySum => "ARRAY_SUM",
551                Self::ArraySort => "ARRAY_SORT",
552                Self::ArrayContains => "ARRAY_CONTAINS",
553                Self::ArrayContained => "ARRAY_CONTAINED",
554                Self::ArrayFlatten => "ARRAY_FLATTEN",
555                Self::HexToInt256 => "HEX_TO_INT256",
556                Self::JsonbAccess => "JSONB_ACCESS",
557                Self::JsonbAccessStr => "JSONB_ACCESS_STR",
558                Self::JsonbExtractPath => "JSONB_EXTRACT_PATH",
559                Self::JsonbExtractPathVariadic => "JSONB_EXTRACT_PATH_VARIADIC",
560                Self::JsonbExtractPathText => "JSONB_EXTRACT_PATH_TEXT",
561                Self::JsonbExtractPathTextVariadic => "JSONB_EXTRACT_PATH_TEXT_VARIADIC",
562                Self::JsonbTypeof => "JSONB_TYPEOF",
563                Self::JsonbArrayLength => "JSONB_ARRAY_LENGTH",
564                Self::IsJson => "IS_JSON",
565                Self::JsonbConcat => "JSONB_CONCAT",
566                Self::JsonbObject => "JSONB_OBJECT",
567                Self::JsonbPretty => "JSONB_PRETTY",
568                Self::JsonbContains => "JSONB_CONTAINS",
569                Self::JsonbContained => "JSONB_CONTAINED",
570                Self::JsonbExists => "JSONB_EXISTS",
571                Self::JsonbExistsAny => "JSONB_EXISTS_ANY",
572                Self::JsonbExistsAll => "JSONB_EXISTS_ALL",
573                Self::JsonbDeletePath => "JSONB_DELETE_PATH",
574                Self::JsonbStripNulls => "JSONB_STRIP_NULLS",
575                Self::ToJsonb => "TO_JSONB",
576                Self::JsonbBuildArray => "JSONB_BUILD_ARRAY",
577                Self::JsonbBuildArrayVariadic => "JSONB_BUILD_ARRAY_VARIADIC",
578                Self::JsonbBuildObject => "JSONB_BUILD_OBJECT",
579                Self::JsonbBuildObjectVariadic => "JSONB_BUILD_OBJECT_VARIADIC",
580                Self::JsonbPathExists => "JSONB_PATH_EXISTS",
581                Self::JsonbPathMatch => "JSONB_PATH_MATCH",
582                Self::JsonbPathQueryArray => "JSONB_PATH_QUERY_ARRAY",
583                Self::JsonbPathQueryFirst => "JSONB_PATH_QUERY_FIRST",
584                Self::JsonbPopulateRecord => "JSONB_POPULATE_RECORD",
585                Self::JsonbToRecord => "JSONB_TO_RECORD",
586                Self::JsonbSet => "JSONB_SET",
587                Self::JsonbPopulateMap => "JSONB_POPULATE_MAP",
588                Self::MapFromEntries => "MAP_FROM_ENTRIES",
589                Self::MapAccess => "MAP_ACCESS",
590                Self::MapKeys => "MAP_KEYS",
591                Self::MapValues => "MAP_VALUES",
592                Self::MapEntries => "MAP_ENTRIES",
593                Self::MapFromKeyValues => "MAP_FROM_KEY_VALUES",
594                Self::MapLength => "MAP_LENGTH",
595                Self::MapContains => "MAP_CONTAINS",
596                Self::MapCat => "MAP_CAT",
597                Self::MapInsert => "MAP_INSERT",
598                Self::MapDelete => "MAP_DELETE",
599                Self::MapFilter => "MAP_FILTER",
600                Self::L2Distance => "L2_DISTANCE",
601                Self::CompositeCast => "COMPOSITE_CAST",
602                Self::Vnode => "VNODE",
603                Self::TestPaidTier => "TEST_PAID_TIER",
604                Self::VnodeUser => "VNODE_USER",
605                Self::License => "LICENSE",
606                Self::Proctime => "PROCTIME",
607                Self::PgSleep => "PG_SLEEP",
608                Self::PgSleepFor => "PG_SLEEP_FOR",
609                Self::PgSleepUntil => "PG_SLEEP_UNTIL",
610                Self::CastRegclass => "CAST_REGCLASS",
611                Self::PgGetIndexdef => "PG_GET_INDEXDEF",
612                Self::ColDescription => "COL_DESCRIPTION",
613                Self::PgGetViewdef => "PG_GET_VIEWDEF",
614                Self::PgGetUserbyid => "PG_GET_USERBYID",
615                Self::PgIndexesSize => "PG_INDEXES_SIZE",
616                Self::PgRelationSize => "PG_RELATION_SIZE",
617                Self::PgGetSerialSequence => "PG_GET_SERIAL_SEQUENCE",
618                Self::PgIndexColumnHasProperty => "PG_INDEX_COLUMN_HAS_PROPERTY",
619                Self::HasTablePrivilege => "HAS_TABLE_PRIVILEGE",
620                Self::HasAnyColumnPrivilege => "HAS_ANY_COLUMN_PRIVILEGE",
621                Self::HasSchemaPrivilege => "HAS_SCHEMA_PRIVILEGE",
622                Self::PgIsInRecovery => "PG_IS_IN_RECOVERY",
623                Self::RwRecoveryStatus => "RW_RECOVERY_STATUS",
624                Self::RwEpochToTs => "RW_EPOCH_TO_TS",
625                Self::PgTableIsVisible => "PG_TABLE_IS_VISIBLE",
626                Self::HasFunctionPrivilege => "HAS_FUNCTION_PRIVILEGE",
627                Self::HasDatabasePrivilege => "HAS_DATABASE_PRIVILEGE",
628                Self::IcebergTransform => "ICEBERG_TRANSFORM",
629                Self::OpenaiEmbedding => "OPENAI_EMBEDDING",
630            }
631        }
632        /// Creates an enum from field names used in the ProtoBuf definition.
633        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
634            match value {
635                "UNSPECIFIED" => Some(Self::Unspecified),
636                "ADD" => Some(Self::Add),
637                "SUBTRACT" => Some(Self::Subtract),
638                "MULTIPLY" => Some(Self::Multiply),
639                "DIVIDE" => Some(Self::Divide),
640                "MODULUS" => Some(Self::Modulus),
641                "EQUAL" => Some(Self::Equal),
642                "NOT_EQUAL" => Some(Self::NotEqual),
643                "LESS_THAN" => Some(Self::LessThan),
644                "LESS_THAN_OR_EQUAL" => Some(Self::LessThanOrEqual),
645                "GREATER_THAN" => Some(Self::GreaterThan),
646                "GREATER_THAN_OR_EQUAL" => Some(Self::GreaterThanOrEqual),
647                "GREATEST" => Some(Self::Greatest),
648                "LEAST" => Some(Self::Least),
649                "AND" => Some(Self::And),
650                "OR" => Some(Self::Or),
651                "NOT" => Some(Self::Not),
652                "IN" => Some(Self::In),
653                "SOME" => Some(Self::Some),
654                "ALL" => Some(Self::All),
655                "BITWISE_AND" => Some(Self::BitwiseAnd),
656                "BITWISE_OR" => Some(Self::BitwiseOr),
657                "BITWISE_XOR" => Some(Self::BitwiseXor),
658                "BITWISE_NOT" => Some(Self::BitwiseNot),
659                "BITWISE_SHIFT_LEFT" => Some(Self::BitwiseShiftLeft),
660                "BITWISE_SHIFT_RIGHT" => Some(Self::BitwiseShiftRight),
661                "EXTRACT" => Some(Self::Extract),
662                "DATE_PART" => Some(Self::DatePart),
663                "TUMBLE_START" => Some(Self::TumbleStart),
664                "MAKE_DATE" => Some(Self::MakeDate),
665                "MAKE_TIME" => Some(Self::MakeTime),
666                "MAKE_TIMESTAMP" => Some(Self::MakeTimestamp),
667                "DATE_BIN" => Some(Self::DateBin),
668                "SEC_TO_TIMESTAMPTZ" => Some(Self::SecToTimestamptz),
669                "AT_TIME_ZONE" => Some(Self::AtTimeZone),
670                "DATE_TRUNC" => Some(Self::DateTrunc),
671                "CHAR_TO_TIMESTAMPTZ" => Some(Self::CharToTimestamptz),
672                "CHAR_TO_DATE" => Some(Self::CharToDate),
673                "CAST_WITH_TIME_ZONE" => Some(Self::CastWithTimeZone),
674                "ADD_WITH_TIME_ZONE" => Some(Self::AddWithTimeZone),
675                "SUBTRACT_WITH_TIME_ZONE" => Some(Self::SubtractWithTimeZone),
676                "MAKE_TIMESTAMPTZ" => Some(Self::MakeTimestamptz),
677                "CAST" => Some(Self::Cast),
678                "SUBSTR" => Some(Self::Substr),
679                "LENGTH" => Some(Self::Length),
680                "LIKE" => Some(Self::Like),
681                "I_LIKE" => Some(Self::ILike),
682                "SIMILAR_TO_ESCAPE" => Some(Self::SimilarToEscape),
683                "UPPER" => Some(Self::Upper),
684                "LOWER" => Some(Self::Lower),
685                "TRIM" => Some(Self::Trim),
686                "REPLACE" => Some(Self::Replace),
687                "POSITION" => Some(Self::Position),
688                "LTRIM" => Some(Self::Ltrim),
689                "RTRIM" => Some(Self::Rtrim),
690                "CASE" => Some(Self::Case),
691                "CONSTANT_LOOKUP" => Some(Self::ConstantLookup),
692                "ROUND_DIGIT" => Some(Self::RoundDigit),
693                "ROUND" => Some(Self::Round),
694                "ASCII" => Some(Self::Ascii),
695                "TRANSLATE" => Some(Self::Translate),
696                "COALESCE" => Some(Self::Coalesce),
697                "CONCAT_WS" => Some(Self::ConcatWs),
698                "CONCAT_WS_VARIADIC" => Some(Self::ConcatWsVariadic),
699                "ABS" => Some(Self::Abs),
700                "SPLIT_PART" => Some(Self::SplitPart),
701                "CEIL" => Some(Self::Ceil),
702                "FLOOR" => Some(Self::Floor),
703                "TO_CHAR" => Some(Self::ToChar),
704                "MD5" => Some(Self::Md5),
705                "CHAR_LENGTH" => Some(Self::CharLength),
706                "REPEAT" => Some(Self::Repeat),
707                "CONCAT_OP" => Some(Self::ConcatOp),
708                "BYTEA_CONCAT_OP" => Some(Self::ByteaConcatOp),
709                "CONCAT" => Some(Self::Concat),
710                "CONCAT_VARIADIC" => Some(Self::ConcatVariadic),
711                "BOOL_OUT" => Some(Self::BoolOut),
712                "OCTET_LENGTH" => Some(Self::OctetLength),
713                "BIT_LENGTH" => Some(Self::BitLength),
714                "OVERLAY" => Some(Self::Overlay),
715                "REGEXP_MATCH" => Some(Self::RegexpMatch),
716                "REGEXP_REPLACE" => Some(Self::RegexpReplace),
717                "REGEXP_COUNT" => Some(Self::RegexpCount),
718                "REGEXP_SPLIT_TO_ARRAY" => Some(Self::RegexpSplitToArray),
719                "REGEXP_EQ" => Some(Self::RegexpEq),
720                "POW" => Some(Self::Pow),
721                "EXP" => Some(Self::Exp),
722                "CHR" => Some(Self::Chr),
723                "STARTS_WITH" => Some(Self::StartsWith),
724                "INITCAP" => Some(Self::Initcap),
725                "LPAD" => Some(Self::Lpad),
726                "RPAD" => Some(Self::Rpad),
727                "REVERSE" => Some(Self::Reverse),
728                "STRPOS" => Some(Self::Strpos),
729                "TO_ASCII" => Some(Self::ToAscii),
730                "TO_HEX" => Some(Self::ToHex),
731                "QUOTE_IDENT" => Some(Self::QuoteIdent),
732                "SIN" => Some(Self::Sin),
733                "COS" => Some(Self::Cos),
734                "TAN" => Some(Self::Tan),
735                "COT" => Some(Self::Cot),
736                "ASIN" => Some(Self::Asin),
737                "ACOS" => Some(Self::Acos),
738                "ATAN" => Some(Self::Atan),
739                "ATAN2" => Some(Self::Atan2),
740                "SIND" => Some(Self::Sind),
741                "COSD" => Some(Self::Cosd),
742                "COTD" => Some(Self::Cotd),
743                "TAND" => Some(Self::Tand),
744                "ASIND" => Some(Self::Asind),
745                "SQRT" => Some(Self::Sqrt),
746                "DEGREES" => Some(Self::Degrees),
747                "RADIANS" => Some(Self::Radians),
748                "COSH" => Some(Self::Cosh),
749                "TANH" => Some(Self::Tanh),
750                "COTH" => Some(Self::Coth),
751                "ASINH" => Some(Self::Asinh),
752                "ACOSH" => Some(Self::Acosh),
753                "ATANH" => Some(Self::Atanh),
754                "SINH" => Some(Self::Sinh),
755                "ACOSD" => Some(Self::Acosd),
756                "ATAND" => Some(Self::Atand),
757                "ATAN2D" => Some(Self::Atan2d),
758                "TRUNC" => Some(Self::Trunc),
759                "LN" => Some(Self::Ln),
760                "LOG10" => Some(Self::Log10),
761                "CBRT" => Some(Self::Cbrt),
762                "SIGN" => Some(Self::Sign),
763                "SCALE" => Some(Self::Scale),
764                "MIN_SCALE" => Some(Self::MinScale),
765                "TRIM_SCALE" => Some(Self::TrimScale),
766                "IS_TRUE" => Some(Self::IsTrue),
767                "IS_NOT_TRUE" => Some(Self::IsNotTrue),
768                "IS_FALSE" => Some(Self::IsFalse),
769                "IS_NOT_FALSE" => Some(Self::IsNotFalse),
770                "IS_NULL" => Some(Self::IsNull),
771                "IS_NOT_NULL" => Some(Self::IsNotNull),
772                "IS_DISTINCT_FROM" => Some(Self::IsDistinctFrom),
773                "IS_NOT_DISTINCT_FROM" => Some(Self::IsNotDistinctFrom),
774                "ENCODE" => Some(Self::Encode),
775                "DECODE" => Some(Self::Decode),
776                "SHA1" => Some(Self::Sha1),
777                "SHA224" => Some(Self::Sha224),
778                "SHA256" => Some(Self::Sha256),
779                "SHA384" => Some(Self::Sha384),
780                "SHA512" => Some(Self::Sha512),
781                "LEFT" => Some(Self::Left),
782                "RIGHT" => Some(Self::Right),
783                "FORMAT" => Some(Self::Format),
784                "FORMAT_VARIADIC" => Some(Self::FormatVariadic),
785                "PGWIRE_SEND" => Some(Self::PgwireSend),
786                "PGWIRE_RECV" => Some(Self::PgwireRecv),
787                "CONVERT_FROM" => Some(Self::ConvertFrom),
788                "CONVERT_TO" => Some(Self::ConvertTo),
789                "DECRYPT" => Some(Self::Decrypt),
790                "ENCRYPT" => Some(Self::Encrypt),
791                "INET_ATON" => Some(Self::InetAton),
792                "INET_NTOA" => Some(Self::InetNtoa),
793                "QUOTE_LITERAL" => Some(Self::QuoteLiteral),
794                "QUOTE_NULLABLE" => Some(Self::QuoteNullable),
795                "HMAC" => Some(Self::Hmac),
796                "SECURE_COMPARE" => Some(Self::SecureCompare),
797                "CHECK_NOT_NULL" => Some(Self::CheckNotNull),
798                "NEG" => Some(Self::Neg),
799                "FIELD" => Some(Self::Field),
800                "ARRAY" => Some(Self::Array),
801                "ARRAY_ACCESS" => Some(Self::ArrayAccess),
802                "ROW" => Some(Self::Row),
803                "ARRAY_TO_STRING" => Some(Self::ArrayToString),
804                "ARRAY_RANGE_ACCESS" => Some(Self::ArrayRangeAccess),
805                "ARRAY_CAT" => Some(Self::ArrayCat),
806                "ARRAY_APPEND" => Some(Self::ArrayAppend),
807                "ARRAY_PREPEND" => Some(Self::ArrayPrepend),
808                "FORMAT_TYPE" => Some(Self::FormatType),
809                "ARRAY_DISTINCT" => Some(Self::ArrayDistinct),
810                "ARRAY_LENGTH" => Some(Self::ArrayLength),
811                "CARDINALITY" => Some(Self::Cardinality),
812                "ARRAY_REMOVE" => Some(Self::ArrayRemove),
813                "ARRAY_POSITIONS" => Some(Self::ArrayPositions),
814                "TRIM_ARRAY" => Some(Self::TrimArray),
815                "STRING_TO_ARRAY" => Some(Self::StringToArray),
816                "ARRAY_POSITION" => Some(Self::ArrayPosition),
817                "ARRAY_REPLACE" => Some(Self::ArrayReplace),
818                "ARRAY_DIMS" => Some(Self::ArrayDims),
819                "ARRAY_TRANSFORM" => Some(Self::ArrayTransform),
820                "ARRAY_MIN" => Some(Self::ArrayMin),
821                "ARRAY_MAX" => Some(Self::ArrayMax),
822                "ARRAY_SUM" => Some(Self::ArraySum),
823                "ARRAY_SORT" => Some(Self::ArraySort),
824                "ARRAY_CONTAINS" => Some(Self::ArrayContains),
825                "ARRAY_CONTAINED" => Some(Self::ArrayContained),
826                "ARRAY_FLATTEN" => Some(Self::ArrayFlatten),
827                "HEX_TO_INT256" => Some(Self::HexToInt256),
828                "JSONB_ACCESS" => Some(Self::JsonbAccess),
829                "JSONB_ACCESS_STR" => Some(Self::JsonbAccessStr),
830                "JSONB_EXTRACT_PATH" => Some(Self::JsonbExtractPath),
831                "JSONB_EXTRACT_PATH_VARIADIC" => Some(Self::JsonbExtractPathVariadic),
832                "JSONB_EXTRACT_PATH_TEXT" => Some(Self::JsonbExtractPathText),
833                "JSONB_EXTRACT_PATH_TEXT_VARIADIC" => {
834                    Some(Self::JsonbExtractPathTextVariadic)
835                }
836                "JSONB_TYPEOF" => Some(Self::JsonbTypeof),
837                "JSONB_ARRAY_LENGTH" => Some(Self::JsonbArrayLength),
838                "IS_JSON" => Some(Self::IsJson),
839                "JSONB_CONCAT" => Some(Self::JsonbConcat),
840                "JSONB_OBJECT" => Some(Self::JsonbObject),
841                "JSONB_PRETTY" => Some(Self::JsonbPretty),
842                "JSONB_CONTAINS" => Some(Self::JsonbContains),
843                "JSONB_CONTAINED" => Some(Self::JsonbContained),
844                "JSONB_EXISTS" => Some(Self::JsonbExists),
845                "JSONB_EXISTS_ANY" => Some(Self::JsonbExistsAny),
846                "JSONB_EXISTS_ALL" => Some(Self::JsonbExistsAll),
847                "JSONB_DELETE_PATH" => Some(Self::JsonbDeletePath),
848                "JSONB_STRIP_NULLS" => Some(Self::JsonbStripNulls),
849                "TO_JSONB" => Some(Self::ToJsonb),
850                "JSONB_BUILD_ARRAY" => Some(Self::JsonbBuildArray),
851                "JSONB_BUILD_ARRAY_VARIADIC" => Some(Self::JsonbBuildArrayVariadic),
852                "JSONB_BUILD_OBJECT" => Some(Self::JsonbBuildObject),
853                "JSONB_BUILD_OBJECT_VARIADIC" => Some(Self::JsonbBuildObjectVariadic),
854                "JSONB_PATH_EXISTS" => Some(Self::JsonbPathExists),
855                "JSONB_PATH_MATCH" => Some(Self::JsonbPathMatch),
856                "JSONB_PATH_QUERY_ARRAY" => Some(Self::JsonbPathQueryArray),
857                "JSONB_PATH_QUERY_FIRST" => Some(Self::JsonbPathQueryFirst),
858                "JSONB_POPULATE_RECORD" => Some(Self::JsonbPopulateRecord),
859                "JSONB_TO_RECORD" => Some(Self::JsonbToRecord),
860                "JSONB_SET" => Some(Self::JsonbSet),
861                "JSONB_POPULATE_MAP" => Some(Self::JsonbPopulateMap),
862                "MAP_FROM_ENTRIES" => Some(Self::MapFromEntries),
863                "MAP_ACCESS" => Some(Self::MapAccess),
864                "MAP_KEYS" => Some(Self::MapKeys),
865                "MAP_VALUES" => Some(Self::MapValues),
866                "MAP_ENTRIES" => Some(Self::MapEntries),
867                "MAP_FROM_KEY_VALUES" => Some(Self::MapFromKeyValues),
868                "MAP_LENGTH" => Some(Self::MapLength),
869                "MAP_CONTAINS" => Some(Self::MapContains),
870                "MAP_CAT" => Some(Self::MapCat),
871                "MAP_INSERT" => Some(Self::MapInsert),
872                "MAP_DELETE" => Some(Self::MapDelete),
873                "MAP_FILTER" => Some(Self::MapFilter),
874                "L2_DISTANCE" => Some(Self::L2Distance),
875                "COMPOSITE_CAST" => Some(Self::CompositeCast),
876                "VNODE" => Some(Self::Vnode),
877                "TEST_PAID_TIER" => Some(Self::TestPaidTier),
878                "VNODE_USER" => Some(Self::VnodeUser),
879                "LICENSE" => Some(Self::License),
880                "PROCTIME" => Some(Self::Proctime),
881                "PG_SLEEP" => Some(Self::PgSleep),
882                "PG_SLEEP_FOR" => Some(Self::PgSleepFor),
883                "PG_SLEEP_UNTIL" => Some(Self::PgSleepUntil),
884                "CAST_REGCLASS" => Some(Self::CastRegclass),
885                "PG_GET_INDEXDEF" => Some(Self::PgGetIndexdef),
886                "COL_DESCRIPTION" => Some(Self::ColDescription),
887                "PG_GET_VIEWDEF" => Some(Self::PgGetViewdef),
888                "PG_GET_USERBYID" => Some(Self::PgGetUserbyid),
889                "PG_INDEXES_SIZE" => Some(Self::PgIndexesSize),
890                "PG_RELATION_SIZE" => Some(Self::PgRelationSize),
891                "PG_GET_SERIAL_SEQUENCE" => Some(Self::PgGetSerialSequence),
892                "PG_INDEX_COLUMN_HAS_PROPERTY" => Some(Self::PgIndexColumnHasProperty),
893                "HAS_TABLE_PRIVILEGE" => Some(Self::HasTablePrivilege),
894                "HAS_ANY_COLUMN_PRIVILEGE" => Some(Self::HasAnyColumnPrivilege),
895                "HAS_SCHEMA_PRIVILEGE" => Some(Self::HasSchemaPrivilege),
896                "PG_IS_IN_RECOVERY" => Some(Self::PgIsInRecovery),
897                "RW_RECOVERY_STATUS" => Some(Self::RwRecoveryStatus),
898                "RW_EPOCH_TO_TS" => Some(Self::RwEpochToTs),
899                "PG_TABLE_IS_VISIBLE" => Some(Self::PgTableIsVisible),
900                "HAS_FUNCTION_PRIVILEGE" => Some(Self::HasFunctionPrivilege),
901                "HAS_DATABASE_PRIVILEGE" => Some(Self::HasDatabasePrivilege),
902                "ICEBERG_TRANSFORM" => Some(Self::IcebergTransform),
903                "OPENAI_EMBEDDING" => Some(Self::OpenaiEmbedding),
904                _ => None,
905            }
906        }
907    }
908    #[derive(prost_helpers::AnyPB)]
909    #[derive(::enum_as_inner::EnumAsInner)]
910    #[derive(Eq, Hash)]
911    #[derive(Clone, PartialEq, ::prost::Oneof)]
912    pub enum RexNode {
913        #[prost(uint32, tag = "4")]
914        InputRef(u32),
915        #[prost(message, tag = "5")]
916        Constant(super::super::data::Datum),
917        #[prost(message, tag = "6")]
918        FuncCall(super::FunctionCall),
919        #[prost(message, tag = "7")]
920        Udf(::prost::alloc::boxed::Box<super::UserDefinedFunction>),
921        #[prost(message, tag = "8")]
922        Now(NowRexNode),
923    }
924}
925#[derive(prost_helpers::AnyPB)]
926#[derive(Clone, PartialEq, ::prost::Message)]
927pub struct TableFunction {
928    #[prost(enumeration = "table_function::Type", tag = "1")]
929    pub function_type: i32,
930    #[prost(message, repeated, tag = "2")]
931    pub args: ::prost::alloc::vec::Vec<ExprNode>,
932    #[prost(message, optional, tag = "3")]
933    pub return_type: ::core::option::Option<super::data::DataType>,
934    /// optional. only used when the type is USER_DEFINED.
935    #[prost(message, optional, tag = "4")]
936    pub udf: ::core::option::Option<UserDefinedFunctionMetadata>,
937}
938/// Nested message and enum types in `TableFunction`.
939pub mod table_function {
940    #[derive(prost_helpers::AnyPB)]
941    #[derive(
942        Clone,
943        Copy,
944        Debug,
945        PartialEq,
946        Eq,
947        Hash,
948        PartialOrd,
949        Ord,
950        ::prost::Enumeration
951    )]
952    #[repr(i32)]
953    pub enum Type {
954        Unspecified = 0,
955        GenerateSeries = 1,
956        Unnest = 2,
957        RegexpMatches = 3,
958        Range = 4,
959        GenerateSubscripts = 5,
960        /// buf:lint:ignore ENUM_VALUE_UPPER_SNAKE_CASE
961        PgExpandarray = 6,
962        PgGetKeywords = 18,
963        /// Jsonb functions
964        JsonbArrayElements = 10,
965        JsonbArrayElementsText = 11,
966        JsonbEach = 12,
967        JsonbEachText = 13,
968        JsonbObjectKeys = 14,
969        JsonbPathQuery = 15,
970        JsonbPopulateRecordset = 16,
971        JsonbToRecordset = 17,
972        /// file scan
973        FileScan = 19,
974        /// postgres query
975        PostgresQuery = 20,
976        /// mysql query
977        MysqlQuery = 21,
978        /// Internal backfill table function
979        InternalBackfillProgress = 30,
980        /// Internal source backfill table function
981        InternalSourceBackfillProgress = 31,
982        /// User defined table function
983        UserDefined = 100,
984    }
985    impl Type {
986        /// String value of the enum field names used in the ProtoBuf definition.
987        ///
988        /// The values are not transformed in any way and thus are considered stable
989        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
990        pub fn as_str_name(&self) -> &'static str {
991            match self {
992                Self::Unspecified => "UNSPECIFIED",
993                Self::GenerateSeries => "GENERATE_SERIES",
994                Self::Unnest => "UNNEST",
995                Self::RegexpMatches => "REGEXP_MATCHES",
996                Self::Range => "RANGE",
997                Self::GenerateSubscripts => "GENERATE_SUBSCRIPTS",
998                Self::PgExpandarray => "_PG_EXPANDARRAY",
999                Self::PgGetKeywords => "PG_GET_KEYWORDS",
1000                Self::JsonbArrayElements => "JSONB_ARRAY_ELEMENTS",
1001                Self::JsonbArrayElementsText => "JSONB_ARRAY_ELEMENTS_TEXT",
1002                Self::JsonbEach => "JSONB_EACH",
1003                Self::JsonbEachText => "JSONB_EACH_TEXT",
1004                Self::JsonbObjectKeys => "JSONB_OBJECT_KEYS",
1005                Self::JsonbPathQuery => "JSONB_PATH_QUERY",
1006                Self::JsonbPopulateRecordset => "JSONB_POPULATE_RECORDSET",
1007                Self::JsonbToRecordset => "JSONB_TO_RECORDSET",
1008                Self::FileScan => "FILE_SCAN",
1009                Self::PostgresQuery => "POSTGRES_QUERY",
1010                Self::MysqlQuery => "MYSQL_QUERY",
1011                Self::InternalBackfillProgress => "INTERNAL_BACKFILL_PROGRESS",
1012                Self::InternalSourceBackfillProgress => {
1013                    "INTERNAL_SOURCE_BACKFILL_PROGRESS"
1014                }
1015                Self::UserDefined => "USER_DEFINED",
1016            }
1017        }
1018        /// Creates an enum from field names used in the ProtoBuf definition.
1019        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1020            match value {
1021                "UNSPECIFIED" => Some(Self::Unspecified),
1022                "GENERATE_SERIES" => Some(Self::GenerateSeries),
1023                "UNNEST" => Some(Self::Unnest),
1024                "REGEXP_MATCHES" => Some(Self::RegexpMatches),
1025                "RANGE" => Some(Self::Range),
1026                "GENERATE_SUBSCRIPTS" => Some(Self::GenerateSubscripts),
1027                "_PG_EXPANDARRAY" => Some(Self::PgExpandarray),
1028                "PG_GET_KEYWORDS" => Some(Self::PgGetKeywords),
1029                "JSONB_ARRAY_ELEMENTS" => Some(Self::JsonbArrayElements),
1030                "JSONB_ARRAY_ELEMENTS_TEXT" => Some(Self::JsonbArrayElementsText),
1031                "JSONB_EACH" => Some(Self::JsonbEach),
1032                "JSONB_EACH_TEXT" => Some(Self::JsonbEachText),
1033                "JSONB_OBJECT_KEYS" => Some(Self::JsonbObjectKeys),
1034                "JSONB_PATH_QUERY" => Some(Self::JsonbPathQuery),
1035                "JSONB_POPULATE_RECORDSET" => Some(Self::JsonbPopulateRecordset),
1036                "JSONB_TO_RECORDSET" => Some(Self::JsonbToRecordset),
1037                "FILE_SCAN" => Some(Self::FileScan),
1038                "POSTGRES_QUERY" => Some(Self::PostgresQuery),
1039                "MYSQL_QUERY" => Some(Self::MysqlQuery),
1040                "INTERNAL_BACKFILL_PROGRESS" => Some(Self::InternalBackfillProgress),
1041                "INTERNAL_SOURCE_BACKFILL_PROGRESS" => {
1042                    Some(Self::InternalSourceBackfillProgress)
1043                }
1044                "USER_DEFINED" => Some(Self::UserDefined),
1045                _ => None,
1046            }
1047        }
1048    }
1049}
1050/// Reference to an upstream column, containing its index and data type.
1051#[derive(prost_helpers::AnyPB)]
1052#[derive(Eq, Hash)]
1053#[derive(Clone, PartialEq, ::prost::Message)]
1054pub struct InputRef {
1055    #[prost(uint32, tag = "1")]
1056    pub index: u32,
1057    #[prost(message, optional, tag = "2")]
1058    pub r#type: ::core::option::Option<super::data::DataType>,
1059}
1060#[derive(prost_helpers::AnyPB)]
1061#[derive(Clone, PartialEq, ::prost::Message)]
1062pub struct Constant {
1063    #[prost(message, optional, tag = "1")]
1064    pub datum: ::core::option::Option<super::data::Datum>,
1065    #[prost(message, optional, tag = "2")]
1066    pub r#type: ::core::option::Option<super::data::DataType>,
1067}
1068/// The items which can occur in the select list of `ProjectSet` operator.
1069///
1070/// When there are table functions in the SQL query `SELECT ...`, it will be planned as `ProjectSet`.
1071/// Otherwise it will be planned as `Project`.
1072///
1073/// # Examples
1074///
1075/// ```sql
1076/// # Project
1077/// select 1;
1078///
1079/// # ProjectSet
1080/// select unnest(array\[1,2,3\]);
1081///
1082/// # ProjectSet (table function & usual expression)
1083/// select unnest(array\[1,2,3\]), 1;
1084///
1085/// # ProjectSet (multiple table functions)
1086/// select unnest(array\[1,2,3\]), unnest(array\[4,5\]);
1087///
1088/// # ProjectSet over ProjectSet (table function as parameters of table function)
1089/// select unnest(regexp_matches(v1, 'a(\d)c(\d)', 'g')) from t;
1090///
1091/// # Project over ProjectSet (table function as parameters of usual function)
1092/// select unnest(regexp_matches(v1, 'a(\d)c(\d)', 'g')) from t;
1093/// ```
1094#[derive(prost_helpers::AnyPB)]
1095#[derive(Clone, PartialEq, ::prost::Message)]
1096pub struct ProjectSetSelectItem {
1097    #[prost(oneof = "project_set_select_item::SelectItem", tags = "1, 2")]
1098    pub select_item: ::core::option::Option<project_set_select_item::SelectItem>,
1099}
1100/// Nested message and enum types in `ProjectSetSelectItem`.
1101pub mod project_set_select_item {
1102    #[derive(prost_helpers::AnyPB)]
1103    #[derive(Clone, PartialEq, ::prost::Oneof)]
1104    pub enum SelectItem {
1105        #[prost(message, tag = "1")]
1106        Expr(super::ExprNode),
1107        #[prost(message, tag = "2")]
1108        TableFunction(super::TableFunction),
1109    }
1110}
1111#[derive(prost_helpers::AnyPB)]
1112#[derive(Eq, Hash)]
1113#[derive(Clone, PartialEq, ::prost::Message)]
1114pub struct FunctionCall {
1115    #[prost(message, repeated, tag = "1")]
1116    pub children: ::prost::alloc::vec::Vec<ExprNode>,
1117}
1118/// Aggregate Function Calls for Aggregation
1119#[derive(prost_helpers::AnyPB)]
1120#[derive(Clone, PartialEq, ::prost::Message)]
1121pub struct AggCall {
1122    #[prost(enumeration = "agg_call::Kind", tag = "1")]
1123    pub kind: i32,
1124    #[prost(message, repeated, tag = "2")]
1125    pub args: ::prost::alloc::vec::Vec<InputRef>,
1126    #[prost(message, optional, tag = "3")]
1127    pub return_type: ::core::option::Option<super::data::DataType>,
1128    #[prost(bool, tag = "4")]
1129    pub distinct: bool,
1130    #[prost(message, repeated, tag = "5")]
1131    pub order_by: ::prost::alloc::vec::Vec<super::common::ColumnOrder>,
1132    #[prost(message, optional, tag = "6")]
1133    pub filter: ::core::option::Option<ExprNode>,
1134    #[prost(message, repeated, tag = "7")]
1135    pub direct_args: ::prost::alloc::vec::Vec<Constant>,
1136    /// optional. only used when the kind is USER_DEFINED.
1137    #[prost(message, optional, tag = "8")]
1138    pub udf: ::core::option::Option<UserDefinedFunctionMetadata>,
1139    /// optional. only used when the kind is WRAP_SCALAR.
1140    #[prost(message, optional, tag = "9")]
1141    pub scalar: ::core::option::Option<ExprNode>,
1142}
1143/// Nested message and enum types in `AggCall`.
1144pub mod agg_call {
1145    #[derive(prost_helpers::AnyPB)]
1146    #[derive(
1147        Clone,
1148        Copy,
1149        Debug,
1150        PartialEq,
1151        Eq,
1152        Hash,
1153        PartialOrd,
1154        Ord,
1155        ::prost::Enumeration
1156    )]
1157    #[repr(i32)]
1158    pub enum Kind {
1159        Unspecified = 0,
1160        Sum = 1,
1161        Min = 2,
1162        Max = 3,
1163        Count = 4,
1164        Avg = 5,
1165        StringAgg = 6,
1166        ApproxCountDistinct = 7,
1167        ArrayAgg = 8,
1168        FirstValue = 9,
1169        Sum0 = 10,
1170        VarPop = 11,
1171        VarSamp = 12,
1172        StddevPop = 13,
1173        StddevSamp = 14,
1174        BitAnd = 15,
1175        BitOr = 16,
1176        BitXor = 17,
1177        BoolAnd = 18,
1178        BoolOr = 19,
1179        JsonbAgg = 20,
1180        JsonbObjectAgg = 21,
1181        PercentileCont = 22,
1182        PercentileDisc = 23,
1183        Mode = 24,
1184        LastValue = 25,
1185        Grouping = 26,
1186        InternalLastSeenValue = 27,
1187        ApproxPercentile = 28,
1188        /// user defined aggregate function
1189        UserDefined = 100,
1190        /// wraps a scalar function that takes a list as input as an aggregate function.
1191        WrapScalar = 101,
1192    }
1193    impl Kind {
1194        /// String value of the enum field names used in the ProtoBuf definition.
1195        ///
1196        /// The values are not transformed in any way and thus are considered stable
1197        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1198        pub fn as_str_name(&self) -> &'static str {
1199            match self {
1200                Self::Unspecified => "UNSPECIFIED",
1201                Self::Sum => "SUM",
1202                Self::Min => "MIN",
1203                Self::Max => "MAX",
1204                Self::Count => "COUNT",
1205                Self::Avg => "AVG",
1206                Self::StringAgg => "STRING_AGG",
1207                Self::ApproxCountDistinct => "APPROX_COUNT_DISTINCT",
1208                Self::ArrayAgg => "ARRAY_AGG",
1209                Self::FirstValue => "FIRST_VALUE",
1210                Self::Sum0 => "SUM0",
1211                Self::VarPop => "VAR_POP",
1212                Self::VarSamp => "VAR_SAMP",
1213                Self::StddevPop => "STDDEV_POP",
1214                Self::StddevSamp => "STDDEV_SAMP",
1215                Self::BitAnd => "BIT_AND",
1216                Self::BitOr => "BIT_OR",
1217                Self::BitXor => "BIT_XOR",
1218                Self::BoolAnd => "BOOL_AND",
1219                Self::BoolOr => "BOOL_OR",
1220                Self::JsonbAgg => "JSONB_AGG",
1221                Self::JsonbObjectAgg => "JSONB_OBJECT_AGG",
1222                Self::PercentileCont => "PERCENTILE_CONT",
1223                Self::PercentileDisc => "PERCENTILE_DISC",
1224                Self::Mode => "MODE",
1225                Self::LastValue => "LAST_VALUE",
1226                Self::Grouping => "GROUPING",
1227                Self::InternalLastSeenValue => "INTERNAL_LAST_SEEN_VALUE",
1228                Self::ApproxPercentile => "APPROX_PERCENTILE",
1229                Self::UserDefined => "USER_DEFINED",
1230                Self::WrapScalar => "WRAP_SCALAR",
1231            }
1232        }
1233        /// Creates an enum from field names used in the ProtoBuf definition.
1234        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1235            match value {
1236                "UNSPECIFIED" => Some(Self::Unspecified),
1237                "SUM" => Some(Self::Sum),
1238                "MIN" => Some(Self::Min),
1239                "MAX" => Some(Self::Max),
1240                "COUNT" => Some(Self::Count),
1241                "AVG" => Some(Self::Avg),
1242                "STRING_AGG" => Some(Self::StringAgg),
1243                "APPROX_COUNT_DISTINCT" => Some(Self::ApproxCountDistinct),
1244                "ARRAY_AGG" => Some(Self::ArrayAgg),
1245                "FIRST_VALUE" => Some(Self::FirstValue),
1246                "SUM0" => Some(Self::Sum0),
1247                "VAR_POP" => Some(Self::VarPop),
1248                "VAR_SAMP" => Some(Self::VarSamp),
1249                "STDDEV_POP" => Some(Self::StddevPop),
1250                "STDDEV_SAMP" => Some(Self::StddevSamp),
1251                "BIT_AND" => Some(Self::BitAnd),
1252                "BIT_OR" => Some(Self::BitOr),
1253                "BIT_XOR" => Some(Self::BitXor),
1254                "BOOL_AND" => Some(Self::BoolAnd),
1255                "BOOL_OR" => Some(Self::BoolOr),
1256                "JSONB_AGG" => Some(Self::JsonbAgg),
1257                "JSONB_OBJECT_AGG" => Some(Self::JsonbObjectAgg),
1258                "PERCENTILE_CONT" => Some(Self::PercentileCont),
1259                "PERCENTILE_DISC" => Some(Self::PercentileDisc),
1260                "MODE" => Some(Self::Mode),
1261                "LAST_VALUE" => Some(Self::LastValue),
1262                "GROUPING" => Some(Self::Grouping),
1263                "INTERNAL_LAST_SEEN_VALUE" => Some(Self::InternalLastSeenValue),
1264                "APPROX_PERCENTILE" => Some(Self::ApproxPercentile),
1265                "USER_DEFINED" => Some(Self::UserDefined),
1266                "WRAP_SCALAR" => Some(Self::WrapScalar),
1267                _ => None,
1268            }
1269        }
1270    }
1271}
1272/// The aggregation type.
1273///
1274/// Ideally this should be used to encode the Rust `AggCall::agg_type` field, but historically we
1275/// flattened it into multiple fields in proto `AggCall` - `kind` + `udf` + `scalar`. So this
1276/// `AggType` proto type is only used by `WindowFunction` currently.
1277#[derive(prost_helpers::AnyPB)]
1278#[derive(Clone, PartialEq, ::prost::Message)]
1279pub struct AggType {
1280    #[prost(enumeration = "agg_call::Kind", tag = "1")]
1281    pub kind: i32,
1282    /// UDF metadata. Only present when the kind is `USER_DEFINED`.
1283    #[prost(message, optional, tag = "8")]
1284    pub udf_meta: ::core::option::Option<UserDefinedFunctionMetadata>,
1285    /// Wrapped scalar expression. Only present when the kind is `WRAP_SCALAR`.
1286    #[prost(message, optional, tag = "9")]
1287    pub scalar_expr: ::core::option::Option<ExprNode>,
1288}
1289#[derive(prost_helpers::AnyPB)]
1290#[derive(Clone, PartialEq, ::prost::Message)]
1291pub struct WindowFrame {
1292    #[prost(enumeration = "window_frame::Type", tag = "1")]
1293    pub r#type: i32,
1294    /// Deprecated since we introduced `RANGE` frame.
1295    #[deprecated]
1296    #[prost(message, optional, tag = "2")]
1297    pub start: ::core::option::Option<window_frame::Bound>,
1298    /// Deprecated since we introduced `RANGE` frame.
1299    #[deprecated]
1300    #[prost(message, optional, tag = "3")]
1301    pub end: ::core::option::Option<window_frame::Bound>,
1302    #[prost(enumeration = "window_frame::Exclusion", tag = "4")]
1303    pub exclusion: i32,
1304    #[prost(oneof = "window_frame::Bounds", tags = "10, 15, 20")]
1305    pub bounds: ::core::option::Option<window_frame::Bounds>,
1306}
1307/// Nested message and enum types in `WindowFrame`.
1308pub mod window_frame {
1309    /// Deprecated since we introduced `RANGE` frame.
1310    #[derive(prost_helpers::AnyPB)]
1311    #[derive(Clone, PartialEq, ::prost::Message)]
1312    pub struct Bound {
1313        #[prost(enumeration = "BoundType", tag = "1")]
1314        pub r#type: i32,
1315        #[prost(oneof = "bound::Offset", tags = "2, 3")]
1316        pub offset: ::core::option::Option<bound::Offset>,
1317    }
1318    /// Nested message and enum types in `Bound`.
1319    pub mod bound {
1320        #[derive(prost_helpers::AnyPB)]
1321        #[derive(Clone, PartialEq, ::prost::Oneof)]
1322        pub enum Offset {
1323            #[prost(uint64, tag = "2")]
1324            Integer(u64),
1325            #[prost(message, tag = "3")]
1326            Datum(super::super::super::data::Datum),
1327        }
1328    }
1329    #[derive(prost_helpers::AnyPB)]
1330    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
1331    pub struct RowsFrameBounds {
1332        #[prost(message, optional, tag = "1")]
1333        pub start: ::core::option::Option<RowsFrameBound>,
1334        #[prost(message, optional, tag = "2")]
1335        pub end: ::core::option::Option<RowsFrameBound>,
1336    }
1337    #[derive(prost_helpers::AnyPB)]
1338    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
1339    pub struct RowsFrameBound {
1340        #[prost(enumeration = "BoundType", tag = "1")]
1341        pub r#type: i32,
1342        #[prost(uint64, optional, tag = "3")]
1343        pub offset: ::core::option::Option<u64>,
1344    }
1345    #[derive(prost_helpers::AnyPB)]
1346    #[derive(Clone, PartialEq, ::prost::Message)]
1347    pub struct RangeFrameBounds {
1348        #[prost(message, optional, tag = "1")]
1349        pub start: ::core::option::Option<RangeFrameBound>,
1350        #[prost(message, optional, tag = "2")]
1351        pub end: ::core::option::Option<RangeFrameBound>,
1352        #[prost(message, optional, tag = "10")]
1353        pub order_data_type: ::core::option::Option<super::super::data::DataType>,
1354        #[prost(message, optional, tag = "15")]
1355        pub order_type: ::core::option::Option<super::super::common::OrderType>,
1356        #[prost(message, optional, tag = "20")]
1357        pub offset_data_type: ::core::option::Option<super::super::data::DataType>,
1358    }
1359    #[derive(prost_helpers::AnyPB)]
1360    #[derive(Clone, PartialEq, ::prost::Message)]
1361    pub struct RangeFrameBound {
1362        #[prost(enumeration = "BoundType", tag = "1")]
1363        pub r#type: i32,
1364        #[prost(message, optional, tag = "3")]
1365        pub offset: ::core::option::Option<super::super::data::Datum>,
1366    }
1367    #[derive(prost_helpers::AnyPB)]
1368    #[derive(Clone, PartialEq, ::prost::Message)]
1369    pub struct SessionFrameBounds {
1370        #[prost(message, optional, tag = "1")]
1371        pub gap: ::core::option::Option<super::super::data::Datum>,
1372        #[prost(message, optional, tag = "10")]
1373        pub order_data_type: ::core::option::Option<super::super::data::DataType>,
1374        #[prost(message, optional, tag = "15")]
1375        pub order_type: ::core::option::Option<super::super::common::OrderType>,
1376        #[prost(message, optional, tag = "20")]
1377        pub gap_data_type: ::core::option::Option<super::super::data::DataType>,
1378    }
1379    #[derive(prost_helpers::AnyPB)]
1380    #[derive(
1381        Clone,
1382        Copy,
1383        Debug,
1384        PartialEq,
1385        Eq,
1386        Hash,
1387        PartialOrd,
1388        Ord,
1389        ::prost::Enumeration
1390    )]
1391    #[repr(i32)]
1392    pub enum Type {
1393        Unspecified = 0,
1394        /// Deprecated since we introduced `RANGE` frame.
1395        RowsLegacy = 2,
1396        Rows = 5,
1397        Range = 10,
1398        Session = 15,
1399    }
1400    impl Type {
1401        /// String value of the enum field names used in the ProtoBuf definition.
1402        ///
1403        /// The values are not transformed in any way and thus are considered stable
1404        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1405        pub fn as_str_name(&self) -> &'static str {
1406            match self {
1407                Self::Unspecified => "TYPE_UNSPECIFIED",
1408                Self::RowsLegacy => "TYPE_ROWS_LEGACY",
1409                Self::Rows => "TYPE_ROWS",
1410                Self::Range => "TYPE_RANGE",
1411                Self::Session => "TYPE_SESSION",
1412            }
1413        }
1414        /// Creates an enum from field names used in the ProtoBuf definition.
1415        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1416            match value {
1417                "TYPE_UNSPECIFIED" => Some(Self::Unspecified),
1418                "TYPE_ROWS_LEGACY" => Some(Self::RowsLegacy),
1419                "TYPE_ROWS" => Some(Self::Rows),
1420                "TYPE_RANGE" => Some(Self::Range),
1421                "TYPE_SESSION" => Some(Self::Session),
1422                _ => None,
1423            }
1424        }
1425    }
1426    #[derive(prost_helpers::AnyPB)]
1427    #[derive(
1428        Clone,
1429        Copy,
1430        Debug,
1431        PartialEq,
1432        Eq,
1433        Hash,
1434        PartialOrd,
1435        Ord,
1436        ::prost::Enumeration
1437    )]
1438    #[repr(i32)]
1439    pub enum BoundType {
1440        Unspecified = 0,
1441        UnboundedPreceding = 1,
1442        Preceding = 2,
1443        CurrentRow = 3,
1444        Following = 4,
1445        UnboundedFollowing = 5,
1446    }
1447    impl BoundType {
1448        /// String value of the enum field names used in the ProtoBuf definition.
1449        ///
1450        /// The values are not transformed in any way and thus are considered stable
1451        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1452        pub fn as_str_name(&self) -> &'static str {
1453            match self {
1454                Self::Unspecified => "BOUND_TYPE_UNSPECIFIED",
1455                Self::UnboundedPreceding => "BOUND_TYPE_UNBOUNDED_PRECEDING",
1456                Self::Preceding => "BOUND_TYPE_PRECEDING",
1457                Self::CurrentRow => "BOUND_TYPE_CURRENT_ROW",
1458                Self::Following => "BOUND_TYPE_FOLLOWING",
1459                Self::UnboundedFollowing => "BOUND_TYPE_UNBOUNDED_FOLLOWING",
1460            }
1461        }
1462        /// Creates an enum from field names used in the ProtoBuf definition.
1463        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1464            match value {
1465                "BOUND_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
1466                "BOUND_TYPE_UNBOUNDED_PRECEDING" => Some(Self::UnboundedPreceding),
1467                "BOUND_TYPE_PRECEDING" => Some(Self::Preceding),
1468                "BOUND_TYPE_CURRENT_ROW" => Some(Self::CurrentRow),
1469                "BOUND_TYPE_FOLLOWING" => Some(Self::Following),
1470                "BOUND_TYPE_UNBOUNDED_FOLLOWING" => Some(Self::UnboundedFollowing),
1471                _ => None,
1472            }
1473        }
1474    }
1475    #[derive(prost_helpers::AnyPB)]
1476    #[derive(
1477        Clone,
1478        Copy,
1479        Debug,
1480        PartialEq,
1481        Eq,
1482        Hash,
1483        PartialOrd,
1484        Ord,
1485        ::prost::Enumeration
1486    )]
1487    #[repr(i32)]
1488    pub enum Exclusion {
1489        Unspecified = 0,
1490        CurrentRow = 1,
1491        /// EXCLUSION_GROUP = 2;
1492        /// EXCLUSION_TIES = 3;
1493        NoOthers = 4,
1494    }
1495    impl Exclusion {
1496        /// String value of the enum field names used in the ProtoBuf definition.
1497        ///
1498        /// The values are not transformed in any way and thus are considered stable
1499        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1500        pub fn as_str_name(&self) -> &'static str {
1501            match self {
1502                Self::Unspecified => "EXCLUSION_UNSPECIFIED",
1503                Self::CurrentRow => "EXCLUSION_CURRENT_ROW",
1504                Self::NoOthers => "EXCLUSION_NO_OTHERS",
1505            }
1506        }
1507        /// Creates an enum from field names used in the ProtoBuf definition.
1508        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1509            match value {
1510                "EXCLUSION_UNSPECIFIED" => Some(Self::Unspecified),
1511                "EXCLUSION_CURRENT_ROW" => Some(Self::CurrentRow),
1512                "EXCLUSION_NO_OTHERS" => Some(Self::NoOthers),
1513                _ => None,
1514            }
1515        }
1516    }
1517    #[derive(prost_helpers::AnyPB)]
1518    #[derive(Clone, PartialEq, ::prost::Oneof)]
1519    pub enum Bounds {
1520        #[prost(message, tag = "10")]
1521        Rows(RowsFrameBounds),
1522        #[prost(message, tag = "15")]
1523        Range(RangeFrameBounds),
1524        #[prost(message, tag = "20")]
1525        Session(SessionFrameBounds),
1526    }
1527}
1528#[derive(prost_helpers::AnyPB)]
1529#[derive(Clone, PartialEq, ::prost::Message)]
1530pub struct WindowFunction {
1531    #[prost(message, repeated, tag = "3")]
1532    pub args: ::prost::alloc::vec::Vec<InputRef>,
1533    #[prost(message, optional, tag = "4")]
1534    pub return_type: ::core::option::Option<super::data::DataType>,
1535    #[prost(message, optional, tag = "5")]
1536    pub frame: ::core::option::Option<WindowFrame>,
1537    #[prost(bool, tag = "6")]
1538    pub ignore_nulls: bool,
1539    #[prost(oneof = "window_function::Type", tags = "1, 2, 103")]
1540    pub r#type: ::core::option::Option<window_function::Type>,
1541}
1542/// Nested message and enum types in `WindowFunction`.
1543pub mod window_function {
1544    #[derive(prost_helpers::AnyPB)]
1545    #[derive(
1546        Clone,
1547        Copy,
1548        Debug,
1549        PartialEq,
1550        Eq,
1551        Hash,
1552        PartialOrd,
1553        Ord,
1554        ::prost::Enumeration
1555    )]
1556    #[repr(i32)]
1557    pub enum GeneralType {
1558        Unspecified = 0,
1559        RowNumber = 1,
1560        Rank = 2,
1561        DenseRank = 3,
1562        /// PERCENT_RANK = 4;
1563        /// CUME_DIST = 5;
1564        /// NTILE = 6;
1565        Lag = 7,
1566        Lead = 8,
1567    }
1568    impl GeneralType {
1569        /// String value of the enum field names used in the ProtoBuf definition.
1570        ///
1571        /// The values are not transformed in any way and thus are considered stable
1572        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1573        pub fn as_str_name(&self) -> &'static str {
1574            match self {
1575                Self::Unspecified => "UNSPECIFIED",
1576                Self::RowNumber => "ROW_NUMBER",
1577                Self::Rank => "RANK",
1578                Self::DenseRank => "DENSE_RANK",
1579                Self::Lag => "LAG",
1580                Self::Lead => "LEAD",
1581            }
1582        }
1583        /// Creates an enum from field names used in the ProtoBuf definition.
1584        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1585            match value {
1586                "UNSPECIFIED" => Some(Self::Unspecified),
1587                "ROW_NUMBER" => Some(Self::RowNumber),
1588                "RANK" => Some(Self::Rank),
1589                "DENSE_RANK" => Some(Self::DenseRank),
1590                "LAG" => Some(Self::Lag),
1591                "LEAD" => Some(Self::Lead),
1592                _ => None,
1593            }
1594        }
1595    }
1596    #[derive(prost_helpers::AnyPB)]
1597    #[derive(Clone, PartialEq, ::prost::Oneof)]
1598    pub enum Type {
1599        #[prost(enumeration = "GeneralType", tag = "1")]
1600        General(i32),
1601        /// Deprecated since we have a new `aggregate2` variant.
1602        #[prost(enumeration = "super::agg_call::Kind", tag = "2")]
1603        Aggregate(i32),
1604        #[prost(message, tag = "103")]
1605        Aggregate2(super::AggType),
1606    }
1607}
1608#[derive(prost_helpers::AnyPB)]
1609#[derive(Eq, Hash)]
1610#[derive(Clone, PartialEq, ::prost::Message)]
1611pub struct UserDefinedFunction {
1612    #[prost(message, repeated, tag = "1")]
1613    pub children: ::prost::alloc::vec::Vec<ExprNode>,
1614    #[prost(string, tag = "2")]
1615    pub name: ::prost::alloc::string::String,
1616    #[prost(string, repeated, tag = "8")]
1617    pub arg_names: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
1618    #[prost(message, repeated, tag = "3")]
1619    pub arg_types: ::prost::alloc::vec::Vec<super::data::DataType>,
1620    #[prost(string, tag = "4")]
1621    pub language: ::prost::alloc::string::String,
1622    /// The link to the external function service.
1623    #[prost(string, optional, tag = "5")]
1624    pub link: ::core::option::Option<::prost::alloc::string::String>,
1625    /// This is re-interpreted as `name_in_runtime`.
1626    #[prost(string, optional, tag = "6")]
1627    pub identifier: ::core::option::Option<::prost::alloc::string::String>,
1628    /// - If `language` is `javascript` or `python`, the source code of the function.
1629    #[prost(string, optional, tag = "7")]
1630    pub body: ::core::option::Option<::prost::alloc::string::String>,
1631    /// - If `language` is `rust` or `wasm`, the zstd-compressed wasm binary.
1632    #[prost(bytes = "vec", optional, tag = "10")]
1633    pub compressed_binary: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
1634    #[prost(bool, tag = "9")]
1635    pub always_retry_on_network_error: bool,
1636    /// The runtime selected when multiple runtimes are available for the language. Now is not used.
1637    #[prost(string, optional, tag = "11")]
1638    pub runtime: ::core::option::Option<::prost::alloc::string::String>,
1639    /// additional options for javascript functions
1640    #[prost(bool, optional, tag = "13")]
1641    pub is_async: ::core::option::Option<bool>,
1642    #[prost(bool, optional, tag = "14")]
1643    pub is_batched: ::core::option::Option<bool>,
1644    #[prost(enumeration = "UdfExprVersion", tag = "1000")]
1645    pub version: i32,
1646}
1647/// Additional information for user defined table/aggregate functions.
1648#[derive(prost_helpers::AnyPB)]
1649#[derive(Eq, Hash)]
1650#[derive(Clone, PartialEq, ::prost::Message)]
1651pub struct UserDefinedFunctionMetadata {
1652    #[prost(string, repeated, tag = "8")]
1653    pub arg_names: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
1654    #[prost(message, repeated, tag = "3")]
1655    pub arg_types: ::prost::alloc::vec::Vec<super::data::DataType>,
1656    #[prost(message, optional, tag = "13")]
1657    pub return_type: ::core::option::Option<super::data::DataType>,
1658    #[prost(string, tag = "4")]
1659    pub language: ::prost::alloc::string::String,
1660    #[prost(string, optional, tag = "5")]
1661    pub link: ::core::option::Option<::prost::alloc::string::String>,
1662    /// This is re-interpreted as `name_in_runtime`.
1663    #[prost(string, optional, tag = "6")]
1664    pub identifier: ::core::option::Option<::prost::alloc::string::String>,
1665    #[prost(string, optional, tag = "7")]
1666    pub body: ::core::option::Option<::prost::alloc::string::String>,
1667    #[prost(bytes = "vec", optional, tag = "10")]
1668    pub compressed_binary: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
1669    #[prost(string, optional, tag = "11")]
1670    pub runtime: ::core::option::Option<::prost::alloc::string::String>,
1671    #[prost(enumeration = "UdfExprVersion", tag = "1000")]
1672    pub version: i32,
1673}
1674#[derive(prost_helpers::AnyPB)]
1675#[derive(prost_helpers::Version)]
1676#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1677#[repr(i32)]
1678pub enum UdfExprVersion {
1679    /// Versions before introducing this enum.
1680    Unspecified = 0,
1681    /// Begin from this version, we re-interpret `identifier` as `name_in_runtime`.
1682    NameInRuntime = 1,
1683}
1684impl UdfExprVersion {
1685    /// String value of the enum field names used in the ProtoBuf definition.
1686    ///
1687    /// The values are not transformed in any way and thus are considered stable
1688    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1689    pub fn as_str_name(&self) -> &'static str {
1690        match self {
1691            Self::Unspecified => "UDF_EXPR_VERSION_UNSPECIFIED",
1692            Self::NameInRuntime => "UDF_EXPR_VERSION_NAME_IN_RUNTIME",
1693        }
1694    }
1695    /// Creates an enum from field names used in the ProtoBuf definition.
1696    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1697        match value {
1698            "UDF_EXPR_VERSION_UNSPECIFIED" => Some(Self::Unspecified),
1699            "UDF_EXPR_VERSION_NAME_IN_RUNTIME" => Some(Self::NameInRuntime),
1700            _ => None,
1701        }
1702    }
1703}
risingwave_pb/expr.rs

risingwave_pb/
expr.rs
