datafusion_proto_models/generated/
datafusion_proto_common.rs

1// This file is @generated by prost-build.
2#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
3pub struct ColumnRelation {
4    #[prost(string, tag = "1")]
5    pub relation: ::prost::alloc::string::String,
6}
7#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
8pub struct Column {
9    #[prost(string, tag = "1")]
10    pub name: ::prost::alloc::string::String,
11    #[prost(message, optional, tag = "2")]
12    pub relation: ::core::option::Option<ColumnRelation>,
13}
14#[derive(Clone, PartialEq, ::prost::Message)]
15pub struct DfField {
16    #[prost(message, optional, tag = "1")]
17    pub field: ::core::option::Option<Field>,
18    #[prost(message, optional, tag = "2")]
19    pub qualifier: ::core::option::Option<ColumnRelation>,
20}
21#[derive(Clone, PartialEq, ::prost::Message)]
22pub struct DfSchema {
23    #[prost(message, repeated, tag = "1")]
24    pub columns: ::prost::alloc::vec::Vec<DfField>,
25    #[prost(map = "string, string", tag = "2")]
26    pub metadata: ::std::collections::HashMap<
27        ::prost::alloc::string::String,
28        ::prost::alloc::string::String,
29    >,
30}
31#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
32pub struct CsvFormat {
33    #[prost(message, optional, tag = "5")]
34    pub options: ::core::option::Option<CsvOptions>,
35}
36#[derive(Clone, PartialEq, ::prost::Message)]
37pub struct ParquetFormat {
38    #[prost(message, optional, tag = "2")]
39    pub options: ::core::option::Option<TableParquetOptions>,
40}
41#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
42pub struct AvroFormat {}
43#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
44pub struct NdJsonFormat {
45    #[prost(message, optional, tag = "1")]
46    pub options: ::core::option::Option<JsonOptions>,
47}
48#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
49pub struct ArrowFormat {}
50#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
51pub struct PrimaryKeyConstraint {
52    #[prost(uint64, repeated, tag = "1")]
53    pub indices: ::prost::alloc::vec::Vec<u64>,
54}
55#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
56pub struct UniqueConstraint {
57    #[prost(uint64, repeated, tag = "1")]
58    pub indices: ::prost::alloc::vec::Vec<u64>,
59}
60#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
61pub struct Constraint {
62    #[prost(oneof = "constraint::ConstraintMode", tags = "1, 2")]
63    pub constraint_mode: ::core::option::Option<constraint::ConstraintMode>,
64}
65/// Nested message and enum types in `Constraint`.
66pub mod constraint {
67    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
68    pub enum ConstraintMode {
69        #[prost(message, tag = "1")]
70        PrimaryKey(super::PrimaryKeyConstraint),
71        #[prost(message, tag = "2")]
72        Unique(super::UniqueConstraint),
73    }
74}
75#[derive(Clone, PartialEq, ::prost::Message)]
76pub struct Constraints {
77    #[prost(message, repeated, tag = "1")]
78    pub constraints: ::prost::alloc::vec::Vec<Constraint>,
79}
80#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
81pub struct AvroOptions {}
82#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
83pub struct ArrowOptions {}
84#[derive(Clone, PartialEq, ::prost::Message)]
85pub struct Schema {
86    #[prost(message, repeated, tag = "1")]
87    pub columns: ::prost::alloc::vec::Vec<Field>,
88    #[prost(map = "string, string", tag = "2")]
89    pub metadata: ::std::collections::HashMap<
90        ::prost::alloc::string::String,
91        ::prost::alloc::string::String,
92    >,
93}
94#[derive(Clone, PartialEq, ::prost::Message)]
95pub struct Field {
96    /// name of the field
97    #[prost(string, tag = "1")]
98    pub name: ::prost::alloc::string::String,
99    #[prost(message, optional, boxed, tag = "2")]
100    pub arrow_type: ::core::option::Option<::prost::alloc::boxed::Box<ArrowType>>,
101    #[prost(bool, tag = "3")]
102    pub nullable: bool,
103    /// for complex data types like structs, unions
104    #[prost(message, repeated, tag = "4")]
105    pub children: ::prost::alloc::vec::Vec<Field>,
106    #[prost(map = "string, string", tag = "5")]
107    pub metadata: ::std::collections::HashMap<
108        ::prost::alloc::string::String,
109        ::prost::alloc::string::String,
110    >,
111}
112#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
113pub struct Timestamp {
114    #[prost(enumeration = "TimeUnit", tag = "1")]
115    pub time_unit: i32,
116    #[prost(string, tag = "2")]
117    pub timezone: ::prost::alloc::string::String,
118}
119#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
120pub struct Decimal32Type {
121    #[prost(uint32, tag = "3")]
122    pub precision: u32,
123    #[prost(int32, tag = "4")]
124    pub scale: i32,
125}
126#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
127pub struct Decimal64Type {
128    #[prost(uint32, tag = "3")]
129    pub precision: u32,
130    #[prost(int32, tag = "4")]
131    pub scale: i32,
132}
133#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
134pub struct Decimal128Type {
135    #[prost(uint32, tag = "3")]
136    pub precision: u32,
137    #[prost(int32, tag = "4")]
138    pub scale: i32,
139}
140#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
141pub struct Decimal256Type {
142    #[prost(uint32, tag = "3")]
143    pub precision: u32,
144    #[prost(int32, tag = "4")]
145    pub scale: i32,
146}
147#[derive(Clone, PartialEq, ::prost::Message)]
148pub struct List {
149    #[prost(message, optional, boxed, tag = "1")]
150    pub field_type: ::core::option::Option<::prost::alloc::boxed::Box<Field>>,
151}
152#[derive(Clone, PartialEq, ::prost::Message)]
153pub struct FixedSizeList {
154    #[prost(message, optional, boxed, tag = "1")]
155    pub field_type: ::core::option::Option<::prost::alloc::boxed::Box<Field>>,
156    #[prost(int32, tag = "2")]
157    pub list_size: i32,
158}
159#[derive(Clone, PartialEq, ::prost::Message)]
160pub struct Dictionary {
161    #[prost(message, optional, boxed, tag = "1")]
162    pub key: ::core::option::Option<::prost::alloc::boxed::Box<ArrowType>>,
163    #[prost(message, optional, boxed, tag = "2")]
164    pub value: ::core::option::Option<::prost::alloc::boxed::Box<ArrowType>>,
165}
166#[derive(Clone, PartialEq, ::prost::Message)]
167pub struct Struct {
168    #[prost(message, repeated, tag = "1")]
169    pub sub_field_types: ::prost::alloc::vec::Vec<Field>,
170}
171#[derive(Clone, PartialEq, ::prost::Message)]
172pub struct Map {
173    #[prost(message, optional, boxed, tag = "1")]
174    pub field_type: ::core::option::Option<::prost::alloc::boxed::Box<Field>>,
175    #[prost(bool, tag = "2")]
176    pub keys_sorted: bool,
177}
178#[derive(Clone, PartialEq, ::prost::Message)]
179pub struct RunEndEncoded {
180    #[prost(message, optional, boxed, tag = "1")]
181    pub run_ends_field: ::core::option::Option<::prost::alloc::boxed::Box<Field>>,
182    #[prost(message, optional, boxed, tag = "2")]
183    pub values_field: ::core::option::Option<::prost::alloc::boxed::Box<Field>>,
184}
185#[derive(Clone, PartialEq, ::prost::Message)]
186pub struct Union {
187    #[prost(message, repeated, tag = "1")]
188    pub union_types: ::prost::alloc::vec::Vec<Field>,
189    #[prost(enumeration = "UnionMode", tag = "2")]
190    pub union_mode: i32,
191    #[prost(int32, repeated, tag = "3")]
192    pub type_ids: ::prost::alloc::vec::Vec<i32>,
193}
194/// Used for List/FixedSizeList/LargeList/ListView/LargeListView/Struct/Map
195#[derive(Clone, PartialEq, ::prost::Message)]
196pub struct ScalarNestedValue {
197    #[prost(bytes = "vec", tag = "1")]
198    pub ipc_message: ::prost::alloc::vec::Vec<u8>,
199    #[prost(bytes = "vec", tag = "2")]
200    pub arrow_data: ::prost::alloc::vec::Vec<u8>,
201    #[prost(message, optional, tag = "3")]
202    pub schema: ::core::option::Option<Schema>,
203    #[prost(message, repeated, tag = "4")]
204    pub dictionaries: ::prost::alloc::vec::Vec<scalar_nested_value::Dictionary>,
205}
206/// Nested message and enum types in `ScalarNestedValue`.
207pub mod scalar_nested_value {
208    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
209    pub struct Dictionary {
210        #[prost(bytes = "vec", tag = "1")]
211        pub ipc_message: ::prost::alloc::vec::Vec<u8>,
212        #[prost(bytes = "vec", tag = "2")]
213        pub arrow_data: ::prost::alloc::vec::Vec<u8>,
214    }
215}
216#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
217pub struct ScalarTime32Value {
218    #[prost(oneof = "scalar_time32_value::Value", tags = "1, 2")]
219    pub value: ::core::option::Option<scalar_time32_value::Value>,
220}
221/// Nested message and enum types in `ScalarTime32Value`.
222pub mod scalar_time32_value {
223    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Oneof)]
224    pub enum Value {
225        #[prost(int32, tag = "1")]
226        Time32SecondValue(i32),
227        #[prost(int32, tag = "2")]
228        Time32MillisecondValue(i32),
229    }
230}
231#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
232pub struct ScalarTime64Value {
233    #[prost(oneof = "scalar_time64_value::Value", tags = "1, 2")]
234    pub value: ::core::option::Option<scalar_time64_value::Value>,
235}
236/// Nested message and enum types in `ScalarTime64Value`.
237pub mod scalar_time64_value {
238    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Oneof)]
239    pub enum Value {
240        #[prost(int64, tag = "1")]
241        Time64MicrosecondValue(i64),
242        #[prost(int64, tag = "2")]
243        Time64NanosecondValue(i64),
244    }
245}
246#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
247pub struct ScalarTimestampValue {
248    #[prost(string, tag = "5")]
249    pub timezone: ::prost::alloc::string::String,
250    #[prost(oneof = "scalar_timestamp_value::Value", tags = "1, 2, 3, 4")]
251    pub value: ::core::option::Option<scalar_timestamp_value::Value>,
252}
253/// Nested message and enum types in `ScalarTimestampValue`.
254pub mod scalar_timestamp_value {
255    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Oneof)]
256    pub enum Value {
257        #[prost(int64, tag = "1")]
258        TimeMicrosecondValue(i64),
259        #[prost(int64, tag = "2")]
260        TimeNanosecondValue(i64),
261        #[prost(int64, tag = "3")]
262        TimeSecondValue(i64),
263        #[prost(int64, tag = "4")]
264        TimeMillisecondValue(i64),
265    }
266}
267#[derive(Clone, PartialEq, ::prost::Message)]
268pub struct ScalarDictionaryValue {
269    #[prost(message, optional, tag = "1")]
270    pub index_type: ::core::option::Option<ArrowType>,
271    #[prost(message, optional, boxed, tag = "2")]
272    pub value: ::core::option::Option<::prost::alloc::boxed::Box<ScalarValue>>,
273}
274#[derive(Clone, PartialEq, ::prost::Message)]
275pub struct ScalarRunEndEncodedValue {
276    #[prost(message, optional, tag = "1")]
277    pub run_ends_field: ::core::option::Option<Field>,
278    #[prost(message, optional, tag = "2")]
279    pub values_field: ::core::option::Option<Field>,
280    #[prost(message, optional, boxed, tag = "3")]
281    pub value: ::core::option::Option<::prost::alloc::boxed::Box<ScalarValue>>,
282}
283#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
284pub struct IntervalDayTimeValue {
285    #[prost(int32, tag = "1")]
286    pub days: i32,
287    #[prost(int32, tag = "2")]
288    pub milliseconds: i32,
289}
290#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
291pub struct IntervalMonthDayNanoValue {
292    #[prost(int32, tag = "1")]
293    pub months: i32,
294    #[prost(int32, tag = "2")]
295    pub days: i32,
296    #[prost(int64, tag = "3")]
297    pub nanos: i64,
298}
299#[derive(Clone, PartialEq, ::prost::Message)]
300pub struct UnionField {
301    #[prost(int32, tag = "1")]
302    pub field_id: i32,
303    #[prost(message, optional, tag = "2")]
304    pub field: ::core::option::Option<Field>,
305}
306#[derive(Clone, PartialEq, ::prost::Message)]
307pub struct UnionValue {
308    /// Note that a null union value must have one or more fields, so we
309    /// encode a null UnionValue as one with value_id == 128
310    #[prost(int32, tag = "1")]
311    pub value_id: i32,
312    #[prost(message, optional, boxed, tag = "2")]
313    pub value: ::core::option::Option<::prost::alloc::boxed::Box<ScalarValue>>,
314    #[prost(message, repeated, tag = "3")]
315    pub fields: ::prost::alloc::vec::Vec<UnionField>,
316    #[prost(enumeration = "UnionMode", tag = "4")]
317    pub mode: i32,
318}
319#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
320pub struct ScalarFixedSizeBinary {
321    #[prost(bytes = "vec", tag = "1")]
322    pub values: ::prost::alloc::vec::Vec<u8>,
323    #[prost(int32, tag = "2")]
324    pub length: i32,
325}
326#[derive(Clone, PartialEq, ::prost::Message)]
327pub struct ScalarValue {
328    #[prost(
329        oneof = "scalar_value::Value",
330        tags = "33, 1, 2, 3, 23, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 46, 47, 32, 41, 43, 44, 20, 39, 21, 24, 35, 36, 37, 38, 26, 27, 28, 29, 22, 30, 25, 31, 34, 42, 45"
331    )]
332    pub value: ::core::option::Option<scalar_value::Value>,
333}
334/// Nested message and enum types in `ScalarValue`.
335pub mod scalar_value {
336    #[derive(Clone, PartialEq, ::prost::Oneof)]
337    pub enum Value {
338        /// was PrimitiveScalarType null_value = 19;
339        /// Null value of any type
340        #[prost(message, tag = "33")]
341        NullValue(super::ArrowType),
342        #[prost(bool, tag = "1")]
343        BoolValue(bool),
344        #[prost(string, tag = "2")]
345        Utf8Value(::prost::alloc::string::String),
346        #[prost(string, tag = "3")]
347        LargeUtf8Value(::prost::alloc::string::String),
348        #[prost(string, tag = "23")]
349        Utf8ViewValue(::prost::alloc::string::String),
350        #[prost(int32, tag = "4")]
351        Int8Value(i32),
352        #[prost(int32, tag = "5")]
353        Int16Value(i32),
354        #[prost(int32, tag = "6")]
355        Int32Value(i32),
356        #[prost(int64, tag = "7")]
357        Int64Value(i64),
358        #[prost(uint32, tag = "8")]
359        Uint8Value(u32),
360        #[prost(uint32, tag = "9")]
361        Uint16Value(u32),
362        #[prost(uint32, tag = "10")]
363        Uint32Value(u32),
364        #[prost(uint64, tag = "11")]
365        Uint64Value(u64),
366        #[prost(float, tag = "12")]
367        Float32Value(f32),
368        #[prost(double, tag = "13")]
369        Float64Value(f64),
370        /// Literal Date32 value always has a unit of day
371        #[prost(int32, tag = "14")]
372        Date32Value(i32),
373        #[prost(message, tag = "15")]
374        Time32Value(super::ScalarTime32Value),
375        #[prost(message, tag = "16")]
376        LargeListValue(super::ScalarNestedValue),
377        #[prost(message, tag = "17")]
378        ListValue(super::ScalarNestedValue),
379        #[prost(message, tag = "18")]
380        FixedSizeListValue(super::ScalarNestedValue),
381        #[prost(message, tag = "46")]
382        ListViewValue(super::ScalarNestedValue),
383        #[prost(message, tag = "47")]
384        LargeListViewValue(super::ScalarNestedValue),
385        #[prost(message, tag = "32")]
386        StructValue(super::ScalarNestedValue),
387        #[prost(message, tag = "41")]
388        MapValue(super::ScalarNestedValue),
389        #[prost(message, tag = "43")]
390        Decimal32Value(super::Decimal32),
391        #[prost(message, tag = "44")]
392        Decimal64Value(super::Decimal64),
393        #[prost(message, tag = "20")]
394        Decimal128Value(super::Decimal128),
395        #[prost(message, tag = "39")]
396        Decimal256Value(super::Decimal256),
397        #[prost(int64, tag = "21")]
398        Date64Value(i64),
399        #[prost(int32, tag = "24")]
400        IntervalYearmonthValue(i32),
401        #[prost(int64, tag = "35")]
402        DurationSecondValue(i64),
403        #[prost(int64, tag = "36")]
404        DurationMillisecondValue(i64),
405        #[prost(int64, tag = "37")]
406        DurationMicrosecondValue(i64),
407        #[prost(int64, tag = "38")]
408        DurationNanosecondValue(i64),
409        #[prost(message, tag = "26")]
410        TimestampValue(super::ScalarTimestampValue),
411        #[prost(message, tag = "27")]
412        DictionaryValue(::prost::alloc::boxed::Box<super::ScalarDictionaryValue>),
413        #[prost(bytes, tag = "28")]
414        BinaryValue(::prost::alloc::vec::Vec<u8>),
415        #[prost(bytes, tag = "29")]
416        LargeBinaryValue(::prost::alloc::vec::Vec<u8>),
417        #[prost(bytes, tag = "22")]
418        BinaryViewValue(::prost::alloc::vec::Vec<u8>),
419        #[prost(message, tag = "30")]
420        Time64Value(super::ScalarTime64Value),
421        #[prost(message, tag = "25")]
422        IntervalDaytimeValue(super::IntervalDayTimeValue),
423        #[prost(message, tag = "31")]
424        IntervalMonthDayNano(super::IntervalMonthDayNanoValue),
425        #[prost(message, tag = "34")]
426        FixedSizeBinaryValue(super::ScalarFixedSizeBinary),
427        #[prost(message, tag = "42")]
428        UnionValue(::prost::alloc::boxed::Box<super::UnionValue>),
429        #[prost(message, tag = "45")]
430        RunEndEncodedValue(::prost::alloc::boxed::Box<super::ScalarRunEndEncodedValue>),
431    }
432}
433#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
434pub struct Decimal32 {
435    #[prost(bytes = "vec", tag = "1")]
436    pub value: ::prost::alloc::vec::Vec<u8>,
437    #[prost(int64, tag = "2")]
438    pub p: i64,
439    #[prost(int64, tag = "3")]
440    pub s: i64,
441}
442#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
443pub struct Decimal64 {
444    #[prost(bytes = "vec", tag = "1")]
445    pub value: ::prost::alloc::vec::Vec<u8>,
446    #[prost(int64, tag = "2")]
447    pub p: i64,
448    #[prost(int64, tag = "3")]
449    pub s: i64,
450}
451#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
452pub struct Decimal128 {
453    #[prost(bytes = "vec", tag = "1")]
454    pub value: ::prost::alloc::vec::Vec<u8>,
455    #[prost(int64, tag = "2")]
456    pub p: i64,
457    #[prost(int64, tag = "3")]
458    pub s: i64,
459}
460#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
461pub struct Decimal256 {
462    #[prost(bytes = "vec", tag = "1")]
463    pub value: ::prost::alloc::vec::Vec<u8>,
464    #[prost(int64, tag = "2")]
465    pub p: i64,
466    #[prost(int64, tag = "3")]
467    pub s: i64,
468}
469/// Serialized data type
470#[derive(Clone, PartialEq, ::prost::Message)]
471pub struct ArrowType {
472    #[prost(
473        oneof = "arrow_type::ArrowTypeEnum",
474        tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 35, 32, 15, 34, 16, 31, 17, 18, 19, 20, 21, 22, 23, 40, 41, 24, 36, 25, 26, 27, 43, 44, 28, 29, 30, 33, 42"
475    )]
476    pub arrow_type_enum: ::core::option::Option<arrow_type::ArrowTypeEnum>,
477}
478/// Nested message and enum types in `ArrowType`.
479pub mod arrow_type {
480    #[derive(Clone, PartialEq, ::prost::Oneof)]
481    pub enum ArrowTypeEnum {
482        /// arrow::Type::NA
483        #[prost(message, tag = "1")]
484        None(super::EmptyMessage),
485        /// arrow::Type::BOOL
486        #[prost(message, tag = "2")]
487        Bool(super::EmptyMessage),
488        /// arrow::Type::UINT8
489        #[prost(message, tag = "3")]
490        Uint8(super::EmptyMessage),
491        /// arrow::Type::INT8
492        #[prost(message, tag = "4")]
493        Int8(super::EmptyMessage),
494        /// represents arrow::Type fields in src/arrow/type.h
495        #[prost(message, tag = "5")]
496        Uint16(super::EmptyMessage),
497        #[prost(message, tag = "6")]
498        Int16(super::EmptyMessage),
499        #[prost(message, tag = "7")]
500        Uint32(super::EmptyMessage),
501        #[prost(message, tag = "8")]
502        Int32(super::EmptyMessage),
503        #[prost(message, tag = "9")]
504        Uint64(super::EmptyMessage),
505        #[prost(message, tag = "10")]
506        Int64(super::EmptyMessage),
507        #[prost(message, tag = "11")]
508        Float16(super::EmptyMessage),
509        #[prost(message, tag = "12")]
510        Float32(super::EmptyMessage),
511        #[prost(message, tag = "13")]
512        Float64(super::EmptyMessage),
513        #[prost(message, tag = "14")]
514        Utf8(super::EmptyMessage),
515        #[prost(message, tag = "35")]
516        Utf8View(super::EmptyMessage),
517        #[prost(message, tag = "32")]
518        LargeUtf8(super::EmptyMessage),
519        #[prost(message, tag = "15")]
520        Binary(super::EmptyMessage),
521        #[prost(message, tag = "34")]
522        BinaryView(super::EmptyMessage),
523        #[prost(int32, tag = "16")]
524        FixedSizeBinary(i32),
525        #[prost(message, tag = "31")]
526        LargeBinary(super::EmptyMessage),
527        #[prost(message, tag = "17")]
528        Date32(super::EmptyMessage),
529        #[prost(message, tag = "18")]
530        Date64(super::EmptyMessage),
531        #[prost(enumeration = "super::TimeUnit", tag = "19")]
532        Duration(i32),
533        #[prost(message, tag = "20")]
534        Timestamp(super::Timestamp),
535        #[prost(enumeration = "super::TimeUnit", tag = "21")]
536        Time32(i32),
537        #[prost(enumeration = "super::TimeUnit", tag = "22")]
538        Time64(i32),
539        #[prost(enumeration = "super::IntervalUnit", tag = "23")]
540        Interval(i32),
541        #[prost(message, tag = "40")]
542        Decimal32(super::Decimal32Type),
543        #[prost(message, tag = "41")]
544        Decimal64(super::Decimal64Type),
545        #[prost(message, tag = "24")]
546        Decimal128(super::Decimal128Type),
547        #[prost(message, tag = "36")]
548        Decimal256(super::Decimal256Type),
549        #[prost(message, tag = "25")]
550        List(::prost::alloc::boxed::Box<super::List>),
551        #[prost(message, tag = "26")]
552        LargeList(::prost::alloc::boxed::Box<super::List>),
553        #[prost(message, tag = "27")]
554        FixedSizeList(::prost::alloc::boxed::Box<super::FixedSizeList>),
555        #[prost(message, tag = "43")]
556        ListView(::prost::alloc::boxed::Box<super::List>),
557        #[prost(message, tag = "44")]
558        LargeListView(::prost::alloc::boxed::Box<super::List>),
559        #[prost(message, tag = "28")]
560        Struct(super::Struct),
561        #[prost(message, tag = "29")]
562        Union(super::Union),
563        #[prost(message, tag = "30")]
564        Dictionary(::prost::alloc::boxed::Box<super::Dictionary>),
565        #[prost(message, tag = "33")]
566        Map(::prost::alloc::boxed::Box<super::Map>),
567        #[prost(message, tag = "42")]
568        RunEndEncoded(::prost::alloc::boxed::Box<super::RunEndEncoded>),
569    }
570}
571/// Useful for representing an empty enum variant in rust
572/// E.G. enum example{One, Two(i32)}
573/// maps to
574/// message example{
575///     oneof{
576///         EmptyMessage One = 1;
577///         i32 Two = 2;
578///    }
579/// }
580#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
581pub struct EmptyMessage {}
582#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
583pub struct JsonWriterOptions {
584    #[prost(enumeration = "CompressionTypeVariant", tag = "1")]
585    pub compression: i32,
586}
587#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
588pub struct CsvWriterOptions {
589    /// Compression type
590    #[prost(enumeration = "CompressionTypeVariant", tag = "1")]
591    pub compression: i32,
592    /// Optional column delimiter. Defaults to `b','`
593    #[prost(string, tag = "2")]
594    pub delimiter: ::prost::alloc::string::String,
595    /// Whether to write column names as file headers. Defaults to `true`
596    #[prost(bool, tag = "3")]
597    pub has_header: bool,
598    /// Optional date format for date arrays
599    #[prost(string, tag = "4")]
600    pub date_format: ::prost::alloc::string::String,
601    /// Optional datetime format for datetime arrays
602    #[prost(string, tag = "5")]
603    pub datetime_format: ::prost::alloc::string::String,
604    /// Optional timestamp format for timestamp arrays
605    #[prost(string, tag = "6")]
606    pub timestamp_format: ::prost::alloc::string::String,
607    /// Optional time format for time arrays
608    #[prost(string, tag = "7")]
609    pub time_format: ::prost::alloc::string::String,
610    /// Optional value to represent null
611    #[prost(string, tag = "8")]
612    pub null_value: ::prost::alloc::string::String,
613    /// Optional quote. Defaults to `b'"'`
614    #[prost(string, tag = "9")]
615    pub quote: ::prost::alloc::string::String,
616    /// Optional escape. Defaults to `'\\'`
617    #[prost(string, tag = "10")]
618    pub escape: ::prost::alloc::string::String,
619    /// Optional flag whether to double quotes, instead of escaping. Defaults to `true`
620    #[prost(bool, tag = "11")]
621    pub double_quote: bool,
622    /// Quote style for CSV writing
623    #[prost(enumeration = "CsvQuoteStyle", tag = "12")]
624    pub quote_style: i32,
625    /// Whether to ignore leading whitespace in string values
626    #[prost(bool, tag = "13")]
627    pub ignore_leading_whitespace: bool,
628    /// Whether to ignore trailing whitespace in string values
629    #[prost(bool, tag = "14")]
630    pub ignore_trailing_whitespace: bool,
631}
632/// Options controlling CSV format
633#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
634pub struct CsvOptions {
635    /// Indicates if the CSV has a header row
636    #[prost(bytes = "vec", tag = "1")]
637    pub has_header: ::prost::alloc::vec::Vec<u8>,
638    /// Delimiter character as a byte
639    #[prost(bytes = "vec", tag = "2")]
640    pub delimiter: ::prost::alloc::vec::Vec<u8>,
641    /// Quote character as a byte
642    #[prost(bytes = "vec", tag = "3")]
643    pub quote: ::prost::alloc::vec::Vec<u8>,
644    /// Optional escape character as a byte
645    #[prost(bytes = "vec", tag = "4")]
646    pub escape: ::prost::alloc::vec::Vec<u8>,
647    /// Compression type
648    #[prost(enumeration = "CompressionTypeVariant", tag = "5")]
649    pub compression: i32,
650    /// Optional max records for schema inference
651    #[prost(uint64, optional, tag = "6")]
652    pub schema_infer_max_rec: ::core::option::Option<u64>,
653    /// Optional date format
654    #[prost(string, tag = "7")]
655    pub date_format: ::prost::alloc::string::String,
656    /// Optional datetime format
657    #[prost(string, tag = "8")]
658    pub datetime_format: ::prost::alloc::string::String,
659    /// Optional timestamp format
660    #[prost(string, tag = "9")]
661    pub timestamp_format: ::prost::alloc::string::String,
662    /// Optional timestamp with timezone format
663    #[prost(string, tag = "10")]
664    pub timestamp_tz_format: ::prost::alloc::string::String,
665    /// Optional time format
666    #[prost(string, tag = "11")]
667    pub time_format: ::prost::alloc::string::String,
668    /// Optional representation of null value
669    #[prost(string, tag = "12")]
670    pub null_value: ::prost::alloc::string::String,
671    /// Optional representation of null loading regex
672    #[prost(string, tag = "13")]
673    pub null_regex: ::prost::alloc::string::String,
674    /// Optional comment character as a byte
675    #[prost(bytes = "vec", tag = "14")]
676    pub comment: ::prost::alloc::vec::Vec<u8>,
677    /// Indicates if quotes are doubled
678    #[prost(bytes = "vec", tag = "15")]
679    pub double_quote: ::prost::alloc::vec::Vec<u8>,
680    /// Indicates if newlines are supported in values
681    #[prost(bytes = "vec", tag = "16")]
682    pub newlines_in_values: ::prost::alloc::vec::Vec<u8>,
683    /// Optional terminator character as a byte
684    #[prost(bytes = "vec", tag = "17")]
685    pub terminator: ::prost::alloc::vec::Vec<u8>,
686    /// Indicates if truncated rows are allowed
687    #[prost(bytes = "vec", tag = "18")]
688    pub truncated_rows: ::prost::alloc::vec::Vec<u8>,
689    /// Optional compression level
690    #[prost(uint32, optional, tag = "19")]
691    pub compression_level: ::core::option::Option<u32>,
692    /// Quote style for CSV writing
693    #[prost(enumeration = "CsvQuoteStyle", tag = "20")]
694    pub quote_style: i32,
695    /// Whether to ignore leading whitespace in string values
696    #[prost(bytes = "vec", tag = "21")]
697    pub ignore_leading_whitespace: ::prost::alloc::vec::Vec<u8>,
698    /// Whether to ignore trailing whitespace in string values
699    #[prost(bytes = "vec", tag = "22")]
700    pub ignore_trailing_whitespace: ::prost::alloc::vec::Vec<u8>,
701}
702/// Options controlling CSV format
703#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
704pub struct JsonOptions {
705    /// Compression type
706    #[prost(enumeration = "CompressionTypeVariant", tag = "1")]
707    pub compression: i32,
708    /// Optional max records for schema inference
709    #[prost(uint64, optional, tag = "2")]
710    pub schema_infer_max_rec: ::core::option::Option<u64>,
711    /// Optional compression level
712    #[prost(uint32, optional, tag = "3")]
713    pub compression_level: ::core::option::Option<u32>,
714    /// Whether to read as newline-delimited JSON (default true). When false, expects JSON array format \[{},...\]
715    #[prost(bool, optional, tag = "4")]
716    pub newline_delimited: ::core::option::Option<bool>,
717}
718#[derive(Clone, PartialEq, ::prost::Message)]
719pub struct TableParquetOptions {
720    #[prost(message, optional, tag = "1")]
721    pub global: ::core::option::Option<ParquetOptions>,
722    #[prost(message, repeated, tag = "2")]
723    pub column_specific_options: ::prost::alloc::vec::Vec<ParquetColumnSpecificOptions>,
724    #[prost(map = "string, string", tag = "3")]
725    pub key_value_metadata: ::std::collections::HashMap<
726        ::prost::alloc::string::String,
727        ::prost::alloc::string::String,
728    >,
729}
730#[derive(Clone, PartialEq, ::prost::Message)]
731pub struct ParquetColumnSpecificOptions {
732    #[prost(string, tag = "1")]
733    pub column_name: ::prost::alloc::string::String,
734    #[prost(message, optional, tag = "2")]
735    pub options: ::core::option::Option<ParquetColumnOptions>,
736}
737#[derive(Clone, PartialEq, ::prost::Message)]
738pub struct ParquetColumnOptions {
739    #[prost(oneof = "parquet_column_options::BloomFilterEnabledOpt", tags = "1")]
740    pub bloom_filter_enabled_opt: ::core::option::Option<
741        parquet_column_options::BloomFilterEnabledOpt,
742    >,
743    #[prost(oneof = "parquet_column_options::EncodingOpt", tags = "2")]
744    pub encoding_opt: ::core::option::Option<parquet_column_options::EncodingOpt>,
745    #[prost(oneof = "parquet_column_options::DictionaryEnabledOpt", tags = "3")]
746    pub dictionary_enabled_opt: ::core::option::Option<
747        parquet_column_options::DictionaryEnabledOpt,
748    >,
749    #[prost(oneof = "parquet_column_options::CompressionOpt", tags = "4")]
750    pub compression_opt: ::core::option::Option<parquet_column_options::CompressionOpt>,
751    #[prost(oneof = "parquet_column_options::StatisticsEnabledOpt", tags = "5")]
752    pub statistics_enabled_opt: ::core::option::Option<
753        parquet_column_options::StatisticsEnabledOpt,
754    >,
755    #[prost(oneof = "parquet_column_options::BloomFilterFppOpt", tags = "6")]
756    pub bloom_filter_fpp_opt: ::core::option::Option<
757        parquet_column_options::BloomFilterFppOpt,
758    >,
759    #[prost(oneof = "parquet_column_options::BloomFilterNdvOpt", tags = "7")]
760    pub bloom_filter_ndv_opt: ::core::option::Option<
761        parquet_column_options::BloomFilterNdvOpt,
762    >,
763}
764/// Nested message and enum types in `ParquetColumnOptions`.
765pub mod parquet_column_options {
766    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Oneof)]
767    pub enum BloomFilterEnabledOpt {
768        #[prost(bool, tag = "1")]
769        BloomFilterEnabled(bool),
770    }
771    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
772    pub enum EncodingOpt {
773        #[prost(string, tag = "2")]
774        Encoding(::prost::alloc::string::String),
775    }
776    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Oneof)]
777    pub enum DictionaryEnabledOpt {
778        #[prost(bool, tag = "3")]
779        DictionaryEnabled(bool),
780    }
781    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
782    pub enum CompressionOpt {
783        #[prost(string, tag = "4")]
784        Compression(::prost::alloc::string::String),
785    }
786    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
787    pub enum StatisticsEnabledOpt {
788        #[prost(string, tag = "5")]
789        StatisticsEnabled(::prost::alloc::string::String),
790    }
791    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
792    pub enum BloomFilterFppOpt {
793        #[prost(double, tag = "6")]
794        BloomFilterFpp(f64),
795    }
796    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Oneof)]
797    pub enum BloomFilterNdvOpt {
798        #[prost(uint64, tag = "7")]
799        BloomFilterNdv(u64),
800    }
801}
802#[derive(Clone, PartialEq, ::prost::Message)]
803pub struct ParquetOptions {
804    /// Regular fields
805    ///
806    /// default = true
807    #[prost(bool, tag = "1")]
808    pub enable_page_index: bool,
809    /// default = true
810    #[prost(bool, tag = "2")]
811    pub pruning: bool,
812    /// default = true
813    #[prost(bool, tag = "3")]
814    pub skip_metadata: bool,
815    /// default = false
816    #[prost(bool, tag = "5")]
817    pub pushdown_filters: bool,
818    /// default = false
819    #[prost(bool, tag = "6")]
820    pub reorder_filters: bool,
821    /// default = false
822    #[prost(bool, tag = "34")]
823    pub force_filter_selections: bool,
824    /// default = 1024 * 1024
825    #[prost(uint64, tag = "7")]
826    pub data_pagesize_limit: u64,
827    /// default = 1024
828    #[prost(uint64, tag = "8")]
829    pub write_batch_size: u64,
830    /// default = "1.0"
831    #[prost(string, tag = "9")]
832    pub writer_version: ::prost::alloc::string::String,
833    /// bool bloom_filter_enabled = 20; // default = false
834    ///
835    /// default = true
836    #[prost(bool, tag = "23")]
837    pub allow_single_file_parallelism: bool,
838    /// default = 1
839    #[prost(uint64, tag = "24")]
840    pub maximum_parallel_row_group_writers: u64,
841    /// default = 2
842    #[prost(uint64, tag = "25")]
843    pub maximum_buffered_record_batches_per_stream: u64,
844    /// default = true
845    #[prost(bool, tag = "26")]
846    pub bloom_filter_on_read: bool,
847    /// default = false
848    #[prost(bool, tag = "27")]
849    pub bloom_filter_on_write: bool,
850    /// default = false
851    #[prost(bool, tag = "28")]
852    pub schema_force_view_types: bool,
853    /// default = false
854    #[prost(bool, tag = "29")]
855    pub binary_as_string: bool,
856    /// default = false
857    #[prost(bool, tag = "30")]
858    pub skip_arrow_metadata: bool,
859    #[prost(uint64, tag = "12")]
860    pub dictionary_page_size_limit: u64,
861    #[prost(uint64, tag = "18")]
862    pub data_page_row_count_limit: u64,
863    #[prost(uint64, tag = "15")]
864    pub max_row_group_size: u64,
865    #[prost(uint64, tag = "38")]
866    pub max_in_list_size: u64,
867    #[prost(string, tag = "16")]
868    pub created_by: ::prost::alloc::string::String,
869    #[prost(message, optional, tag = "35")]
870    pub content_defined_chunking: ::core::option::Option<ParquetCdcOptions>,
871    #[prost(oneof = "parquet_options::MetadataSizeHintOpt", tags = "4")]
872    pub metadata_size_hint_opt: ::core::option::Option<
873        parquet_options::MetadataSizeHintOpt,
874    >,
875    #[prost(oneof = "parquet_options::CompressionOpt", tags = "10")]
876    pub compression_opt: ::core::option::Option<parquet_options::CompressionOpt>,
877    #[prost(oneof = "parquet_options::DictionaryEnabledOpt", tags = "11")]
878    pub dictionary_enabled_opt: ::core::option::Option<
879        parquet_options::DictionaryEnabledOpt,
880    >,
881    #[prost(oneof = "parquet_options::StatisticsEnabledOpt", tags = "13")]
882    pub statistics_enabled_opt: ::core::option::Option<
883        parquet_options::StatisticsEnabledOpt,
884    >,
885    #[prost(oneof = "parquet_options::ColumnIndexTruncateLengthOpt", tags = "17")]
886    pub column_index_truncate_length_opt: ::core::option::Option<
887        parquet_options::ColumnIndexTruncateLengthOpt,
888    >,
889    #[prost(oneof = "parquet_options::StatisticsTruncateLengthOpt", tags = "31")]
890    pub statistics_truncate_length_opt: ::core::option::Option<
891        parquet_options::StatisticsTruncateLengthOpt,
892    >,
893    #[prost(oneof = "parquet_options::EncodingOpt", tags = "19")]
894    pub encoding_opt: ::core::option::Option<parquet_options::EncodingOpt>,
895    #[prost(oneof = "parquet_options::BloomFilterFppOpt", tags = "21")]
896    pub bloom_filter_fpp_opt: ::core::option::Option<parquet_options::BloomFilterFppOpt>,
897    #[prost(oneof = "parquet_options::BloomFilterNdvOpt", tags = "22")]
898    pub bloom_filter_ndv_opt: ::core::option::Option<parquet_options::BloomFilterNdvOpt>,
899    #[prost(oneof = "parquet_options::CoerceInt96Opt", tags = "32")]
900    pub coerce_int96_opt: ::core::option::Option<parquet_options::CoerceInt96Opt>,
901    #[prost(oneof = "parquet_options::MaxPredicateCacheSizeOpt", tags = "33")]
902    pub max_predicate_cache_size_opt: ::core::option::Option<
903        parquet_options::MaxPredicateCacheSizeOpt,
904    >,
905    #[prost(oneof = "parquet_options::MaxRowGroupBytesOpt", tags = "37")]
906    pub max_row_group_bytes_opt: ::core::option::Option<
907        parquet_options::MaxRowGroupBytesOpt,
908    >,
909    /// Optional timezone applied to INT96-coerced timestamps when `coerce_int96`
910    /// is set. When `Some`, INT96 columns coerce to
911    /// `Timestamp(<coerce_int96>, Some(<tz>))` instead of the default
912    /// `Timestamp(<coerce_int96>, None)`. No effect when `coerce_int96` is unset.
913    #[prost(oneof = "parquet_options::CoerceInt96TzOpt", tags = "36")]
914    pub coerce_int96_tz_opt: ::core::option::Option<parquet_options::CoerceInt96TzOpt>,
915}
916/// Nested message and enum types in `ParquetOptions`.
917pub mod parquet_options {
918    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Oneof)]
919    pub enum MetadataSizeHintOpt {
920        #[prost(uint64, tag = "4")]
921        MetadataSizeHint(u64),
922    }
923    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
924    pub enum CompressionOpt {
925        #[prost(string, tag = "10")]
926        Compression(::prost::alloc::string::String),
927    }
928    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Oneof)]
929    pub enum DictionaryEnabledOpt {
930        #[prost(bool, tag = "11")]
931        DictionaryEnabled(bool),
932    }
933    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
934    pub enum StatisticsEnabledOpt {
935        #[prost(string, tag = "13")]
936        StatisticsEnabled(::prost::alloc::string::String),
937    }
938    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Oneof)]
939    pub enum ColumnIndexTruncateLengthOpt {
940        #[prost(uint64, tag = "17")]
941        ColumnIndexTruncateLength(u64),
942    }
943    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Oneof)]
944    pub enum StatisticsTruncateLengthOpt {
945        #[prost(uint64, tag = "31")]
946        StatisticsTruncateLength(u64),
947    }
948    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
949    pub enum EncodingOpt {
950        #[prost(string, tag = "19")]
951        Encoding(::prost::alloc::string::String),
952    }
953    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
954    pub enum BloomFilterFppOpt {
955        #[prost(double, tag = "21")]
956        BloomFilterFpp(f64),
957    }
958    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Oneof)]
959    pub enum BloomFilterNdvOpt {
960        #[prost(uint64, tag = "22")]
961        BloomFilterNdv(u64),
962    }
963    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
964    pub enum CoerceInt96Opt {
965        #[prost(string, tag = "32")]
966        CoerceInt96(::prost::alloc::string::String),
967    }
968    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Oneof)]
969    pub enum MaxPredicateCacheSizeOpt {
970        #[prost(uint64, tag = "33")]
971        MaxPredicateCacheSize(u64),
972    }
973    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Oneof)]
974    pub enum MaxRowGroupBytesOpt {
975        #[prost(uint64, tag = "37")]
976        MaxRowGroupBytes(u64),
977    }
978    /// Optional timezone applied to INT96-coerced timestamps when `coerce_int96`
979    /// is set. When `Some`, INT96 columns coerce to
980    /// `Timestamp(<coerce_int96>, Some(<tz>))` instead of the default
981    /// `Timestamp(<coerce_int96>, None)`. No effect when `coerce_int96` is unset.
982    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
983    pub enum CoerceInt96TzOpt {
984        #[prost(string, tag = "36")]
985        CoerceInt96Tz(::prost::alloc::string::String),
986    }
987}
988/// Content-defined chunking (CDC) options for writing parquet files.
989#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
990pub struct ParquetCdcOptions {
991    #[prost(bool, tag = "1")]
992    pub enabled: bool,
993    #[prost(uint64, tag = "2")]
994    pub min_chunk_size: u64,
995    #[prost(uint64, tag = "3")]
996    pub max_chunk_size: u64,
997    #[prost(int32, tag = "4")]
998    pub norm_level: i32,
999}
1000#[derive(Clone, PartialEq, ::prost::Message)]
1001pub struct Precision {
1002    #[prost(enumeration = "PrecisionInfo", tag = "1")]
1003    pub precision_info: i32,
1004    #[prost(message, optional, tag = "2")]
1005    pub val: ::core::option::Option<ScalarValue>,
1006}
1007#[derive(Clone, PartialEq, ::prost::Message)]
1008pub struct Statistics {
1009    #[prost(message, optional, tag = "1")]
1010    pub num_rows: ::core::option::Option<Precision>,
1011    #[prost(message, optional, tag = "2")]
1012    pub total_byte_size: ::core::option::Option<Precision>,
1013    #[prost(message, repeated, tag = "3")]
1014    pub column_stats: ::prost::alloc::vec::Vec<ColumnStats>,
1015}
1016#[derive(Clone, PartialEq, ::prost::Message)]
1017pub struct ColumnStats {
1018    #[prost(message, optional, tag = "1")]
1019    pub min_value: ::core::option::Option<Precision>,
1020    #[prost(message, optional, tag = "2")]
1021    pub max_value: ::core::option::Option<Precision>,
1022    #[prost(message, optional, tag = "5")]
1023    pub sum_value: ::core::option::Option<Precision>,
1024    #[prost(message, optional, tag = "3")]
1025    pub null_count: ::core::option::Option<Precision>,
1026    #[prost(message, optional, tag = "4")]
1027    pub distinct_count: ::core::option::Option<Precision>,
1028    #[prost(message, optional, tag = "6")]
1029    pub byte_size: ::core::option::Option<Precision>,
1030}
1031/// Wire encoding for `datafusion_common::format::ExplainAnalyzeCategories`.
1032///
1033/// If `all` is true, every category is shown (the `only` list is ignored).
1034/// If `all` is false, only the categories listed in `only` are shown — an
1035/// empty `only` means "plan only", i.e. suppress all metrics.
1036#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
1037pub struct ExplainAnalyzeCategoriesNode {
1038    #[prost(bool, tag = "1")]
1039    pub all: bool,
1040    #[prost(enumeration = "MetricCategory", repeated, tag = "2")]
1041    pub only: ::prost::alloc::vec::Vec<i32>,
1042}
1043#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1044#[repr(i32)]
1045pub enum JoinType {
1046    Inner = 0,
1047    Left = 1,
1048    Right = 2,
1049    Full = 3,
1050    Leftsemi = 4,
1051    Leftanti = 5,
1052    Rightsemi = 6,
1053    Rightanti = 7,
1054    Leftmark = 8,
1055    Rightmark = 9,
1056}
1057impl JoinType {
1058    /// String value of the enum field names used in the ProtoBuf definition.
1059    ///
1060    /// The values are not transformed in any way and thus are considered stable
1061    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1062    pub fn as_str_name(&self) -> &'static str {
1063        match self {
1064            Self::Inner => "INNER",
1065            Self::Left => "LEFT",
1066            Self::Right => "RIGHT",
1067            Self::Full => "FULL",
1068            Self::Leftsemi => "LEFTSEMI",
1069            Self::Leftanti => "LEFTANTI",
1070            Self::Rightsemi => "RIGHTSEMI",
1071            Self::Rightanti => "RIGHTANTI",
1072            Self::Leftmark => "LEFTMARK",
1073            Self::Rightmark => "RIGHTMARK",
1074        }
1075    }
1076    /// Creates an enum from field names used in the ProtoBuf definition.
1077    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1078        match value {
1079            "INNER" => Some(Self::Inner),
1080            "LEFT" => Some(Self::Left),
1081            "RIGHT" => Some(Self::Right),
1082            "FULL" => Some(Self::Full),
1083            "LEFTSEMI" => Some(Self::Leftsemi),
1084            "LEFTANTI" => Some(Self::Leftanti),
1085            "RIGHTSEMI" => Some(Self::Rightsemi),
1086            "RIGHTANTI" => Some(Self::Rightanti),
1087            "LEFTMARK" => Some(Self::Leftmark),
1088            "RIGHTMARK" => Some(Self::Rightmark),
1089            _ => None,
1090        }
1091    }
1092}
1093#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1094#[repr(i32)]
1095pub enum JoinConstraint {
1096    On = 0,
1097    Using = 1,
1098}
1099impl JoinConstraint {
1100    /// String value of the enum field names used in the ProtoBuf definition.
1101    ///
1102    /// The values are not transformed in any way and thus are considered stable
1103    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1104    pub fn as_str_name(&self) -> &'static str {
1105        match self {
1106            Self::On => "ON",
1107            Self::Using => "USING",
1108        }
1109    }
1110    /// Creates an enum from field names used in the ProtoBuf definition.
1111    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1112        match value {
1113            "ON" => Some(Self::On),
1114            "USING" => Some(Self::Using),
1115            _ => None,
1116        }
1117    }
1118}
1119#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1120#[repr(i32)]
1121pub enum NullEquality {
1122    NullEqualsNothing = 0,
1123    NullEqualsNull = 1,
1124}
1125impl NullEquality {
1126    /// String value of the enum field names used in the ProtoBuf definition.
1127    ///
1128    /// The values are not transformed in any way and thus are considered stable
1129    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1130    pub fn as_str_name(&self) -> &'static str {
1131        match self {
1132            Self::NullEqualsNothing => "NULL_EQUALS_NOTHING",
1133            Self::NullEqualsNull => "NULL_EQUALS_NULL",
1134        }
1135    }
1136    /// Creates an enum from field names used in the ProtoBuf definition.
1137    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1138        match value {
1139            "NULL_EQUALS_NOTHING" => Some(Self::NullEqualsNothing),
1140            "NULL_EQUALS_NULL" => Some(Self::NullEqualsNull),
1141            _ => None,
1142        }
1143    }
1144}
1145#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1146#[repr(i32)]
1147pub enum TimeUnit {
1148    Second = 0,
1149    Millisecond = 1,
1150    Microsecond = 2,
1151    Nanosecond = 3,
1152}
1153impl TimeUnit {
1154    /// String value of the enum field names used in the ProtoBuf definition.
1155    ///
1156    /// The values are not transformed in any way and thus are considered stable
1157    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1158    pub fn as_str_name(&self) -> &'static str {
1159        match self {
1160            Self::Second => "Second",
1161            Self::Millisecond => "Millisecond",
1162            Self::Microsecond => "Microsecond",
1163            Self::Nanosecond => "Nanosecond",
1164        }
1165    }
1166    /// Creates an enum from field names used in the ProtoBuf definition.
1167    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1168        match value {
1169            "Second" => Some(Self::Second),
1170            "Millisecond" => Some(Self::Millisecond),
1171            "Microsecond" => Some(Self::Microsecond),
1172            "Nanosecond" => Some(Self::Nanosecond),
1173            _ => None,
1174        }
1175    }
1176}
1177#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1178#[repr(i32)]
1179pub enum IntervalUnit {
1180    YearMonth = 0,
1181    DayTime = 1,
1182    MonthDayNano = 2,
1183}
1184impl IntervalUnit {
1185    /// String value of the enum field names used in the ProtoBuf definition.
1186    ///
1187    /// The values are not transformed in any way and thus are considered stable
1188    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1189    pub fn as_str_name(&self) -> &'static str {
1190        match self {
1191            Self::YearMonth => "YearMonth",
1192            Self::DayTime => "DayTime",
1193            Self::MonthDayNano => "MonthDayNano",
1194        }
1195    }
1196    /// Creates an enum from field names used in the ProtoBuf definition.
1197    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1198        match value {
1199            "YearMonth" => Some(Self::YearMonth),
1200            "DayTime" => Some(Self::DayTime),
1201            "MonthDayNano" => Some(Self::MonthDayNano),
1202            _ => None,
1203        }
1204    }
1205}
1206#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1207#[repr(i32)]
1208pub enum UnionMode {
1209    Sparse = 0,
1210    Dense = 1,
1211}
1212impl UnionMode {
1213    /// String value of the enum field names used in the ProtoBuf definition.
1214    ///
1215    /// The values are not transformed in any way and thus are considered stable
1216    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1217    pub fn as_str_name(&self) -> &'static str {
1218        match self {
1219            Self::Sparse => "sparse",
1220            Self::Dense => "dense",
1221        }
1222    }
1223    /// Creates an enum from field names used in the ProtoBuf definition.
1224    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1225        match value {
1226            "sparse" => Some(Self::Sparse),
1227            "dense" => Some(Self::Dense),
1228            _ => None,
1229        }
1230    }
1231}
1232#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1233#[repr(i32)]
1234pub enum CompressionTypeVariant {
1235    Gzip = 0,
1236    Bzip2 = 1,
1237    Xz = 2,
1238    Zstd = 3,
1239    Uncompressed = 4,
1240}
1241impl CompressionTypeVariant {
1242    /// String value of the enum field names used in the ProtoBuf definition.
1243    ///
1244    /// The values are not transformed in any way and thus are considered stable
1245    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1246    pub fn as_str_name(&self) -> &'static str {
1247        match self {
1248            Self::Gzip => "GZIP",
1249            Self::Bzip2 => "BZIP2",
1250            Self::Xz => "XZ",
1251            Self::Zstd => "ZSTD",
1252            Self::Uncompressed => "UNCOMPRESSED",
1253        }
1254    }
1255    /// Creates an enum from field names used in the ProtoBuf definition.
1256    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1257        match value {
1258            "GZIP" => Some(Self::Gzip),
1259            "BZIP2" => Some(Self::Bzip2),
1260            "XZ" => Some(Self::Xz),
1261            "ZSTD" => Some(Self::Zstd),
1262            "UNCOMPRESSED" => Some(Self::Uncompressed),
1263            _ => None,
1264        }
1265    }
1266}
1267#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1268#[repr(i32)]
1269pub enum CsvQuoteStyle {
1270    Necessary = 0,
1271    Always = 1,
1272    NonNumeric = 2,
1273    Never = 3,
1274}
1275impl CsvQuoteStyle {
1276    /// String value of the enum field names used in the ProtoBuf definition.
1277    ///
1278    /// The values are not transformed in any way and thus are considered stable
1279    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1280    pub fn as_str_name(&self) -> &'static str {
1281        match self {
1282            Self::Necessary => "NECESSARY",
1283            Self::Always => "ALWAYS",
1284            Self::NonNumeric => "NON_NUMERIC",
1285            Self::Never => "NEVER",
1286        }
1287    }
1288    /// Creates an enum from field names used in the ProtoBuf definition.
1289    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1290        match value {
1291            "NECESSARY" => Some(Self::Necessary),
1292            "ALWAYS" => Some(Self::Always),
1293            "NON_NUMERIC" => Some(Self::NonNumeric),
1294            "NEVER" => Some(Self::Never),
1295            _ => None,
1296        }
1297    }
1298}
1299#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1300#[repr(i32)]
1301pub enum JoinSide {
1302    LeftSide = 0,
1303    RightSide = 1,
1304    None = 2,
1305}
1306impl JoinSide {
1307    /// String value of the enum field names used in the ProtoBuf definition.
1308    ///
1309    /// The values are not transformed in any way and thus are considered stable
1310    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1311    pub fn as_str_name(&self) -> &'static str {
1312        match self {
1313            Self::LeftSide => "LEFT_SIDE",
1314            Self::RightSide => "RIGHT_SIDE",
1315            Self::None => "NONE",
1316        }
1317    }
1318    /// Creates an enum from field names used in the ProtoBuf definition.
1319    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1320        match value {
1321            "LEFT_SIDE" => Some(Self::LeftSide),
1322            "RIGHT_SIDE" => Some(Self::RightSide),
1323            "NONE" => Some(Self::None),
1324            _ => None,
1325        }
1326    }
1327}
1328#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1329#[repr(i32)]
1330pub enum PrecisionInfo {
1331    Exact = 0,
1332    Inexact = 1,
1333    Absent = 2,
1334}
1335impl PrecisionInfo {
1336    /// String value of the enum field names used in the ProtoBuf definition.
1337    ///
1338    /// The values are not transformed in any way and thus are considered stable
1339    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1340    pub fn as_str_name(&self) -> &'static str {
1341        match self {
1342            Self::Exact => "EXACT",
1343            Self::Inexact => "INEXACT",
1344            Self::Absent => "ABSENT",
1345        }
1346    }
1347    /// Creates an enum from field names used in the ProtoBuf definition.
1348    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1349        match value {
1350            "EXACT" => Some(Self::Exact),
1351            "INEXACT" => Some(Self::Inexact),
1352            "ABSENT" => Some(Self::Absent),
1353            _ => None,
1354        }
1355    }
1356}
1357#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1358#[repr(i32)]
1359pub enum ExplainFormat {
1360    Indent = 0,
1361    Tree = 1,
1362    Pgjson = 2,
1363    Graphviz = 3,
1364}
1365impl ExplainFormat {
1366    /// String value of the enum field names used in the ProtoBuf definition.
1367    ///
1368    /// The values are not transformed in any way and thus are considered stable
1369    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1370    pub fn as_str_name(&self) -> &'static str {
1371        match self {
1372            Self::Indent => "EXPLAIN_FORMAT_INDENT",
1373            Self::Tree => "EXPLAIN_FORMAT_TREE",
1374            Self::Pgjson => "EXPLAIN_FORMAT_PGJSON",
1375            Self::Graphviz => "EXPLAIN_FORMAT_GRAPHVIZ",
1376        }
1377    }
1378    /// Creates an enum from field names used in the ProtoBuf definition.
1379    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1380        match value {
1381            "EXPLAIN_FORMAT_INDENT" => Some(Self::Indent),
1382            "EXPLAIN_FORMAT_TREE" => Some(Self::Tree),
1383            "EXPLAIN_FORMAT_PGJSON" => Some(Self::Pgjson),
1384            "EXPLAIN_FORMAT_GRAPHVIZ" => Some(Self::Graphviz),
1385            _ => None,
1386        }
1387    }
1388}
1389/// Verbosity level for `EXPLAIN ANALYZE`. Mirrors
1390/// `datafusion_common::format::MetricType`.
1391#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1392#[repr(i32)]
1393pub enum MetricType {
1394    Summary = 0,
1395    Dev = 1,
1396}
1397impl MetricType {
1398    /// String value of the enum field names used in the ProtoBuf definition.
1399    ///
1400    /// The values are not transformed in any way and thus are considered stable
1401    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1402    pub fn as_str_name(&self) -> &'static str {
1403        match self {
1404            Self::Summary => "METRIC_TYPE_SUMMARY",
1405            Self::Dev => "METRIC_TYPE_DEV",
1406        }
1407    }
1408    /// Creates an enum from field names used in the ProtoBuf definition.
1409    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1410        match value {
1411            "METRIC_TYPE_SUMMARY" => Some(Self::Summary),
1412            "METRIC_TYPE_DEV" => Some(Self::Dev),
1413            _ => None,
1414        }
1415    }
1416}
1417/// Category of an `EXPLAIN ANALYZE` metric. Mirrors
1418/// `datafusion_common::format::MetricCategory`.
1419#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
1420#[repr(i32)]
1421pub enum MetricCategory {
1422    Rows = 0,
1423    Bytes = 1,
1424    Timing = 2,
1425    Uncategorized = 3,
1426}
1427impl MetricCategory {
1428    /// String value of the enum field names used in the ProtoBuf definition.
1429    ///
1430    /// The values are not transformed in any way and thus are considered stable
1431    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
1432    pub fn as_str_name(&self) -> &'static str {
1433        match self {
1434            Self::Rows => "METRIC_CATEGORY_ROWS",
1435            Self::Bytes => "METRIC_CATEGORY_BYTES",
1436            Self::Timing => "METRIC_CATEGORY_TIMING",
1437            Self::Uncategorized => "METRIC_CATEGORY_UNCATEGORIZED",
1438        }
1439    }
1440    /// Creates an enum from field names used in the ProtoBuf definition.
1441    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
1442        match value {
1443            "METRIC_CATEGORY_ROWS" => Some(Self::Rows),
1444            "METRIC_CATEGORY_BYTES" => Some(Self::Bytes),
1445            "METRIC_CATEGORY_TIMING" => Some(Self::Timing),
1446            "METRIC_CATEGORY_UNCATEGORIZED" => Some(Self::Uncategorized),
1447            _ => None,
1448        }
1449    }
1450}
datafusion_proto_models/generated/datafusion_proto_common.rs

datafusion_proto_models/generated/
datafusion_proto_common.rs
