#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ColumnRelation {
#[prost(string, tag = "1")]
pub relation: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Column {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub relation: ::core::option::Option<ColumnRelation>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DfField {
#[prost(message, optional, tag = "1")]
pub field: ::core::option::Option<Field>,
#[prost(message, optional, tag = "2")]
pub qualifier: ::core::option::Option<ColumnRelation>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DfSchema {
#[prost(message, repeated, tag = "1")]
pub columns: ::prost::alloc::vec::Vec<DfField>,
#[prost(map = "string, string", tag = "2")]
pub metadata: ::std::collections::HashMap<
::prost::alloc::string::String,
::prost::alloc::string::String,
>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CsvFormat {
#[prost(message, optional, tag = "5")]
pub options: ::core::option::Option<CsvOptions>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ParquetFormat {
#[prost(message, optional, tag = "2")]
pub options: ::core::option::Option<TableParquetOptions>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AvroFormat {}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PrimaryKeyConstraint {
#[prost(uint64, repeated, tag = "1")]
pub indices: ::prost::alloc::vec::Vec<u64>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UniqueConstraint {
#[prost(uint64, repeated, tag = "1")]
pub indices: ::prost::alloc::vec::Vec<u64>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Constraint {
#[prost(oneof = "constraint::ConstraintMode", tags = "1, 2")]
pub constraint_mode: ::core::option::Option<constraint::ConstraintMode>,
}
pub mod constraint {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum ConstraintMode {
#[prost(message, tag = "1")]
PrimaryKey(super::PrimaryKeyConstraint),
#[prost(message, tag = "2")]
Unique(super::UniqueConstraint),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Constraints {
#[prost(message, repeated, tag = "1")]
pub constraints: ::prost::alloc::vec::Vec<Constraint>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AvroOptions {}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArrowOptions {}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Schema {
#[prost(message, repeated, tag = "1")]
pub columns: ::prost::alloc::vec::Vec<Field>,
#[prost(map = "string, string", tag = "2")]
pub metadata: ::std::collections::HashMap<
::prost::alloc::string::String,
::prost::alloc::string::String,
>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Field {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, optional, boxed, tag = "2")]
pub arrow_type: ::core::option::Option<::prost::alloc::boxed::Box<ArrowType>>,
#[prost(bool, tag = "3")]
pub nullable: bool,
#[prost(message, repeated, tag = "4")]
pub children: ::prost::alloc::vec::Vec<Field>,
#[prost(map = "string, string", tag = "5")]
pub metadata: ::std::collections::HashMap<
::prost::alloc::string::String,
::prost::alloc::string::String,
>,
#[prost(int64, tag = "6")]
pub dict_id: i64,
#[prost(bool, tag = "7")]
pub dict_ordered: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Timestamp {
#[prost(enumeration = "TimeUnit", tag = "1")]
pub time_unit: i32,
#[prost(string, tag = "2")]
pub timezone: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Decimal {
#[prost(uint32, tag = "3")]
pub precision: u32,
#[prost(int32, tag = "4")]
pub scale: i32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct List {
#[prost(message, optional, boxed, tag = "1")]
pub field_type: ::core::option::Option<::prost::alloc::boxed::Box<Field>>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FixedSizeList {
#[prost(message, optional, boxed, tag = "1")]
pub field_type: ::core::option::Option<::prost::alloc::boxed::Box<Field>>,
#[prost(int32, tag = "2")]
pub list_size: i32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Dictionary {
#[prost(message, optional, boxed, tag = "1")]
pub key: ::core::option::Option<::prost::alloc::boxed::Box<ArrowType>>,
#[prost(message, optional, boxed, tag = "2")]
pub value: ::core::option::Option<::prost::alloc::boxed::Box<ArrowType>>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Struct {
#[prost(message, repeated, tag = "1")]
pub sub_field_types: ::prost::alloc::vec::Vec<Field>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Map {
#[prost(message, optional, boxed, tag = "1")]
pub field_type: ::core::option::Option<::prost::alloc::boxed::Box<Field>>,
#[prost(bool, tag = "2")]
pub keys_sorted: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Union {
#[prost(message, repeated, tag = "1")]
pub union_types: ::prost::alloc::vec::Vec<Field>,
#[prost(enumeration = "UnionMode", tag = "2")]
pub union_mode: i32,
#[prost(int32, repeated, tag = "3")]
pub type_ids: ::prost::alloc::vec::Vec<i32>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ScalarNestedValue {
#[prost(bytes = "vec", tag = "1")]
pub ipc_message: ::prost::alloc::vec::Vec<u8>,
#[prost(bytes = "vec", tag = "2")]
pub arrow_data: ::prost::alloc::vec::Vec<u8>,
#[prost(message, optional, tag = "3")]
pub schema: ::core::option::Option<Schema>,
#[prost(message, repeated, tag = "4")]
pub dictionaries: ::prost::alloc::vec::Vec<scalar_nested_value::Dictionary>,
}
pub mod scalar_nested_value {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Dictionary {
#[prost(bytes = "vec", tag = "1")]
pub ipc_message: ::prost::alloc::vec::Vec<u8>,
#[prost(bytes = "vec", tag = "2")]
pub arrow_data: ::prost::alloc::vec::Vec<u8>,
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ScalarTime32Value {
#[prost(oneof = "scalar_time32_value::Value", tags = "1, 2")]
pub value: ::core::option::Option<scalar_time32_value::Value>,
}
pub mod scalar_time32_value {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Value {
#[prost(int32, tag = "1")]
Time32SecondValue(i32),
#[prost(int32, tag = "2")]
Time32MillisecondValue(i32),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ScalarTime64Value {
#[prost(oneof = "scalar_time64_value::Value", tags = "1, 2")]
pub value: ::core::option::Option<scalar_time64_value::Value>,
}
pub mod scalar_time64_value {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Value {
#[prost(int64, tag = "1")]
Time64MicrosecondValue(i64),
#[prost(int64, tag = "2")]
Time64NanosecondValue(i64),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ScalarTimestampValue {
#[prost(string, tag = "5")]
pub timezone: ::prost::alloc::string::String,
#[prost(oneof = "scalar_timestamp_value::Value", tags = "1, 2, 3, 4")]
pub value: ::core::option::Option<scalar_timestamp_value::Value>,
}
pub mod scalar_timestamp_value {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Value {
#[prost(int64, tag = "1")]
TimeMicrosecondValue(i64),
#[prost(int64, tag = "2")]
TimeNanosecondValue(i64),
#[prost(int64, tag = "3")]
TimeSecondValue(i64),
#[prost(int64, tag = "4")]
TimeMillisecondValue(i64),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ScalarDictionaryValue {
#[prost(message, optional, tag = "1")]
pub index_type: ::core::option::Option<ArrowType>,
#[prost(message, optional, boxed, tag = "2")]
pub value: ::core::option::Option<::prost::alloc::boxed::Box<ScalarValue>>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct IntervalDayTimeValue {
#[prost(int32, tag = "1")]
pub days: i32,
#[prost(int32, tag = "2")]
pub milliseconds: i32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct IntervalMonthDayNanoValue {
#[prost(int32, tag = "1")]
pub months: i32,
#[prost(int32, tag = "2")]
pub days: i32,
#[prost(int64, tag = "3")]
pub nanos: i64,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UnionField {
#[prost(int32, tag = "1")]
pub field_id: i32,
#[prost(message, optional, tag = "2")]
pub field: ::core::option::Option<Field>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UnionValue {
#[prost(int32, tag = "1")]
pub value_id: i32,
#[prost(message, optional, boxed, tag = "2")]
pub value: ::core::option::Option<::prost::alloc::boxed::Box<ScalarValue>>,
#[prost(message, repeated, tag = "3")]
pub fields: ::prost::alloc::vec::Vec<UnionField>,
#[prost(enumeration = "UnionMode", tag = "4")]
pub mode: i32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ScalarFixedSizeBinary {
#[prost(bytes = "vec", tag = "1")]
pub values: ::prost::alloc::vec::Vec<u8>,
#[prost(int32, tag = "2")]
pub length: i32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ScalarValue {
#[prost(
oneof = "scalar_value::Value",
tags = "33, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 32, 20, 39, 21, 24, 35, 36, 37, 38, 26, 27, 28, 29, 30, 25, 31, 34, 42"
)]
pub value: ::core::option::Option<scalar_value::Value>,
}
pub mod scalar_value {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Value {
#[prost(message, tag = "33")]
NullValue(super::ArrowType),
#[prost(bool, tag = "1")]
BoolValue(bool),
#[prost(string, tag = "2")]
Utf8Value(::prost::alloc::string::String),
#[prost(string, tag = "3")]
LargeUtf8Value(::prost::alloc::string::String),
#[prost(int32, tag = "4")]
Int8Value(i32),
#[prost(int32, tag = "5")]
Int16Value(i32),
#[prost(int32, tag = "6")]
Int32Value(i32),
#[prost(int64, tag = "7")]
Int64Value(i64),
#[prost(uint32, tag = "8")]
Uint8Value(u32),
#[prost(uint32, tag = "9")]
Uint16Value(u32),
#[prost(uint32, tag = "10")]
Uint32Value(u32),
#[prost(uint64, tag = "11")]
Uint64Value(u64),
#[prost(float, tag = "12")]
Float32Value(f32),
#[prost(double, tag = "13")]
Float64Value(f64),
#[prost(int32, tag = "14")]
Date32Value(i32),
#[prost(message, tag = "15")]
Time32Value(super::ScalarTime32Value),
#[prost(message, tag = "16")]
LargeListValue(super::ScalarNestedValue),
#[prost(message, tag = "17")]
ListValue(super::ScalarNestedValue),
#[prost(message, tag = "18")]
FixedSizeListValue(super::ScalarNestedValue),
#[prost(message, tag = "32")]
StructValue(super::ScalarNestedValue),
#[prost(message, tag = "20")]
Decimal128Value(super::Decimal128),
#[prost(message, tag = "39")]
Decimal256Value(super::Decimal256),
#[prost(int64, tag = "21")]
Date64Value(i64),
#[prost(int32, tag = "24")]
IntervalYearmonthValue(i32),
#[prost(int64, tag = "35")]
DurationSecondValue(i64),
#[prost(int64, tag = "36")]
DurationMillisecondValue(i64),
#[prost(int64, tag = "37")]
DurationMicrosecondValue(i64),
#[prost(int64, tag = "38")]
DurationNanosecondValue(i64),
#[prost(message, tag = "26")]
TimestampValue(super::ScalarTimestampValue),
#[prost(message, tag = "27")]
DictionaryValue(::prost::alloc::boxed::Box<super::ScalarDictionaryValue>),
#[prost(bytes, tag = "28")]
BinaryValue(::prost::alloc::vec::Vec<u8>),
#[prost(bytes, tag = "29")]
LargeBinaryValue(::prost::alloc::vec::Vec<u8>),
#[prost(message, tag = "30")]
Time64Value(super::ScalarTime64Value),
#[prost(message, tag = "25")]
IntervalDaytimeValue(super::IntervalDayTimeValue),
#[prost(message, tag = "31")]
IntervalMonthDayNano(super::IntervalMonthDayNanoValue),
#[prost(message, tag = "34")]
FixedSizeBinaryValue(super::ScalarFixedSizeBinary),
#[prost(message, tag = "42")]
UnionValue(::prost::alloc::boxed::Box<super::UnionValue>),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Decimal128 {
#[prost(bytes = "vec", tag = "1")]
pub value: ::prost::alloc::vec::Vec<u8>,
#[prost(int64, tag = "2")]
pub p: i64,
#[prost(int64, tag = "3")]
pub s: i64,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Decimal256 {
#[prost(bytes = "vec", tag = "1")]
pub value: ::prost::alloc::vec::Vec<u8>,
#[prost(int64, tag = "2")]
pub p: i64,
#[prost(int64, tag = "3")]
pub s: i64,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArrowType {
#[prost(
oneof = "arrow_type::ArrowTypeEnum",
tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 32, 15, 16, 31, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 33"
)]
pub arrow_type_enum: ::core::option::Option<arrow_type::ArrowTypeEnum>,
}
pub mod arrow_type {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum ArrowTypeEnum {
#[prost(message, tag = "1")]
None(super::EmptyMessage),
#[prost(message, tag = "2")]
Bool(super::EmptyMessage),
#[prost(message, tag = "3")]
Uint8(super::EmptyMessage),
#[prost(message, tag = "4")]
Int8(super::EmptyMessage),
#[prost(message, tag = "5")]
Uint16(super::EmptyMessage),
#[prost(message, tag = "6")]
Int16(super::EmptyMessage),
#[prost(message, tag = "7")]
Uint32(super::EmptyMessage),
#[prost(message, tag = "8")]
Int32(super::EmptyMessage),
#[prost(message, tag = "9")]
Uint64(super::EmptyMessage),
#[prost(message, tag = "10")]
Int64(super::EmptyMessage),
#[prost(message, tag = "11")]
Float16(super::EmptyMessage),
#[prost(message, tag = "12")]
Float32(super::EmptyMessage),
#[prost(message, tag = "13")]
Float64(super::EmptyMessage),
#[prost(message, tag = "14")]
Utf8(super::EmptyMessage),
#[prost(message, tag = "32")]
LargeUtf8(super::EmptyMessage),
#[prost(message, tag = "15")]
Binary(super::EmptyMessage),
#[prost(int32, tag = "16")]
FixedSizeBinary(i32),
#[prost(message, tag = "31")]
LargeBinary(super::EmptyMessage),
#[prost(message, tag = "17")]
Date32(super::EmptyMessage),
#[prost(message, tag = "18")]
Date64(super::EmptyMessage),
#[prost(enumeration = "super::TimeUnit", tag = "19")]
Duration(i32),
#[prost(message, tag = "20")]
Timestamp(super::Timestamp),
#[prost(enumeration = "super::TimeUnit", tag = "21")]
Time32(i32),
#[prost(enumeration = "super::TimeUnit", tag = "22")]
Time64(i32),
#[prost(enumeration = "super::IntervalUnit", tag = "23")]
Interval(i32),
#[prost(message, tag = "24")]
Decimal(super::Decimal),
#[prost(message, tag = "25")]
List(::prost::alloc::boxed::Box<super::List>),
#[prost(message, tag = "26")]
LargeList(::prost::alloc::boxed::Box<super::List>),
#[prost(message, tag = "27")]
FixedSizeList(::prost::alloc::boxed::Box<super::FixedSizeList>),
#[prost(message, tag = "28")]
Struct(super::Struct),
#[prost(message, tag = "29")]
Union(super::Union),
#[prost(message, tag = "30")]
Dictionary(::prost::alloc::boxed::Box<super::Dictionary>),
#[prost(message, tag = "33")]
Map(::prost::alloc::boxed::Box<super::Map>),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EmptyMessage {}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct JsonWriterOptions {
#[prost(enumeration = "CompressionTypeVariant", tag = "1")]
pub compression: i32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CsvWriterOptions {
#[prost(enumeration = "CompressionTypeVariant", tag = "1")]
pub compression: i32,
#[prost(string, tag = "2")]
pub delimiter: ::prost::alloc::string::String,
#[prost(bool, tag = "3")]
pub has_header: bool,
#[prost(string, tag = "4")]
pub date_format: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub datetime_format: ::prost::alloc::string::String,
#[prost(string, tag = "6")]
pub timestamp_format: ::prost::alloc::string::String,
#[prost(string, tag = "7")]
pub time_format: ::prost::alloc::string::String,
#[prost(string, tag = "8")]
pub null_value: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CsvOptions {
#[prost(bytes = "vec", tag = "1")]
pub has_header: ::prost::alloc::vec::Vec<u8>,
#[prost(bytes = "vec", tag = "2")]
pub delimiter: ::prost::alloc::vec::Vec<u8>,
#[prost(bytes = "vec", tag = "3")]
pub quote: ::prost::alloc::vec::Vec<u8>,
#[prost(bytes = "vec", tag = "4")]
pub escape: ::prost::alloc::vec::Vec<u8>,
#[prost(enumeration = "CompressionTypeVariant", tag = "5")]
pub compression: i32,
#[prost(uint64, tag = "6")]
pub schema_infer_max_rec: u64,
#[prost(string, tag = "7")]
pub date_format: ::prost::alloc::string::String,
#[prost(string, tag = "8")]
pub datetime_format: ::prost::alloc::string::String,
#[prost(string, tag = "9")]
pub timestamp_format: ::prost::alloc::string::String,
#[prost(string, tag = "10")]
pub timestamp_tz_format: ::prost::alloc::string::String,
#[prost(string, tag = "11")]
pub time_format: ::prost::alloc::string::String,
#[prost(string, tag = "12")]
pub null_value: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct JsonOptions {
#[prost(enumeration = "CompressionTypeVariant", tag = "1")]
pub compression: i32,
#[prost(uint64, tag = "2")]
pub schema_infer_max_rec: u64,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableParquetOptions {
#[prost(message, optional, tag = "1")]
pub global: ::core::option::Option<ParquetOptions>,
#[prost(message, repeated, tag = "2")]
pub column_specific_options: ::prost::alloc::vec::Vec<ColumnSpecificOptions>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ColumnSpecificOptions {
#[prost(string, tag = "1")]
pub column_name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub options: ::core::option::Option<ColumnOptions>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ColumnOptions {
#[prost(oneof = "column_options::BloomFilterEnabledOpt", tags = "1")]
pub bloom_filter_enabled_opt: ::core::option::Option<
column_options::BloomFilterEnabledOpt,
>,
#[prost(oneof = "column_options::EncodingOpt", tags = "2")]
pub encoding_opt: ::core::option::Option<column_options::EncodingOpt>,
#[prost(oneof = "column_options::DictionaryEnabledOpt", tags = "3")]
pub dictionary_enabled_opt: ::core::option::Option<
column_options::DictionaryEnabledOpt,
>,
#[prost(oneof = "column_options::CompressionOpt", tags = "4")]
pub compression_opt: ::core::option::Option<column_options::CompressionOpt>,
#[prost(oneof = "column_options::StatisticsEnabledOpt", tags = "5")]
pub statistics_enabled_opt: ::core::option::Option<
column_options::StatisticsEnabledOpt,
>,
#[prost(oneof = "column_options::BloomFilterFppOpt", tags = "6")]
pub bloom_filter_fpp_opt: ::core::option::Option<column_options::BloomFilterFppOpt>,
#[prost(oneof = "column_options::BloomFilterNdvOpt", tags = "7")]
pub bloom_filter_ndv_opt: ::core::option::Option<column_options::BloomFilterNdvOpt>,
#[prost(oneof = "column_options::MaxStatisticsSizeOpt", tags = "8")]
pub max_statistics_size_opt: ::core::option::Option<
column_options::MaxStatisticsSizeOpt,
>,
}
pub mod column_options {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum BloomFilterEnabledOpt {
#[prost(bool, tag = "1")]
BloomFilterEnabled(bool),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum EncodingOpt {
#[prost(string, tag = "2")]
Encoding(::prost::alloc::string::String),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum DictionaryEnabledOpt {
#[prost(bool, tag = "3")]
DictionaryEnabled(bool),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum CompressionOpt {
#[prost(string, tag = "4")]
Compression(::prost::alloc::string::String),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum StatisticsEnabledOpt {
#[prost(string, tag = "5")]
StatisticsEnabled(::prost::alloc::string::String),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum BloomFilterFppOpt {
#[prost(double, tag = "6")]
BloomFilterFpp(f64),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum BloomFilterNdvOpt {
#[prost(uint64, tag = "7")]
BloomFilterNdv(u64),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum MaxStatisticsSizeOpt {
#[prost(uint32, tag = "8")]
MaxStatisticsSize(u32),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ParquetOptions {
#[prost(bool, tag = "1")]
pub enable_page_index: bool,
#[prost(bool, tag = "2")]
pub pruning: bool,
#[prost(bool, tag = "3")]
pub skip_metadata: bool,
#[prost(bool, tag = "5")]
pub pushdown_filters: bool,
#[prost(bool, tag = "6")]
pub reorder_filters: bool,
#[prost(uint64, tag = "7")]
pub data_pagesize_limit: u64,
#[prost(uint64, tag = "8")]
pub write_batch_size: u64,
#[prost(string, tag = "9")]
pub writer_version: ::prost::alloc::string::String,
#[prost(bool, tag = "23")]
pub allow_single_file_parallelism: bool,
#[prost(uint64, tag = "24")]
pub maximum_parallel_row_group_writers: u64,
#[prost(uint64, tag = "25")]
pub maximum_buffered_record_batches_per_stream: u64,
#[prost(bool, tag = "26")]
pub bloom_filter_on_read: bool,
#[prost(bool, tag = "27")]
pub bloom_filter_on_write: bool,
#[prost(uint64, tag = "12")]
pub dictionary_page_size_limit: u64,
#[prost(uint64, tag = "18")]
pub data_page_row_count_limit: u64,
#[prost(uint64, tag = "15")]
pub max_row_group_size: u64,
#[prost(string, tag = "16")]
pub created_by: ::prost::alloc::string::String,
#[prost(oneof = "parquet_options::MetadataSizeHintOpt", tags = "4")]
pub metadata_size_hint_opt: ::core::option::Option<
parquet_options::MetadataSizeHintOpt,
>,
#[prost(oneof = "parquet_options::CompressionOpt", tags = "10")]
pub compression_opt: ::core::option::Option<parquet_options::CompressionOpt>,
#[prost(oneof = "parquet_options::DictionaryEnabledOpt", tags = "11")]
pub dictionary_enabled_opt: ::core::option::Option<
parquet_options::DictionaryEnabledOpt,
>,
#[prost(oneof = "parquet_options::StatisticsEnabledOpt", tags = "13")]
pub statistics_enabled_opt: ::core::option::Option<
parquet_options::StatisticsEnabledOpt,
>,
#[prost(oneof = "parquet_options::MaxStatisticsSizeOpt", tags = "14")]
pub max_statistics_size_opt: ::core::option::Option<
parquet_options::MaxStatisticsSizeOpt,
>,
#[prost(oneof = "parquet_options::ColumnIndexTruncateLengthOpt", tags = "17")]
pub column_index_truncate_length_opt: ::core::option::Option<
parquet_options::ColumnIndexTruncateLengthOpt,
>,
#[prost(oneof = "parquet_options::EncodingOpt", tags = "19")]
pub encoding_opt: ::core::option::Option<parquet_options::EncodingOpt>,
#[prost(oneof = "parquet_options::BloomFilterFppOpt", tags = "21")]
pub bloom_filter_fpp_opt: ::core::option::Option<parquet_options::BloomFilterFppOpt>,
#[prost(oneof = "parquet_options::BloomFilterNdvOpt", tags = "22")]
pub bloom_filter_ndv_opt: ::core::option::Option<parquet_options::BloomFilterNdvOpt>,
}
pub mod parquet_options {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum MetadataSizeHintOpt {
#[prost(uint64, tag = "4")]
MetadataSizeHint(u64),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum CompressionOpt {
#[prost(string, tag = "10")]
Compression(::prost::alloc::string::String),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum DictionaryEnabledOpt {
#[prost(bool, tag = "11")]
DictionaryEnabled(bool),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum StatisticsEnabledOpt {
#[prost(string, tag = "13")]
StatisticsEnabled(::prost::alloc::string::String),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum MaxStatisticsSizeOpt {
#[prost(uint64, tag = "14")]
MaxStatisticsSize(u64),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum ColumnIndexTruncateLengthOpt {
#[prost(uint64, tag = "17")]
ColumnIndexTruncateLength(u64),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum EncodingOpt {
#[prost(string, tag = "19")]
Encoding(::prost::alloc::string::String),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum BloomFilterFppOpt {
#[prost(double, tag = "21")]
BloomFilterFpp(f64),
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum BloomFilterNdvOpt {
#[prost(uint64, tag = "22")]
BloomFilterNdv(u64),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Precision {
#[prost(enumeration = "PrecisionInfo", tag = "1")]
pub precision_info: i32,
#[prost(message, optional, tag = "2")]
pub val: ::core::option::Option<ScalarValue>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Statistics {
#[prost(message, optional, tag = "1")]
pub num_rows: ::core::option::Option<Precision>,
#[prost(message, optional, tag = "2")]
pub total_byte_size: ::core::option::Option<Precision>,
#[prost(message, repeated, tag = "3")]
pub column_stats: ::prost::alloc::vec::Vec<ColumnStats>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ColumnStats {
#[prost(message, optional, tag = "1")]
pub min_value: ::core::option::Option<Precision>,
#[prost(message, optional, tag = "2")]
pub max_value: ::core::option::Option<Precision>,
#[prost(message, optional, tag = "3")]
pub null_count: ::core::option::Option<Precision>,
#[prost(message, optional, tag = "4")]
pub distinct_count: ::core::option::Option<Precision>,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum JoinType {
Inner = 0,
Left = 1,
Right = 2,
Full = 3,
Leftsemi = 4,
Leftanti = 5,
Rightsemi = 6,
Rightanti = 7,
}
impl JoinType {
pub fn as_str_name(&self) -> &'static str {
match self {
JoinType::Inner => "INNER",
JoinType::Left => "LEFT",
JoinType::Right => "RIGHT",
JoinType::Full => "FULL",
JoinType::Leftsemi => "LEFTSEMI",
JoinType::Leftanti => "LEFTANTI",
JoinType::Rightsemi => "RIGHTSEMI",
JoinType::Rightanti => "RIGHTANTI",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"INNER" => Some(Self::Inner),
"LEFT" => Some(Self::Left),
"RIGHT" => Some(Self::Right),
"FULL" => Some(Self::Full),
"LEFTSEMI" => Some(Self::Leftsemi),
"LEFTANTI" => Some(Self::Leftanti),
"RIGHTSEMI" => Some(Self::Rightsemi),
"RIGHTANTI" => Some(Self::Rightanti),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum JoinConstraint {
On = 0,
Using = 1,
}
impl JoinConstraint {
pub fn as_str_name(&self) -> &'static str {
match self {
JoinConstraint::On => "ON",
JoinConstraint::Using => "USING",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"ON" => Some(Self::On),
"USING" => Some(Self::Using),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum TimeUnit {
Second = 0,
Millisecond = 1,
Microsecond = 2,
Nanosecond = 3,
}
impl TimeUnit {
pub fn as_str_name(&self) -> &'static str {
match self {
TimeUnit::Second => "Second",
TimeUnit::Millisecond => "Millisecond",
TimeUnit::Microsecond => "Microsecond",
TimeUnit::Nanosecond => "Nanosecond",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"Second" => Some(Self::Second),
"Millisecond" => Some(Self::Millisecond),
"Microsecond" => Some(Self::Microsecond),
"Nanosecond" => Some(Self::Nanosecond),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum IntervalUnit {
YearMonth = 0,
DayTime = 1,
MonthDayNano = 2,
}
impl IntervalUnit {
pub fn as_str_name(&self) -> &'static str {
match self {
IntervalUnit::YearMonth => "YearMonth",
IntervalUnit::DayTime => "DayTime",
IntervalUnit::MonthDayNano => "MonthDayNano",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"YearMonth" => Some(Self::YearMonth),
"DayTime" => Some(Self::DayTime),
"MonthDayNano" => Some(Self::MonthDayNano),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum UnionMode {
Sparse = 0,
Dense = 1,
}
impl UnionMode {
pub fn as_str_name(&self) -> &'static str {
match self {
UnionMode::Sparse => "sparse",
UnionMode::Dense => "dense",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"sparse" => Some(Self::Sparse),
"dense" => Some(Self::Dense),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum CompressionTypeVariant {
Gzip = 0,
Bzip2 = 1,
Xz = 2,
Zstd = 3,
Uncompressed = 4,
}
impl CompressionTypeVariant {
pub fn as_str_name(&self) -> &'static str {
match self {
CompressionTypeVariant::Gzip => "GZIP",
CompressionTypeVariant::Bzip2 => "BZIP2",
CompressionTypeVariant::Xz => "XZ",
CompressionTypeVariant::Zstd => "ZSTD",
CompressionTypeVariant::Uncompressed => "UNCOMPRESSED",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"GZIP" => Some(Self::Gzip),
"BZIP2" => Some(Self::Bzip2),
"XZ" => Some(Self::Xz),
"ZSTD" => Some(Self::Zstd),
"UNCOMPRESSED" => Some(Self::Uncompressed),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum JoinSide {
LeftSide = 0,
RightSide = 1,
}
impl JoinSide {
pub fn as_str_name(&self) -> &'static str {
match self {
JoinSide::LeftSide => "LEFT_SIDE",
JoinSide::RightSide => "RIGHT_SIDE",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"LEFT_SIDE" => Some(Self::LeftSide),
"RIGHT_SIDE" => Some(Self::RightSide),
_ => None,
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum PrecisionInfo {
Exact = 0,
Inexact = 1,
Absent = 2,
}
impl PrecisionInfo {
pub fn as_str_name(&self) -> &'static str {
match self {
PrecisionInfo::Exact => "EXACT",
PrecisionInfo::Inexact => "INEXACT",
PrecisionInfo::Absent => "ABSENT",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"EXACT" => Some(Self::Exact),
"INEXACT" => Some(Self::Inexact),
"ABSENT" => Some(Self::Absent),
_ => None,
}
}
}