From 45f4415ad52c0545ba9ebdea724f321dd9c0de34 Mon Sep 17 00:00:00 2001 From: Zhenchi Date: Wed, 19 Mar 2025 03:17:44 +0000 Subject: [PATCH] feat: add backend option to `SetFulltext` Signed-off-by: Zhenchi --- c++/greptime/v1/ddl.pb.cc | 126 +++++-- c++/greptime/v1/ddl.pb.h | 61 +++ go/greptime/v1/ddl.pb.go | 417 ++++++++++++--------- java/src/main/java/io/greptime/v1/Ddl.java | 268 +++++++++++-- proto/greptime/v1/ddl.proto | 6 + 5 files changed, 636 insertions(+), 242 deletions(-) diff --git a/c++/greptime/v1/ddl.pb.cc b/c++/greptime/v1/ddl.pb.cc index dffe9d76..4c556bc8 100644 --- a/c++/greptime/v1/ddl.pb.cc +++ b/c++/greptime/v1/ddl.pb.cc @@ -479,6 +479,7 @@ PROTOBUF_CONSTEXPR SetFulltext::SetFulltext( , /*decltype(_impl_.analyzer_)*/0 , /*decltype(_impl_.enable_)*/false , /*decltype(_impl_.case_sensitive_)*/false + , /*decltype(_impl_.backend_)*/0 , /*decltype(_impl_._cached_size_)*/{}} {} struct SetFulltextDefaultTypeInternal { PROTOBUF_CONSTEXPR SetFulltextDefaultTypeInternal() @@ -602,7 +603,7 @@ PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORIT } // namespace v1 } // namespace greptime static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fddl_2eproto[39]; -static const ::_pb::EnumDescriptor* file_level_enum_descriptors_greptime_2fv1_2fddl_2eproto[3]; +static const ::_pb::EnumDescriptor* file_level_enum_descriptors_greptime_2fv1_2fddl_2eproto[4]; static constexpr ::_pb::ServiceDescriptor const** file_level_service_descriptors_greptime_2fv1_2fddl_2eproto = nullptr; const uint32_t TableStruct_greptime_2fv1_2fddl_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = { @@ -922,6 +923,7 @@ const uint32_t TableStruct_greptime_2fv1_2fddl_2eproto::offsets[] PROTOBUF_SECTI PROTOBUF_FIELD_OFFSET(::greptime::v1::SetFulltext, _impl_.enable_), PROTOBUF_FIELD_OFFSET(::greptime::v1::SetFulltext, _impl_.analyzer_), PROTOBUF_FIELD_OFFSET(::greptime::v1::SetFulltext, _impl_.case_sensitive_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::SetFulltext, _impl_.backend_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::UnsetFulltext, _internal_metadata_), ~0u, // no _extensions_ @@ -1018,14 +1020,14 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode { 284, -1, -1, sizeof(::greptime::v1::ColumnDef)}, { 298, -1, -1, sizeof(::greptime::v1::AddColumnLocation)}, { 306, -1, -1, sizeof(::greptime::v1::SetFulltext)}, - { 316, -1, -1, sizeof(::greptime::v1::UnsetFulltext)}, - { 323, -1, -1, sizeof(::greptime::v1::SetInverted)}, - { 330, -1, -1, sizeof(::greptime::v1::UnsetInverted)}, - { 337, -1, -1, sizeof(::greptime::v1::SetSkipping)}, - { 347, -1, -1, sizeof(::greptime::v1::UnsetSkipping)}, - { 354, -1, -1, sizeof(::greptime::v1::AlterDatabaseExpr)}, - { 365, -1, -1, sizeof(::greptime::v1::SetDatabaseOptions)}, - { 372, -1, -1, sizeof(::greptime::v1::UnsetDatabaseOptions)}, + { 317, -1, -1, sizeof(::greptime::v1::UnsetFulltext)}, + { 324, -1, -1, sizeof(::greptime::v1::SetInverted)}, + { 331, -1, -1, sizeof(::greptime::v1::UnsetInverted)}, + { 338, -1, -1, sizeof(::greptime::v1::SetSkipping)}, + { 348, -1, -1, sizeof(::greptime::v1::UnsetSkipping)}, + { 355, -1, -1, sizeof(::greptime::v1::AlterDatabaseExpr)}, + { 366, -1, -1, sizeof(::greptime::v1::SetDatabaseOptions)}, + { 373, -1, -1, sizeof(::greptime::v1::UnsetDatabaseOptions)}, }; static const ::_pb::Message* const file_default_instances[] = { @@ -1184,36 +1186,39 @@ const char descriptor_table_protodef_greptime_2fv1_2fddl_2eproto[] PROTOBUF_SECT "\n\021AddColumnLocation\022B\n\rlocation_type\030\001 \001" "(\0162+.greptime.v1.AddColumnLocation.Locat" "ionType\022\031\n\021after_column_name\030\002 \001(\t\"$\n\014Lo" - "cationType\022\t\n\005FIRST\020\000\022\t\n\005AFTER\020\001\"s\n\013SetF" - "ulltext\022\023\n\013column_name\030\001 \001(\t\022\016\n\006enable\030\002" - " \001(\010\022\'\n\010analyzer\030\003 \001(\0162\025.greptime.v1.Ana" - "lyzer\022\026\n\016case_sensitive\030\004 \001(\010\"$\n\rUnsetFu" - "lltext\022\023\n\013column_name\030\001 \001(\t\"\"\n\013SetInvert" - "ed\022\023\n\013column_name\030\001 \001(\t\"$\n\rUnsetInverted" - "\022\023\n\013column_name\030\001 \001(\t\"\204\001\n\013SetSkipping\022\023\n" - "\013column_name\030\001 \001(\t\022\016\n\006enable\030\002 \001(\010\022\023\n\013gr" - "anularity\030\003 \001(\004\022;\n\023skipping_index_type\030\004" - " \001(\0162\036.greptime.v1.SkippingIndexType\"$\n\r" - "UnsetSkipping\022\023\n\013column_name\030\001 \001(\t\"\314\001\n\021A" - "lterDatabaseExpr\022\024\n\014catalog_name\030\001 \001(\t\022\023" - "\n\013schema_name\030\002 \001(\t\022\?\n\024set_database_opti" - "ons\030\003 \001(\0132\037.greptime.v1.SetDatabaseOptio" - "nsH\000\022C\n\026unset_database_options\030\004 \001(\0132!.g" - "reptime.v1.UnsetDatabaseOptionsH\000B\006\n\004kin" - "d\"G\n\022SetDatabaseOptions\0221\n\024set_database_" - "options\030\001 \003(\0132\023.greptime.v1.Option\"$\n\024Un" - "setDatabaseOptions\022\014\n\004keys\030\001 \003(\t*$\n\010Anal" - "yzer\022\013\n\007ENGLISH\020\000\022\013\n\007CHINESE\020\001*%\n\021Skippi" - "ngIndexType\022\020\n\014BLOOM_FILTER\020\000BL\n\016io.grep" - "time.v1B\003DdlZ5github.com/GreptimeTeam/gr" - "eptime-proto/go/greptime/v1b\006proto3" + "cationType\022\t\n\005FIRST\020\000\022\t\n\005AFTER\020\001\"\242\001\n\013Set" + "Fulltext\022\023\n\013column_name\030\001 \001(\t\022\016\n\006enable\030" + "\002 \001(\010\022\'\n\010analyzer\030\003 \001(\0162\025.greptime.v1.An" + "alyzer\022\026\n\016case_sensitive\030\004 \001(\010\022-\n\007backen" + "d\030\005 \001(\0162\034.greptime.v1.FulltextBackend\"$\n" + "\rUnsetFulltext\022\023\n\013column_name\030\001 \001(\t\"\"\n\013S" + "etInverted\022\023\n\013column_name\030\001 \001(\t\"$\n\rUnset" + "Inverted\022\023\n\013column_name\030\001 \001(\t\"\204\001\n\013SetSki" + "pping\022\023\n\013column_name\030\001 \001(\t\022\016\n\006enable\030\002 \001" + "(\010\022\023\n\013granularity\030\003 \001(\004\022;\n\023skipping_inde" + "x_type\030\004 \001(\0162\036.greptime.v1.SkippingIndex" + "Type\"$\n\rUnsetSkipping\022\023\n\013column_name\030\001 \001" + "(\t\"\314\001\n\021AlterDatabaseExpr\022\024\n\014catalog_name" + "\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022\?\n\024set_datab" + "ase_options\030\003 \001(\0132\037.greptime.v1.SetDatab" + "aseOptionsH\000\022C\n\026unset_database_options\030\004" + " \001(\0132!.greptime.v1.UnsetDatabaseOptionsH" + "\000B\006\n\004kind\"G\n\022SetDatabaseOptions\0221\n\024set_d" + "atabase_options\030\001 \003(\0132\023.greptime.v1.Opti" + "on\"$\n\024UnsetDatabaseOptions\022\014\n\004keys\030\001 \003(\t" + "*$\n\010Analyzer\022\013\n\007ENGLISH\020\000\022\013\n\007CHINESE\020\001*)" + "\n\017FulltextBackend\022\013\n\007TANTIVY\020\000\022\t\n\005BLOOM\020" + "\001*%\n\021SkippingIndexType\022\020\n\014BLOOM_FILTER\020\000" + "BL\n\016io.greptime.v1B\003DdlZ5github.com/Grep" + "timeTeam/greptime-proto/go/greptime/v1b\006" + "proto3" ; 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, 5435, descriptor_table_protodef_greptime_2fv1_2fddl_2eproto, + false, false, 5526, 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, 39, schemas, file_default_instances, TableStruct_greptime_2fv1_2fddl_2eproto::offsets, @@ -1263,10 +1268,24 @@ bool Analyzer_IsValid(int value) { } } -const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* SkippingIndexType_descriptor() { +const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* FulltextBackend_descriptor() { ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_greptime_2fv1_2fddl_2eproto); return file_level_enum_descriptors_greptime_2fv1_2fddl_2eproto[2]; } +bool FulltextBackend_IsValid(int value) { + switch (value) { + case 0: + case 1: + return true; + default: + return false; + } +} + +const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* SkippingIndexType_descriptor() { + ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_greptime_2fv1_2fddl_2eproto); + return file_level_enum_descriptors_greptime_2fv1_2fddl_2eproto[3]; +} bool SkippingIndexType_IsValid(int value) { switch (value) { case 0: @@ -10752,6 +10771,7 @@ SetFulltext::SetFulltext(const SetFulltext& from) , decltype(_impl_.analyzer_){} , decltype(_impl_.enable_){} , decltype(_impl_.case_sensitive_){} + , decltype(_impl_.backend_){} , /*decltype(_impl_._cached_size_)*/{}}; _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); @@ -10764,8 +10784,8 @@ SetFulltext::SetFulltext(const SetFulltext& from) _this->GetArenaForAllocation()); } ::memcpy(&_impl_.analyzer_, &from._impl_.analyzer_, - static_cast(reinterpret_cast(&_impl_.case_sensitive_) - - reinterpret_cast(&_impl_.analyzer_)) + sizeof(_impl_.case_sensitive_)); + static_cast(reinterpret_cast(&_impl_.backend_) - + reinterpret_cast(&_impl_.analyzer_)) + sizeof(_impl_.backend_)); // @@protoc_insertion_point(copy_constructor:greptime.v1.SetFulltext) } @@ -10778,6 +10798,7 @@ inline void SetFulltext::SharedCtor( , decltype(_impl_.analyzer_){0} , decltype(_impl_.enable_){false} , decltype(_impl_.case_sensitive_){false} + , decltype(_impl_.backend_){0} , /*decltype(_impl_._cached_size_)*/{} }; _impl_.column_name_.InitDefault(); @@ -10812,8 +10833,8 @@ void SetFulltext::Clear() { _impl_.column_name_.ClearToEmpty(); ::memset(&_impl_.analyzer_, 0, static_cast( - reinterpret_cast(&_impl_.case_sensitive_) - - reinterpret_cast(&_impl_.analyzer_)) + sizeof(_impl_.case_sensitive_)); + reinterpret_cast(&_impl_.backend_) - + reinterpret_cast(&_impl_.analyzer_)) + sizeof(_impl_.backend_)); _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } @@ -10858,6 +10879,15 @@ const char* SetFulltext::_InternalParse(const char* ptr, ::_pbi::ParseContext* c } else goto handle_unusual; continue; + // .greptime.v1.FulltextBackend backend = 5; + case 5: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 40)) { + uint64_t val = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr); + CHK_(ptr); + _internal_set_backend(static_cast<::greptime::v1::FulltextBackend>(val)); + } else + goto handle_unusual; + continue; default: goto handle_unusual; } // switch @@ -10916,6 +10946,13 @@ uint8_t* SetFulltext::_InternalSerialize( target = ::_pbi::WireFormatLite::WriteBoolToArray(4, this->_internal_case_sensitive(), target); } + // .greptime.v1.FulltextBackend backend = 5; + if (this->_internal_backend() != 0) { + target = stream->EnsureSpace(target); + target = ::_pbi::WireFormatLite::WriteEnumToArray( + 5, this->_internal_backend(), target); + } + 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); @@ -10955,6 +10992,12 @@ size_t SetFulltext::ByteSizeLong() const { total_size += 1 + 1; } + // .greptime.v1.FulltextBackend backend = 5; + if (this->_internal_backend() != 0) { + total_size += 1 + + ::_pbi::WireFormatLite::EnumSize(this->_internal_backend()); + } + return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_); } @@ -10985,6 +11028,9 @@ void SetFulltext::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PR if (from._internal_case_sensitive() != 0) { _this->_internal_set_case_sensitive(from._internal_case_sensitive()); } + if (from._internal_backend() != 0) { + _this->_internal_set_backend(from._internal_backend()); + } _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); } @@ -11009,8 +11055,8 @@ void SetFulltext::InternalSwap(SetFulltext* other) { &other->_impl_.column_name_, rhs_arena ); ::PROTOBUF_NAMESPACE_ID::internal::memswap< - PROTOBUF_FIELD_OFFSET(SetFulltext, _impl_.case_sensitive_) - + sizeof(SetFulltext::_impl_.case_sensitive_) + PROTOBUF_FIELD_OFFSET(SetFulltext, _impl_.backend_) + + sizeof(SetFulltext::_impl_.backend_) - PROTOBUF_FIELD_OFFSET(SetFulltext, _impl_.analyzer_)>( reinterpret_cast(&_impl_.analyzer_), reinterpret_cast(&other->_impl_.analyzer_)); diff --git a/c++/greptime/v1/ddl.pb.h b/c++/greptime/v1/ddl.pb.h index 42bdd31a..0fc04842 100644 --- a/c++/greptime/v1/ddl.pb.h +++ b/c++/greptime/v1/ddl.pb.h @@ -264,6 +264,31 @@ inline bool Analyzer_Parse( return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum( Analyzer_descriptor(), name, value); } +enum FulltextBackend : int { + TANTIVY = 0, + BLOOM = 1, + FulltextBackend_INT_MIN_SENTINEL_DO_NOT_USE_ = std::numeric_limits::min(), + FulltextBackend_INT_MAX_SENTINEL_DO_NOT_USE_ = std::numeric_limits::max() +}; +bool FulltextBackend_IsValid(int value); +constexpr FulltextBackend FulltextBackend_MIN = TANTIVY; +constexpr FulltextBackend FulltextBackend_MAX = BLOOM; +constexpr int FulltextBackend_ARRAYSIZE = FulltextBackend_MAX + 1; + +const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* FulltextBackend_descriptor(); +template +inline const std::string& FulltextBackend_Name(T enum_t_value) { + static_assert(::std::is_same::value || + ::std::is_integral::value, + "Incorrect type passed to function FulltextBackend_Name."); + return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum( + FulltextBackend_descriptor(), enum_t_value); +} +inline bool FulltextBackend_Parse( + ::PROTOBUF_NAMESPACE_ID::ConstStringParam name, FulltextBackend* value) { + return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum( + FulltextBackend_descriptor(), name, value); +} enum SkippingIndexType : int { BLOOM_FILTER = 0, SkippingIndexType_INT_MIN_SENTINEL_DO_NOT_USE_ = std::numeric_limits::min(), @@ -6248,6 +6273,7 @@ class SetFulltext final : kAnalyzerFieldNumber = 3, kEnableFieldNumber = 2, kCaseSensitiveFieldNumber = 4, + kBackendFieldNumber = 5, }; // string column_name = 1; void clear_column_name(); @@ -6290,6 +6316,15 @@ class SetFulltext final : void _internal_set_case_sensitive(bool value); public: + // .greptime.v1.FulltextBackend backend = 5; + void clear_backend(); + ::greptime::v1::FulltextBackend backend() const; + void set_backend(::greptime::v1::FulltextBackend value); + private: + ::greptime::v1::FulltextBackend _internal_backend() const; + void _internal_set_backend(::greptime::v1::FulltextBackend value); + public: + // @@protoc_insertion_point(class_scope:greptime.v1.SetFulltext) private: class _Internal; @@ -6302,6 +6337,7 @@ class SetFulltext final : int analyzer_; bool enable_; bool case_sensitive_; + int backend_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; }; union { Impl_ _impl_; }; @@ -13876,6 +13912,26 @@ inline void SetFulltext::set_case_sensitive(bool value) { // @@protoc_insertion_point(field_set:greptime.v1.SetFulltext.case_sensitive) } +// .greptime.v1.FulltextBackend backend = 5; +inline void SetFulltext::clear_backend() { + _impl_.backend_ = 0; +} +inline ::greptime::v1::FulltextBackend SetFulltext::_internal_backend() const { + return static_cast< ::greptime::v1::FulltextBackend >(_impl_.backend_); +} +inline ::greptime::v1::FulltextBackend SetFulltext::backend() const { + // @@protoc_insertion_point(field_get:greptime.v1.SetFulltext.backend) + return _internal_backend(); +} +inline void SetFulltext::_internal_set_backend(::greptime::v1::FulltextBackend value) { + + _impl_.backend_ = value; +} +inline void SetFulltext::set_backend(::greptime::v1::FulltextBackend value) { + _internal_set_backend(value); + // @@protoc_insertion_point(field_set:greptime.v1.SetFulltext.backend) +} + // ------------------------------------------------------------------- // UnsetFulltext @@ -14687,6 +14743,11 @@ template <> inline const EnumDescriptor* GetEnumDescriptor< ::greptime::v1::Analyzer>() { return ::greptime::v1::Analyzer_descriptor(); } +template <> struct is_proto_enum< ::greptime::v1::FulltextBackend> : ::std::true_type {}; +template <> +inline const EnumDescriptor* GetEnumDescriptor< ::greptime::v1::FulltextBackend>() { + return ::greptime::v1::FulltextBackend_descriptor(); +} template <> struct is_proto_enum< ::greptime::v1::SkippingIndexType> : ::std::true_type {}; template <> inline const EnumDescriptor* GetEnumDescriptor< ::greptime::v1::SkippingIndexType>() { diff --git a/go/greptime/v1/ddl.pb.go b/go/greptime/v1/ddl.pb.go index 6d9fbca4..e8bfc3e2 100644 --- a/go/greptime/v1/ddl.pb.go +++ b/go/greptime/v1/ddl.pb.go @@ -80,6 +80,52 @@ func (Analyzer) EnumDescriptor() ([]byte, []int) { return file_greptime_v1_ddl_proto_rawDescGZIP(), []int{0} } +type FulltextBackend int32 + +const ( + FulltextBackend_TANTIVY FulltextBackend = 0 + FulltextBackend_BLOOM FulltextBackend = 1 +) + +// Enum value maps for FulltextBackend. +var ( + FulltextBackend_name = map[int32]string{ + 0: "TANTIVY", + 1: "BLOOM", + } + FulltextBackend_value = map[string]int32{ + "TANTIVY": 0, + "BLOOM": 1, + } +) + +func (x FulltextBackend) Enum() *FulltextBackend { + p := new(FulltextBackend) + *p = x + return p +} + +func (x FulltextBackend) String() string { + return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) +} + +func (FulltextBackend) Descriptor() protoreflect.EnumDescriptor { + return file_greptime_v1_ddl_proto_enumTypes[1].Descriptor() +} + +func (FulltextBackend) Type() protoreflect.EnumType { + return &file_greptime_v1_ddl_proto_enumTypes[1] +} + +func (x FulltextBackend) Number() protoreflect.EnumNumber { + return protoreflect.EnumNumber(x) +} + +// Deprecated: Use FulltextBackend.Descriptor instead. +func (FulltextBackend) EnumDescriptor() ([]byte, []int) { + return file_greptime_v1_ddl_proto_rawDescGZIP(), []int{1} +} + type SkippingIndexType int32 const ( @@ -107,11 +153,11 @@ func (x SkippingIndexType) String() string { } func (SkippingIndexType) Descriptor() protoreflect.EnumDescriptor { - return file_greptime_v1_ddl_proto_enumTypes[1].Descriptor() + return file_greptime_v1_ddl_proto_enumTypes[2].Descriptor() } func (SkippingIndexType) Type() protoreflect.EnumType { - return &file_greptime_v1_ddl_proto_enumTypes[1] + return &file_greptime_v1_ddl_proto_enumTypes[2] } func (x SkippingIndexType) Number() protoreflect.EnumNumber { @@ -120,7 +166,7 @@ func (x SkippingIndexType) Number() protoreflect.EnumNumber { // Deprecated: Use SkippingIndexType.Descriptor instead. func (SkippingIndexType) EnumDescriptor() ([]byte, []int) { - return file_greptime_v1_ddl_proto_rawDescGZIP(), []int{1} + return file_greptime_v1_ddl_proto_rawDescGZIP(), []int{2} } type AddColumnLocation_LocationType int32 @@ -153,11 +199,11 @@ func (x AddColumnLocation_LocationType) String() string { } func (AddColumnLocation_LocationType) Descriptor() protoreflect.EnumDescriptor { - return file_greptime_v1_ddl_proto_enumTypes[2].Descriptor() + return file_greptime_v1_ddl_proto_enumTypes[3].Descriptor() } func (AddColumnLocation_LocationType) Type() protoreflect.EnumType { - return &file_greptime_v1_ddl_proto_enumTypes[2] + return &file_greptime_v1_ddl_proto_enumTypes[3] } func (x AddColumnLocation_LocationType) Number() protoreflect.EnumNumber { @@ -2318,10 +2364,11 @@ type SetFulltext struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - ColumnName string `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"` - Enable bool `protobuf:"varint,2,opt,name=enable,proto3" json:"enable,omitempty"` - Analyzer Analyzer `protobuf:"varint,3,opt,name=analyzer,proto3,enum=greptime.v1.Analyzer" json:"analyzer,omitempty"` - CaseSensitive bool `protobuf:"varint,4,opt,name=case_sensitive,json=caseSensitive,proto3" json:"case_sensitive,omitempty"` + ColumnName string `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"` + Enable bool `protobuf:"varint,2,opt,name=enable,proto3" json:"enable,omitempty"` + Analyzer Analyzer `protobuf:"varint,3,opt,name=analyzer,proto3,enum=greptime.v1.Analyzer" json:"analyzer,omitempty"` + CaseSensitive bool `protobuf:"varint,4,opt,name=case_sensitive,json=caseSensitive,proto3" json:"case_sensitive,omitempty"` + Backend FulltextBackend `protobuf:"varint,5,opt,name=backend,proto3,enum=greptime.v1.FulltextBackend" json:"backend,omitempty"` } func (x *SetFulltext) Reset() { @@ -2384,6 +2431,13 @@ func (x *SetFulltext) GetCaseSensitive() bool { return false } +func (x *SetFulltext) GetBackend() FulltextBackend { + if x != nil { + return x.Backend + } + return FulltextBackend_TANTIVY +} + type UnsetFulltext struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -3206,7 +3260,7 @@ var file_greptime_v1_ddl_proto_rawDesc = []byte{ 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x61, 0x66, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x24, 0x0a, 0x0c, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x12, 0x09, 0x0a, 0x05, 0x46, 0x49, 0x52, 0x53, - 0x54, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x41, 0x46, 0x54, 0x45, 0x52, 0x10, 0x01, 0x22, 0xa0, + 0x54, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x41, 0x46, 0x54, 0x45, 0x52, 0x10, 0x01, 0x22, 0xd8, 0x01, 0x0a, 0x0b, 0x53, 0x65, 0x74, 0x46, 0x75, 0x6c, 0x6c, 0x74, 0x65, 0x78, 0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x12, @@ -3217,66 +3271,73 @@ var file_greptime_v1_ddl_proto_rawDesc = []byte{ 0x52, 0x08, 0x61, 0x6e, 0x61, 0x6c, 0x79, 0x7a, 0x65, 0x72, 0x12, 0x25, 0x0a, 0x0e, 0x63, 0x61, 0x73, 0x65, 0x5f, 0x73, 0x65, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x76, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0d, 0x63, 0x61, 0x73, 0x65, 0x53, 0x65, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x76, - 0x65, 0x22, 0x30, 0x0a, 0x0d, 0x55, 0x6e, 0x73, 0x65, 0x74, 0x46, 0x75, 0x6c, 0x6c, 0x74, 0x65, - 0x78, 0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, - 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4e, - 0x61, 0x6d, 0x65, 0x22, 0x2e, 0x0a, 0x0b, 0x53, 0x65, 0x74, 0x49, 0x6e, 0x76, 0x65, 0x72, 0x74, - 0x65, 0x64, 0x12, 0x1f, 0x0a, 0x0b, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, - 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4e, - 0x61, 0x6d, 0x65, 0x22, 0x30, 0x0a, 0x0d, 0x55, 0x6e, 0x73, 0x65, 0x74, 0x49, 0x6e, 0x76, 0x65, - 0x72, 0x74, 0x65, 0x64, 0x12, 0x1f, 0x0a, 0x0b, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x6e, - 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, - 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0xb8, 0x01, 0x0a, 0x0b, 0x53, 0x65, 0x74, 0x53, 0x6b, 0x69, - 0x70, 0x70, 0x69, 0x6e, 0x67, 0x12, 0x1f, 0x0a, 0x0b, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, - 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x63, 0x6f, 0x6c, 0x75, - 0x6d, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, - 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x20, - 0x0a, 0x0b, 0x67, 0x72, 0x61, 0x6e, 0x75, 0x6c, 0x61, 0x72, 0x69, 0x74, 0x79, 0x18, 0x03, 0x20, - 0x01, 0x28, 0x04, 0x52, 0x0b, 0x67, 0x72, 0x61, 0x6e, 0x75, 0x6c, 0x61, 0x72, 0x69, 0x74, 0x79, - 0x12, 0x4e, 0x0a, 0x13, 0x73, 0x6b, 0x69, 0x70, 0x70, 0x69, 0x6e, 0x67, 0x5f, 0x69, 0x6e, 0x64, - 0x65, 0x78, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1e, 0x2e, - 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x6b, 0x69, 0x70, - 0x70, 0x69, 0x6e, 0x67, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x54, 0x79, 0x70, 0x65, 0x52, 0x11, 0x73, - 0x6b, 0x69, 0x70, 0x70, 0x69, 0x6e, 0x67, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x54, 0x79, 0x70, 0x65, - 0x22, 0x30, 0x0a, 0x0d, 0x55, 0x6e, 0x73, 0x65, 0x74, 0x53, 0x6b, 0x69, 0x70, 0x70, 0x69, 0x6e, - 0x67, 0x12, 0x1f, 0x0a, 0x0b, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, - 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4e, 0x61, - 0x6d, 0x65, 0x22, 0x8f, 0x02, 0x0a, 0x11, 0x41, 0x6c, 0x74, 0x65, 0x72, 0x44, 0x61, 0x74, 0x61, - 0x62, 0x61, 0x73, 0x65, 0x45, 0x78, 0x70, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x61, 0x74, 0x61, - 0x6c, 0x6f, 0x67, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, - 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x73, - 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, - 0x52, 0x0a, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x53, 0x0a, 0x14, - 0x73, 0x65, 0x74, 0x5f, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x5f, 0x6f, 0x70, 0x74, - 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, - 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x65, 0x74, 0x44, 0x61, 0x74, 0x61, - 0x62, 0x61, 0x73, 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x48, 0x00, 0x52, 0x12, 0x73, - 0x65, 0x74, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, - 0x73, 0x12, 0x59, 0x0a, 0x16, 0x75, 0x6e, 0x73, 0x65, 0x74, 0x5f, 0x64, 0x61, 0x74, 0x61, 0x62, - 0x61, 0x73, 0x65, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, - 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, - 0x55, 0x6e, 0x73, 0x65, 0x74, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x4f, 0x70, 0x74, - 0x69, 0x6f, 0x6e, 0x73, 0x48, 0x00, 0x52, 0x14, 0x75, 0x6e, 0x73, 0x65, 0x74, 0x44, 0x61, 0x74, - 0x61, 0x62, 0x61, 0x73, 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x42, 0x06, 0x0a, 0x04, - 0x6b, 0x69, 0x6e, 0x64, 0x22, 0x5b, 0x0a, 0x12, 0x53, 0x65, 0x74, 0x44, 0x61, 0x74, 0x61, 0x62, - 0x61, 0x73, 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x45, 0x0a, 0x14, 0x73, 0x65, - 0x74, 0x5f, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, - 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x13, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, - 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x12, 0x73, + 0x65, 0x12, 0x36, 0x0a, 0x07, 0x62, 0x61, 0x63, 0x6b, 0x65, 0x6e, 0x64, 0x18, 0x05, 0x20, 0x01, + 0x28, 0x0e, 0x32, 0x1c, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, + 0x2e, 0x46, 0x75, 0x6c, 0x6c, 0x74, 0x65, 0x78, 0x74, 0x42, 0x61, 0x63, 0x6b, 0x65, 0x6e, 0x64, + 0x52, 0x07, 0x62, 0x61, 0x63, 0x6b, 0x65, 0x6e, 0x64, 0x22, 0x30, 0x0a, 0x0d, 0x55, 0x6e, 0x73, + 0x65, 0x74, 0x46, 0x75, 0x6c, 0x6c, 0x74, 0x65, 0x78, 0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x63, 0x6f, + 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x2e, 0x0a, 0x0b, 0x53, + 0x65, 0x74, 0x49, 0x6e, 0x76, 0x65, 0x72, 0x74, 0x65, 0x64, 0x12, 0x1f, 0x0a, 0x0b, 0x63, 0x6f, + 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x30, 0x0a, 0x0d, 0x55, + 0x6e, 0x73, 0x65, 0x74, 0x49, 0x6e, 0x76, 0x65, 0x72, 0x74, 0x65, 0x64, 0x12, 0x1f, 0x0a, 0x0b, + 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0xb8, 0x01, + 0x0a, 0x0b, 0x53, 0x65, 0x74, 0x53, 0x6b, 0x69, 0x70, 0x70, 0x69, 0x6e, 0x67, 0x12, 0x1f, 0x0a, + 0x0b, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x16, + 0x0a, 0x06, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, + 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x67, 0x72, 0x61, 0x6e, 0x75, 0x6c, + 0x61, 0x72, 0x69, 0x74, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0b, 0x67, 0x72, 0x61, + 0x6e, 0x75, 0x6c, 0x61, 0x72, 0x69, 0x74, 0x79, 0x12, 0x4e, 0x0a, 0x13, 0x73, 0x6b, 0x69, 0x70, + 0x70, 0x69, 0x6e, 0x67, 0x5f, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, + 0x04, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1e, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, + 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x6b, 0x69, 0x70, 0x70, 0x69, 0x6e, 0x67, 0x49, 0x6e, 0x64, 0x65, + 0x78, 0x54, 0x79, 0x70, 0x65, 0x52, 0x11, 0x73, 0x6b, 0x69, 0x70, 0x70, 0x69, 0x6e, 0x67, 0x49, + 0x6e, 0x64, 0x65, 0x78, 0x54, 0x79, 0x70, 0x65, 0x22, 0x30, 0x0a, 0x0d, 0x55, 0x6e, 0x73, 0x65, + 0x74, 0x53, 0x6b, 0x69, 0x70, 0x70, 0x69, 0x6e, 0x67, 0x12, 0x1f, 0x0a, 0x0b, 0x63, 0x6f, 0x6c, + 0x75, 0x6d, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, + 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x8f, 0x02, 0x0a, 0x11, 0x41, + 0x6c, 0x74, 0x65, 0x72, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x45, 0x78, 0x70, 0x72, + 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x5f, 0x6e, 0x61, 0x6d, 0x65, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x4e, + 0x61, 0x6d, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x6e, 0x61, + 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, + 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x53, 0x0a, 0x14, 0x73, 0x65, 0x74, 0x5f, 0x64, 0x61, 0x74, 0x61, + 0x62, 0x61, 0x73, 0x65, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x03, 0x20, 0x01, + 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, + 0x2e, 0x53, 0x65, 0x74, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x4f, 0x70, 0x74, 0x69, + 0x6f, 0x6e, 0x73, 0x48, 0x00, 0x52, 0x12, 0x73, 0x65, 0x74, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, + 0x73, 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x59, 0x0a, 0x16, 0x75, 0x6e, 0x73, + 0x65, 0x74, 0x5f, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x5f, 0x6f, 0x70, 0x74, 0x69, + 0x6f, 0x6e, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, + 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x55, 0x6e, 0x73, 0x65, 0x74, 0x44, 0x61, 0x74, + 0x61, 0x62, 0x61, 0x73, 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x48, 0x00, 0x52, 0x14, + 0x75, 0x6e, 0x73, 0x65, 0x74, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x4f, 0x70, 0x74, + 0x69, 0x6f, 0x6e, 0x73, 0x42, 0x06, 0x0a, 0x04, 0x6b, 0x69, 0x6e, 0x64, 0x22, 0x5b, 0x0a, 0x12, + 0x53, 0x65, 0x74, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, + 0x6e, 0x73, 0x12, 0x45, 0x0a, 0x14, 0x73, 0x65, 0x74, 0x5f, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, + 0x73, 0x65, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, + 0x32, 0x13, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x4f, + 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x12, 0x73, 0x65, 0x74, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, + 0x73, 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x22, 0x2a, 0x0a, 0x14, 0x55, 0x6e, 0x73, 0x65, 0x74, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, - 0x73, 0x22, 0x2a, 0x0a, 0x14, 0x55, 0x6e, 0x73, 0x65, 0x74, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, - 0x73, 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x6b, 0x65, 0x79, - 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x2a, 0x24, 0x0a, - 0x08, 0x41, 0x6e, 0x61, 0x6c, 0x79, 0x7a, 0x65, 0x72, 0x12, 0x0b, 0x0a, 0x07, 0x45, 0x4e, 0x47, - 0x4c, 0x49, 0x53, 0x48, 0x10, 0x00, 0x12, 0x0b, 0x0a, 0x07, 0x43, 0x48, 0x49, 0x4e, 0x45, 0x53, - 0x45, 0x10, 0x01, 0x2a, 0x25, 0x0a, 0x11, 0x53, 0x6b, 0x69, 0x70, 0x70, 0x69, 0x6e, 0x67, 0x49, - 0x6e, 0x64, 0x65, 0x78, 0x54, 0x79, 0x70, 0x65, 0x12, 0x10, 0x0a, 0x0c, 0x42, 0x4c, 0x4f, 0x4f, - 0x4d, 0x5f, 0x46, 0x49, 0x4c, 0x54, 0x45, 0x52, 0x10, 0x00, 0x42, 0x4c, 0x0a, 0x0e, 0x69, 0x6f, - 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x42, 0x03, 0x44, 0x64, - 0x6c, 0x5a, 0x35, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, - 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, - 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, - 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + 0x73, 0x12, 0x12, 0x0a, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, + 0x04, 0x6b, 0x65, 0x79, 0x73, 0x2a, 0x24, 0x0a, 0x08, 0x41, 0x6e, 0x61, 0x6c, 0x79, 0x7a, 0x65, + 0x72, 0x12, 0x0b, 0x0a, 0x07, 0x45, 0x4e, 0x47, 0x4c, 0x49, 0x53, 0x48, 0x10, 0x00, 0x12, 0x0b, + 0x0a, 0x07, 0x43, 0x48, 0x49, 0x4e, 0x45, 0x53, 0x45, 0x10, 0x01, 0x2a, 0x29, 0x0a, 0x0f, 0x46, + 0x75, 0x6c, 0x6c, 0x74, 0x65, 0x78, 0x74, 0x42, 0x61, 0x63, 0x6b, 0x65, 0x6e, 0x64, 0x12, 0x0b, + 0x0a, 0x07, 0x54, 0x41, 0x4e, 0x54, 0x49, 0x56, 0x59, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x42, + 0x4c, 0x4f, 0x4f, 0x4d, 0x10, 0x01, 0x2a, 0x25, 0x0a, 0x11, 0x53, 0x6b, 0x69, 0x70, 0x70, 0x69, + 0x6e, 0x67, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x54, 0x79, 0x70, 0x65, 0x12, 0x10, 0x0a, 0x0c, 0x42, + 0x4c, 0x4f, 0x4f, 0x4d, 0x5f, 0x46, 0x49, 0x4c, 0x54, 0x45, 0x52, 0x10, 0x00, 0x42, 0x4c, 0x0a, + 0x0e, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x42, + 0x03, 0x44, 0x64, 0x6c, 0x5a, 0x35, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, + 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, + 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, + 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, + 0x74, 0x6f, 0x33, } var ( @@ -3291,119 +3352,121 @@ func file_greptime_v1_ddl_proto_rawDescGZIP() []byte { return file_greptime_v1_ddl_proto_rawDescData } -var file_greptime_v1_ddl_proto_enumTypes = make([]protoimpl.EnumInfo, 3) +var file_greptime_v1_ddl_proto_enumTypes = make([]protoimpl.EnumInfo, 4) var file_greptime_v1_ddl_proto_msgTypes = make([]protoimpl.MessageInfo, 39) var file_greptime_v1_ddl_proto_goTypes = []interface{}{ (Analyzer)(0), // 0: greptime.v1.Analyzer - (SkippingIndexType)(0), // 1: greptime.v1.SkippingIndexType - (AddColumnLocation_LocationType)(0), // 2: greptime.v1.AddColumnLocation.LocationType - (*DdlRequest)(nil), // 3: greptime.v1.DdlRequest - (*CreateFlowExpr)(nil), // 4: greptime.v1.CreateFlowExpr - (*DropFlowExpr)(nil), // 5: greptime.v1.DropFlowExpr - (*CreateViewExpr)(nil), // 6: greptime.v1.CreateViewExpr - (*DropViewExpr)(nil), // 7: greptime.v1.DropViewExpr - (*CreateTableExpr)(nil), // 8: greptime.v1.CreateTableExpr - (*AlterTableExpr)(nil), // 9: greptime.v1.AlterTableExpr - (*SetIndex)(nil), // 10: greptime.v1.SetIndex - (*UnsetIndex)(nil), // 11: greptime.v1.UnsetIndex - (*DropTableExpr)(nil), // 12: greptime.v1.DropTableExpr - (*CreateDatabaseExpr)(nil), // 13: greptime.v1.CreateDatabaseExpr - (*TruncateTableExpr)(nil), // 14: greptime.v1.TruncateTableExpr - (*DropDatabaseExpr)(nil), // 15: greptime.v1.DropDatabaseExpr - (*AddColumns)(nil), // 16: greptime.v1.AddColumns - (*DropColumns)(nil), // 17: greptime.v1.DropColumns - (*ModifyColumnTypes)(nil), // 18: greptime.v1.ModifyColumnTypes - (*RenameTable)(nil), // 19: greptime.v1.RenameTable - (*AddColumn)(nil), // 20: greptime.v1.AddColumn - (*ModifyColumnType)(nil), // 21: greptime.v1.ModifyColumnType - (*Option)(nil), // 22: greptime.v1.Option - (*SetTableOptions)(nil), // 23: greptime.v1.SetTableOptions - (*UnsetTableOptions)(nil), // 24: greptime.v1.UnsetTableOptions - (*DropColumn)(nil), // 25: greptime.v1.DropColumn - (*TableId)(nil), // 26: greptime.v1.TableId - (*FlowId)(nil), // 27: greptime.v1.FlowId - (*ColumnDef)(nil), // 28: greptime.v1.ColumnDef - (*AddColumnLocation)(nil), // 29: greptime.v1.AddColumnLocation - (*SetFulltext)(nil), // 30: greptime.v1.SetFulltext - (*UnsetFulltext)(nil), // 31: greptime.v1.UnsetFulltext - (*SetInverted)(nil), // 32: greptime.v1.SetInverted - (*UnsetInverted)(nil), // 33: greptime.v1.UnsetInverted - (*SetSkipping)(nil), // 34: greptime.v1.SetSkipping - (*UnsetSkipping)(nil), // 35: greptime.v1.UnsetSkipping - (*AlterDatabaseExpr)(nil), // 36: greptime.v1.AlterDatabaseExpr - (*SetDatabaseOptions)(nil), // 37: greptime.v1.SetDatabaseOptions - (*UnsetDatabaseOptions)(nil), // 38: greptime.v1.UnsetDatabaseOptions - nil, // 39: greptime.v1.CreateFlowExpr.FlowOptionsEntry - nil, // 40: greptime.v1.CreateTableExpr.TableOptionsEntry - nil, // 41: greptime.v1.CreateDatabaseExpr.OptionsEntry - (*TableName)(nil), // 42: greptime.v1.TableName - (*ExpireAfter)(nil), // 43: greptime.v1.ExpireAfter - (ColumnDataType)(0), // 44: greptime.v1.ColumnDataType - (*ColumnDataTypeExtension)(nil), // 45: greptime.v1.ColumnDataTypeExtension - (SemanticType)(0), // 46: greptime.v1.SemanticType - (*ColumnOptions)(nil), // 47: greptime.v1.ColumnOptions + (FulltextBackend)(0), // 1: greptime.v1.FulltextBackend + (SkippingIndexType)(0), // 2: greptime.v1.SkippingIndexType + (AddColumnLocation_LocationType)(0), // 3: greptime.v1.AddColumnLocation.LocationType + (*DdlRequest)(nil), // 4: greptime.v1.DdlRequest + (*CreateFlowExpr)(nil), // 5: greptime.v1.CreateFlowExpr + (*DropFlowExpr)(nil), // 6: greptime.v1.DropFlowExpr + (*CreateViewExpr)(nil), // 7: greptime.v1.CreateViewExpr + (*DropViewExpr)(nil), // 8: greptime.v1.DropViewExpr + (*CreateTableExpr)(nil), // 9: greptime.v1.CreateTableExpr + (*AlterTableExpr)(nil), // 10: greptime.v1.AlterTableExpr + (*SetIndex)(nil), // 11: greptime.v1.SetIndex + (*UnsetIndex)(nil), // 12: greptime.v1.UnsetIndex + (*DropTableExpr)(nil), // 13: greptime.v1.DropTableExpr + (*CreateDatabaseExpr)(nil), // 14: greptime.v1.CreateDatabaseExpr + (*TruncateTableExpr)(nil), // 15: greptime.v1.TruncateTableExpr + (*DropDatabaseExpr)(nil), // 16: greptime.v1.DropDatabaseExpr + (*AddColumns)(nil), // 17: greptime.v1.AddColumns + (*DropColumns)(nil), // 18: greptime.v1.DropColumns + (*ModifyColumnTypes)(nil), // 19: greptime.v1.ModifyColumnTypes + (*RenameTable)(nil), // 20: greptime.v1.RenameTable + (*AddColumn)(nil), // 21: greptime.v1.AddColumn + (*ModifyColumnType)(nil), // 22: greptime.v1.ModifyColumnType + (*Option)(nil), // 23: greptime.v1.Option + (*SetTableOptions)(nil), // 24: greptime.v1.SetTableOptions + (*UnsetTableOptions)(nil), // 25: greptime.v1.UnsetTableOptions + (*DropColumn)(nil), // 26: greptime.v1.DropColumn + (*TableId)(nil), // 27: greptime.v1.TableId + (*FlowId)(nil), // 28: greptime.v1.FlowId + (*ColumnDef)(nil), // 29: greptime.v1.ColumnDef + (*AddColumnLocation)(nil), // 30: greptime.v1.AddColumnLocation + (*SetFulltext)(nil), // 31: greptime.v1.SetFulltext + (*UnsetFulltext)(nil), // 32: greptime.v1.UnsetFulltext + (*SetInverted)(nil), // 33: greptime.v1.SetInverted + (*UnsetInverted)(nil), // 34: greptime.v1.UnsetInverted + (*SetSkipping)(nil), // 35: greptime.v1.SetSkipping + (*UnsetSkipping)(nil), // 36: greptime.v1.UnsetSkipping + (*AlterDatabaseExpr)(nil), // 37: greptime.v1.AlterDatabaseExpr + (*SetDatabaseOptions)(nil), // 38: greptime.v1.SetDatabaseOptions + (*UnsetDatabaseOptions)(nil), // 39: greptime.v1.UnsetDatabaseOptions + nil, // 40: greptime.v1.CreateFlowExpr.FlowOptionsEntry + nil, // 41: greptime.v1.CreateTableExpr.TableOptionsEntry + nil, // 42: greptime.v1.CreateDatabaseExpr.OptionsEntry + (*TableName)(nil), // 43: greptime.v1.TableName + (*ExpireAfter)(nil), // 44: greptime.v1.ExpireAfter + (ColumnDataType)(0), // 45: greptime.v1.ColumnDataType + (*ColumnDataTypeExtension)(nil), // 46: greptime.v1.ColumnDataTypeExtension + (SemanticType)(0), // 47: greptime.v1.SemanticType + (*ColumnOptions)(nil), // 48: greptime.v1.ColumnOptions } var file_greptime_v1_ddl_proto_depIdxs = []int32{ - 13, // 0: greptime.v1.DdlRequest.create_database:type_name -> greptime.v1.CreateDatabaseExpr - 8, // 1: greptime.v1.DdlRequest.create_table:type_name -> greptime.v1.CreateTableExpr - 9, // 2: greptime.v1.DdlRequest.alter_table:type_name -> greptime.v1.AlterTableExpr - 12, // 3: greptime.v1.DdlRequest.drop_table:type_name -> greptime.v1.DropTableExpr - 14, // 4: greptime.v1.DdlRequest.truncate_table:type_name -> greptime.v1.TruncateTableExpr - 4, // 5: greptime.v1.DdlRequest.create_flow:type_name -> greptime.v1.CreateFlowExpr - 5, // 6: greptime.v1.DdlRequest.drop_flow:type_name -> greptime.v1.DropFlowExpr - 6, // 7: greptime.v1.DdlRequest.create_view:type_name -> greptime.v1.CreateViewExpr - 7, // 8: greptime.v1.DdlRequest.drop_view:type_name -> greptime.v1.DropViewExpr - 36, // 9: greptime.v1.DdlRequest.alter_database:type_name -> greptime.v1.AlterDatabaseExpr - 42, // 10: greptime.v1.CreateFlowExpr.source_table_names:type_name -> greptime.v1.TableName - 42, // 11: greptime.v1.CreateFlowExpr.sink_table_name:type_name -> greptime.v1.TableName - 43, // 12: greptime.v1.CreateFlowExpr.expire_after:type_name -> greptime.v1.ExpireAfter - 39, // 13: greptime.v1.CreateFlowExpr.flow_options:type_name -> greptime.v1.CreateFlowExpr.FlowOptionsEntry - 27, // 14: greptime.v1.DropFlowExpr.flow_id:type_name -> greptime.v1.FlowId - 42, // 15: greptime.v1.CreateViewExpr.table_names:type_name -> greptime.v1.TableName - 26, // 16: greptime.v1.DropViewExpr.view_id:type_name -> greptime.v1.TableId - 28, // 17: greptime.v1.CreateTableExpr.column_defs:type_name -> greptime.v1.ColumnDef - 40, // 18: greptime.v1.CreateTableExpr.table_options:type_name -> greptime.v1.CreateTableExpr.TableOptionsEntry - 26, // 19: greptime.v1.CreateTableExpr.table_id:type_name -> greptime.v1.TableId - 16, // 20: greptime.v1.AlterTableExpr.add_columns:type_name -> greptime.v1.AddColumns - 17, // 21: greptime.v1.AlterTableExpr.drop_columns:type_name -> greptime.v1.DropColumns - 19, // 22: greptime.v1.AlterTableExpr.rename_table:type_name -> greptime.v1.RenameTable - 18, // 23: greptime.v1.AlterTableExpr.modify_column_types:type_name -> greptime.v1.ModifyColumnTypes - 23, // 24: greptime.v1.AlterTableExpr.set_table_options:type_name -> greptime.v1.SetTableOptions - 24, // 25: greptime.v1.AlterTableExpr.unset_table_options:type_name -> greptime.v1.UnsetTableOptions - 10, // 26: greptime.v1.AlterTableExpr.set_index:type_name -> greptime.v1.SetIndex - 11, // 27: greptime.v1.AlterTableExpr.unset_index:type_name -> greptime.v1.UnsetIndex - 30, // 28: greptime.v1.SetIndex.fulltext:type_name -> greptime.v1.SetFulltext - 32, // 29: greptime.v1.SetIndex.inverted:type_name -> greptime.v1.SetInverted - 34, // 30: greptime.v1.SetIndex.skipping:type_name -> greptime.v1.SetSkipping - 31, // 31: greptime.v1.UnsetIndex.fulltext:type_name -> greptime.v1.UnsetFulltext - 33, // 32: greptime.v1.UnsetIndex.inverted:type_name -> greptime.v1.UnsetInverted - 35, // 33: greptime.v1.UnsetIndex.skipping:type_name -> greptime.v1.UnsetSkipping - 26, // 34: greptime.v1.DropTableExpr.table_id:type_name -> greptime.v1.TableId - 41, // 35: greptime.v1.CreateDatabaseExpr.options:type_name -> greptime.v1.CreateDatabaseExpr.OptionsEntry - 26, // 36: greptime.v1.TruncateTableExpr.table_id:type_name -> greptime.v1.TableId - 20, // 37: greptime.v1.AddColumns.add_columns:type_name -> greptime.v1.AddColumn - 25, // 38: greptime.v1.DropColumns.drop_columns:type_name -> greptime.v1.DropColumn - 21, // 39: greptime.v1.ModifyColumnTypes.modify_column_types:type_name -> greptime.v1.ModifyColumnType - 28, // 40: greptime.v1.AddColumn.column_def:type_name -> greptime.v1.ColumnDef - 29, // 41: greptime.v1.AddColumn.location:type_name -> greptime.v1.AddColumnLocation - 44, // 42: greptime.v1.ModifyColumnType.target_type:type_name -> greptime.v1.ColumnDataType - 45, // 43: greptime.v1.ModifyColumnType.target_type_extension:type_name -> greptime.v1.ColumnDataTypeExtension - 22, // 44: greptime.v1.SetTableOptions.table_options:type_name -> greptime.v1.Option - 44, // 45: greptime.v1.ColumnDef.data_type:type_name -> greptime.v1.ColumnDataType - 46, // 46: greptime.v1.ColumnDef.semantic_type:type_name -> greptime.v1.SemanticType - 45, // 47: greptime.v1.ColumnDef.datatype_extension:type_name -> greptime.v1.ColumnDataTypeExtension - 47, // 48: greptime.v1.ColumnDef.options:type_name -> greptime.v1.ColumnOptions - 2, // 49: greptime.v1.AddColumnLocation.location_type:type_name -> greptime.v1.AddColumnLocation.LocationType + 14, // 0: greptime.v1.DdlRequest.create_database:type_name -> greptime.v1.CreateDatabaseExpr + 9, // 1: greptime.v1.DdlRequest.create_table:type_name -> greptime.v1.CreateTableExpr + 10, // 2: greptime.v1.DdlRequest.alter_table:type_name -> greptime.v1.AlterTableExpr + 13, // 3: greptime.v1.DdlRequest.drop_table:type_name -> greptime.v1.DropTableExpr + 15, // 4: greptime.v1.DdlRequest.truncate_table:type_name -> greptime.v1.TruncateTableExpr + 5, // 5: greptime.v1.DdlRequest.create_flow:type_name -> greptime.v1.CreateFlowExpr + 6, // 6: greptime.v1.DdlRequest.drop_flow:type_name -> greptime.v1.DropFlowExpr + 7, // 7: greptime.v1.DdlRequest.create_view:type_name -> greptime.v1.CreateViewExpr + 8, // 8: greptime.v1.DdlRequest.drop_view:type_name -> greptime.v1.DropViewExpr + 37, // 9: greptime.v1.DdlRequest.alter_database:type_name -> greptime.v1.AlterDatabaseExpr + 43, // 10: greptime.v1.CreateFlowExpr.source_table_names:type_name -> greptime.v1.TableName + 43, // 11: greptime.v1.CreateFlowExpr.sink_table_name:type_name -> greptime.v1.TableName + 44, // 12: greptime.v1.CreateFlowExpr.expire_after:type_name -> greptime.v1.ExpireAfter + 40, // 13: greptime.v1.CreateFlowExpr.flow_options:type_name -> greptime.v1.CreateFlowExpr.FlowOptionsEntry + 28, // 14: greptime.v1.DropFlowExpr.flow_id:type_name -> greptime.v1.FlowId + 43, // 15: greptime.v1.CreateViewExpr.table_names:type_name -> greptime.v1.TableName + 27, // 16: greptime.v1.DropViewExpr.view_id:type_name -> greptime.v1.TableId + 29, // 17: greptime.v1.CreateTableExpr.column_defs:type_name -> greptime.v1.ColumnDef + 41, // 18: greptime.v1.CreateTableExpr.table_options:type_name -> greptime.v1.CreateTableExpr.TableOptionsEntry + 27, // 19: greptime.v1.CreateTableExpr.table_id:type_name -> greptime.v1.TableId + 17, // 20: greptime.v1.AlterTableExpr.add_columns:type_name -> greptime.v1.AddColumns + 18, // 21: greptime.v1.AlterTableExpr.drop_columns:type_name -> greptime.v1.DropColumns + 20, // 22: greptime.v1.AlterTableExpr.rename_table:type_name -> greptime.v1.RenameTable + 19, // 23: greptime.v1.AlterTableExpr.modify_column_types:type_name -> greptime.v1.ModifyColumnTypes + 24, // 24: greptime.v1.AlterTableExpr.set_table_options:type_name -> greptime.v1.SetTableOptions + 25, // 25: greptime.v1.AlterTableExpr.unset_table_options:type_name -> greptime.v1.UnsetTableOptions + 11, // 26: greptime.v1.AlterTableExpr.set_index:type_name -> greptime.v1.SetIndex + 12, // 27: greptime.v1.AlterTableExpr.unset_index:type_name -> greptime.v1.UnsetIndex + 31, // 28: greptime.v1.SetIndex.fulltext:type_name -> greptime.v1.SetFulltext + 33, // 29: greptime.v1.SetIndex.inverted:type_name -> greptime.v1.SetInverted + 35, // 30: greptime.v1.SetIndex.skipping:type_name -> greptime.v1.SetSkipping + 32, // 31: greptime.v1.UnsetIndex.fulltext:type_name -> greptime.v1.UnsetFulltext + 34, // 32: greptime.v1.UnsetIndex.inverted:type_name -> greptime.v1.UnsetInverted + 36, // 33: greptime.v1.UnsetIndex.skipping:type_name -> greptime.v1.UnsetSkipping + 27, // 34: greptime.v1.DropTableExpr.table_id:type_name -> greptime.v1.TableId + 42, // 35: greptime.v1.CreateDatabaseExpr.options:type_name -> greptime.v1.CreateDatabaseExpr.OptionsEntry + 27, // 36: greptime.v1.TruncateTableExpr.table_id:type_name -> greptime.v1.TableId + 21, // 37: greptime.v1.AddColumns.add_columns:type_name -> greptime.v1.AddColumn + 26, // 38: greptime.v1.DropColumns.drop_columns:type_name -> greptime.v1.DropColumn + 22, // 39: greptime.v1.ModifyColumnTypes.modify_column_types:type_name -> greptime.v1.ModifyColumnType + 29, // 40: greptime.v1.AddColumn.column_def:type_name -> greptime.v1.ColumnDef + 30, // 41: greptime.v1.AddColumn.location:type_name -> greptime.v1.AddColumnLocation + 45, // 42: greptime.v1.ModifyColumnType.target_type:type_name -> greptime.v1.ColumnDataType + 46, // 43: greptime.v1.ModifyColumnType.target_type_extension:type_name -> greptime.v1.ColumnDataTypeExtension + 23, // 44: greptime.v1.SetTableOptions.table_options:type_name -> greptime.v1.Option + 45, // 45: greptime.v1.ColumnDef.data_type:type_name -> greptime.v1.ColumnDataType + 47, // 46: greptime.v1.ColumnDef.semantic_type:type_name -> greptime.v1.SemanticType + 46, // 47: greptime.v1.ColumnDef.datatype_extension:type_name -> greptime.v1.ColumnDataTypeExtension + 48, // 48: greptime.v1.ColumnDef.options:type_name -> greptime.v1.ColumnOptions + 3, // 49: greptime.v1.AddColumnLocation.location_type:type_name -> greptime.v1.AddColumnLocation.LocationType 0, // 50: greptime.v1.SetFulltext.analyzer:type_name -> greptime.v1.Analyzer - 1, // 51: greptime.v1.SetSkipping.skipping_index_type:type_name -> greptime.v1.SkippingIndexType - 37, // 52: greptime.v1.AlterDatabaseExpr.set_database_options:type_name -> greptime.v1.SetDatabaseOptions - 38, // 53: greptime.v1.AlterDatabaseExpr.unset_database_options:type_name -> greptime.v1.UnsetDatabaseOptions - 22, // 54: greptime.v1.SetDatabaseOptions.set_database_options:type_name -> greptime.v1.Option - 55, // [55:55] is the sub-list for method output_type - 55, // [55:55] is the sub-list for method input_type - 55, // [55:55] is the sub-list for extension type_name - 55, // [55:55] is the sub-list for extension extendee - 0, // [0:55] is the sub-list for field type_name + 1, // 51: greptime.v1.SetFulltext.backend:type_name -> greptime.v1.FulltextBackend + 2, // 52: greptime.v1.SetSkipping.skipping_index_type:type_name -> greptime.v1.SkippingIndexType + 38, // 53: greptime.v1.AlterDatabaseExpr.set_database_options:type_name -> greptime.v1.SetDatabaseOptions + 39, // 54: greptime.v1.AlterDatabaseExpr.unset_database_options:type_name -> greptime.v1.UnsetDatabaseOptions + 23, // 55: greptime.v1.SetDatabaseOptions.set_database_options:type_name -> greptime.v1.Option + 56, // [56:56] is the sub-list for method output_type + 56, // [56:56] is the sub-list for method input_type + 56, // [56:56] is the sub-list for extension type_name + 56, // [56:56] is the sub-list for extension extendee + 0, // [0:56] is the sub-list for field type_name } func init() { file_greptime_v1_ddl_proto_init() } @@ -3887,7 +3950,7 @@ func file_greptime_v1_ddl_proto_init() { File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_greptime_v1_ddl_proto_rawDesc, - NumEnums: 3, + NumEnums: 4, NumMessages: 39, NumExtensions: 0, NumServices: 0, diff --git a/java/src/main/java/io/greptime/v1/Ddl.java b/java/src/main/java/io/greptime/v1/Ddl.java index e3536a4d..355a1de4 100644 --- a/java/src/main/java/io/greptime/v1/Ddl.java +++ b/java/src/main/java/io/greptime/v1/Ddl.java @@ -122,6 +122,114 @@ private Analyzer(int value) { // @@protoc_insertion_point(enum_scope:greptime.v1.Analyzer) } + /** + * Protobuf enum {@code greptime.v1.FulltextBackend} + */ + public enum FulltextBackend + implements com.google.protobuf.ProtocolMessageEnum { + /** + * TANTIVY = 0; + */ + TANTIVY(0), + /** + * BLOOM = 1; + */ + BLOOM(1), + UNRECOGNIZED(-1), + ; + + /** + * TANTIVY = 0; + */ + public static final int TANTIVY_VALUE = 0; + /** + * BLOOM = 1; + */ + public static final int BLOOM_VALUE = 1; + + + public final int getNumber() { + if (this == UNRECOGNIZED) { + throw new java.lang.IllegalArgumentException( + "Can't get the number of an unknown enum value."); + } + return value; + } + + /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. + * @deprecated Use {@link #forNumber(int)} instead. + */ + @java.lang.Deprecated + public static FulltextBackend valueOf(int value) { + return forNumber(value); + } + + /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. + */ + public static FulltextBackend forNumber(int value) { + switch (value) { + case 0: return TANTIVY; + case 1: return BLOOM; + default: return null; + } + } + + public static com.google.protobuf.Internal.EnumLiteMap + internalGetValueMap() { + return internalValueMap; + } + private static final com.google.protobuf.Internal.EnumLiteMap< + FulltextBackend> internalValueMap = + new com.google.protobuf.Internal.EnumLiteMap() { + public FulltextBackend findValueByNumber(int number) { + return FulltextBackend.forNumber(number); + } + }; + + public final com.google.protobuf.Descriptors.EnumValueDescriptor + getValueDescriptor() { + if (this == UNRECOGNIZED) { + throw new java.lang.IllegalStateException( + "Can't get the descriptor of an unrecognized enum value."); + } + return getDescriptor().getValues().get(ordinal()); + } + public final com.google.protobuf.Descriptors.EnumDescriptor + getDescriptorForType() { + return getDescriptor(); + } + public static final com.google.protobuf.Descriptors.EnumDescriptor + getDescriptor() { + return io.greptime.v1.Ddl.getDescriptor().getEnumTypes().get(1); + } + + private static final FulltextBackend[] VALUES = values(); + + public static FulltextBackend valueOf( + com.google.protobuf.Descriptors.EnumValueDescriptor desc) { + if (desc.getType() != getDescriptor()) { + throw new java.lang.IllegalArgumentException( + "EnumValueDescriptor is not for this type."); + } + if (desc.getIndex() == -1) { + return UNRECOGNIZED; + } + return VALUES[desc.getIndex()]; + } + + private final int value; + + private FulltextBackend(int value) { + this.value = value; + } + + // @@protoc_insertion_point(enum_scope:greptime.v1.FulltextBackend) + } + /** * Protobuf enum {@code greptime.v1.SkippingIndexType} */ @@ -195,7 +303,7 @@ public SkippingIndexType findValueByNumber(int number) { } public static final com.google.protobuf.Descriptors.EnumDescriptor getDescriptor() { - return io.greptime.v1.Ddl.getDescriptor().getEnumTypes().get(1); + return io.greptime.v1.Ddl.getDescriptor().getEnumTypes().get(2); } private static final SkippingIndexType[] VALUES = values(); @@ -32206,6 +32314,17 @@ public interface SetFulltextOrBuilder extends * @return The caseSensitive. */ boolean getCaseSensitive(); + + /** + * .greptime.v1.FulltextBackend backend = 5; + * @return The enum numeric value on the wire for backend. + */ + int getBackendValue(); + /** + * .greptime.v1.FulltextBackend backend = 5; + * @return The backend. + */ + io.greptime.v1.Ddl.FulltextBackend getBackend(); } /** * Protobuf type {@code greptime.v1.SetFulltext} @@ -32222,6 +32341,7 @@ private SetFulltext(com.google.protobuf.GeneratedMessageV3.Builder builder) { private SetFulltext() { columnName_ = ""; analyzer_ = 0; + backend_ = 0; } @java.lang.Override @@ -32276,6 +32396,12 @@ private SetFulltext( caseSensitive_ = input.readBool(); break; } + case 40: { + int rawValue = input.readEnum(); + + backend_ = rawValue; + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -32389,6 +32515,25 @@ public boolean getCaseSensitive() { return caseSensitive_; } + public static final int BACKEND_FIELD_NUMBER = 5; + private int backend_; + /** + * .greptime.v1.FulltextBackend backend = 5; + * @return The enum numeric value on the wire for backend. + */ + @java.lang.Override public int getBackendValue() { + return backend_; + } + /** + * .greptime.v1.FulltextBackend backend = 5; + * @return The backend. + */ + @java.lang.Override public io.greptime.v1.Ddl.FulltextBackend getBackend() { + @SuppressWarnings("deprecation") + io.greptime.v1.Ddl.FulltextBackend result = io.greptime.v1.Ddl.FulltextBackend.valueOf(backend_); + return result == null ? io.greptime.v1.Ddl.FulltextBackend.UNRECOGNIZED : result; + } + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -32415,6 +32560,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) if (caseSensitive_ != false) { output.writeBool(4, caseSensitive_); } + if (backend_ != io.greptime.v1.Ddl.FulltextBackend.TANTIVY.getNumber()) { + output.writeEnum(5, backend_); + } unknownFields.writeTo(output); } @@ -32439,6 +32587,10 @@ public int getSerializedSize() { size += com.google.protobuf.CodedOutputStream .computeBoolSize(4, caseSensitive_); } + if (backend_ != io.greptime.v1.Ddl.FulltextBackend.TANTIVY.getNumber()) { + size += com.google.protobuf.CodedOutputStream + .computeEnumSize(5, backend_); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -32461,6 +32613,7 @@ public boolean equals(final java.lang.Object obj) { if (analyzer_ != other.analyzer_) return false; if (getCaseSensitive() != other.getCaseSensitive()) return false; + if (backend_ != other.backend_) return false; if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -32482,6 +32635,8 @@ public int hashCode() { hash = (37 * hash) + CASE_SENSITIVE_FIELD_NUMBER; hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean( getCaseSensitive()); + hash = (37 * hash) + BACKEND_FIELD_NUMBER; + hash = (53 * hash) + backend_; hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -32623,6 +32778,8 @@ public Builder clear() { caseSensitive_ = false; + backend_ = 0; + return this; } @@ -32653,6 +32810,7 @@ public io.greptime.v1.Ddl.SetFulltext buildPartial() { result.enable_ = enable_; result.analyzer_ = analyzer_; result.caseSensitive_ = caseSensitive_; + result.backend_ = backend_; onBuilt(); return result; } @@ -32714,6 +32872,9 @@ public Builder mergeFrom(io.greptime.v1.Ddl.SetFulltext other) { if (other.getCaseSensitive() != false) { setCaseSensitive(other.getCaseSensitive()); } + if (other.backend_ != 0) { + setBackendValue(other.getBackendValue()); + } this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -32934,6 +33095,60 @@ public Builder clearCaseSensitive() { onChanged(); return this; } + + private int backend_ = 0; + /** + * .greptime.v1.FulltextBackend backend = 5; + * @return The enum numeric value on the wire for backend. + */ + @java.lang.Override public int getBackendValue() { + return backend_; + } + /** + * .greptime.v1.FulltextBackend backend = 5; + * @param value The enum numeric value on the wire for backend to set. + * @return This builder for chaining. + */ + public Builder setBackendValue(int value) { + + backend_ = value; + onChanged(); + return this; + } + /** + * .greptime.v1.FulltextBackend backend = 5; + * @return The backend. + */ + @java.lang.Override + public io.greptime.v1.Ddl.FulltextBackend getBackend() { + @SuppressWarnings("deprecation") + io.greptime.v1.Ddl.FulltextBackend result = io.greptime.v1.Ddl.FulltextBackend.valueOf(backend_); + return result == null ? io.greptime.v1.Ddl.FulltextBackend.UNRECOGNIZED : result; + } + /** + * .greptime.v1.FulltextBackend backend = 5; + * @param value The backend to set. + * @return This builder for chaining. + */ + public Builder setBackend(io.greptime.v1.Ddl.FulltextBackend value) { + if (value == null) { + throw new NullPointerException(); + } + + backend_ = value.getNumber(); + onChanged(); + return this; + } + /** + * .greptime.v1.FulltextBackend backend = 5; + * @return This builder for chaining. + */ + public Builder clearBackend() { + + backend_ = 0; + onChanged(); + return this; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -39089,29 +39304,32 @@ public io.greptime.v1.Ddl.UnsetDatabaseOptions getDefaultInstanceForType() { "\n\021AddColumnLocation\022B\n\rlocation_type\030\001 \001" + "(\0162+.greptime.v1.AddColumnLocation.Locat" + "ionType\022\031\n\021after_column_name\030\002 \001(\t\"$\n\014Lo" + - "cationType\022\t\n\005FIRST\020\000\022\t\n\005AFTER\020\001\"s\n\013SetF" + - "ulltext\022\023\n\013column_name\030\001 \001(\t\022\016\n\006enable\030\002" + - " \001(\010\022\'\n\010analyzer\030\003 \001(\0162\025.greptime.v1.Ana" + - "lyzer\022\026\n\016case_sensitive\030\004 \001(\010\"$\n\rUnsetFu" + - "lltext\022\023\n\013column_name\030\001 \001(\t\"\"\n\013SetInvert" + - "ed\022\023\n\013column_name\030\001 \001(\t\"$\n\rUnsetInverted" + - "\022\023\n\013column_name\030\001 \001(\t\"\204\001\n\013SetSkipping\022\023\n" + - "\013column_name\030\001 \001(\t\022\016\n\006enable\030\002 \001(\010\022\023\n\013gr" + - "anularity\030\003 \001(\004\022;\n\023skipping_index_type\030\004" + - " \001(\0162\036.greptime.v1.SkippingIndexType\"$\n\r" + - "UnsetSkipping\022\023\n\013column_name\030\001 \001(\t\"\314\001\n\021A" + - "lterDatabaseExpr\022\024\n\014catalog_name\030\001 \001(\t\022\023" + - "\n\013schema_name\030\002 \001(\t\022?\n\024set_database_opti" + - "ons\030\003 \001(\0132\037.greptime.v1.SetDatabaseOptio" + - "nsH\000\022C\n\026unset_database_options\030\004 \001(\0132!.g" + - "reptime.v1.UnsetDatabaseOptionsH\000B\006\n\004kin" + - "d\"G\n\022SetDatabaseOptions\0221\n\024set_database_" + - "options\030\001 \003(\0132\023.greptime.v1.Option\"$\n\024Un" + - "setDatabaseOptions\022\014\n\004keys\030\001 \003(\t*$\n\010Anal" + - "yzer\022\013\n\007ENGLISH\020\000\022\013\n\007CHINESE\020\001*%\n\021Skippi" + - "ngIndexType\022\020\n\014BLOOM_FILTER\020\000BL\n\016io.grep" + - "time.v1B\003DdlZ5github.com/GreptimeTeam/gr" + - "eptime-proto/go/greptime/v1b\006proto3" + "cationType\022\t\n\005FIRST\020\000\022\t\n\005AFTER\020\001\"\242\001\n\013Set" + + "Fulltext\022\023\n\013column_name\030\001 \001(\t\022\016\n\006enable\030" + + "\002 \001(\010\022\'\n\010analyzer\030\003 \001(\0162\025.greptime.v1.An" + + "alyzer\022\026\n\016case_sensitive\030\004 \001(\010\022-\n\007backen" + + "d\030\005 \001(\0162\034.greptime.v1.FulltextBackend\"$\n" + + "\rUnsetFulltext\022\023\n\013column_name\030\001 \001(\t\"\"\n\013S" + + "etInverted\022\023\n\013column_name\030\001 \001(\t\"$\n\rUnset" + + "Inverted\022\023\n\013column_name\030\001 \001(\t\"\204\001\n\013SetSki" + + "pping\022\023\n\013column_name\030\001 \001(\t\022\016\n\006enable\030\002 \001" + + "(\010\022\023\n\013granularity\030\003 \001(\004\022;\n\023skipping_inde" + + "x_type\030\004 \001(\0162\036.greptime.v1.SkippingIndex" + + "Type\"$\n\rUnsetSkipping\022\023\n\013column_name\030\001 \001" + + "(\t\"\314\001\n\021AlterDatabaseExpr\022\024\n\014catalog_name" + + "\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022?\n\024set_datab" + + "ase_options\030\003 \001(\0132\037.greptime.v1.SetDatab" + + "aseOptionsH\000\022C\n\026unset_database_options\030\004" + + " \001(\0132!.greptime.v1.UnsetDatabaseOptionsH" + + "\000B\006\n\004kind\"G\n\022SetDatabaseOptions\0221\n\024set_d" + + "atabase_options\030\001 \003(\0132\023.greptime.v1.Opti" + + "on\"$\n\024UnsetDatabaseOptions\022\014\n\004keys\030\001 \003(\t" + + "*$\n\010Analyzer\022\013\n\007ENGLISH\020\000\022\013\n\007CHINESE\020\001*)" + + "\n\017FulltextBackend\022\013\n\007TANTIVY\020\000\022\t\n\005BLOOM\020" + + "\001*%\n\021SkippingIndexType\022\020\n\014BLOOM_FILTER\020\000" + + "BL\n\016io.greptime.v1B\003DdlZ5github.com/Grep" + + "timeTeam/greptime-proto/go/greptime/v1b\006" + + "proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor .internalBuildGeneratedFileFrom(descriptorData, @@ -39303,7 +39521,7 @@ public io.greptime.v1.Ddl.UnsetDatabaseOptions getDefaultInstanceForType() { internal_static_greptime_v1_SetFulltext_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_greptime_v1_SetFulltext_descriptor, - new java.lang.String[] { "ColumnName", "Enable", "Analyzer", "CaseSensitive", }); + new java.lang.String[] { "ColumnName", "Enable", "Analyzer", "CaseSensitive", "Backend", }); internal_static_greptime_v1_UnsetFulltext_descriptor = getDescriptor().getMessageTypes().get(28); internal_static_greptime_v1_UnsetFulltext_fieldAccessorTable = new diff --git a/proto/greptime/v1/ddl.proto b/proto/greptime/v1/ddl.proto index dc545c0b..02bd9c60 100644 --- a/proto/greptime/v1/ddl.proto +++ b/proto/greptime/v1/ddl.proto @@ -231,11 +231,17 @@ enum Analyzer { CHINESE = 1; } +enum FulltextBackend { + TANTIVY = 0; + BLOOM = 1; +} + message SetFulltext { string column_name = 1; bool enable = 2; Analyzer analyzer = 3; bool case_sensitive = 4; + FulltextBackend backend = 5; } message UnsetFulltext {