chalk_client/gen/
chalk.dataframe.v1.rs

1// This file is @generated by prost-build.
2/// / A (dynamically-typed) operand passed to a DataFrame function.
3#[derive(Clone, PartialEq, ::prost::Message)]
4pub struct DataFrameOperand {
5    #[prost(
6        oneof = "data_frame_operand::Operand",
7        tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11"
8    )]
9    pub operand: ::core::option::Option<data_frame_operand::Operand>,
10}
11/// Nested message and enum types in `DataFrameOperand`.
12pub mod data_frame_operand {
13    #[derive(Clone, PartialEq, ::prost::Oneof)]
14    pub enum Operand {
15        #[prost(string, tag = "1")]
16        ValueString(::prost::alloc::string::String),
17        #[prost(int64, tag = "2")]
18        ValueInt(i64),
19        #[prost(bool, tag = "3")]
20        ValueBool(bool),
21        #[prost(message, tag = "4")]
22        ValueNone(super::PyNone),
23        #[prost(message, tag = "5")]
24        ValueList(super::PyList),
25        #[prost(message, tag = "6")]
26        ValueDict(super::PyDict),
27        #[prost(message, tag = "7")]
28        ValueDataframeIndex(super::DataFrameIndex),
29        #[prost(message, tag = "8")]
30        ArrowSchema(super::super::super::arrow::v1::Schema),
31        #[prost(message, tag = "9")]
32        ArrowTable(super::super::super::arrow::v1::TableParquetBytes),
33        #[prost(message, tag = "10")]
34        UnderscoreExpr(super::super::super::expression::v1::LogicalExprNode),
35        #[prost(message, tag = "11")]
36        LibchalkExpr(super::super::super::expression::v1::LogicalExprNode),
37    }
38}
39#[derive(Clone, Copy, PartialEq, ::prost::Message)]
40pub struct DataFrameIndex {
41    /// The index of this dataframe operator within the plan.
42    #[prost(int32, tag = "1")]
43    pub dataframe_op_index: i32,
44}
45#[derive(Clone, Copy, PartialEq, ::prost::Message)]
46pub struct PyNone {}
47#[derive(Clone, PartialEq, ::prost::Message)]
48pub struct PyList {
49    #[prost(message, repeated, tag = "1")]
50    pub list_items: ::prost::alloc::vec::Vec<DataFrameOperand>,
51}
52#[derive(Clone, PartialEq, ::prost::Message)]
53pub struct PyDictEntry {
54    #[prost(message, optional, tag = "1")]
55    pub entry_key: ::core::option::Option<DataFrameOperand>,
56    #[prost(message, optional, tag = "2")]
57    pub entry_value: ::core::option::Option<DataFrameOperand>,
58}
59#[derive(Clone, PartialEq, ::prost::Message)]
60pub struct PyDict {
61    #[prost(message, repeated, tag = "1")]
62    pub dict_entries: ::prost::alloc::vec::Vec<PyDictEntry>,
63}
64#[derive(Clone, PartialEq, ::prost::Message)]
65pub struct DataFrameConstructor {
66    /// / If present, this is a method called on `self_operand`.
67    /// / Otherwise, it is a static method on the class itself.
68    #[prost(message, optional, tag = "1")]
69    pub self_operand: ::core::option::Option<DataFrameIndex>,
70    /// / The name of the function to construct the dataframe object.
71    #[prost(string, tag = "2")]
72    pub function_name: ::prost::alloc::string::String,
73    /// / Positional arguments passed to the function.
74    #[prost(message, optional, tag = "3")]
75    pub args: ::core::option::Option<PyList>,
76    /// / Keyword arguments passed to the function.
77    #[prost(message, optional, tag = "4")]
78    pub kwargs: ::core::option::Option<PyDict>,
79}
80#[derive(Clone, PartialEq, ::prost::Message)]
81pub struct DataFramePlan {
82    /// / A sequence of intermediate constructors used to build this plan.
83    /// / Constructors can refer to earlier dataframes in the sequence.
84    /// /
85    /// / The last constructor is the output of the plan.
86    #[prost(message, repeated, tag = "1")]
87    pub constructors: ::prost::alloc::vec::Vec<DataFrameConstructor>,
88}
chalk_client/gen/chalk.dataframe.v1.rs

chalk_client/gen/
chalk.dataframe.v1.rs
