feat: add fulltext options for column (#179)
* feat: add fulltext options for column Signed-off-by: Zhenchi <zhongzc_arch@outlook.com> * feat: use string instead Signed-off-by: Zhenchi <zhongzc_arch@outlook.com> * chore: polish Signed-off-by: Zhenchi <zhongzc_arch@outlook.com> * chore: copy every where Signed-off-by: Zhenchi <zhongzc_arch@outlook.com> * doc: polish Signed-off-by: Zhenchi <zhongzc_arch@outlook.com> * extract as message Signed-off-by: Zhenchi <zhongzc_arch@outlook.com> --------- Signed-off-by: Zhenchi <zhongzc_arch@outlook.com>
This commit is contained in:
Zhenchi
@@ -87,6 +87,7 @@ PROTOBUF_CONSTEXPR Column::Column(
|
||||
, /*decltype(_impl_.null_mask_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
|
||||
, /*decltype(_impl_.values_)*/nullptr
|
||||
, /*decltype(_impl_.datatype_extension_)*/nullptr
|
||||
, /*decltype(_impl_.options_)*/nullptr
|
||||
, /*decltype(_impl_.semantic_type_)*/0
|
||||
, /*decltype(_impl_.datatype_)*/0
|
||||
, /*decltype(_impl_._cached_size_)*/{}} {}
|
||||
@@ -151,6 +152,7 @@ const uint32_t TableStruct_greptime_2fv1_2fcolumn_2eproto::offsets[] PROTOBUF_SE
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::Column, _impl_.null_mask_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::Column, _impl_.datatype_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::Column, _impl_.datatype_extension_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::Column, _impl_.options_),
|
||||
};
|
||||
static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
|
||||
{ 0, -1, -1, sizeof(::greptime::v1::Column_Values)},
|
||||
@@ -164,43 +166,44 @@ static const ::_pb::Message* const file_default_instances[] = {
|
||||
|
||||
const char descriptor_table_protodef_greptime_2fv1_2fcolumn_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) =
|
||||
"\n\030greptime/v1/column.proto\022\013greptime.v1\032"
|
||||
"\030greptime/v1/common.proto\"\226\010\n\006Column\022\023\n\013"
|
||||
"\030greptime/v1/common.proto\"\303\010\n\006Column\022\023\n\013"
|
||||
"column_name\030\001 \001(\t\0220\n\rsemantic_type\030\002 \001(\016"
|
||||
"2\031.greptime.v1.SemanticType\022*\n\006values\030\003 "
|
||||
"\001(\0132\032.greptime.v1.Column.Values\022\021\n\tnull_"
|
||||
"mask\030\004 \001(\014\022-\n\010datatype\030\005 \001(\0162\033.greptime."
|
||||
"v1.ColumnDataType\022@\n\022datatype_extension\030"
|
||||
"\006 \001(\0132$.greptime.v1.ColumnDataTypeExtens"
|
||||
"ion\032\224\006\n\006Values\022\021\n\ti8_values\030\001 \003(\005\022\022\n\ni16"
|
||||
"_values\030\002 \003(\005\022\022\n\ni32_values\030\003 \003(\005\022\022\n\ni64"
|
||||
"_values\030\004 \003(\003\022\021\n\tu8_values\030\005 \003(\r\022\022\n\nu16_"
|
||||
"values\030\006 \003(\r\022\022\n\nu32_values\030\007 \003(\r\022\022\n\nu64_"
|
||||
"values\030\010 \003(\004\022\022\n\nf32_values\030\t \003(\002\022\022\n\nf64_"
|
||||
"values\030\n \003(\001\022\023\n\013bool_values\030\013 \003(\010\022\025\n\rbin"
|
||||
"ary_values\030\014 \003(\014\022\025\n\rstring_values\030\r \003(\t\022"
|
||||
"\023\n\013date_values\030\016 \003(\005\022\027\n\017datetime_values\030"
|
||||
"\017 \003(\003\022\037\n\027timestamp_second_values\030\020 \003(\003\022$"
|
||||
"\n\034timestamp_millisecond_values\030\021 \003(\003\022$\n\034"
|
||||
"timestamp_microsecond_values\030\022 \003(\003\022#\n\033ti"
|
||||
"mestamp_nanosecond_values\030\023 \003(\003\022\032\n\022time_"
|
||||
"second_values\030\024 \003(\003\022\037\n\027time_millisecond_"
|
||||
"values\030\025 \003(\003\022\037\n\027time_microsecond_values\030"
|
||||
"\026 \003(\003\022\036\n\026time_nanosecond_values\030\027 \003(\003\022\"\n"
|
||||
"\032interval_year_month_values\030\030 \003(\005\022 \n\030int"
|
||||
"erval_day_time_values\030\031 \003(\003\022I\n\036interval_"
|
||||
"month_day_nano_values\030\032 \003(\0132!.greptime.v"
|
||||
"1.IntervalMonthDayNano\0222\n\021decimal128_val"
|
||||
"ues\030\037 \003(\0132\027.greptime.v1.Decimal128BP\n\016io"
|
||||
".greptime.v1B\007ColumnsZ5github.com/Grepti"
|
||||
"meTeam/greptime-proto/go/greptime/v1b\006pr"
|
||||
"oto3"
|
||||
"ion\022+\n\007options\030\007 \001(\0132\032.greptime.v1.Colum"
|
||||
"nOptions\032\224\006\n\006Values\022\021\n\ti8_values\030\001 \003(\005\022\022"
|
||||
"\n\ni16_values\030\002 \003(\005\022\022\n\ni32_values\030\003 \003(\005\022\022"
|
||||
"\n\ni64_values\030\004 \003(\003\022\021\n\tu8_values\030\005 \003(\r\022\022\n"
|
||||
"\nu16_values\030\006 \003(\r\022\022\n\nu32_values\030\007 \003(\r\022\022\n"
|
||||
"\nu64_values\030\010 \003(\004\022\022\n\nf32_values\030\t \003(\002\022\022\n"
|
||||
"\nf64_values\030\n \003(\001\022\023\n\013bool_values\030\013 \003(\010\022\025"
|
||||
"\n\rbinary_values\030\014 \003(\014\022\025\n\rstring_values\030\r"
|
||||
" \003(\t\022\023\n\013date_values\030\016 \003(\005\022\027\n\017datetime_va"
|
||||
"lues\030\017 \003(\003\022\037\n\027timestamp_second_values\030\020 "
|
||||
"\003(\003\022$\n\034timestamp_millisecond_values\030\021 \003("
|
||||
"\003\022$\n\034timestamp_microsecond_values\030\022 \003(\003\022"
|
||||
"#\n\033timestamp_nanosecond_values\030\023 \003(\003\022\032\n\022"
|
||||
"time_second_values\030\024 \003(\003\022\037\n\027time_millise"
|
||||
"cond_values\030\025 \003(\003\022\037\n\027time_microsecond_va"
|
||||
"lues\030\026 \003(\003\022\036\n\026time_nanosecond_values\030\027 \003"
|
||||
"(\003\022\"\n\032interval_year_month_values\030\030 \003(\005\022 "
|
||||
"\n\030interval_day_time_values\030\031 \003(\003\022I\n\036inte"
|
||||
"rval_month_day_nano_values\030\032 \003(\0132!.grept"
|
||||
"ime.v1.IntervalMonthDayNano\0222\n\021decimal12"
|
||||
"8_values\030\037 \003(\0132\027.greptime.v1.Decimal128B"
|
||||
"P\n\016io.greptime.v1B\007ColumnsZ5github.com/G"
|
||||
"reptimeTeam/greptime-proto/go/greptime/v"
|
||||
"1b\006proto3"
|
||||
;
|
||||
static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2fcolumn_2eproto_deps[1] = {
|
||||
&::descriptor_table_greptime_2fv1_2fcommon_2eproto,
|
||||
};
|
||||
static ::_pbi::once_flag descriptor_table_greptime_2fv1_2fcolumn_2eproto_once;
|
||||
const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2fcolumn_2eproto = {
|
||||
false, false, 1204, descriptor_table_protodef_greptime_2fv1_2fcolumn_2eproto,
|
||||
false, false, 1249, descriptor_table_protodef_greptime_2fv1_2fcolumn_2eproto,
|
||||
"greptime/v1/column.proto",
|
||||
&descriptor_table_greptime_2fv1_2fcolumn_2eproto_once, descriptor_table_greptime_2fv1_2fcolumn_2eproto_deps, 1, 2,
|
||||
schemas, file_default_instances, TableStruct_greptime_2fv1_2fcolumn_2eproto::offsets,
|
||||
@@ -1459,6 +1462,7 @@ class Column::_Internal {
|
||||
public:
|
||||
static const ::greptime::v1::Column_Values& values(const Column* msg);
|
||||
static const ::greptime::v1::ColumnDataTypeExtension& datatype_extension(const Column* msg);
|
||||
static const ::greptime::v1::ColumnOptions& options(const Column* msg);
|
||||
};
|
||||
|
||||
const ::greptime::v1::Column_Values&
|
||||
@@ -1469,12 +1473,22 @@ const ::greptime::v1::ColumnDataTypeExtension&
|
||||
Column::_Internal::datatype_extension(const Column* msg) {
|
||||
return *msg->_impl_.datatype_extension_;
|
||||
}
|
||||
const ::greptime::v1::ColumnOptions&
|
||||
Column::_Internal::options(const Column* msg) {
|
||||
return *msg->_impl_.options_;
|
||||
}
|
||||
void Column::clear_datatype_extension() {
|
||||
if (GetArenaForAllocation() == nullptr && _impl_.datatype_extension_ != nullptr) {
|
||||
delete _impl_.datatype_extension_;
|
||||
}
|
||||
_impl_.datatype_extension_ = nullptr;
|
||||
}
|
||||
void Column::clear_options() {
|
||||
if (GetArenaForAllocation() == nullptr && _impl_.options_ != nullptr) {
|
||||
delete _impl_.options_;
|
||||
}
|
||||
_impl_.options_ = nullptr;
|
||||
}
|
||||
Column::Column(::PROTOBUF_NAMESPACE_ID::Arena* arena,
|
||||
bool is_message_owned)
|
||||
: ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
|
||||
@@ -1489,6 +1503,7 @@ Column::Column(const Column& from)
|
||||
, decltype(_impl_.null_mask_){}
|
||||
, decltype(_impl_.values_){nullptr}
|
||||
, decltype(_impl_.datatype_extension_){nullptr}
|
||||
, decltype(_impl_.options_){nullptr}
|
||||
, decltype(_impl_.semantic_type_){}
|
||||
, decltype(_impl_.datatype_){}
|
||||
, /*decltype(_impl_._cached_size_)*/{}};
|
||||
@@ -1516,6 +1531,9 @@ Column::Column(const Column& from)
|
||||
if (from._internal_has_datatype_extension()) {
|
||||
_this->_impl_.datatype_extension_ = new ::greptime::v1::ColumnDataTypeExtension(*from._impl_.datatype_extension_);
|
||||
}
|
||||
if (from._internal_has_options()) {
|
||||
_this->_impl_.options_ = new ::greptime::v1::ColumnOptions(*from._impl_.options_);
|
||||
}
|
||||
::memcpy(&_impl_.semantic_type_, &from._impl_.semantic_type_,
|
||||
static_cast<size_t>(reinterpret_cast<char*>(&_impl_.datatype_) -
|
||||
reinterpret_cast<char*>(&_impl_.semantic_type_)) + sizeof(_impl_.datatype_));
|
||||
@@ -1531,6 +1549,7 @@ inline void Column::SharedCtor(
|
||||
, decltype(_impl_.null_mask_){}
|
||||
, decltype(_impl_.values_){nullptr}
|
||||
, decltype(_impl_.datatype_extension_){nullptr}
|
||||
, decltype(_impl_.options_){nullptr}
|
||||
, decltype(_impl_.semantic_type_){0}
|
||||
, decltype(_impl_.datatype_){0}
|
||||
, /*decltype(_impl_._cached_size_)*/{}
|
||||
@@ -1560,6 +1579,7 @@ inline void Column::SharedDtor() {
|
||||
_impl_.null_mask_.Destroy();
|
||||
if (this != internal_default_instance()) delete _impl_.values_;
|
||||
if (this != internal_default_instance()) delete _impl_.datatype_extension_;
|
||||
if (this != internal_default_instance()) delete _impl_.options_;
|
||||
}
|
||||
|
||||
void Column::SetCachedSize(int size) const {
|
||||
@@ -1582,6 +1602,10 @@ void Column::Clear() {
|
||||
delete _impl_.datatype_extension_;
|
||||
}
|
||||
_impl_.datatype_extension_ = nullptr;
|
||||
if (GetArenaForAllocation() == nullptr && _impl_.options_ != nullptr) {
|
||||
delete _impl_.options_;
|
||||
}
|
||||
_impl_.options_ = nullptr;
|
||||
::memset(&_impl_.semantic_type_, 0, static_cast<size_t>(
|
||||
reinterpret_cast<char*>(&_impl_.datatype_) -
|
||||
reinterpret_cast<char*>(&_impl_.semantic_type_)) + sizeof(_impl_.datatype_));
|
||||
@@ -1647,6 +1671,14 @@ const char* Column::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
|
||||
} else
|
||||
goto handle_unusual;
|
||||
continue;
|
||||
// .greptime.v1.ColumnOptions options = 7;
|
||||
case 7:
|
||||
if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 58)) {
|
||||
ptr = ctx->ParseMessage(_internal_mutable_options(), ptr);
|
||||
CHK_(ptr);
|
||||
} else
|
||||
goto handle_unusual;
|
||||
continue;
|
||||
default:
|
||||
goto handle_unusual;
|
||||
} // switch
|
||||
@@ -1720,6 +1752,13 @@ uint8_t* Column::_InternalSerialize(
|
||||
_Internal::datatype_extension(this).GetCachedSize(), target, stream);
|
||||
}
|
||||
|
||||
// .greptime.v1.ColumnOptions options = 7;
|
||||
if (this->_internal_has_options()) {
|
||||
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
||||
InternalWriteMessage(7, _Internal::options(this),
|
||||
_Internal::options(this).GetCachedSize(), target, stream);
|
||||
}
|
||||
|
||||
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
||||
target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
|
||||
_internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
|
||||
@@ -1764,6 +1803,13 @@ size_t Column::ByteSizeLong() const {
|
||||
*_impl_.datatype_extension_);
|
||||
}
|
||||
|
||||
// .greptime.v1.ColumnOptions options = 7;
|
||||
if (this->_internal_has_options()) {
|
||||
total_size += 1 +
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
||||
*_impl_.options_);
|
||||
}
|
||||
|
||||
// .greptime.v1.SemanticType semantic_type = 2;
|
||||
if (this->_internal_semantic_type() != 0) {
|
||||
total_size += 1 +
|
||||
@@ -1808,6 +1854,10 @@ void Column::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBU
|
||||
_this->_internal_mutable_datatype_extension()->::greptime::v1::ColumnDataTypeExtension::MergeFrom(
|
||||
from._internal_datatype_extension());
|
||||
}
|
||||
if (from._internal_has_options()) {
|
||||
_this->_internal_mutable_options()->::greptime::v1::ColumnOptions::MergeFrom(
|
||||
from._internal_options());
|
||||
}
|
||||
if (from._internal_semantic_type() != 0) {
|
||||
_this->_internal_set_semantic_type(from._internal_semantic_type());
|
||||
}
|
||||
|
||||
@@ -992,6 +992,7 @@ class Column final :
|
||||
kNullMaskFieldNumber = 4,
|
||||
kValuesFieldNumber = 3,
|
||||
kDatatypeExtensionFieldNumber = 6,
|
||||
kOptionsFieldNumber = 7,
|
||||
kSemanticTypeFieldNumber = 2,
|
||||
kDatatypeFieldNumber = 5,
|
||||
};
|
||||
@@ -1059,6 +1060,24 @@ class Column final :
|
||||
::greptime::v1::ColumnDataTypeExtension* datatype_extension);
|
||||
::greptime::v1::ColumnDataTypeExtension* unsafe_arena_release_datatype_extension();
|
||||
|
||||
// .greptime.v1.ColumnOptions options = 7;
|
||||
bool has_options() const;
|
||||
private:
|
||||
bool _internal_has_options() const;
|
||||
public:
|
||||
void clear_options();
|
||||
const ::greptime::v1::ColumnOptions& options() const;
|
||||
PROTOBUF_NODISCARD ::greptime::v1::ColumnOptions* release_options();
|
||||
::greptime::v1::ColumnOptions* mutable_options();
|
||||
void set_allocated_options(::greptime::v1::ColumnOptions* options);
|
||||
private:
|
||||
const ::greptime::v1::ColumnOptions& _internal_options() const;
|
||||
::greptime::v1::ColumnOptions* _internal_mutable_options();
|
||||
public:
|
||||
void unsafe_arena_set_allocated_options(
|
||||
::greptime::v1::ColumnOptions* options);
|
||||
::greptime::v1::ColumnOptions* unsafe_arena_release_options();
|
||||
|
||||
// .greptime.v1.SemanticType semantic_type = 2;
|
||||
void clear_semantic_type();
|
||||
::greptime::v1::SemanticType semantic_type() const;
|
||||
@@ -1089,6 +1108,7 @@ class Column final :
|
||||
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr null_mask_;
|
||||
::greptime::v1::Column_Values* values_;
|
||||
::greptime::v1::ColumnDataTypeExtension* datatype_extension_;
|
||||
::greptime::v1::ColumnOptions* options_;
|
||||
int semantic_type_;
|
||||
int datatype_;
|
||||
mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
|
||||
@@ -2731,6 +2751,91 @@ inline void Column::set_allocated_datatype_extension(::greptime::v1::ColumnDataT
|
||||
// @@protoc_insertion_point(field_set_allocated:greptime.v1.Column.datatype_extension)
|
||||
}
|
||||
|
||||
// .greptime.v1.ColumnOptions options = 7;
|
||||
inline bool Column::_internal_has_options() const {
|
||||
return this != internal_default_instance() && _impl_.options_ != nullptr;
|
||||
}
|
||||
inline bool Column::has_options() const {
|
||||
return _internal_has_options();
|
||||
}
|
||||
inline const ::greptime::v1::ColumnOptions& Column::_internal_options() const {
|
||||
const ::greptime::v1::ColumnOptions* p = _impl_.options_;
|
||||
return p != nullptr ? *p : reinterpret_cast<const ::greptime::v1::ColumnOptions&>(
|
||||
::greptime::v1::_ColumnOptions_default_instance_);
|
||||
}
|
||||
inline const ::greptime::v1::ColumnOptions& Column::options() const {
|
||||
// @@protoc_insertion_point(field_get:greptime.v1.Column.options)
|
||||
return _internal_options();
|
||||
}
|
||||
inline void Column::unsafe_arena_set_allocated_options(
|
||||
::greptime::v1::ColumnOptions* options) {
|
||||
if (GetArenaForAllocation() == nullptr) {
|
||||
delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.options_);
|
||||
}
|
||||
_impl_.options_ = options;
|
||||
if (options) {
|
||||
|
||||
} else {
|
||||
|
||||
}
|
||||
// @@protoc_insertion_point(field_unsafe_arena_set_allocated:greptime.v1.Column.options)
|
||||
}
|
||||
inline ::greptime::v1::ColumnOptions* Column::release_options() {
|
||||
|
||||
::greptime::v1::ColumnOptions* temp = _impl_.options_;
|
||||
_impl_.options_ = nullptr;
|
||||
#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
|
||||
auto* old = reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp);
|
||||
temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
|
||||
if (GetArenaForAllocation() == nullptr) { delete old; }
|
||||
#else // PROTOBUF_FORCE_COPY_IN_RELEASE
|
||||
if (GetArenaForAllocation() != nullptr) {
|
||||
temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
|
||||
}
|
||||
#endif // !PROTOBUF_FORCE_COPY_IN_RELEASE
|
||||
return temp;
|
||||
}
|
||||
inline ::greptime::v1::ColumnOptions* Column::unsafe_arena_release_options() {
|
||||
// @@protoc_insertion_point(field_release:greptime.v1.Column.options)
|
||||
|
||||
::greptime::v1::ColumnOptions* temp = _impl_.options_;
|
||||
_impl_.options_ = nullptr;
|
||||
return temp;
|
||||
}
|
||||
inline ::greptime::v1::ColumnOptions* Column::_internal_mutable_options() {
|
||||
|
||||
if (_impl_.options_ == nullptr) {
|
||||
auto* p = CreateMaybeMessage<::greptime::v1::ColumnOptions>(GetArenaForAllocation());
|
||||
_impl_.options_ = p;
|
||||
}
|
||||
return _impl_.options_;
|
||||
}
|
||||
inline ::greptime::v1::ColumnOptions* Column::mutable_options() {
|
||||
::greptime::v1::ColumnOptions* _msg = _internal_mutable_options();
|
||||
// @@protoc_insertion_point(field_mutable:greptime.v1.Column.options)
|
||||
return _msg;
|
||||
}
|
||||
inline void Column::set_allocated_options(::greptime::v1::ColumnOptions* options) {
|
||||
::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
|
||||
if (message_arena == nullptr) {
|
||||
delete reinterpret_cast< ::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.options_);
|
||||
}
|
||||
if (options) {
|
||||
::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
|
||||
::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(
|
||||
reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(options));
|
||||
if (message_arena != submessage_arena) {
|
||||
options = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
|
||||
message_arena, options, submessage_arena);
|
||||
}
|
||||
|
||||
} else {
|
||||
|
||||
}
|
||||
_impl_.options_ = options;
|
||||
// @@protoc_insertion_point(field_set_allocated:greptime.v1.Column.options)
|
||||
}
|
||||
|
||||
#ifdef __GNUC__
|
||||
#pragma GCC diagnostic pop
|
||||
#endif // __GNUC__
|
||||
|
||||
+309
-20
@@ -271,9 +271,33 @@ struct DecimalTypeExtensionDefaultTypeInternal {
|
||||
};
|
||||
};
|
||||
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 DecimalTypeExtensionDefaultTypeInternal _DecimalTypeExtension_default_instance_;
|
||||
PROTOBUF_CONSTEXPR ColumnOptions_OptionsEntry_DoNotUse::ColumnOptions_OptionsEntry_DoNotUse(
|
||||
::_pbi::ConstantInitialized) {}
|
||||
struct ColumnOptions_OptionsEntry_DoNotUseDefaultTypeInternal {
|
||||
PROTOBUF_CONSTEXPR ColumnOptions_OptionsEntry_DoNotUseDefaultTypeInternal()
|
||||
: _instance(::_pbi::ConstantInitialized{}) {}
|
||||
~ColumnOptions_OptionsEntry_DoNotUseDefaultTypeInternal() {}
|
||||
union {
|
||||
ColumnOptions_OptionsEntry_DoNotUse _instance;
|
||||
};
|
||||
};
|
||||
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 ColumnOptions_OptionsEntry_DoNotUseDefaultTypeInternal _ColumnOptions_OptionsEntry_DoNotUse_default_instance_;
|
||||
PROTOBUF_CONSTEXPR ColumnOptions::ColumnOptions(
|
||||
::_pbi::ConstantInitialized): _impl_{
|
||||
/*decltype(_impl_.options_)*/{::_pbi::ConstantInitialized()}
|
||||
, /*decltype(_impl_._cached_size_)*/{}} {}
|
||||
struct ColumnOptionsDefaultTypeInternal {
|
||||
PROTOBUF_CONSTEXPR ColumnOptionsDefaultTypeInternal()
|
||||
: _instance(::_pbi::ConstantInitialized{}) {}
|
||||
~ColumnOptionsDefaultTypeInternal() {}
|
||||
union {
|
||||
ColumnOptions _instance;
|
||||
};
|
||||
};
|
||||
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 ColumnOptionsDefaultTypeInternal _ColumnOptions_default_instance_;
|
||||
} // namespace v1
|
||||
} // namespace greptime
|
||||
static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fcommon_2eproto[18];
|
||||
static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fcommon_2eproto[20];
|
||||
static const ::_pb::EnumDescriptor* file_level_enum_descriptors_greptime_2fv1_2fcommon_2eproto[2];
|
||||
static constexpr ::_pb::ServiceDescriptor const** file_level_service_descriptors_greptime_2fv1_2fcommon_2eproto = nullptr;
|
||||
|
||||
@@ -430,6 +454,23 @@ const uint32_t TableStruct_greptime_2fv1_2fcommon_2eproto::offsets[] PROTOBUF_SE
|
||||
~0u, // no _inlined_string_donated_
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::DecimalTypeExtension, _impl_.precision_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::DecimalTypeExtension, _impl_.scale_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnOptions_OptionsEntry_DoNotUse, _has_bits_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnOptions_OptionsEntry_DoNotUse, _internal_metadata_),
|
||||
~0u, // no _extensions_
|
||||
~0u, // no _oneof_case_
|
||||
~0u, // no _weak_field_map_
|
||||
~0u, // no _inlined_string_donated_
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnOptions_OptionsEntry_DoNotUse, key_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnOptions_OptionsEntry_DoNotUse, value_),
|
||||
0,
|
||||
1,
|
||||
~0u, // no _has_bits_
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnOptions, _internal_metadata_),
|
||||
~0u, // no _extensions_
|
||||
~0u, // no _oneof_case_
|
||||
~0u, // no _weak_field_map_
|
||||
~0u, // no _inlined_string_donated_
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnOptions, _impl_.options_),
|
||||
};
|
||||
static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
|
||||
{ 0, 8, -1, sizeof(::greptime::v1::QueryContext_ExtensionsEntry_DoNotUse)},
|
||||
@@ -450,6 +491,8 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode
|
||||
{ 128, -1, -1, sizeof(::greptime::v1::Decimal128)},
|
||||
{ 136, -1, -1, sizeof(::greptime::v1::ColumnDataTypeExtension)},
|
||||
{ 144, -1, -1, sizeof(::greptime::v1::DecimalTypeExtension)},
|
||||
{ 152, 160, -1, sizeof(::greptime::v1::ColumnOptions_OptionsEntry_DoNotUse)},
|
||||
{ 162, -1, -1, sizeof(::greptime::v1::ColumnOptions)},
|
||||
};
|
||||
|
||||
static const ::_pb::Message* const file_default_instances[] = {
|
||||
@@ -471,6 +514,8 @@ static const ::_pb::Message* const file_default_instances[] = {
|
||||
&::greptime::v1::_Decimal128_default_instance_._instance,
|
||||
&::greptime::v1::_ColumnDataTypeExtension_default_instance_._instance,
|
||||
&::greptime::v1::_DecimalTypeExtension_default_instance_._instance,
|
||||
&::greptime::v1::_ColumnOptions_OptionsEntry_DoNotUse_default_instance_._instance,
|
||||
&::greptime::v1::_ColumnOptions_default_instance_._instance,
|
||||
};
|
||||
|
||||
const char descriptor_table_protodef_greptime_2fv1_2fcommon_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) =
|
||||
@@ -506,29 +551,32 @@ const char descriptor_table_protodef_greptime_2fv1_2fcommon_2eproto[] PROTOBUF_S
|
||||
"\n\027ColumnDataTypeExtension\0229\n\014decimal_typ"
|
||||
"e\030\001 \001(\0132!.greptime.v1.DecimalTypeExtensi"
|
||||
"onH\000B\n\n\010type_ext\"8\n\024DecimalTypeExtension"
|
||||
"\022\021\n\tprecision\030\001 \001(\005\022\r\n\005scale\030\002 \001(\005*1\n\014Se"
|
||||
"manticType\022\007\n\003TAG\020\000\022\t\n\005FIELD\020\001\022\r\n\tTIMEST"
|
||||
"AMP\020\002*\326\003\n\016ColumnDataType\022\013\n\007BOOLEAN\020\000\022\010\n"
|
||||
"\004INT8\020\001\022\t\n\005INT16\020\002\022\t\n\005INT32\020\003\022\t\n\005INT64\020\004"
|
||||
"\022\t\n\005UINT8\020\005\022\n\n\006UINT16\020\006\022\n\n\006UINT32\020\007\022\n\n\006U"
|
||||
"INT64\020\010\022\013\n\007FLOAT32\020\t\022\013\n\007FLOAT64\020\n\022\n\n\006BIN"
|
||||
"ARY\020\013\022\n\n\006STRING\020\014\022\010\n\004DATE\020\r\022\014\n\010DATETIME\020"
|
||||
"\016\022\024\n\020TIMESTAMP_SECOND\020\017\022\031\n\025TIMESTAMP_MIL"
|
||||
"LISECOND\020\020\022\031\n\025TIMESTAMP_MICROSECOND\020\021\022\030\n"
|
||||
"\024TIMESTAMP_NANOSECOND\020\022\022\017\n\013TIME_SECOND\020\023"
|
||||
"\022\024\n\020TIME_MILLISECOND\020\024\022\024\n\020TIME_MICROSECO"
|
||||
"ND\020\025\022\023\n\017TIME_NANOSECOND\020\026\022\027\n\023INTERVAL_YE"
|
||||
"AR_MONTH\020\027\022\025\n\021INTERVAL_DAY_TIME\020\030\022\033\n\027INT"
|
||||
"ERVAL_MONTH_DAY_NANO\020\031\022\016\n\nDECIMAL128\020\036BO"
|
||||
"\n\016io.greptime.v1B\006CommonZ5github.com/Gre"
|
||||
"ptimeTeam/greptime-proto/go/greptime/v1b"
|
||||
"\006proto3"
|
||||
"\022\021\n\tprecision\030\001 \001(\005\022\r\n\005scale\030\002 \001(\005\"y\n\rCo"
|
||||
"lumnOptions\0228\n\007options\030\001 \003(\0132\'.greptime."
|
||||
"v1.ColumnOptions.OptionsEntry\032.\n\014Options"
|
||||
"Entry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001*1\n"
|
||||
"\014SemanticType\022\007\n\003TAG\020\000\022\t\n\005FIELD\020\001\022\r\n\tTIM"
|
||||
"ESTAMP\020\002*\326\003\n\016ColumnDataType\022\013\n\007BOOLEAN\020\000"
|
||||
"\022\010\n\004INT8\020\001\022\t\n\005INT16\020\002\022\t\n\005INT32\020\003\022\t\n\005INT6"
|
||||
"4\020\004\022\t\n\005UINT8\020\005\022\n\n\006UINT16\020\006\022\n\n\006UINT32\020\007\022\n"
|
||||
"\n\006UINT64\020\010\022\013\n\007FLOAT32\020\t\022\013\n\007FLOAT64\020\n\022\n\n\006"
|
||||
"BINARY\020\013\022\n\n\006STRING\020\014\022\010\n\004DATE\020\r\022\014\n\010DATETI"
|
||||
"ME\020\016\022\024\n\020TIMESTAMP_SECOND\020\017\022\031\n\025TIMESTAMP_"
|
||||
"MILLISECOND\020\020\022\031\n\025TIMESTAMP_MICROSECOND\020\021"
|
||||
"\022\030\n\024TIMESTAMP_NANOSECOND\020\022\022\017\n\013TIME_SECON"
|
||||
"D\020\023\022\024\n\020TIME_MILLISECOND\020\024\022\024\n\020TIME_MICROS"
|
||||
"ECOND\020\025\022\023\n\017TIME_NANOSECOND\020\026\022\027\n\023INTERVAL"
|
||||
"_YEAR_MONTH\020\027\022\025\n\021INTERVAL_DAY_TIME\020\030\022\033\n\027"
|
||||
"INTERVAL_MONTH_DAY_NANO\020\031\022\016\n\nDECIMAL128\020"
|
||||
"\036BO\n\016io.greptime.v1B\006CommonZ5github.com/"
|
||||
"GreptimeTeam/greptime-proto/go/greptime/"
|
||||
"v1b\006proto3"
|
||||
;
|
||||
static ::_pbi::once_flag descriptor_table_greptime_2fv1_2fcommon_2eproto_once;
|
||||
const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2fcommon_2eproto = {
|
||||
false, false, 1927, descriptor_table_protodef_greptime_2fv1_2fcommon_2eproto,
|
||||
false, false, 2050, descriptor_table_protodef_greptime_2fv1_2fcommon_2eproto,
|
||||
"greptime/v1/common.proto",
|
||||
&descriptor_table_greptime_2fv1_2fcommon_2eproto_once, nullptr, 0, 18,
|
||||
&descriptor_table_greptime_2fv1_2fcommon_2eproto_once, nullptr, 0, 20,
|
||||
schemas, file_default_instances, TableStruct_greptime_2fv1_2fcommon_2eproto::offsets,
|
||||
file_level_metadata_greptime_2fv1_2fcommon_2eproto, file_level_enum_descriptors_greptime_2fv1_2fcommon_2eproto,
|
||||
file_level_service_descriptors_greptime_2fv1_2fcommon_2eproto,
|
||||
@@ -4642,6 +4690,239 @@ void DecimalTypeExtension::InternalSwap(DecimalTypeExtension* other) {
|
||||
file_level_metadata_greptime_2fv1_2fcommon_2eproto[17]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
|
||||
ColumnOptions_OptionsEntry_DoNotUse::ColumnOptions_OptionsEntry_DoNotUse() {}
|
||||
ColumnOptions_OptionsEntry_DoNotUse::ColumnOptions_OptionsEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena)
|
||||
: SuperType(arena) {}
|
||||
void ColumnOptions_OptionsEntry_DoNotUse::MergeFrom(const ColumnOptions_OptionsEntry_DoNotUse& other) {
|
||||
MergeFromInternal(other);
|
||||
}
|
||||
::PROTOBUF_NAMESPACE_ID::Metadata ColumnOptions_OptionsEntry_DoNotUse::GetMetadata() const {
|
||||
return ::_pbi::AssignDescriptors(
|
||||
&descriptor_table_greptime_2fv1_2fcommon_2eproto_getter, &descriptor_table_greptime_2fv1_2fcommon_2eproto_once,
|
||||
file_level_metadata_greptime_2fv1_2fcommon_2eproto[18]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
|
||||
class ColumnOptions::_Internal {
|
||||
public:
|
||||
};
|
||||
|
||||
ColumnOptions::ColumnOptions(::PROTOBUF_NAMESPACE_ID::Arena* arena,
|
||||
bool is_message_owned)
|
||||
: ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
|
||||
SharedCtor(arena, is_message_owned);
|
||||
if (arena != nullptr && !is_message_owned) {
|
||||
arena->OwnCustomDestructor(this, &ColumnOptions::ArenaDtor);
|
||||
}
|
||||
// @@protoc_insertion_point(arena_constructor:greptime.v1.ColumnOptions)
|
||||
}
|
||||
ColumnOptions::ColumnOptions(const ColumnOptions& from)
|
||||
: ::PROTOBUF_NAMESPACE_ID::Message() {
|
||||
ColumnOptions* const _this = this; (void)_this;
|
||||
new (&_impl_) Impl_{
|
||||
/*decltype(_impl_.options_)*/{}
|
||||
, /*decltype(_impl_._cached_size_)*/{}};
|
||||
|
||||
_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
|
||||
_this->_impl_.options_.MergeFrom(from._impl_.options_);
|
||||
// @@protoc_insertion_point(copy_constructor:greptime.v1.ColumnOptions)
|
||||
}
|
||||
|
||||
inline void ColumnOptions::SharedCtor(
|
||||
::_pb::Arena* arena, bool is_message_owned) {
|
||||
(void)arena;
|
||||
(void)is_message_owned;
|
||||
new (&_impl_) Impl_{
|
||||
/*decltype(_impl_.options_)*/{::_pbi::ArenaInitialized(), arena}
|
||||
, /*decltype(_impl_._cached_size_)*/{}
|
||||
};
|
||||
}
|
||||
|
||||
ColumnOptions::~ColumnOptions() {
|
||||
// @@protoc_insertion_point(destructor:greptime.v1.ColumnOptions)
|
||||
if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) {
|
||||
(void)arena;
|
||||
ArenaDtor(this);
|
||||
return;
|
||||
}
|
||||
SharedDtor();
|
||||
}
|
||||
|
||||
inline void ColumnOptions::SharedDtor() {
|
||||
GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
|
||||
_impl_.options_.Destruct();
|
||||
_impl_.options_.~MapField();
|
||||
}
|
||||
|
||||
void ColumnOptions::ArenaDtor(void* object) {
|
||||
ColumnOptions* _this = reinterpret_cast< ColumnOptions* >(object);
|
||||
_this->_impl_.options_.Destruct();
|
||||
}
|
||||
void ColumnOptions::SetCachedSize(int size) const {
|
||||
_impl_._cached_size_.Set(size);
|
||||
}
|
||||
|
||||
void ColumnOptions::Clear() {
|
||||
// @@protoc_insertion_point(message_clear_start:greptime.v1.ColumnOptions)
|
||||
uint32_t cached_has_bits = 0;
|
||||
// Prevent compiler warnings about cached_has_bits being unused
|
||||
(void) cached_has_bits;
|
||||
|
||||
_impl_.options_.Clear();
|
||||
_internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
|
||||
}
|
||||
|
||||
const char* ColumnOptions::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
|
||||
#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
|
||||
while (!ctx->Done(&ptr)) {
|
||||
uint32_t tag;
|
||||
ptr = ::_pbi::ReadTag(ptr, &tag);
|
||||
switch (tag >> 3) {
|
||||
// map<string, string> options = 1;
|
||||
case 1:
|
||||
if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 10)) {
|
||||
ptr -= 1;
|
||||
do {
|
||||
ptr += 1;
|
||||
ptr = ctx->ParseMessage(&_impl_.options_, ptr);
|
||||
CHK_(ptr);
|
||||
if (!ctx->DataAvailable(ptr)) break;
|
||||
} while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<10>(ptr));
|
||||
} else
|
||||
goto handle_unusual;
|
||||
continue;
|
||||
default:
|
||||
goto handle_unusual;
|
||||
} // switch
|
||||
handle_unusual:
|
||||
if ((tag == 0) || ((tag & 7) == 4)) {
|
||||
CHK_(ptr);
|
||||
ctx->SetLastTag(tag);
|
||||
goto message_done;
|
||||
}
|
||||
ptr = UnknownFieldParse(
|
||||
tag,
|
||||
_internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(),
|
||||
ptr, ctx);
|
||||
CHK_(ptr != nullptr);
|
||||
} // while
|
||||
message_done:
|
||||
return ptr;
|
||||
failure:
|
||||
ptr = nullptr;
|
||||
goto message_done;
|
||||
#undef CHK_
|
||||
}
|
||||
|
||||
uint8_t* ColumnOptions::_InternalSerialize(
|
||||
uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
|
||||
// @@protoc_insertion_point(serialize_to_array_start:greptime.v1.ColumnOptions)
|
||||
uint32_t cached_has_bits = 0;
|
||||
(void) cached_has_bits;
|
||||
|
||||
// map<string, string> options = 1;
|
||||
if (!this->_internal_options().empty()) {
|
||||
using MapType = ::_pb::Map<std::string, std::string>;
|
||||
using WireHelper = ColumnOptions_OptionsEntry_DoNotUse::Funcs;
|
||||
const auto& map_field = this->_internal_options();
|
||||
auto check_utf8 = [](const MapType::value_type& entry) {
|
||||
(void)entry;
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
|
||||
entry.first.data(), static_cast<int>(entry.first.length()),
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
|
||||
"greptime.v1.ColumnOptions.OptionsEntry.key");
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
|
||||
entry.second.data(), static_cast<int>(entry.second.length()),
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
|
||||
"greptime.v1.ColumnOptions.OptionsEntry.value");
|
||||
};
|
||||
|
||||
if (stream->IsSerializationDeterministic() && map_field.size() > 1) {
|
||||
for (const auto& entry : ::_pbi::MapSorterPtr<MapType>(map_field)) {
|
||||
target = WireHelper::InternalSerialize(1, entry.first, entry.second, target, stream);
|
||||
check_utf8(entry);
|
||||
}
|
||||
} else {
|
||||
for (const auto& entry : map_field) {
|
||||
target = WireHelper::InternalSerialize(1, entry.first, entry.second, target, stream);
|
||||
check_utf8(entry);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
||||
target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
|
||||
_internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
|
||||
}
|
||||
// @@protoc_insertion_point(serialize_to_array_end:greptime.v1.ColumnOptions)
|
||||
return target;
|
||||
}
|
||||
|
||||
size_t ColumnOptions::ByteSizeLong() const {
|
||||
// @@protoc_insertion_point(message_byte_size_start:greptime.v1.ColumnOptions)
|
||||
size_t total_size = 0;
|
||||
|
||||
uint32_t cached_has_bits = 0;
|
||||
// Prevent compiler warnings about cached_has_bits being unused
|
||||
(void) cached_has_bits;
|
||||
|
||||
// map<string, string> options = 1;
|
||||
total_size += 1 *
|
||||
::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(this->_internal_options_size());
|
||||
for (::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_iterator
|
||||
it = this->_internal_options().begin();
|
||||
it != this->_internal_options().end(); ++it) {
|
||||
total_size += ColumnOptions_OptionsEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second);
|
||||
}
|
||||
|
||||
return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
|
||||
}
|
||||
|
||||
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData ColumnOptions::_class_data_ = {
|
||||
::PROTOBUF_NAMESPACE_ID::Message::CopyWithSourceCheck,
|
||||
ColumnOptions::MergeImpl
|
||||
};
|
||||
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*ColumnOptions::GetClassData() const { return &_class_data_; }
|
||||
|
||||
|
||||
void ColumnOptions::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg) {
|
||||
auto* const _this = static_cast<ColumnOptions*>(&to_msg);
|
||||
auto& from = static_cast<const ColumnOptions&>(from_msg);
|
||||
// @@protoc_insertion_point(class_specific_merge_from_start:greptime.v1.ColumnOptions)
|
||||
GOOGLE_DCHECK_NE(&from, _this);
|
||||
uint32_t cached_has_bits = 0;
|
||||
(void) cached_has_bits;
|
||||
|
||||
_this->_impl_.options_.MergeFrom(from._impl_.options_);
|
||||
_this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
|
||||
}
|
||||
|
||||
void ColumnOptions::CopyFrom(const ColumnOptions& from) {
|
||||
// @@protoc_insertion_point(class_specific_copy_from_start:greptime.v1.ColumnOptions)
|
||||
if (&from == this) return;
|
||||
Clear();
|
||||
MergeFrom(from);
|
||||
}
|
||||
|
||||
bool ColumnOptions::IsInitialized() const {
|
||||
return true;
|
||||
}
|
||||
|
||||
void ColumnOptions::InternalSwap(ColumnOptions* other) {
|
||||
using std::swap;
|
||||
_internal_metadata_.InternalSwap(&other->_internal_metadata_);
|
||||
_impl_.options_.InternalSwap(&other->_impl_.options_);
|
||||
}
|
||||
|
||||
::PROTOBUF_NAMESPACE_ID::Metadata ColumnOptions::GetMetadata() const {
|
||||
return ::_pbi::AssignDescriptors(
|
||||
&descriptor_table_greptime_2fv1_2fcommon_2eproto_getter, &descriptor_table_greptime_2fv1_2fcommon_2eproto_once,
|
||||
file_level_metadata_greptime_2fv1_2fcommon_2eproto[19]);
|
||||
}
|
||||
|
||||
// @@protoc_insertion_point(namespace_scope)
|
||||
} // namespace v1
|
||||
} // namespace greptime
|
||||
@@ -4718,6 +4999,14 @@ template<> PROTOBUF_NOINLINE ::greptime::v1::DecimalTypeExtension*
|
||||
Arena::CreateMaybeMessage< ::greptime::v1::DecimalTypeExtension >(Arena* arena) {
|
||||
return Arena::CreateMessageInternal< ::greptime::v1::DecimalTypeExtension >(arena);
|
||||
}
|
||||
template<> PROTOBUF_NOINLINE ::greptime::v1::ColumnOptions_OptionsEntry_DoNotUse*
|
||||
Arena::CreateMaybeMessage< ::greptime::v1::ColumnOptions_OptionsEntry_DoNotUse >(Arena* arena) {
|
||||
return Arena::CreateMessageInternal< ::greptime::v1::ColumnOptions_OptionsEntry_DoNotUse >(arena);
|
||||
}
|
||||
template<> PROTOBUF_NOINLINE ::greptime::v1::ColumnOptions*
|
||||
Arena::CreateMaybeMessage< ::greptime::v1::ColumnOptions >(Arena* arena) {
|
||||
return Arena::CreateMessageInternal< ::greptime::v1::ColumnOptions >(arena);
|
||||
}
|
||||
PROTOBUF_NAMESPACE_CLOSE
|
||||
|
||||
// @@protoc_insertion_point(global_scope)
|
||||
|
||||
@@ -62,6 +62,12 @@ extern BasicDefaultTypeInternal _Basic_default_instance_;
|
||||
class ColumnDataTypeExtension;
|
||||
struct ColumnDataTypeExtensionDefaultTypeInternal;
|
||||
extern ColumnDataTypeExtensionDefaultTypeInternal _ColumnDataTypeExtension_default_instance_;
|
||||
class ColumnOptions;
|
||||
struct ColumnOptionsDefaultTypeInternal;
|
||||
extern ColumnOptionsDefaultTypeInternal _ColumnOptions_default_instance_;
|
||||
class ColumnOptions_OptionsEntry_DoNotUse;
|
||||
struct ColumnOptions_OptionsEntry_DoNotUseDefaultTypeInternal;
|
||||
extern ColumnOptions_OptionsEntry_DoNotUseDefaultTypeInternal _ColumnOptions_OptionsEntry_DoNotUse_default_instance_;
|
||||
class Decimal128;
|
||||
struct Decimal128DefaultTypeInternal;
|
||||
extern Decimal128DefaultTypeInternal _Decimal128_default_instance_;
|
||||
@@ -111,6 +117,8 @@ template<> ::greptime::v1::AffectedRows* Arena::CreateMaybeMessage<::greptime::v
|
||||
template<> ::greptime::v1::AuthHeader* Arena::CreateMaybeMessage<::greptime::v1::AuthHeader>(Arena*);
|
||||
template<> ::greptime::v1::Basic* Arena::CreateMaybeMessage<::greptime::v1::Basic>(Arena*);
|
||||
template<> ::greptime::v1::ColumnDataTypeExtension* Arena::CreateMaybeMessage<::greptime::v1::ColumnDataTypeExtension>(Arena*);
|
||||
template<> ::greptime::v1::ColumnOptions* Arena::CreateMaybeMessage<::greptime::v1::ColumnOptions>(Arena*);
|
||||
template<> ::greptime::v1::ColumnOptions_OptionsEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::ColumnOptions_OptionsEntry_DoNotUse>(Arena*);
|
||||
template<> ::greptime::v1::Decimal128* Arena::CreateMaybeMessage<::greptime::v1::Decimal128>(Arena*);
|
||||
template<> ::greptime::v1::DecimalTypeExtension* Arena::CreateMaybeMessage<::greptime::v1::DecimalTypeExtension>(Arena*);
|
||||
template<> ::greptime::v1::ExpireAfter* Arena::CreateMaybeMessage<::greptime::v1::ExpireAfter>(Arena*);
|
||||
@@ -3031,6 +3039,197 @@ class DecimalTypeExtension final :
|
||||
union { Impl_ _impl_; };
|
||||
friend struct ::TableStruct_greptime_2fv1_2fcommon_2eproto;
|
||||
};
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
class ColumnOptions_OptionsEntry_DoNotUse : public ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<ColumnOptions_OptionsEntry_DoNotUse,
|
||||
std::string, std::string,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING> {
|
||||
public:
|
||||
typedef ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<ColumnOptions_OptionsEntry_DoNotUse,
|
||||
std::string, std::string,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING> SuperType;
|
||||
ColumnOptions_OptionsEntry_DoNotUse();
|
||||
explicit PROTOBUF_CONSTEXPR ColumnOptions_OptionsEntry_DoNotUse(
|
||||
::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
|
||||
explicit ColumnOptions_OptionsEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena);
|
||||
void MergeFrom(const ColumnOptions_OptionsEntry_DoNotUse& other);
|
||||
static const ColumnOptions_OptionsEntry_DoNotUse* internal_default_instance() { return reinterpret_cast<const ColumnOptions_OptionsEntry_DoNotUse*>(&_ColumnOptions_OptionsEntry_DoNotUse_default_instance_); }
|
||||
static bool ValidateKey(std::string* s) {
|
||||
return ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(s->data(), static_cast<int>(s->size()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "greptime.v1.ColumnOptions.OptionsEntry.key");
|
||||
}
|
||||
static bool ValidateValue(std::string* s) {
|
||||
return ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(s->data(), static_cast<int>(s->size()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "greptime.v1.ColumnOptions.OptionsEntry.value");
|
||||
}
|
||||
using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
|
||||
::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
|
||||
friend struct ::TableStruct_greptime_2fv1_2fcommon_2eproto;
|
||||
};
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
class ColumnOptions final :
|
||||
public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:greptime.v1.ColumnOptions) */ {
|
||||
public:
|
||||
inline ColumnOptions() : ColumnOptions(nullptr) {}
|
||||
~ColumnOptions() override;
|
||||
explicit PROTOBUF_CONSTEXPR ColumnOptions(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
|
||||
|
||||
ColumnOptions(const ColumnOptions& from);
|
||||
ColumnOptions(ColumnOptions&& from) noexcept
|
||||
: ColumnOptions() {
|
||||
*this = ::std::move(from);
|
||||
}
|
||||
|
||||
inline ColumnOptions& operator=(const ColumnOptions& from) {
|
||||
CopyFrom(from);
|
||||
return *this;
|
||||
}
|
||||
inline ColumnOptions& operator=(ColumnOptions&& from) noexcept {
|
||||
if (this == &from) return *this;
|
||||
if (GetOwningArena() == from.GetOwningArena()
|
||||
#ifdef PROTOBUF_FORCE_COPY_IN_MOVE
|
||||
&& GetOwningArena() != nullptr
|
||||
#endif // !PROTOBUF_FORCE_COPY_IN_MOVE
|
||||
) {
|
||||
InternalSwap(&from);
|
||||
} else {
|
||||
CopyFrom(from);
|
||||
}
|
||||
return *this;
|
||||
}
|
||||
|
||||
static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
|
||||
return GetDescriptor();
|
||||
}
|
||||
static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
|
||||
return default_instance().GetMetadata().descriptor;
|
||||
}
|
||||
static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
|
||||
return default_instance().GetMetadata().reflection;
|
||||
}
|
||||
static const ColumnOptions& default_instance() {
|
||||
return *internal_default_instance();
|
||||
}
|
||||
static inline const ColumnOptions* internal_default_instance() {
|
||||
return reinterpret_cast<const ColumnOptions*>(
|
||||
&_ColumnOptions_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
19;
|
||||
|
||||
friend void swap(ColumnOptions& a, ColumnOptions& b) {
|
||||
a.Swap(&b);
|
||||
}
|
||||
inline void Swap(ColumnOptions* other) {
|
||||
if (other == this) return;
|
||||
#ifdef PROTOBUF_FORCE_COPY_IN_SWAP
|
||||
if (GetOwningArena() != nullptr &&
|
||||
GetOwningArena() == other->GetOwningArena()) {
|
||||
#else // PROTOBUF_FORCE_COPY_IN_SWAP
|
||||
if (GetOwningArena() == other->GetOwningArena()) {
|
||||
#endif // !PROTOBUF_FORCE_COPY_IN_SWAP
|
||||
InternalSwap(other);
|
||||
} else {
|
||||
::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
|
||||
}
|
||||
}
|
||||
void UnsafeArenaSwap(ColumnOptions* other) {
|
||||
if (other == this) return;
|
||||
GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
|
||||
InternalSwap(other);
|
||||
}
|
||||
|
||||
// implements Message ----------------------------------------------
|
||||
|
||||
ColumnOptions* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
|
||||
return CreateMaybeMessage<ColumnOptions>(arena);
|
||||
}
|
||||
using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
|
||||
void CopyFrom(const ColumnOptions& from);
|
||||
using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
|
||||
void MergeFrom( const ColumnOptions& from) {
|
||||
ColumnOptions::MergeImpl(*this, from);
|
||||
}
|
||||
private:
|
||||
static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
|
||||
public:
|
||||
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
|
||||
bool IsInitialized() const final;
|
||||
|
||||
size_t ByteSizeLong() const final;
|
||||
const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
|
||||
uint8_t* _InternalSerialize(
|
||||
uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
|
||||
int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
|
||||
|
||||
private:
|
||||
void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
|
||||
void SharedDtor();
|
||||
void SetCachedSize(int size) const final;
|
||||
void InternalSwap(ColumnOptions* other);
|
||||
|
||||
private:
|
||||
friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
|
||||
static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
|
||||
return "greptime.v1.ColumnOptions";
|
||||
}
|
||||
protected:
|
||||
explicit ColumnOptions(::PROTOBUF_NAMESPACE_ID::Arena* arena,
|
||||
bool is_message_owned = false);
|
||||
private:
|
||||
static void ArenaDtor(void* object);
|
||||
public:
|
||||
|
||||
static const ClassData _class_data_;
|
||||
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
|
||||
|
||||
::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
|
||||
|
||||
// nested types ----------------------------------------------------
|
||||
|
||||
|
||||
// accessors -------------------------------------------------------
|
||||
|
||||
enum : int {
|
||||
kOptionsFieldNumber = 1,
|
||||
};
|
||||
// map<string, string> options = 1;
|
||||
int options_size() const;
|
||||
private:
|
||||
int _internal_options_size() const;
|
||||
public:
|
||||
void clear_options();
|
||||
private:
|
||||
const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
|
||||
_internal_options() const;
|
||||
::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
|
||||
_internal_mutable_options();
|
||||
public:
|
||||
const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
|
||||
options() const;
|
||||
::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
|
||||
mutable_options();
|
||||
|
||||
// @@protoc_insertion_point(class_scope:greptime.v1.ColumnOptions)
|
||||
private:
|
||||
class _Internal;
|
||||
|
||||
template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
|
||||
typedef void InternalArenaConstructable_;
|
||||
typedef void DestructorSkippable_;
|
||||
struct Impl_ {
|
||||
::PROTOBUF_NAMESPACE_ID::internal::MapField<
|
||||
ColumnOptions_OptionsEntry_DoNotUse,
|
||||
std::string, std::string,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING> options_;
|
||||
mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
|
||||
};
|
||||
union { Impl_ _impl_; };
|
||||
friend struct ::TableStruct_greptime_2fv1_2fcommon_2eproto;
|
||||
};
|
||||
// ===================================================================
|
||||
|
||||
|
||||
@@ -4714,6 +4913,41 @@ inline void DecimalTypeExtension::set_scale(int32_t value) {
|
||||
// @@protoc_insertion_point(field_set:greptime.v1.DecimalTypeExtension.scale)
|
||||
}
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// ColumnOptions
|
||||
|
||||
// map<string, string> options = 1;
|
||||
inline int ColumnOptions::_internal_options_size() const {
|
||||
return _impl_.options_.size();
|
||||
}
|
||||
inline int ColumnOptions::options_size() const {
|
||||
return _internal_options_size();
|
||||
}
|
||||
inline void ColumnOptions::clear_options() {
|
||||
_impl_.options_.Clear();
|
||||
}
|
||||
inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
|
||||
ColumnOptions::_internal_options() const {
|
||||
return _impl_.options_.GetMap();
|
||||
}
|
||||
inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
|
||||
ColumnOptions::options() const {
|
||||
// @@protoc_insertion_point(field_map:greptime.v1.ColumnOptions.options)
|
||||
return _internal_options();
|
||||
}
|
||||
inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
|
||||
ColumnOptions::_internal_mutable_options() {
|
||||
return _impl_.options_.MutableMap();
|
||||
}
|
||||
inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
|
||||
ColumnOptions::mutable_options() {
|
||||
// @@protoc_insertion_point(field_mutable_map:greptime.v1.ColumnOptions.options)
|
||||
return _internal_mutable_options();
|
||||
}
|
||||
|
||||
#ifdef __GNUC__
|
||||
#pragma GCC diagnostic pop
|
||||
#endif // __GNUC__
|
||||
@@ -4751,6 +4985,10 @@ inline void DecimalTypeExtension::set_scale(int32_t value) {
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
|
||||
// @@protoc_insertion_point(namespace_scope)
|
||||
|
||||
|
||||
+60
-10
@@ -373,6 +373,7 @@ PROTOBUF_CONSTEXPR ColumnDef::ColumnDef(
|
||||
, /*decltype(_impl_.default_constraint_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
|
||||
, /*decltype(_impl_.comment_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
|
||||
, /*decltype(_impl_.datatype_extension_)*/nullptr
|
||||
, /*decltype(_impl_.options_)*/nullptr
|
||||
, /*decltype(_impl_.data_type_)*/0
|
||||
, /*decltype(_impl_.is_nullable_)*/false
|
||||
, /*decltype(_impl_.semantic_type_)*/0
|
||||
@@ -653,6 +654,7 @@ const uint32_t TableStruct_greptime_2fv1_2fddl_2eproto::offsets[] PROTOBUF_SECTI
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnDef, _impl_.semantic_type_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnDef, _impl_.comment_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnDef, _impl_.datatype_extension_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnDef, _impl_.options_),
|
||||
~0u, // no _has_bits_
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::AddColumnLocation, _internal_metadata_),
|
||||
~0u, // no _extensions_
|
||||
@@ -687,7 +689,7 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode
|
||||
{ 219, -1, -1, sizeof(::greptime::v1::TableId)},
|
||||
{ 226, -1, -1, sizeof(::greptime::v1::FlowId)},
|
||||
{ 233, -1, -1, sizeof(::greptime::v1::ColumnDef)},
|
||||
{ 246, -1, -1, sizeof(::greptime::v1::AddColumnLocation)},
|
||||
{ 247, -1, -1, sizeof(::greptime::v1::AddColumnLocation)},
|
||||
};
|
||||
|
||||
static const ::_pb::Message* const file_default_instances[] = {
|
||||
@@ -800,26 +802,27 @@ const char descriptor_table_protodef_greptime_2fv1_2fddl_2eproto[] PROTOBUF_SECT
|
||||
"type_extension\030\003 \001(\0132$.greptime.v1.Colum"
|
||||
"nDataTypeExtension\"\032\n\nDropColumn\022\014\n\004name"
|
||||
"\030\001 \001(\t\"\025\n\007TableId\022\n\n\002id\030\001 \001(\r\"\024\n\006FlowId\022"
|
||||
"\n\n\002id\030\001 \001(\r\"\377\001\n\tColumnDef\022\014\n\004name\030\001 \001(\t\022"
|
||||
"\n\n\002id\030\001 \001(\r\"\254\002\n\tColumnDef\022\014\n\004name\030\001 \001(\t\022"
|
||||
".\n\tdata_type\030\002 \001(\0162\033.greptime.v1.ColumnD"
|
||||
"ataType\022\023\n\013is_nullable\030\003 \001(\010\022\032\n\022default_"
|
||||
"constraint\030\004 \001(\014\0220\n\rsemantic_type\030\005 \001(\0162"
|
||||
"\031.greptime.v1.SemanticType\022\017\n\007comment\030\006 "
|
||||
"\001(\t\022@\n\022datatype_extension\030\007 \001(\0132$.grepti"
|
||||
"me.v1.ColumnDataTypeExtension\"\230\001\n\021AddCol"
|
||||
"umnLocation\022B\n\rlocation_type\030\001 \001(\0162+.gre"
|
||||
"ptime.v1.AddColumnLocation.LocationType\022"
|
||||
"\031\n\021after_column_name\030\002 \001(\t\"$\n\014LocationTy"
|
||||
"pe\022\t\n\005FIRST\020\000\022\t\n\005AFTER\020\001BL\n\016io.greptime."
|
||||
"v1B\003DdlZ5github.com/GreptimeTeam/greptim"
|
||||
"e-proto/go/greptime/v1b\006proto3"
|
||||
"me.v1.ColumnDataTypeExtension\022+\n\007options"
|
||||
"\030\010 \001(\0132\032.greptime.v1.ColumnOptions\"\230\001\n\021A"
|
||||
"ddColumnLocation\022B\n\rlocation_type\030\001 \001(\0162"
|
||||
"+.greptime.v1.AddColumnLocation.Location"
|
||||
"Type\022\031\n\021after_column_name\030\002 \001(\t\"$\n\014Locat"
|
||||
"ionType\022\t\n\005FIRST\020\000\022\t\n\005AFTER\020\001BL\n\016io.grep"
|
||||
"time.v1B\003DdlZ5github.com/GreptimeTeam/gr"
|
||||
"eptime-proto/go/greptime/v1b\006proto3"
|
||||
;
|
||||
static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2fddl_2eproto_deps[1] = {
|
||||
&::descriptor_table_greptime_2fv1_2fcommon_2eproto,
|
||||
};
|
||||
static ::_pbi::once_flag descriptor_table_greptime_2fv1_2fddl_2eproto_once;
|
||||
const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2fddl_2eproto = {
|
||||
false, false, 3750, descriptor_table_protodef_greptime_2fv1_2fddl_2eproto,
|
||||
false, false, 3795, descriptor_table_protodef_greptime_2fv1_2fddl_2eproto,
|
||||
"greptime/v1/ddl.proto",
|
||||
&descriptor_table_greptime_2fv1_2fddl_2eproto_once, descriptor_table_greptime_2fv1_2fddl_2eproto_deps, 1, 25,
|
||||
schemas, file_default_instances, TableStruct_greptime_2fv1_2fddl_2eproto::offsets,
|
||||
@@ -7803,18 +7806,29 @@ void FlowId::InternalSwap(FlowId* other) {
|
||||
class ColumnDef::_Internal {
|
||||
public:
|
||||
static const ::greptime::v1::ColumnDataTypeExtension& datatype_extension(const ColumnDef* msg);
|
||||
static const ::greptime::v1::ColumnOptions& options(const ColumnDef* msg);
|
||||
};
|
||||
|
||||
const ::greptime::v1::ColumnDataTypeExtension&
|
||||
ColumnDef::_Internal::datatype_extension(const ColumnDef* msg) {
|
||||
return *msg->_impl_.datatype_extension_;
|
||||
}
|
||||
const ::greptime::v1::ColumnOptions&
|
||||
ColumnDef::_Internal::options(const ColumnDef* msg) {
|
||||
return *msg->_impl_.options_;
|
||||
}
|
||||
void ColumnDef::clear_datatype_extension() {
|
||||
if (GetArenaForAllocation() == nullptr && _impl_.datatype_extension_ != nullptr) {
|
||||
delete _impl_.datatype_extension_;
|
||||
}
|
||||
_impl_.datatype_extension_ = nullptr;
|
||||
}
|
||||
void ColumnDef::clear_options() {
|
||||
if (GetArenaForAllocation() == nullptr && _impl_.options_ != nullptr) {
|
||||
delete _impl_.options_;
|
||||
}
|
||||
_impl_.options_ = nullptr;
|
||||
}
|
||||
ColumnDef::ColumnDef(::PROTOBUF_NAMESPACE_ID::Arena* arena,
|
||||
bool is_message_owned)
|
||||
: ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
|
||||
@@ -7829,6 +7843,7 @@ ColumnDef::ColumnDef(const ColumnDef& from)
|
||||
, decltype(_impl_.default_constraint_){}
|
||||
, decltype(_impl_.comment_){}
|
||||
, decltype(_impl_.datatype_extension_){nullptr}
|
||||
, decltype(_impl_.options_){nullptr}
|
||||
, decltype(_impl_.data_type_){}
|
||||
, decltype(_impl_.is_nullable_){}
|
||||
, decltype(_impl_.semantic_type_){}
|
||||
@@ -7862,6 +7877,9 @@ ColumnDef::ColumnDef(const ColumnDef& from)
|
||||
if (from._internal_has_datatype_extension()) {
|
||||
_this->_impl_.datatype_extension_ = new ::greptime::v1::ColumnDataTypeExtension(*from._impl_.datatype_extension_);
|
||||
}
|
||||
if (from._internal_has_options()) {
|
||||
_this->_impl_.options_ = new ::greptime::v1::ColumnOptions(*from._impl_.options_);
|
||||
}
|
||||
::memcpy(&_impl_.data_type_, &from._impl_.data_type_,
|
||||
static_cast<size_t>(reinterpret_cast<char*>(&_impl_.semantic_type_) -
|
||||
reinterpret_cast<char*>(&_impl_.data_type_)) + sizeof(_impl_.semantic_type_));
|
||||
@@ -7877,6 +7895,7 @@ inline void ColumnDef::SharedCtor(
|
||||
, decltype(_impl_.default_constraint_){}
|
||||
, decltype(_impl_.comment_){}
|
||||
, decltype(_impl_.datatype_extension_){nullptr}
|
||||
, decltype(_impl_.options_){nullptr}
|
||||
, decltype(_impl_.data_type_){0}
|
||||
, decltype(_impl_.is_nullable_){false}
|
||||
, decltype(_impl_.semantic_type_){0}
|
||||
@@ -7911,6 +7930,7 @@ inline void ColumnDef::SharedDtor() {
|
||||
_impl_.default_constraint_.Destroy();
|
||||
_impl_.comment_.Destroy();
|
||||
if (this != internal_default_instance()) delete _impl_.datatype_extension_;
|
||||
if (this != internal_default_instance()) delete _impl_.options_;
|
||||
}
|
||||
|
||||
void ColumnDef::SetCachedSize(int size) const {
|
||||
@@ -7930,6 +7950,10 @@ void ColumnDef::Clear() {
|
||||
delete _impl_.datatype_extension_;
|
||||
}
|
||||
_impl_.datatype_extension_ = nullptr;
|
||||
if (GetArenaForAllocation() == nullptr && _impl_.options_ != nullptr) {
|
||||
delete _impl_.options_;
|
||||
}
|
||||
_impl_.options_ = nullptr;
|
||||
::memset(&_impl_.data_type_, 0, static_cast<size_t>(
|
||||
reinterpret_cast<char*>(&_impl_.semantic_type_) -
|
||||
reinterpret_cast<char*>(&_impl_.data_type_)) + sizeof(_impl_.semantic_type_));
|
||||
@@ -8005,6 +8029,14 @@ const char* ColumnDef::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx
|
||||
} else
|
||||
goto handle_unusual;
|
||||
continue;
|
||||
// .greptime.v1.ColumnOptions options = 8;
|
||||
case 8:
|
||||
if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 66)) {
|
||||
ptr = ctx->ParseMessage(_internal_mutable_options(), ptr);
|
||||
CHK_(ptr);
|
||||
} else
|
||||
goto handle_unusual;
|
||||
continue;
|
||||
default:
|
||||
goto handle_unusual;
|
||||
} // switch
|
||||
@@ -8087,6 +8119,13 @@ uint8_t* ColumnDef::_InternalSerialize(
|
||||
_Internal::datatype_extension(this).GetCachedSize(), target, stream);
|
||||
}
|
||||
|
||||
// .greptime.v1.ColumnOptions options = 8;
|
||||
if (this->_internal_has_options()) {
|
||||
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
||||
InternalWriteMessage(8, _Internal::options(this),
|
||||
_Internal::options(this).GetCachedSize(), target, stream);
|
||||
}
|
||||
|
||||
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
||||
target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
|
||||
_internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
|
||||
@@ -8131,6 +8170,13 @@ size_t ColumnDef::ByteSizeLong() const {
|
||||
*_impl_.datatype_extension_);
|
||||
}
|
||||
|
||||
// .greptime.v1.ColumnOptions options = 8;
|
||||
if (this->_internal_has_options()) {
|
||||
total_size += 1 +
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
||||
*_impl_.options_);
|
||||
}
|
||||
|
||||
// .greptime.v1.ColumnDataType data_type = 2;
|
||||
if (this->_internal_data_type() != 0) {
|
||||
total_size += 1 +
|
||||
@@ -8179,6 +8225,10 @@ void ColumnDef::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROT
|
||||
_this->_internal_mutable_datatype_extension()->::greptime::v1::ColumnDataTypeExtension::MergeFrom(
|
||||
from._internal_datatype_extension());
|
||||
}
|
||||
if (from._internal_has_options()) {
|
||||
_this->_internal_mutable_options()->::greptime::v1::ColumnOptions::MergeFrom(
|
||||
from._internal_options());
|
||||
}
|
||||
if (from._internal_data_type() != 0) {
|
||||
_this->_internal_set_data_type(from._internal_data_type());
|
||||
}
|
||||
|
||||
@@ -4577,6 +4577,7 @@ class ColumnDef final :
|
||||
kDefaultConstraintFieldNumber = 4,
|
||||
kCommentFieldNumber = 6,
|
||||
kDatatypeExtensionFieldNumber = 7,
|
||||
kOptionsFieldNumber = 8,
|
||||
kDataTypeFieldNumber = 2,
|
||||
kIsNullableFieldNumber = 3,
|
||||
kSemanticTypeFieldNumber = 5,
|
||||
@@ -4641,6 +4642,24 @@ class ColumnDef final :
|
||||
::greptime::v1::ColumnDataTypeExtension* datatype_extension);
|
||||
::greptime::v1::ColumnDataTypeExtension* unsafe_arena_release_datatype_extension();
|
||||
|
||||
// .greptime.v1.ColumnOptions options = 8;
|
||||
bool has_options() const;
|
||||
private:
|
||||
bool _internal_has_options() const;
|
||||
public:
|
||||
void clear_options();
|
||||
const ::greptime::v1::ColumnOptions& options() const;
|
||||
PROTOBUF_NODISCARD ::greptime::v1::ColumnOptions* release_options();
|
||||
::greptime::v1::ColumnOptions* mutable_options();
|
||||
void set_allocated_options(::greptime::v1::ColumnOptions* options);
|
||||
private:
|
||||
const ::greptime::v1::ColumnOptions& _internal_options() const;
|
||||
::greptime::v1::ColumnOptions* _internal_mutable_options();
|
||||
public:
|
||||
void unsafe_arena_set_allocated_options(
|
||||
::greptime::v1::ColumnOptions* options);
|
||||
::greptime::v1::ColumnOptions* unsafe_arena_release_options();
|
||||
|
||||
// .greptime.v1.ColumnDataType data_type = 2;
|
||||
void clear_data_type();
|
||||
::greptime::v1::ColumnDataType data_type() const;
|
||||
@@ -4680,6 +4699,7 @@ class ColumnDef final :
|
||||
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr default_constraint_;
|
||||
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr comment_;
|
||||
::greptime::v1::ColumnDataTypeExtension* datatype_extension_;
|
||||
::greptime::v1::ColumnOptions* options_;
|
||||
int data_type_;
|
||||
bool is_nullable_;
|
||||
int semantic_type_;
|
||||
@@ -9545,6 +9565,91 @@ inline void ColumnDef::set_allocated_datatype_extension(::greptime::v1::ColumnDa
|
||||
// @@protoc_insertion_point(field_set_allocated:greptime.v1.ColumnDef.datatype_extension)
|
||||
}
|
||||
|
||||
// .greptime.v1.ColumnOptions options = 8;
|
||||
inline bool ColumnDef::_internal_has_options() const {
|
||||
return this != internal_default_instance() && _impl_.options_ != nullptr;
|
||||
}
|
||||
inline bool ColumnDef::has_options() const {
|
||||
return _internal_has_options();
|
||||
}
|
||||
inline const ::greptime::v1::ColumnOptions& ColumnDef::_internal_options() const {
|
||||
const ::greptime::v1::ColumnOptions* p = _impl_.options_;
|
||||
return p != nullptr ? *p : reinterpret_cast<const ::greptime::v1::ColumnOptions&>(
|
||||
::greptime::v1::_ColumnOptions_default_instance_);
|
||||
}
|
||||
inline const ::greptime::v1::ColumnOptions& ColumnDef::options() const {
|
||||
// @@protoc_insertion_point(field_get:greptime.v1.ColumnDef.options)
|
||||
return _internal_options();
|
||||
}
|
||||
inline void ColumnDef::unsafe_arena_set_allocated_options(
|
||||
::greptime::v1::ColumnOptions* options) {
|
||||
if (GetArenaForAllocation() == nullptr) {
|
||||
delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.options_);
|
||||
}
|
||||
_impl_.options_ = options;
|
||||
if (options) {
|
||||
|
||||
} else {
|
||||
|
||||
}
|
||||
// @@protoc_insertion_point(field_unsafe_arena_set_allocated:greptime.v1.ColumnDef.options)
|
||||
}
|
||||
inline ::greptime::v1::ColumnOptions* ColumnDef::release_options() {
|
||||
|
||||
::greptime::v1::ColumnOptions* temp = _impl_.options_;
|
||||
_impl_.options_ = nullptr;
|
||||
#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
|
||||
auto* old = reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp);
|
||||
temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
|
||||
if (GetArenaForAllocation() == nullptr) { delete old; }
|
||||
#else // PROTOBUF_FORCE_COPY_IN_RELEASE
|
||||
if (GetArenaForAllocation() != nullptr) {
|
||||
temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
|
||||
}
|
||||
#endif // !PROTOBUF_FORCE_COPY_IN_RELEASE
|
||||
return temp;
|
||||
}
|
||||
inline ::greptime::v1::ColumnOptions* ColumnDef::unsafe_arena_release_options() {
|
||||
// @@protoc_insertion_point(field_release:greptime.v1.ColumnDef.options)
|
||||
|
||||
::greptime::v1::ColumnOptions* temp = _impl_.options_;
|
||||
_impl_.options_ = nullptr;
|
||||
return temp;
|
||||
}
|
||||
inline ::greptime::v1::ColumnOptions* ColumnDef::_internal_mutable_options() {
|
||||
|
||||
if (_impl_.options_ == nullptr) {
|
||||
auto* p = CreateMaybeMessage<::greptime::v1::ColumnOptions>(GetArenaForAllocation());
|
||||
_impl_.options_ = p;
|
||||
}
|
||||
return _impl_.options_;
|
||||
}
|
||||
inline ::greptime::v1::ColumnOptions* ColumnDef::mutable_options() {
|
||||
::greptime::v1::ColumnOptions* _msg = _internal_mutable_options();
|
||||
// @@protoc_insertion_point(field_mutable:greptime.v1.ColumnDef.options)
|
||||
return _msg;
|
||||
}
|
||||
inline void ColumnDef::set_allocated_options(::greptime::v1::ColumnOptions* options) {
|
||||
::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
|
||||
if (message_arena == nullptr) {
|
||||
delete reinterpret_cast< ::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.options_);
|
||||
}
|
||||
if (options) {
|
||||
::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
|
||||
::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(
|
||||
reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(options));
|
||||
if (message_arena != submessage_arena) {
|
||||
options = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
|
||||
message_arena, options, submessage_arena);
|
||||
}
|
||||
|
||||
} else {
|
||||
|
||||
}
|
||||
_impl_.options_ = options;
|
||||
// @@protoc_insertion_point(field_set_allocated:greptime.v1.ColumnDef.options)
|
||||
}
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// AddColumnLocation
|
||||
|
||||
+79
-29
@@ -40,6 +40,7 @@ PROTOBUF_CONSTEXPR ColumnSchema::ColumnSchema(
|
||||
::_pbi::ConstantInitialized): _impl_{
|
||||
/*decltype(_impl_.column_name_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
|
||||
, /*decltype(_impl_.datatype_extension_)*/nullptr
|
||||
, /*decltype(_impl_.options_)*/nullptr
|
||||
, /*decltype(_impl_.datatype_)*/0
|
||||
, /*decltype(_impl_.semantic_type_)*/0
|
||||
, /*decltype(_impl_._cached_size_)*/{}} {}
|
||||
@@ -104,6 +105,7 @@ const uint32_t TableStruct_greptime_2fv1_2frow_2eproto::offsets[] PROTOBUF_SECTI
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnSchema, _impl_.datatype_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnSchema, _impl_.semantic_type_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnSchema, _impl_.datatype_extension_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::ColumnSchema, _impl_.options_),
|
||||
~0u, // no _has_bits_
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::Row, _internal_metadata_),
|
||||
~0u, // no _extensions_
|
||||
@@ -149,8 +151,8 @@ const uint32_t TableStruct_greptime_2fv1_2frow_2eproto::offsets[] PROTOBUF_SECTI
|
||||
static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
|
||||
{ 0, -1, -1, sizeof(::greptime::v1::Rows)},
|
||||
{ 8, -1, -1, sizeof(::greptime::v1::ColumnSchema)},
|
||||
{ 18, -1, -1, sizeof(::greptime::v1::Row)},
|
||||
{ 25, -1, -1, sizeof(::greptime::v1::Value)},
|
||||
{ 19, -1, -1, sizeof(::greptime::v1::Row)},
|
||||
{ 26, -1, -1, sizeof(::greptime::v1::Value)},
|
||||
};
|
||||
|
||||
static const ::_pb::Message* const file_default_instances[] = {
|
||||
@@ -164,43 +166,44 @@ const char descriptor_table_protodef_greptime_2fv1_2frow_2eproto[] PROTOBUF_SECT
|
||||
"\n\025greptime/v1/row.proto\022\013greptime.v1\032\030gr"
|
||||
"eptime/v1/common.proto\"Q\n\004Rows\022)\n\006schema"
|
||||
"\030\001 \003(\0132\031.greptime.v1.ColumnSchema\022\036\n\004row"
|
||||
"s\030\002 \003(\0132\020.greptime.v1.Row\"\306\001\n\014ColumnSche"
|
||||
"s\030\002 \003(\0132\020.greptime.v1.Row\"\363\001\n\014ColumnSche"
|
||||
"ma\022\023\n\013column_name\030\001 \001(\t\022-\n\010datatype\030\002 \001("
|
||||
"\0162\033.greptime.v1.ColumnDataType\0220\n\rsemant"
|
||||
"ic_type\030\003 \001(\0162\031.greptime.v1.SemanticType"
|
||||
"\022@\n\022datatype_extension\030\004 \001(\0132$.greptime."
|
||||
"v1.ColumnDataTypeExtension\")\n\003Row\022\"\n\006val"
|
||||
"ues\030\001 \003(\0132\022.greptime.v1.Value\"\274\006\n\005Value\022"
|
||||
"\022\n\010i8_value\030\001 \001(\005H\000\022\023\n\ti16_value\030\002 \001(\005H\000"
|
||||
"\022\023\n\ti32_value\030\003 \001(\005H\000\022\023\n\ti64_value\030\004 \001(\003"
|
||||
"H\000\022\022\n\010u8_value\030\005 \001(\rH\000\022\023\n\tu16_value\030\006 \001("
|
||||
"\rH\000\022\023\n\tu32_value\030\007 \001(\rH\000\022\023\n\tu64_value\030\010 "
|
||||
"\001(\004H\000\022\023\n\tf32_value\030\t \001(\002H\000\022\023\n\tf64_value\030"
|
||||
"\n \001(\001H\000\022\024\n\nbool_value\030\013 \001(\010H\000\022\026\n\014binary_"
|
||||
"value\030\014 \001(\014H\000\022\026\n\014string_value\030\r \001(\tH\000\022\024\n"
|
||||
"\ndate_value\030\016 \001(\005H\000\022\030\n\016datetime_value\030\017 "
|
||||
"\001(\003H\000\022 \n\026timestamp_second_value\030\020 \001(\003H\000\022"
|
||||
"%\n\033timestamp_millisecond_value\030\021 \001(\003H\000\022%"
|
||||
"\n\033timestamp_microsecond_value\030\022 \001(\003H\000\022$\n"
|
||||
"\032timestamp_nanosecond_value\030\023 \001(\003H\000\022\033\n\021t"
|
||||
"ime_second_value\030\024 \001(\003H\000\022 \n\026time_millise"
|
||||
"cond_value\030\025 \001(\003H\000\022 \n\026time_microsecond_v"
|
||||
"alue\030\026 \001(\003H\000\022\037\n\025time_nanosecond_value\030\027 "
|
||||
"\001(\003H\000\022#\n\031interval_year_month_value\030\030 \001(\005"
|
||||
"H\000\022!\n\027interval_day_time_value\030\031 \001(\003H\000\022J\n"
|
||||
"\035interval_month_day_nano_value\030\032 \001(\0132!.g"
|
||||
"reptime.v1.IntervalMonthDayNanoH\000\0223\n\020dec"
|
||||
"imal128_value\030\037 \001(\0132\027.greptime.v1.Decima"
|
||||
"l128H\000B\014\n\nvalue_dataBP\n\016io.greptime.v1B\007"
|
||||
"RowDataZ5github.com/GreptimeTeam/greptim"
|
||||
"e-proto/go/greptime/v1b\006proto3"
|
||||
"v1.ColumnDataTypeExtension\022+\n\007options\030\005 "
|
||||
"\001(\0132\032.greptime.v1.ColumnOptions\")\n\003Row\022\""
|
||||
"\n\006values\030\001 \003(\0132\022.greptime.v1.Value\"\274\006\n\005V"
|
||||
"alue\022\022\n\010i8_value\030\001 \001(\005H\000\022\023\n\ti16_value\030\002 "
|
||||
"\001(\005H\000\022\023\n\ti32_value\030\003 \001(\005H\000\022\023\n\ti64_value\030"
|
||||
"\004 \001(\003H\000\022\022\n\010u8_value\030\005 \001(\rH\000\022\023\n\tu16_value"
|
||||
"\030\006 \001(\rH\000\022\023\n\tu32_value\030\007 \001(\rH\000\022\023\n\tu64_val"
|
||||
"ue\030\010 \001(\004H\000\022\023\n\tf32_value\030\t \001(\002H\000\022\023\n\tf64_v"
|
||||
"alue\030\n \001(\001H\000\022\024\n\nbool_value\030\013 \001(\010H\000\022\026\n\014bi"
|
||||
"nary_value\030\014 \001(\014H\000\022\026\n\014string_value\030\r \001(\t"
|
||||
"H\000\022\024\n\ndate_value\030\016 \001(\005H\000\022\030\n\016datetime_val"
|
||||
"ue\030\017 \001(\003H\000\022 \n\026timestamp_second_value\030\020 \001"
|
||||
"(\003H\000\022%\n\033timestamp_millisecond_value\030\021 \001("
|
||||
"\003H\000\022%\n\033timestamp_microsecond_value\030\022 \001(\003"
|
||||
"H\000\022$\n\032timestamp_nanosecond_value\030\023 \001(\003H\000"
|
||||
"\022\033\n\021time_second_value\030\024 \001(\003H\000\022 \n\026time_mi"
|
||||
"llisecond_value\030\025 \001(\003H\000\022 \n\026time_microsec"
|
||||
"ond_value\030\026 \001(\003H\000\022\037\n\025time_nanosecond_val"
|
||||
"ue\030\027 \001(\003H\000\022#\n\031interval_year_month_value\030"
|
||||
"\030 \001(\005H\000\022!\n\027interval_day_time_value\030\031 \001(\003"
|
||||
"H\000\022J\n\035interval_month_day_nano_value\030\032 \001("
|
||||
"\0132!.greptime.v1.IntervalMonthDayNanoH\000\0223"
|
||||
"\n\020decimal128_value\030\037 \001(\0132\027.greptime.v1.D"
|
||||
"ecimal128H\000B\014\n\nvalue_dataBP\n\016io.greptime"
|
||||
".v1B\007RowDataZ5github.com/GreptimeTeam/gr"
|
||||
"eptime-proto/go/greptime/v1b\006proto3"
|
||||
;
|
||||
static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2frow_2eproto_deps[1] = {
|
||||
&::descriptor_table_greptime_2fv1_2fcommon_2eproto,
|
||||
};
|
||||
static ::_pbi::once_flag descriptor_table_greptime_2fv1_2frow_2eproto_once;
|
||||
const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2frow_2eproto = {
|
||||
false, false, 1310, descriptor_table_protodef_greptime_2fv1_2frow_2eproto,
|
||||
false, false, 1355, descriptor_table_protodef_greptime_2fv1_2frow_2eproto,
|
||||
"greptime/v1/row.proto",
|
||||
&descriptor_table_greptime_2fv1_2frow_2eproto_once, descriptor_table_greptime_2fv1_2frow_2eproto_deps, 1, 4,
|
||||
schemas, file_default_instances, TableStruct_greptime_2fv1_2frow_2eproto::offsets,
|
||||
@@ -440,18 +443,29 @@ void Rows::InternalSwap(Rows* other) {
|
||||
class ColumnSchema::_Internal {
|
||||
public:
|
||||
static const ::greptime::v1::ColumnDataTypeExtension& datatype_extension(const ColumnSchema* msg);
|
||||
static const ::greptime::v1::ColumnOptions& options(const ColumnSchema* msg);
|
||||
};
|
||||
|
||||
const ::greptime::v1::ColumnDataTypeExtension&
|
||||
ColumnSchema::_Internal::datatype_extension(const ColumnSchema* msg) {
|
||||
return *msg->_impl_.datatype_extension_;
|
||||
}
|
||||
const ::greptime::v1::ColumnOptions&
|
||||
ColumnSchema::_Internal::options(const ColumnSchema* msg) {
|
||||
return *msg->_impl_.options_;
|
||||
}
|
||||
void ColumnSchema::clear_datatype_extension() {
|
||||
if (GetArenaForAllocation() == nullptr && _impl_.datatype_extension_ != nullptr) {
|
||||
delete _impl_.datatype_extension_;
|
||||
}
|
||||
_impl_.datatype_extension_ = nullptr;
|
||||
}
|
||||
void ColumnSchema::clear_options() {
|
||||
if (GetArenaForAllocation() == nullptr && _impl_.options_ != nullptr) {
|
||||
delete _impl_.options_;
|
||||
}
|
||||
_impl_.options_ = nullptr;
|
||||
}
|
||||
ColumnSchema::ColumnSchema(::PROTOBUF_NAMESPACE_ID::Arena* arena,
|
||||
bool is_message_owned)
|
||||
: ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
|
||||
@@ -464,6 +478,7 @@ ColumnSchema::ColumnSchema(const ColumnSchema& from)
|
||||
new (&_impl_) Impl_{
|
||||
decltype(_impl_.column_name_){}
|
||||
, decltype(_impl_.datatype_extension_){nullptr}
|
||||
, decltype(_impl_.options_){nullptr}
|
||||
, decltype(_impl_.datatype_){}
|
||||
, decltype(_impl_.semantic_type_){}
|
||||
, /*decltype(_impl_._cached_size_)*/{}};
|
||||
@@ -480,6 +495,9 @@ ColumnSchema::ColumnSchema(const ColumnSchema& from)
|
||||
if (from._internal_has_datatype_extension()) {
|
||||
_this->_impl_.datatype_extension_ = new ::greptime::v1::ColumnDataTypeExtension(*from._impl_.datatype_extension_);
|
||||
}
|
||||
if (from._internal_has_options()) {
|
||||
_this->_impl_.options_ = new ::greptime::v1::ColumnOptions(*from._impl_.options_);
|
||||
}
|
||||
::memcpy(&_impl_.datatype_, &from._impl_.datatype_,
|
||||
static_cast<size_t>(reinterpret_cast<char*>(&_impl_.semantic_type_) -
|
||||
reinterpret_cast<char*>(&_impl_.datatype_)) + sizeof(_impl_.semantic_type_));
|
||||
@@ -493,6 +511,7 @@ inline void ColumnSchema::SharedCtor(
|
||||
new (&_impl_) Impl_{
|
||||
decltype(_impl_.column_name_){}
|
||||
, decltype(_impl_.datatype_extension_){nullptr}
|
||||
, decltype(_impl_.options_){nullptr}
|
||||
, decltype(_impl_.datatype_){0}
|
||||
, decltype(_impl_.semantic_type_){0}
|
||||
, /*decltype(_impl_._cached_size_)*/{}
|
||||
@@ -516,6 +535,7 @@ inline void ColumnSchema::SharedDtor() {
|
||||
GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
|
||||
_impl_.column_name_.Destroy();
|
||||
if (this != internal_default_instance()) delete _impl_.datatype_extension_;
|
||||
if (this != internal_default_instance()) delete _impl_.options_;
|
||||
}
|
||||
|
||||
void ColumnSchema::SetCachedSize(int size) const {
|
||||
@@ -533,6 +553,10 @@ void ColumnSchema::Clear() {
|
||||
delete _impl_.datatype_extension_;
|
||||
}
|
||||
_impl_.datatype_extension_ = nullptr;
|
||||
if (GetArenaForAllocation() == nullptr && _impl_.options_ != nullptr) {
|
||||
delete _impl_.options_;
|
||||
}
|
||||
_impl_.options_ = nullptr;
|
||||
::memset(&_impl_.datatype_, 0, static_cast<size_t>(
|
||||
reinterpret_cast<char*>(&_impl_.semantic_type_) -
|
||||
reinterpret_cast<char*>(&_impl_.datatype_)) + sizeof(_impl_.semantic_type_));
|
||||
@@ -581,6 +605,14 @@ const char* ColumnSchema::_InternalParse(const char* ptr, ::_pbi::ParseContext*
|
||||
} else
|
||||
goto handle_unusual;
|
||||
continue;
|
||||
// .greptime.v1.ColumnOptions options = 5;
|
||||
case 5:
|
||||
if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 42)) {
|
||||
ptr = ctx->ParseMessage(_internal_mutable_options(), ptr);
|
||||
CHK_(ptr);
|
||||
} else
|
||||
goto handle_unusual;
|
||||
continue;
|
||||
default:
|
||||
goto handle_unusual;
|
||||
} // switch
|
||||
@@ -641,6 +673,13 @@ uint8_t* ColumnSchema::_InternalSerialize(
|
||||
_Internal::datatype_extension(this).GetCachedSize(), target, stream);
|
||||
}
|
||||
|
||||
// .greptime.v1.ColumnOptions options = 5;
|
||||
if (this->_internal_has_options()) {
|
||||
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
||||
InternalWriteMessage(5, _Internal::options(this),
|
||||
_Internal::options(this).GetCachedSize(), target, stream);
|
||||
}
|
||||
|
||||
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
||||
target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
|
||||
_internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
|
||||
@@ -671,6 +710,13 @@ size_t ColumnSchema::ByteSizeLong() const {
|
||||
*_impl_.datatype_extension_);
|
||||
}
|
||||
|
||||
// .greptime.v1.ColumnOptions options = 5;
|
||||
if (this->_internal_has_options()) {
|
||||
total_size += 1 +
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
||||
*_impl_.options_);
|
||||
}
|
||||
|
||||
// .greptime.v1.ColumnDataType datatype = 2;
|
||||
if (this->_internal_datatype() != 0) {
|
||||
total_size += 1 +
|
||||
@@ -708,6 +754,10 @@ void ColumnSchema::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::P
|
||||
_this->_internal_mutable_datatype_extension()->::greptime::v1::ColumnDataTypeExtension::MergeFrom(
|
||||
from._internal_datatype_extension());
|
||||
}
|
||||
if (from._internal_has_options()) {
|
||||
_this->_internal_mutable_options()->::greptime::v1::ColumnOptions::MergeFrom(
|
||||
from._internal_options());
|
||||
}
|
||||
if (from._internal_datatype() != 0) {
|
||||
_this->_internal_set_datatype(from._internal_datatype());
|
||||
}
|
||||
|
||||
@@ -372,6 +372,7 @@ class ColumnSchema final :
|
||||
enum : int {
|
||||
kColumnNameFieldNumber = 1,
|
||||
kDatatypeExtensionFieldNumber = 4,
|
||||
kOptionsFieldNumber = 5,
|
||||
kDatatypeFieldNumber = 2,
|
||||
kSemanticTypeFieldNumber = 3,
|
||||
};
|
||||
@@ -407,6 +408,24 @@ class ColumnSchema final :
|
||||
::greptime::v1::ColumnDataTypeExtension* datatype_extension);
|
||||
::greptime::v1::ColumnDataTypeExtension* unsafe_arena_release_datatype_extension();
|
||||
|
||||
// .greptime.v1.ColumnOptions options = 5;
|
||||
bool has_options() const;
|
||||
private:
|
||||
bool _internal_has_options() const;
|
||||
public:
|
||||
void clear_options();
|
||||
const ::greptime::v1::ColumnOptions& options() const;
|
||||
PROTOBUF_NODISCARD ::greptime::v1::ColumnOptions* release_options();
|
||||
::greptime::v1::ColumnOptions* mutable_options();
|
||||
void set_allocated_options(::greptime::v1::ColumnOptions* options);
|
||||
private:
|
||||
const ::greptime::v1::ColumnOptions& _internal_options() const;
|
||||
::greptime::v1::ColumnOptions* _internal_mutable_options();
|
||||
public:
|
||||
void unsafe_arena_set_allocated_options(
|
||||
::greptime::v1::ColumnOptions* options);
|
||||
::greptime::v1::ColumnOptions* unsafe_arena_release_options();
|
||||
|
||||
// .greptime.v1.ColumnDataType datatype = 2;
|
||||
void clear_datatype();
|
||||
::greptime::v1::ColumnDataType datatype() const;
|
||||
@@ -435,6 +454,7 @@ class ColumnSchema final :
|
||||
struct Impl_ {
|
||||
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr column_name_;
|
||||
::greptime::v1::ColumnDataTypeExtension* datatype_extension_;
|
||||
::greptime::v1::ColumnOptions* options_;
|
||||
int datatype_;
|
||||
int semantic_type_;
|
||||
mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
|
||||
@@ -1500,6 +1520,91 @@ inline void ColumnSchema::set_allocated_datatype_extension(::greptime::v1::Colum
|
||||
// @@protoc_insertion_point(field_set_allocated:greptime.v1.ColumnSchema.datatype_extension)
|
||||
}
|
||||
|
||||
// .greptime.v1.ColumnOptions options = 5;
|
||||
inline bool ColumnSchema::_internal_has_options() const {
|
||||
return this != internal_default_instance() && _impl_.options_ != nullptr;
|
||||
}
|
||||
inline bool ColumnSchema::has_options() const {
|
||||
return _internal_has_options();
|
||||
}
|
||||
inline const ::greptime::v1::ColumnOptions& ColumnSchema::_internal_options() const {
|
||||
const ::greptime::v1::ColumnOptions* p = _impl_.options_;
|
||||
return p != nullptr ? *p : reinterpret_cast<const ::greptime::v1::ColumnOptions&>(
|
||||
::greptime::v1::_ColumnOptions_default_instance_);
|
||||
}
|
||||
inline const ::greptime::v1::ColumnOptions& ColumnSchema::options() const {
|
||||
// @@protoc_insertion_point(field_get:greptime.v1.ColumnSchema.options)
|
||||
return _internal_options();
|
||||
}
|
||||
inline void ColumnSchema::unsafe_arena_set_allocated_options(
|
||||
::greptime::v1::ColumnOptions* options) {
|
||||
if (GetArenaForAllocation() == nullptr) {
|
||||
delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.options_);
|
||||
}
|
||||
_impl_.options_ = options;
|
||||
if (options) {
|
||||
|
||||
} else {
|
||||
|
||||
}
|
||||
// @@protoc_insertion_point(field_unsafe_arena_set_allocated:greptime.v1.ColumnSchema.options)
|
||||
}
|
||||
inline ::greptime::v1::ColumnOptions* ColumnSchema::release_options() {
|
||||
|
||||
::greptime::v1::ColumnOptions* temp = _impl_.options_;
|
||||
_impl_.options_ = nullptr;
|
||||
#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
|
||||
auto* old = reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp);
|
||||
temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
|
||||
if (GetArenaForAllocation() == nullptr) { delete old; }
|
||||
#else // PROTOBUF_FORCE_COPY_IN_RELEASE
|
||||
if (GetArenaForAllocation() != nullptr) {
|
||||
temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
|
||||
}
|
||||
#endif // !PROTOBUF_FORCE_COPY_IN_RELEASE
|
||||
return temp;
|
||||
}
|
||||
inline ::greptime::v1::ColumnOptions* ColumnSchema::unsafe_arena_release_options() {
|
||||
// @@protoc_insertion_point(field_release:greptime.v1.ColumnSchema.options)
|
||||
|
||||
::greptime::v1::ColumnOptions* temp = _impl_.options_;
|
||||
_impl_.options_ = nullptr;
|
||||
return temp;
|
||||
}
|
||||
inline ::greptime::v1::ColumnOptions* ColumnSchema::_internal_mutable_options() {
|
||||
|
||||
if (_impl_.options_ == nullptr) {
|
||||
auto* p = CreateMaybeMessage<::greptime::v1::ColumnOptions>(GetArenaForAllocation());
|
||||
_impl_.options_ = p;
|
||||
}
|
||||
return _impl_.options_;
|
||||
}
|
||||
inline ::greptime::v1::ColumnOptions* ColumnSchema::mutable_options() {
|
||||
::greptime::v1::ColumnOptions* _msg = _internal_mutable_options();
|
||||
// @@protoc_insertion_point(field_mutable:greptime.v1.ColumnSchema.options)
|
||||
return _msg;
|
||||
}
|
||||
inline void ColumnSchema::set_allocated_options(::greptime::v1::ColumnOptions* options) {
|
||||
::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
|
||||
if (message_arena == nullptr) {
|
||||
delete reinterpret_cast< ::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.options_);
|
||||
}
|
||||
if (options) {
|
||||
::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
|
||||
::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(
|
||||
reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(options));
|
||||
if (message_arena != submessage_arena) {
|
||||
options = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
|
||||
message_arena, options, submessage_arena);
|
||||
}
|
||||
|
||||
} else {
|
||||
|
||||
}
|
||||
_impl_.options_ = options;
|
||||
// @@protoc_insertion_point(field_set_allocated:greptime.v1.ColumnSchema.options)
|
||||
}
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// Row
|
||||
|
||||
Reference in New Issue
Block a user