chalk-client 0.1.0

Rust client SDK for the Chalk feature store
Documentation 
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

// This file is @generated by prost-build.
/// / A (dynamically-typed) operand passed to a DataFrame function.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataFrameOperand {
    #[prost(
        oneof = "data_frame_operand::Operand",
        tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11"
    )]
    pub operand: ::core::option::Option<data_frame_operand::Operand>,
}
/// Nested message and enum types in `DataFrameOperand`.
pub mod data_frame_operand {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Operand {
        #[prost(string, tag = "1")]
        ValueString(::prost::alloc::string::String),
        #[prost(int64, tag = "2")]
        ValueInt(i64),
        #[prost(bool, tag = "3")]
        ValueBool(bool),
        #[prost(message, tag = "4")]
        ValueNone(super::PyNone),
        #[prost(message, tag = "5")]
        ValueList(super::PyList),
        #[prost(message, tag = "6")]
        ValueDict(super::PyDict),
        #[prost(message, tag = "7")]
        ValueDataframeIndex(super::DataFrameIndex),
        #[prost(message, tag = "8")]
        ArrowSchema(super::super::super::arrow::v1::Schema),
        #[prost(message, tag = "9")]
        ArrowTable(super::super::super::arrow::v1::TableParquetBytes),
        #[prost(message, tag = "10")]
        UnderscoreExpr(super::super::super::expression::v1::LogicalExprNode),
        #[prost(message, tag = "11")]
        LibchalkExpr(super::super::super::expression::v1::LogicalExprNode),
    }
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct DataFrameIndex {
    /// The index of this dataframe operator within the plan.
    #[prost(int32, tag = "1")]
    pub dataframe_op_index: i32,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct PyNone {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PyList {
    #[prost(message, repeated, tag = "1")]
    pub list_items: ::prost::alloc::vec::Vec<DataFrameOperand>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PyDictEntry {
    #[prost(message, optional, tag = "1")]
    pub entry_key: ::core::option::Option<DataFrameOperand>,
    #[prost(message, optional, tag = "2")]
    pub entry_value: ::core::option::Option<DataFrameOperand>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PyDict {
    #[prost(message, repeated, tag = "1")]
    pub dict_entries: ::prost::alloc::vec::Vec<PyDictEntry>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataFrameConstructor {
    /// / If present, this is a method called on `self_operand`.
    /// / Otherwise, it is a static method on the class itself.
    #[prost(message, optional, tag = "1")]
    pub self_operand: ::core::option::Option<DataFrameIndex>,
    /// / The name of the function to construct the dataframe object.
    #[prost(string, tag = "2")]
    pub function_name: ::prost::alloc::string::String,
    /// / Positional arguments passed to the function.
    #[prost(message, optional, tag = "3")]
    pub args: ::core::option::Option<PyList>,
    /// / Keyword arguments passed to the function.
    #[prost(message, optional, tag = "4")]
    pub kwargs: ::core::option::Option<PyDict>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataFramePlan {
    /// / A sequence of intermediate constructors used to build this plan.
    /// / Constructors can refer to earlier dataframes in the sequence.
    /// /
    /// / The last constructor is the output of the plan.
    #[prost(message, repeated, tag = "1")]
    pub constructors: ::prost::alloc::vec::Vec<DataFrameConstructor>,
}