1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137

#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoReducePlan {
    #[prost(oneof="proto_reduce_plan::Kind", tags="1, 2, 3, 4, 5, 6")]
    pub kind: ::core::option::Option<proto_reduce_plan::Kind>,
}
/// Nested message and enum types in `ProtoReducePlan`.
pub mod proto_reduce_plan {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag="1")]
        Distinct(()),
        #[prost(message, tag="2")]
        DistinctNegated(()),
        #[prost(message, tag="3")]
        Accumulable(super::ProtoAccumulablePlan),
        #[prost(message, tag="4")]
        Hierarchical(super::ProtoHierarchicalPlan),
        #[prost(message, tag="5")]
        Basic(super::ProtoBasicPlan),
        #[prost(message, tag="6")]
        Collation(super::ProtoCollationPlan),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoAccumulablePlan {
    #[prost(message, repeated, tag="1")]
    pub full_aggrs: ::prost::alloc::vec::Vec<::mz_expr::ProtoAggregateExpr>,
    #[prost(message, repeated, tag="2")]
    pub simple_aggrs: ::prost::alloc::vec::Vec<proto_accumulable_plan::ProtoAggr>,
    #[prost(message, repeated, tag="3")]
    pub distinct_aggrs: ::prost::alloc::vec::Vec<proto_accumulable_plan::ProtoAggr>,
}
/// Nested message and enum types in `ProtoAccumulablePlan`.
pub mod proto_accumulable_plan {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoAggr {
        #[prost(uint64, tag="1")]
        pub index_agg: u64,
        #[prost(uint64, tag="2")]
        pub index_inp: u64,
        #[prost(message, optional, tag="3")]
        pub expr: ::core::option::Option<::mz_expr::ProtoAggregateExpr>,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoHierarchicalPlan {
    #[prost(oneof="proto_hierarchical_plan::Kind", tags="1, 2")]
    pub kind: ::core::option::Option<proto_hierarchical_plan::Kind>,
}
/// Nested message and enum types in `ProtoHierarchicalPlan`.
pub mod proto_hierarchical_plan {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag="1")]
        Monotonic(super::ProtoMonotonicPlan),
        #[prost(message, tag="2")]
        Bucketed(super::ProtoBucketedPlan),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoMonotonicPlan {
    #[prost(message, repeated, tag="1")]
    pub aggr_funcs: ::prost::alloc::vec::Vec<::mz_expr::ProtoAggregateFunc>,
    #[prost(uint64, repeated, tag="2")]
    pub skips: ::prost::alloc::vec::Vec<u64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoBucketedPlan {
    #[prost(message, repeated, tag="1")]
    pub aggr_funcs: ::prost::alloc::vec::Vec<::mz_expr::ProtoAggregateFunc>,
    #[prost(uint64, repeated, tag="2")]
    pub skips: ::prost::alloc::vec::Vec<u64>,
    #[prost(uint64, repeated, tag="3")]
    pub buckets: ::prost::alloc::vec::Vec<u64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoBasicPlan {
    #[prost(oneof="proto_basic_plan::Kind", tags="1, 2")]
    pub kind: ::core::option::Option<proto_basic_plan::Kind>,
}
/// Nested message and enum types in `ProtoBasicPlan`.
pub mod proto_basic_plan {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoSingleBasicPlan {
        #[prost(uint64, tag="1")]
        pub index: u64,
        #[prost(message, optional, tag="2")]
        pub expr: ::core::option::Option<::mz_expr::ProtoAggregateExpr>,
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ProtoMultipleBasicPlan {
        #[prost(message, repeated, tag="1")]
        pub aggrs: ::prost::alloc::vec::Vec<ProtoSingleBasicPlan>,
    }
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag="1")]
        Single(ProtoSingleBasicPlan),
        #[prost(message, tag="2")]
        Multiple(ProtoMultipleBasicPlan),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoCollationPlan {
    #[prost(message, optional, tag="1")]
    pub accumulable: ::core::option::Option<ProtoAccumulablePlan>,
    #[prost(message, optional, tag="2")]
    pub hierarchical: ::core::option::Option<ProtoHierarchicalPlan>,
    #[prost(message, optional, tag="3")]
    pub basic: ::core::option::Option<ProtoBasicPlan>,
    #[prost(message, repeated, tag="4")]
    pub aggregate_types: ::prost::alloc::vec::Vec<ProtoReductionType>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoReductionType {
    #[prost(oneof="proto_reduction_type::Kind", tags="1, 2, 3")]
    pub kind: ::core::option::Option<proto_reduction_type::Kind>,
}
/// Nested message and enum types in `ProtoReductionType`.
pub mod proto_reduction_type {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Kind {
        #[prost(message, tag="1")]
        Accumulable(()),
        #[prost(message, tag="2")]
        Hierarchical(()),
        #[prost(message, tag="3")]
        Basic(()),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoKeyValPlan {
    #[prost(message, optional, tag="1")]
    pub key_plan: ::core::option::Option<::mz_expr::ProtoSafeMfpPlan>,
    #[prost(message, optional, tag="2")]
    pub val_plan: ::core::option::Option<::mz_expr::ProtoSafeMfpPlan>,
}