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
// @generated
// This file is @generated by prost-build.
/// Information about a single Delta commit ratified by the catalog.
///
/// Mirrors the `CommitInfo` shape used by the Unity Catalog OSS commit
/// coordinator (`uc_delta_commits` rows). All fields are required and must be
/// positive / non-empty (see the `commit` RPC).
#[cfg_attr(feature = "python", ::pyo3::pyclass(get_all, set_all))]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct CommitInfo {
/// The table version this commit produces. Posted commits are >= 1; version 0
/// is established out-of-band by create-table.
#[prost(int64, tag="1")]
pub version: i64,
/// The in-commit timestamp (milliseconds since epoch). Monotonicity is the
/// client's responsibility; the server only requires it to be positive.
#[prost(int64, tag="2")]
pub timestamp: i64,
/// The name of the staged commit file, e.g.
/// `00000000000000000005.<uuid>.json` under `_delta_log/_staged_commits/`.
#[prost(string, tag="3")]
pub file_name: ::prost::alloc::string::String,
/// The size of the staged commit file in bytes.
#[prost(int64, tag="4")]
pub file_size: i64,
/// The filesystem modification timestamp of the staged commit file
/// (milliseconds since epoch).
#[prost(int64, tag="5")]
pub file_modification_timestamp: i64,
}
/// A Delta metadata change accompanying a commit. Modeled minimally; the
/// coordinator stores it opaquely and does not interpret it.
#[cfg_attr(feature = "python", ::pyo3::pyclass(get_all, set_all))]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Metadata {
/// The Delta metadata `id`.
#[prost(string, optional, tag="1")]
pub id: ::core::option::Option<::prost::alloc::string::String>,
/// The serialized schema string from the Delta metadata action.
#[prost(string, optional, tag="2")]
pub schema_string: ::core::option::Option<::prost::alloc::string::String>,
/// Configuration key/value pairs from the Delta metadata action.
#[prost(map="string, string", tag="3")]
pub configuration: ::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
}
/// Response listing ratified-but-unpublished commits for a table.
#[cfg_attr(feature = "python", ::pyo3::pyclass(get_all, set_all))]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCommitsResponse {
/// Ratified commits in `\[start_version, end_version\]`, contiguous and ordered
/// ascending by version. Excludes the internal fully-backfilled marker row.
#[prost(message, repeated, tag="1")]
pub commits: ::prost::alloc::vec::Vec<CommitInfo>,
/// The latest table version the catalog tracks. `0` indicates a managed table
/// with no commits yet.
#[prost(int64, tag="2")]
pub latest_table_version: i64,
}
/// Request to ratify a Delta commit and/or notify the catalog of backfill.
///
/// At least one of `commit_info` or `latest_backfilled_version` must be set.
#[cfg_attr(feature = "python", ::pyo3::pyclass(get_all, set_all))]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CommitRequest {
/// UUID of the catalog-managed table being committed to.
#[prost(string, tag="1")]
pub table_id: ::prost::alloc::string::String,
/// The storage URI of the table. Must match the table's registered storage
/// location (normalized) on the commit path.
#[prost(string, tag="2")]
pub table_uri: ::prost::alloc::string::String,
/// The commit to ratify. Absent for a backfill-only notification.
#[prost(message, optional, tag="3")]
pub commit_info: ::core::option::Option<CommitInfo>,
/// Notify the catalog that commits up to and including this version have been
/// published (backfilled) to the Delta log. The catalog prunes ratified
/// commits accordingly.
#[prost(int64, optional, tag="4")]
pub latest_backfilled_version: ::core::option::Option<i64>,
/// An optional Delta metadata change accompanying the commit.
#[prost(message, optional, tag="5")]
pub metadata: ::core::option::Option<Metadata>,
}
/// Request to read ratified-but-unpublished commits for a table.
#[cfg_attr(feature = "python", ::pyo3::pyclass(get_all, set_all))]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct GetCommitsRequest {
/// UUID of the catalog-managed table.
#[prost(string, tag="1")]
pub table_id: ::prost::alloc::string::String,
/// The storage URI of the table.
#[prost(string, tag="2")]
pub table_uri: ::prost::alloc::string::String,
/// The lowest version to return (inclusive). Defaults to 0.
#[prost(int64, tag="3")]
pub start_version: i64,
/// The highest version to return (inclusive). When set, must be
/// `>= start_version`. Defaults to the latest version.
#[prost(int64, optional, tag="4")]
pub end_version: ::core::option::Option<i64>,
}
include!("unitycatalog.delta_commits.v1.serde.rs");
// @@protoc_insertion_point(module)