risingwave_pb/
plan_common.rs

1// This file is @generated by prost-build.
2/// Field is a column in the streaming or batch plan.
3#[derive(prost_helpers::AnyPB)]
4#[derive(Clone, PartialEq, ::prost::Message)]
5pub struct Field {
6    #[prost(message, optional, tag = "1")]
7    pub data_type: ::core::option::Option<super::data::DataType>,
8    #[prost(string, tag = "2")]
9    pub name: ::prost::alloc::string::String,
10}
11#[derive(prost_helpers::AnyPB)]
12#[derive(Eq, Hash)]
13#[derive(Clone, PartialEq, ::prost::Message)]
14#[prost(skip_debug)]
15pub struct ColumnDesc {
16    #[prost(message, optional, tag = "1")]
17    pub column_type: ::core::option::Option<super::data::DataType>,
18    #[prost(int32, tag = "2")]
19    pub column_id: i32,
20    /// we store the column name in column desc now just for debug, but in future
21    /// we should store it in ColumnCatalog but not here
22    #[prost(string, tag = "3")]
23    pub name: ::prost::alloc::string::String,
24    /// This field is used to store the description set by the `comment on` clause.
25    #[prost(string, optional, tag = "8")]
26    pub description: ::core::option::Option<::prost::alloc::string::String>,
27    /// deprecated, use AdditionalColumn instead, keep for compatibility with v1.6.x
28    #[prost(enumeration = "AdditionalColumnType", tag = "9")]
29    pub additional_column_type: i32,
30    #[prost(enumeration = "ColumnDescVersion", tag = "10")]
31    pub version: i32,
32    #[prost(message, optional, tag = "11")]
33    pub additional_column: ::core::option::Option<AdditionalColumn>,
34    #[prost(bool, tag = "12")]
35    pub nullable: bool,
36    /// Optional description for the generated column or default value.
37    #[prost(oneof = "column_desc::GeneratedOrDefaultColumn", tags = "6, 7")]
38    pub generated_or_default_column: ::core::option::Option<
39        column_desc::GeneratedOrDefaultColumn,
40    >,
41}
42/// Nested message and enum types in `ColumnDesc`.
43pub mod column_desc {
44    /// Optional description for the generated column or default value.
45    #[derive(prost_helpers::AnyPB)]
46    #[derive(Eq, Hash)]
47    #[derive(Clone, PartialEq, ::prost::Oneof)]
48    #[prost(skip_debug)]
49    pub enum GeneratedOrDefaultColumn {
50        #[prost(message, tag = "6")]
51        GeneratedColumn(super::GeneratedColumnDesc),
52        #[prost(message, tag = "7")]
53        DefaultColumn(super::DefaultColumnDesc),
54    }
55}
56#[derive(prost_helpers::AnyPB)]
57#[derive(Clone, PartialEq, ::prost::Message)]
58pub struct ColumnCatalog {
59    #[prost(message, optional, tag = "1")]
60    pub column_desc: ::core::option::Option<ColumnDesc>,
61    #[prost(bool, tag = "2")]
62    pub is_hidden: bool,
63}
64#[derive(prost_helpers::AnyPB)]
65#[derive(Eq, Hash)]
66#[derive(Clone, PartialEq, ::prost::Message)]
67pub struct GeneratedColumnDesc {
68    #[prost(message, optional, tag = "1")]
69    pub expr: ::core::option::Option<super::expr::ExprNode>,
70}
71#[derive(prost_helpers::AnyPB)]
72#[derive(Eq, Hash)]
73#[derive(Clone, PartialEq, ::prost::Message)]
74pub struct DefaultColumnDesc {
75    /// Expression of the `DEFAULT`. Used when inserting new records.
76    #[prost(message, optional, tag = "1")]
77    pub expr: ::core::option::Option<super::expr::ExprNode>,
78    /// Evaluated value of the expression at the time of the table creation or the
79    /// column addition. Used when filling the default value for the records where
80    /// the column is missing.
81    #[prost(message, optional, tag = "2")]
82    pub snapshot_value: ::core::option::Option<super::data::Datum>,
83}
84#[derive(prost_helpers::AnyPB)]
85#[derive(Clone, PartialEq, ::prost::Message)]
86pub struct StorageTableDesc {
87    #[prost(uint32, tag = "1")]
88    pub table_id: u32,
89    #[prost(message, repeated, tag = "2")]
90    pub columns: ::prost::alloc::vec::Vec<ColumnDesc>,
91    /// TODO: may refactor primary key representations
92    #[prost(message, repeated, tag = "3")]
93    pub pk: ::prost::alloc::vec::Vec<super::common::ColumnOrder>,
94    #[prost(uint32, repeated, tag = "4")]
95    pub dist_key_in_pk_indices: ::prost::alloc::vec::Vec<u32>,
96    #[prost(uint32, repeated, tag = "6")]
97    pub value_indices: ::prost::alloc::vec::Vec<u32>,
98    #[prost(uint32, tag = "7")]
99    pub read_prefix_len_hint: u32,
100    /// Whether the table is versioned. If `true`, column-aware row encoding will
101    /// be used to be compatible with schema changes.
102    #[prost(bool, tag = "8")]
103    pub versioned: bool,
104    #[prost(uint32, repeated, tag = "9")]
105    pub stream_key: ::prost::alloc::vec::Vec<u32>,
106    #[prost(uint32, optional, tag = "10")]
107    pub vnode_col_idx_in_pk: ::core::option::Option<u32>,
108    #[prost(uint32, optional, tag = "11")]
109    pub retention_seconds: ::core::option::Option<u32>,
110    /// Total vnode count of the table.
111    ///
112    /// Can be unset if the table is created in older versions where variable vnode count is not
113    /// supported, in which case a default value of 256 (or 1 for singleton) should be used.
114    /// Use `VnodeCountCompat::vnode_count` to access it.
115    #[prost(uint32, optional, tag = "12")]
116    pub maybe_vnode_count: ::core::option::Option<u32>,
117}
118#[derive(prost_helpers::AnyPB)]
119#[derive(Clone, Copy, PartialEq, ::prost::Message)]
120pub struct AsOf {
121    #[prost(oneof = "as_of::AsOfType", tags = "1, 2, 3")]
122    pub as_of_type: ::core::option::Option<as_of::AsOfType>,
123}
124/// Nested message and enum types in `AsOf`.
125pub mod as_of {
126    #[derive(prost_helpers::AnyPB)]
127    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
128    pub struct ProcessTime {}
129    #[derive(prost_helpers::AnyPB)]
130    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
131    pub struct Timestamp {
132        #[prost(int64, tag = "1")]
133        pub timestamp: i64,
134    }
135    #[derive(prost_helpers::AnyPB)]
136    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
137    pub struct Version {
138        #[prost(int64, tag = "1")]
139        pub version: i64,
140    }
141    #[derive(prost_helpers::AnyPB)]
142    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
143    pub enum AsOfType {
144        #[prost(message, tag = "1")]
145        ProcessTime(ProcessTime),
146        #[prost(message, tag = "2")]
147        Timestamp(Timestamp),
148        #[prost(message, tag = "3")]
149        Version(Version),
150    }
151}
152/// Represents a table in external database for CDC scenario
153#[derive(prost_helpers::AnyPB)]
154#[derive(Eq, Hash)]
155#[derive(Clone, PartialEq, ::prost::Message)]
156pub struct ExternalTableDesc {
157    #[prost(uint32, tag = "1")]
158    pub table_id: u32,
159    #[prost(message, repeated, tag = "2")]
160    pub columns: ::prost::alloc::vec::Vec<ColumnDesc>,
161    /// TODO: may refactor primary key representations
162    #[prost(message, repeated, tag = "3")]
163    pub pk: ::prost::alloc::vec::Vec<super::common::ColumnOrder>,
164    #[prost(string, tag = "4")]
165    pub table_name: ::prost::alloc::string::String,
166    #[prost(uint32, repeated, tag = "5")]
167    pub stream_key: ::prost::alloc::vec::Vec<u32>,
168    #[prost(btree_map = "string, string", tag = "6")]
169    pub connect_properties: ::prost::alloc::collections::BTreeMap<
170        ::prost::alloc::string::String,
171        ::prost::alloc::string::String,
172    >,
173    /// upstream cdc source job id
174    #[prost(uint32, tag = "7")]
175    pub source_id: u32,
176    #[prost(btree_map = "string, message", tag = "8")]
177    pub secret_refs: ::prost::alloc::collections::BTreeMap<
178        ::prost::alloc::string::String,
179        super::secret::SecretRef,
180    >,
181}
182#[derive(prost_helpers::AnyPB)]
183#[derive(Eq, Hash)]
184#[derive(Clone, Copy, PartialEq, ::prost::Message)]
185pub struct AsOfJoinDesc {
186    /// The index of the right side's as of column.
187    #[prost(uint32, tag = "1")]
188    pub right_idx: u32,
189    /// The index of the left side's as of column.
190    #[prost(uint32, tag = "2")]
191    pub left_idx: u32,
192    /// The type of the inequality.
193    #[prost(enumeration = "AsOfJoinInequalityType", tag = "3")]
194    pub inequality_type: i32,
195}
196#[derive(prost_helpers::AnyPB)]
197#[derive(Clone, PartialEq, ::prost::Message)]
198pub struct IndexAndExpr {
199    #[prost(uint32, tag = "1")]
200    pub index: u32,
201    #[prost(message, optional, tag = "2")]
202    pub expr: ::core::option::Option<super::expr::ExprNode>,
203}
204#[derive(prost_helpers::AnyPB)]
205#[derive(Clone, PartialEq, ::prost::Message)]
206pub struct DefaultColumns {
207    #[prost(message, repeated, tag = "1")]
208    pub default_columns: ::prost::alloc::vec::Vec<IndexAndExpr>,
209}
210/// The cardinality of the output rows of a plan node. Bounds are inclusive.
211#[derive(prost_helpers::AnyPB)]
212#[derive(Eq, Hash)]
213#[derive(Clone, Copy, PartialEq, ::prost::Message)]
214pub struct Cardinality {
215    #[prost(uint64, tag = "1")]
216    pub lo: u64,
217    /// Unbounded if not set.
218    #[prost(uint64, optional, tag = "2")]
219    pub hi: ::core::option::Option<u64>,
220}
221/// Provide statement-local context, e.g. session info like time zone, for execution.
222#[derive(prost_helpers::AnyPB)]
223#[derive(Clone, PartialEq, ::prost::Message)]
224pub struct ExprContext {
225    #[prost(string, tag = "1")]
226    pub time_zone: ::prost::alloc::string::String,
227    #[prost(bool, tag = "2")]
228    pub strict_mode: bool,
229}
230#[derive(prost_helpers::AnyPB)]
231#[derive(Eq, Hash)]
232#[derive(Clone, Copy, PartialEq, ::prost::Message)]
233pub struct AdditionalColumnKey {}
234#[derive(prost_helpers::AnyPB)]
235#[derive(Eq, Hash)]
236#[derive(Clone, Copy, PartialEq, ::prost::Message)]
237pub struct AdditionalColumnTimestamp {}
238#[derive(prost_helpers::AnyPB)]
239#[derive(Eq, Hash)]
240#[derive(Clone, Copy, PartialEq, ::prost::Message)]
241pub struct AdditionalColumnPartition {}
242#[derive(prost_helpers::AnyPB)]
243#[derive(Eq, Hash)]
244#[derive(Clone, Copy, PartialEq, ::prost::Message)]
245pub struct AdditionalColumnOffset {}
246#[derive(prost_helpers::AnyPB)]
247#[derive(Eq, Hash)]
248#[derive(Clone, Copy, PartialEq, ::prost::Message)]
249pub struct AdditionalColumnFilename {}
250#[derive(prost_helpers::AnyPB)]
251#[derive(Eq, Hash)]
252#[derive(Clone, PartialEq, ::prost::Message)]
253pub struct AdditionalColumnHeader {
254    #[prost(string, tag = "1")]
255    pub inner_field: ::prost::alloc::string::String,
256    #[prost(message, optional, tag = "2")]
257    pub data_type: ::core::option::Option<super::data::DataType>,
258}
259/// metadata column for cdc table
260#[derive(prost_helpers::AnyPB)]
261#[derive(Eq, Hash)]
262#[derive(Clone, Copy, PartialEq, ::prost::Message)]
263pub struct AdditionalDatabaseName {}
264#[derive(prost_helpers::AnyPB)]
265#[derive(Eq, Hash)]
266#[derive(Clone, Copy, PartialEq, ::prost::Message)]
267pub struct AdditionalSchemaName {}
268#[derive(prost_helpers::AnyPB)]
269#[derive(Eq, Hash)]
270#[derive(Clone, Copy, PartialEq, ::prost::Message)]
271pub struct AdditionalTableName {}
272#[derive(prost_helpers::AnyPB)]
273#[derive(Eq, Hash)]
274#[derive(Clone, Copy, PartialEq, ::prost::Message)]
275pub struct AdditionalCollectionName {}
276#[derive(prost_helpers::AnyPB)]
277#[derive(Eq, Hash)]
278#[derive(Clone, Copy, PartialEq, ::prost::Message)]
279pub struct AdditionalColumnPayload {}
280/// this type means we read all headers as a whole
281#[derive(prost_helpers::AnyPB)]
282#[derive(Eq, Hash)]
283#[derive(Clone, Copy, PartialEq, ::prost::Message)]
284pub struct AdditionalColumnHeaders {}
285#[derive(prost_helpers::AnyPB)]
286#[derive(Eq, Hash)]
287#[derive(Clone, Copy, PartialEq, ::prost::Message)]
288pub struct AdditionalSubject {}
289#[derive(prost_helpers::AnyPB)]
290#[derive(Eq, Hash)]
291#[derive(Clone, PartialEq, ::prost::Message)]
292pub struct AdditionalColumn {
293    #[prost(
294        oneof = "additional_column::ColumnType",
295        tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13"
296    )]
297    pub column_type: ::core::option::Option<additional_column::ColumnType>,
298}
299/// Nested message and enum types in `AdditionalColumn`.
300pub mod additional_column {
301    #[derive(prost_helpers::AnyPB)]
302    #[derive(Eq, Hash)]
303    #[derive(Clone, PartialEq, ::prost::Oneof)]
304    pub enum ColumnType {
305        #[prost(message, tag = "1")]
306        Key(super::AdditionalColumnKey),
307        #[prost(message, tag = "2")]
308        Timestamp(super::AdditionalColumnTimestamp),
309        #[prost(message, tag = "3")]
310        Partition(super::AdditionalColumnPartition),
311        #[prost(message, tag = "4")]
312        Offset(super::AdditionalColumnOffset),
313        #[prost(message, tag = "5")]
314        HeaderInner(super::AdditionalColumnHeader),
315        #[prost(message, tag = "6")]
316        Filename(super::AdditionalColumnFilename),
317        #[prost(message, tag = "7")]
318        Headers(super::AdditionalColumnHeaders),
319        #[prost(message, tag = "8")]
320        DatabaseName(super::AdditionalDatabaseName),
321        #[prost(message, tag = "9")]
322        SchemaName(super::AdditionalSchemaName),
323        #[prost(message, tag = "10")]
324        TableName(super::AdditionalTableName),
325        #[prost(message, tag = "11")]
326        CollectionName(super::AdditionalCollectionName),
327        #[prost(message, tag = "12")]
328        Payload(super::AdditionalColumnPayload),
329        #[prost(message, tag = "13")]
330        Subject(super::AdditionalSubject),
331    }
332}
333#[derive(prost_helpers::AnyPB)]
334#[derive(prost_helpers::Version)]
335#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
336#[repr(i32)]
337pub enum ColumnDescVersion {
338    Unspecified = 0,
339    /// Introduced in <https://github.com/risingwavelabs/risingwave/pull/13707#discussion_r1429947537,>
340    /// in case DEFAULT_KEY_COLUMN_NAME changes
341    Pr13707 = 1,
342}
343impl ColumnDescVersion {
344    /// String value of the enum field names used in the ProtoBuf definition.
345    ///
346    /// The values are not transformed in any way and thus are considered stable
347    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
348    pub fn as_str_name(&self) -> &'static str {
349        match self {
350            Self::Unspecified => "COLUMN_DESC_VERSION_UNSPECIFIED",
351            Self::Pr13707 => "COLUMN_DESC_VERSION_PR_13707",
352        }
353    }
354    /// Creates an enum from field names used in the ProtoBuf definition.
355    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
356        match value {
357            "COLUMN_DESC_VERSION_UNSPECIFIED" => Some(Self::Unspecified),
358            "COLUMN_DESC_VERSION_PR_13707" => Some(Self::Pr13707),
359            _ => None,
360        }
361    }
362}
363#[derive(prost_helpers::AnyPB)]
364#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
365#[repr(i32)]
366pub enum JoinType {
367    /// Note that it comes from Calcite's JoinRelType.
368    /// DO NOT HAVE direction for SEMI and ANTI now.
369    Unspecified = 0,
370    Inner = 1,
371    LeftOuter = 2,
372    RightOuter = 3,
373    FullOuter = 4,
374    LeftSemi = 5,
375    LeftAnti = 6,
376    RightSemi = 7,
377    RightAnti = 8,
378    AsofInner = 9,
379    AsofLeftOuter = 10,
380}
381impl JoinType {
382    /// String value of the enum field names used in the ProtoBuf definition.
383    ///
384    /// The values are not transformed in any way and thus are considered stable
385    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
386    pub fn as_str_name(&self) -> &'static str {
387        match self {
388            Self::Unspecified => "JOIN_TYPE_UNSPECIFIED",
389            Self::Inner => "JOIN_TYPE_INNER",
390            Self::LeftOuter => "JOIN_TYPE_LEFT_OUTER",
391            Self::RightOuter => "JOIN_TYPE_RIGHT_OUTER",
392            Self::FullOuter => "JOIN_TYPE_FULL_OUTER",
393            Self::LeftSemi => "JOIN_TYPE_LEFT_SEMI",
394            Self::LeftAnti => "JOIN_TYPE_LEFT_ANTI",
395            Self::RightSemi => "JOIN_TYPE_RIGHT_SEMI",
396            Self::RightAnti => "JOIN_TYPE_RIGHT_ANTI",
397            Self::AsofInner => "JOIN_TYPE_ASOF_INNER",
398            Self::AsofLeftOuter => "JOIN_TYPE_ASOF_LEFT_OUTER",
399        }
400    }
401    /// Creates an enum from field names used in the ProtoBuf definition.
402    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
403        match value {
404            "JOIN_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
405            "JOIN_TYPE_INNER" => Some(Self::Inner),
406            "JOIN_TYPE_LEFT_OUTER" => Some(Self::LeftOuter),
407            "JOIN_TYPE_RIGHT_OUTER" => Some(Self::RightOuter),
408            "JOIN_TYPE_FULL_OUTER" => Some(Self::FullOuter),
409            "JOIN_TYPE_LEFT_SEMI" => Some(Self::LeftSemi),
410            "JOIN_TYPE_LEFT_ANTI" => Some(Self::LeftAnti),
411            "JOIN_TYPE_RIGHT_SEMI" => Some(Self::RightSemi),
412            "JOIN_TYPE_RIGHT_ANTI" => Some(Self::RightAnti),
413            "JOIN_TYPE_ASOF_INNER" => Some(Self::AsofInner),
414            "JOIN_TYPE_ASOF_LEFT_OUTER" => Some(Self::AsofLeftOuter),
415            _ => None,
416        }
417    }
418}
419#[derive(prost_helpers::AnyPB)]
420#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
421#[repr(i32)]
422pub enum AsOfJoinType {
423    Unspecified = 0,
424    Inner = 1,
425    LeftOuter = 2,
426}
427impl AsOfJoinType {
428    /// String value of the enum field names used in the ProtoBuf definition.
429    ///
430    /// The values are not transformed in any way and thus are considered stable
431    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
432    pub fn as_str_name(&self) -> &'static str {
433        match self {
434            Self::Unspecified => "AS_OF_JOIN_TYPE_UNSPECIFIED",
435            Self::Inner => "AS_OF_JOIN_TYPE_INNER",
436            Self::LeftOuter => "AS_OF_JOIN_TYPE_LEFT_OUTER",
437        }
438    }
439    /// Creates an enum from field names used in the ProtoBuf definition.
440    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
441        match value {
442            "AS_OF_JOIN_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
443            "AS_OF_JOIN_TYPE_INNER" => Some(Self::Inner),
444            "AS_OF_JOIN_TYPE_LEFT_OUTER" => Some(Self::LeftOuter),
445            _ => None,
446        }
447    }
448}
449#[derive(prost_helpers::AnyPB)]
450#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
451#[repr(i32)]
452pub enum AsOfJoinInequalityType {
453    AsOfInequalityTypeUnspecified = 0,
454    AsOfInequalityTypeGt = 1,
455    AsOfInequalityTypeGe = 2,
456    AsOfInequalityTypeLt = 3,
457    AsOfInequalityTypeLe = 4,
458}
459impl AsOfJoinInequalityType {
460    /// String value of the enum field names used in the ProtoBuf definition.
461    ///
462    /// The values are not transformed in any way and thus are considered stable
463    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
464    pub fn as_str_name(&self) -> &'static str {
465        match self {
466            Self::AsOfInequalityTypeUnspecified => "AS_OF_INEQUALITY_TYPE_UNSPECIFIED",
467            Self::AsOfInequalityTypeGt => "AS_OF_INEQUALITY_TYPE_GT",
468            Self::AsOfInequalityTypeGe => "AS_OF_INEQUALITY_TYPE_GE",
469            Self::AsOfInequalityTypeLt => "AS_OF_INEQUALITY_TYPE_LT",
470            Self::AsOfInequalityTypeLe => "AS_OF_INEQUALITY_TYPE_LE",
471        }
472    }
473    /// Creates an enum from field names used in the ProtoBuf definition.
474    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
475        match value {
476            "AS_OF_INEQUALITY_TYPE_UNSPECIFIED" => {
477                Some(Self::AsOfInequalityTypeUnspecified)
478            }
479            "AS_OF_INEQUALITY_TYPE_GT" => Some(Self::AsOfInequalityTypeGt),
480            "AS_OF_INEQUALITY_TYPE_GE" => Some(Self::AsOfInequalityTypeGe),
481            "AS_OF_INEQUALITY_TYPE_LT" => Some(Self::AsOfInequalityTypeLt),
482            "AS_OF_INEQUALITY_TYPE_LE" => Some(Self::AsOfInequalityTypeLe),
483            _ => None,
484        }
485    }
486}
487/// <https://github.com/tokio-rs/prost/issues/80>
488#[derive(prost_helpers::AnyPB)]
489#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
490#[repr(i32)]
491pub enum FormatType {
492    Unspecified = 0,
493    Native = 1,
494    Debezium = 2,
495    DebeziumMongo = 3,
496    Maxwell = 4,
497    Canal = 5,
498    Upsert = 6,
499    Plain = 7,
500    None = 8,
501}
502impl FormatType {
503    /// String value of the enum field names used in the ProtoBuf definition.
504    ///
505    /// The values are not transformed in any way and thus are considered stable
506    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
507    pub fn as_str_name(&self) -> &'static str {
508        match self {
509            Self::Unspecified => "FORMAT_TYPE_UNSPECIFIED",
510            Self::Native => "FORMAT_TYPE_NATIVE",
511            Self::Debezium => "FORMAT_TYPE_DEBEZIUM",
512            Self::DebeziumMongo => "FORMAT_TYPE_DEBEZIUM_MONGO",
513            Self::Maxwell => "FORMAT_TYPE_MAXWELL",
514            Self::Canal => "FORMAT_TYPE_CANAL",
515            Self::Upsert => "FORMAT_TYPE_UPSERT",
516            Self::Plain => "FORMAT_TYPE_PLAIN",
517            Self::None => "FORMAT_TYPE_NONE",
518        }
519    }
520    /// Creates an enum from field names used in the ProtoBuf definition.
521    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
522        match value {
523            "FORMAT_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
524            "FORMAT_TYPE_NATIVE" => Some(Self::Native),
525            "FORMAT_TYPE_DEBEZIUM" => Some(Self::Debezium),
526            "FORMAT_TYPE_DEBEZIUM_MONGO" => Some(Self::DebeziumMongo),
527            "FORMAT_TYPE_MAXWELL" => Some(Self::Maxwell),
528            "FORMAT_TYPE_CANAL" => Some(Self::Canal),
529            "FORMAT_TYPE_UPSERT" => Some(Self::Upsert),
530            "FORMAT_TYPE_PLAIN" => Some(Self::Plain),
531            "FORMAT_TYPE_NONE" => Some(Self::None),
532            _ => None,
533        }
534    }
535}
536#[derive(prost_helpers::AnyPB)]
537#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
538#[repr(i32)]
539pub enum EncodeType {
540    Unspecified = 0,
541    Native = 1,
542    Avro = 2,
543    Csv = 3,
544    Protobuf = 4,
545    Json = 5,
546    Bytes = 6,
547    Template = 7,
548    None = 8,
549    Text = 9,
550    Parquet = 10,
551}
552impl EncodeType {
553    /// String value of the enum field names used in the ProtoBuf definition.
554    ///
555    /// The values are not transformed in any way and thus are considered stable
556    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
557    pub fn as_str_name(&self) -> &'static str {
558        match self {
559            Self::Unspecified => "ENCODE_TYPE_UNSPECIFIED",
560            Self::Native => "ENCODE_TYPE_NATIVE",
561            Self::Avro => "ENCODE_TYPE_AVRO",
562            Self::Csv => "ENCODE_TYPE_CSV",
563            Self::Protobuf => "ENCODE_TYPE_PROTOBUF",
564            Self::Json => "ENCODE_TYPE_JSON",
565            Self::Bytes => "ENCODE_TYPE_BYTES",
566            Self::Template => "ENCODE_TYPE_TEMPLATE",
567            Self::None => "ENCODE_TYPE_NONE",
568            Self::Text => "ENCODE_TYPE_TEXT",
569            Self::Parquet => "ENCODE_TYPE_PARQUET",
570        }
571    }
572    /// Creates an enum from field names used in the ProtoBuf definition.
573    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
574        match value {
575            "ENCODE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
576            "ENCODE_TYPE_NATIVE" => Some(Self::Native),
577            "ENCODE_TYPE_AVRO" => Some(Self::Avro),
578            "ENCODE_TYPE_CSV" => Some(Self::Csv),
579            "ENCODE_TYPE_PROTOBUF" => Some(Self::Protobuf),
580            "ENCODE_TYPE_JSON" => Some(Self::Json),
581            "ENCODE_TYPE_BYTES" => Some(Self::Bytes),
582            "ENCODE_TYPE_TEMPLATE" => Some(Self::Template),
583            "ENCODE_TYPE_NONE" => Some(Self::None),
584            "ENCODE_TYPE_TEXT" => Some(Self::Text),
585            "ENCODE_TYPE_PARQUET" => Some(Self::Parquet),
586            _ => None,
587        }
588    }
589}
590#[derive(prost_helpers::AnyPB)]
591#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
592#[repr(i32)]
593pub enum RowFormatType {
594    RowUnspecified = 0,
595    Json = 1,
596    Protobuf = 2,
597    DebeziumJson = 3,
598    Avro = 4,
599    Maxwell = 5,
600    CanalJson = 6,
601    Csv = 7,
602    Native = 8,
603    DebeziumAvro = 9,
604    UpsertJson = 10,
605    UpsertAvro = 11,
606    DebeziumMongoJson = 12,
607    Bytes = 13,
608}
609impl RowFormatType {
610    /// String value of the enum field names used in the ProtoBuf definition.
611    ///
612    /// The values are not transformed in any way and thus are considered stable
613    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
614    pub fn as_str_name(&self) -> &'static str {
615        match self {
616            Self::RowUnspecified => "ROW_UNSPECIFIED",
617            Self::Json => "JSON",
618            Self::Protobuf => "PROTOBUF",
619            Self::DebeziumJson => "DEBEZIUM_JSON",
620            Self::Avro => "AVRO",
621            Self::Maxwell => "MAXWELL",
622            Self::CanalJson => "CANAL_JSON",
623            Self::Csv => "CSV",
624            Self::Native => "NATIVE",
625            Self::DebeziumAvro => "DEBEZIUM_AVRO",
626            Self::UpsertJson => "UPSERT_JSON",
627            Self::UpsertAvro => "UPSERT_AVRO",
628            Self::DebeziumMongoJson => "DEBEZIUM_MONGO_JSON",
629            Self::Bytes => "BYTES",
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            "ROW_UNSPECIFIED" => Some(Self::RowUnspecified),
636            "JSON" => Some(Self::Json),
637            "PROTOBUF" => Some(Self::Protobuf),
638            "DEBEZIUM_JSON" => Some(Self::DebeziumJson),
639            "AVRO" => Some(Self::Avro),
640            "MAXWELL" => Some(Self::Maxwell),
641            "CANAL_JSON" => Some(Self::CanalJson),
642            "CSV" => Some(Self::Csv),
643            "NATIVE" => Some(Self::Native),
644            "DEBEZIUM_AVRO" => Some(Self::DebeziumAvro),
645            "UPSERT_JSON" => Some(Self::UpsertJson),
646            "UPSERT_AVRO" => Some(Self::UpsertAvro),
647            "DEBEZIUM_MONGO_JSON" => Some(Self::DebeziumMongoJson),
648            "BYTES" => Some(Self::Bytes),
649            _ => None,
650        }
651    }
652}
653#[derive(prost_helpers::AnyPB)]
654#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
655#[repr(i32)]
656pub enum AdditionalColumnType {
657    Unspecified = 0,
658    Key = 1,
659    Timestamp = 2,
660    Partition = 3,
661    Offset = 4,
662    Header = 5,
663    Filename = 6,
664    Normal = 7,
665    Payload = 8,
666}
667impl AdditionalColumnType {
668    /// String value of the enum field names used in the ProtoBuf definition.
669    ///
670    /// The values are not transformed in any way and thus are considered stable
671    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
672    pub fn as_str_name(&self) -> &'static str {
673        match self {
674            Self::Unspecified => "ADDITIONAL_COLUMN_TYPE_UNSPECIFIED",
675            Self::Key => "ADDITIONAL_COLUMN_TYPE_KEY",
676            Self::Timestamp => "ADDITIONAL_COLUMN_TYPE_TIMESTAMP",
677            Self::Partition => "ADDITIONAL_COLUMN_TYPE_PARTITION",
678            Self::Offset => "ADDITIONAL_COLUMN_TYPE_OFFSET",
679            Self::Header => "ADDITIONAL_COLUMN_TYPE_HEADER",
680            Self::Filename => "ADDITIONAL_COLUMN_TYPE_FILENAME",
681            Self::Normal => "ADDITIONAL_COLUMN_TYPE_NORMAL",
682            Self::Payload => "ADDITIONAL_COLUMN_TYPE_PAYLOAD",
683        }
684    }
685    /// Creates an enum from field names used in the ProtoBuf definition.
686    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
687        match value {
688            "ADDITIONAL_COLUMN_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
689            "ADDITIONAL_COLUMN_TYPE_KEY" => Some(Self::Key),
690            "ADDITIONAL_COLUMN_TYPE_TIMESTAMP" => Some(Self::Timestamp),
691            "ADDITIONAL_COLUMN_TYPE_PARTITION" => Some(Self::Partition),
692            "ADDITIONAL_COLUMN_TYPE_OFFSET" => Some(Self::Offset),
693            "ADDITIONAL_COLUMN_TYPE_HEADER" => Some(Self::Header),
694            "ADDITIONAL_COLUMN_TYPE_FILENAME" => Some(Self::Filename),
695            "ADDITIONAL_COLUMN_TYPE_NORMAL" => Some(Self::Normal),
696            "ADDITIONAL_COLUMN_TYPE_PAYLOAD" => Some(Self::Payload),
697            _ => None,
698        }
699    }
700}
risingwave_pb/plan_common.rs

risingwave_pb/
plan_common.rs
