Dima/orion_greptime_proto
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: move TableName out of meta common (#152)

Browse Source 
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
This commit is contained in:
Ruihang Xia
2024-04-25 20:14:54 +08:00
committed by GitHub
parent d18b1c8b8a
commit 783682fabc
20 changed files with 2689 additions and 4070 deletions
Download Patch File Download Diff File Expand all files Collapse all files
c++/greptime/v1/ddl.pb.h
+62 -349
View File
@@ -105,9 +105,6 @@ extern DropTableExprDefaultTypeInternal _DropTableExpr_default_instance_;
class RenameTable;
struct RenameTableDefaultTypeInternal;
extern RenameTableDefaultTypeInternal _RenameTable_default_instance_;
class SchemaScopedTableName;
struct SchemaScopedTableNameDefaultTypeInternal;
extern SchemaScopedTableNameDefaultTypeInternal _SchemaScopedTableName_default_instance_;
class TableId;
struct TableIdDefaultTypeInternal;
extern TableIdDefaultTypeInternal _TableId_default_instance_;
@@ -135,7 +132,6 @@ template<> ::greptime::v1::DropDatabaseExpr* Arena::CreateMaybeMessage<::greptim
template<> ::greptime::v1::DropFlowTaskExpr* Arena::CreateMaybeMessage<::greptime::v1::DropFlowTaskExpr>(Arena*);
template<> ::greptime::v1::DropTableExpr* Arena::CreateMaybeMessage<::greptime::v1::DropTableExpr>(Arena*);
template<> ::greptime::v1::RenameTable* Arena::CreateMaybeMessage<::greptime::v1::RenameTable>(Arena*);
template<> ::greptime::v1::SchemaScopedTableName* Arena::CreateMaybeMessage<::greptime::v1::SchemaScopedTableName>(Arena*);
template<> ::greptime::v1::TableId* Arena::CreateMaybeMessage<::greptime::v1::TableId>(Arena*);
template<> ::greptime::v1::TruncateTableExpr* Arena::CreateMaybeMessage<::greptime::v1::TruncateTableExpr>(Arena*);
PROTOBUF_NAMESPACE_CLOSE
@@ -638,22 +634,22 @@ class CreateFlowTaskExpr final :
kOrReplaceFieldNumber = 5,
kCreateIfNotExistsFieldNumber = 6,
};
// repeated .greptime.v1.SchemaScopedTableName source_table_names = 3;
// repeated .greptime.v1.TableName source_table_names = 3;
int source_table_names_size() const;
private:
int _internal_source_table_names_size() const;
public:
void clear_source_table_names();
::greptime::v1::SchemaScopedTableName* mutable_source_table_names(int index);
::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::SchemaScopedTableName >*
::greptime::v1::TableName* mutable_source_table_names(int index);
::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::TableName >*
mutable_source_table_names();
private:
const ::greptime::v1::SchemaScopedTableName& _internal_source_table_names(int index) const;
::greptime::v1::SchemaScopedTableName* _internal_add_source_table_names();
const ::greptime::v1::TableName& _internal_source_table_names(int index) const;
::greptime::v1::TableName* _internal_add_source_table_names();
public:
const ::greptime::v1::SchemaScopedTableName& source_table_names(int index) const;
::greptime::v1::SchemaScopedTableName* add_source_table_names();
const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::SchemaScopedTableName >&
const ::greptime::v1::TableName& source_table_names(int index) const;
::greptime::v1::TableName* add_source_table_names();
const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::TableName >&
source_table_names() const;
// map<string, string> task_options = 10;
@@ -743,23 +739,23 @@ class CreateFlowTaskExpr final :
std::string* _internal_mutable_sql();
public:
// .greptime.v1.SchemaScopedTableName sink_table_name = 4;
// .greptime.v1.TableName sink_table_name = 4;
bool has_sink_table_name() const;
private:
bool _internal_has_sink_table_name() const;
public:
void clear_sink_table_name();
const ::greptime::v1::SchemaScopedTableName& sink_table_name() const;
PROTOBUF_NODISCARD ::greptime::v1::SchemaScopedTableName* release_sink_table_name();
::greptime::v1::SchemaScopedTableName* mutable_sink_table_name();
void set_allocated_sink_table_name(::greptime::v1::SchemaScopedTableName* sink_table_name);
const ::greptime::v1::TableName& sink_table_name() const;
PROTOBUF_NODISCARD ::greptime::v1::TableName* release_sink_table_name();
::greptime::v1::TableName* mutable_sink_table_name();
void set_allocated_sink_table_name(::greptime::v1::TableName* sink_table_name);
private:
const ::greptime::v1::SchemaScopedTableName& _internal_sink_table_name() const;
::greptime::v1::SchemaScopedTableName* _internal_mutable_sink_table_name();
const ::greptime::v1::TableName& _internal_sink_table_name() const;
::greptime::v1::TableName* _internal_mutable_sink_table_name();
public:
void unsafe_arena_set_allocated_sink_table_name(
::greptime::v1::SchemaScopedTableName* sink_table_name);
::greptime::v1::SchemaScopedTableName* unsafe_arena_release_sink_table_name();
::greptime::v1::TableName* sink_table_name);
::greptime::v1::TableName* unsafe_arena_release_sink_table_name();
// bool or_replace = 5;
void clear_or_replace();
@@ -787,7 +783,7 @@ class CreateFlowTaskExpr final :
typedef void InternalArenaConstructable_;
typedef void DestructorSkippable_;
struct Impl_ {
::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::SchemaScopedTableName > source_table_names_;
::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::TableName > source_table_names_;
::PROTOBUF_NAMESPACE_ID::internal::MapField<
CreateFlowTaskExpr_TaskOptionsEntry_DoNotUse,
std::string, std::string,
@@ -798,7 +794,7 @@ class CreateFlowTaskExpr final :
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr expire_when_;
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr comment_;
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr sql_;
::greptime::v1::SchemaScopedTableName* sink_table_name_;
::greptime::v1::TableName* sink_table_name_;
bool or_replace_;
bool create_if_not_exists_;
mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
@@ -808,175 +804,6 @@ class CreateFlowTaskExpr final :
};
// -------------------------------------------------------------------
class SchemaScopedTableName final :
public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:greptime.v1.SchemaScopedTableName) */ {
public:
inline SchemaScopedTableName() : SchemaScopedTableName(nullptr) {}
~SchemaScopedTableName() override;
explicit PROTOBUF_CONSTEXPR SchemaScopedTableName(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
SchemaScopedTableName(const SchemaScopedTableName& from);
SchemaScopedTableName(SchemaScopedTableName&& from) noexcept
: SchemaScopedTableName() {
*this = ::std::move(from);
}
inline SchemaScopedTableName& operator=(const SchemaScopedTableName& from) {
CopyFrom(from);
return *this;
}
inline SchemaScopedTableName& operator=(SchemaScopedTableName&& 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 SchemaScopedTableName& default_instance() {
return *internal_default_instance();
}
static inline const SchemaScopedTableName* internal_default_instance() {
return reinterpret_cast<const SchemaScopedTableName*>(
&_SchemaScopedTableName_default_instance_);
}
static constexpr int kIndexInFileMessages =
3;
friend void swap(SchemaScopedTableName& a, SchemaScopedTableName& b) {
a.Swap(&b);
}
inline void Swap(SchemaScopedTableName* 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(SchemaScopedTableName* other) {
if (other == this) return;
GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
InternalSwap(other);
}
// implements Message ----------------------------------------------
SchemaScopedTableName* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
return CreateMaybeMessage<SchemaScopedTableName>(arena);
}
using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
void CopyFrom(const SchemaScopedTableName& from);
using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
void MergeFrom( const SchemaScopedTableName& from) {
SchemaScopedTableName::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(SchemaScopedTableName* other);
private:
friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
return "greptime.v1.SchemaScopedTableName";
}
protected:
explicit SchemaScopedTableName(::PROTOBUF_NAMESPACE_ID::Arena* arena,
bool is_message_owned = false);
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 {
kSchemaNameFieldNumber = 1,
kTableNameFieldNumber = 2,
};
// string schema_name = 1;
void clear_schema_name();
const std::string& schema_name() const;
template <typename ArgT0 = const std::string&, typename... ArgT>
void set_schema_name(ArgT0&& arg0, ArgT... args);
std::string* mutable_schema_name();
PROTOBUF_NODISCARD std::string* release_schema_name();
void set_allocated_schema_name(std::string* schema_name);
private:
const std::string& _internal_schema_name() const;
inline PROTOBUF_ALWAYS_INLINE void _internal_set_schema_name(const std::string& value);
std::string* _internal_mutable_schema_name();
public:
// string table_name = 2;
void clear_table_name();
const std::string& table_name() const;
template <typename ArgT0 = const std::string&, typename... ArgT>
void set_table_name(ArgT0&& arg0, ArgT... args);
std::string* mutable_table_name();
PROTOBUF_NODISCARD std::string* release_table_name();
void set_allocated_table_name(std::string* table_name);
private:
const std::string& _internal_table_name() const;
inline PROTOBUF_ALWAYS_INLINE void _internal_set_table_name(const std::string& value);
std::string* _internal_mutable_table_name();
public:
// @@protoc_insertion_point(class_scope:greptime.v1.SchemaScopedTableName)
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::ArenaStringPtr schema_name_;
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr table_name_;
mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
};
union { Impl_ _impl_; };
friend struct ::TableStruct_greptime_2fv1_2fddl_2eproto;
};
// -------------------------------------------------------------------
class DropFlowTaskExpr final :
public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:greptime.v1.DropFlowTaskExpr) */ {
public:
@@ -1025,7 +852,7 @@ class DropFlowTaskExpr final :
&_DropFlowTaskExpr_default_instance_);
}
static constexpr int kIndexInFileMessages =
4;
3;
friend void swap(DropFlowTaskExpr& a, DropFlowTaskExpr& b) {
a.Swap(&b);
@@ -1222,7 +1049,7 @@ class CreateTableExpr final :
&_CreateTableExpr_default_instance_);
}
static constexpr int kIndexInFileMessages =
6;
5;
friend void swap(CreateTableExpr& a, CreateTableExpr& b) {
a.Swap(&b);
@@ -1565,7 +1392,7 @@ class AlterExpr final :
&_AlterExpr_default_instance_);
}
static constexpr int kIndexInFileMessages =
7;
6;
friend void swap(AlterExpr& a, AlterExpr& b) {
a.Swap(&b);
@@ -1824,7 +1651,7 @@ class DropTableExpr final :
&_DropTableExpr_default_instance_);
}
static constexpr int kIndexInFileMessages =
8;
7;
friend void swap(DropTableExpr& a, DropTableExpr& b) {
a.Swap(&b);
@@ -2068,7 +1895,7 @@ class CreateDatabaseExpr final :
&_CreateDatabaseExpr_default_instance_);
}
static constexpr int kIndexInFileMessages =
10;
9;
friend void swap(CreateDatabaseExpr& a, CreateDatabaseExpr& b) {
a.Swap(&b);
@@ -2274,7 +2101,7 @@ class TruncateTableExpr final :
&_TruncateTableExpr_default_instance_);
}
static constexpr int kIndexInFileMessages =
11;
10;
friend void swap(TruncateTableExpr& a, TruncateTableExpr& b) {
a.Swap(&b);
@@ -2479,7 +2306,7 @@ class DropDatabaseExpr final :
&_DropDatabaseExpr_default_instance_);
}
static constexpr int kIndexInFileMessages =
12;
11;
friend void swap(DropDatabaseExpr& a, DropDatabaseExpr& b) {
a.Swap(&b);
@@ -2659,7 +2486,7 @@ class AddColumns final :
&_AddColumns_default_instance_);
}
static constexpr int kIndexInFileMessages =
13;
12;
friend void swap(AddColumns& a, AddColumns& b) {
a.Swap(&b);
@@ -2816,7 +2643,7 @@ class DropColumns final :
&_DropColumns_default_instance_);
}
static constexpr int kIndexInFileMessages =
14;
13;
friend void swap(DropColumns& a, DropColumns& b) {
a.Swap(&b);
@@ -2973,7 +2800,7 @@ class RenameTable final :
&_RenameTable_default_instance_);
}
static constexpr int kIndexInFileMessages =
15;
14;
friend void swap(RenameTable& a, RenameTable& b) {
a.Swap(&b);
@@ -3126,7 +2953,7 @@ class AddColumn final :
&_AddColumn_default_instance_);
}
static constexpr int kIndexInFileMessages =
16;
15;
friend void swap(AddColumn& a, AddColumn& b) {
a.Swap(&b);
@@ -3303,7 +3130,7 @@ class DropColumn final :
&_DropColumn_default_instance_);
}
static constexpr int kIndexInFileMessages =
17;
16;
friend void swap(DropColumn& a, DropColumn& b) {
a.Swap(&b);
@@ -3456,7 +3283,7 @@ class TableId final :
&_TableId_default_instance_);
}
static constexpr int kIndexInFileMessages =
18;
17;
friend void swap(TableId& a, TableId& b) {
a.Swap(&b);
@@ -3604,7 +3431,7 @@ class ColumnDef final :
&_ColumnDef_default_instance_);
}
static constexpr int kIndexInFileMessages =
19;
18;
friend void swap(ColumnDef& a, ColumnDef& b) {
a.Swap(&b);
@@ -3842,7 +3669,7 @@ class AddColumnLocation final :
&_AddColumnLocation_default_instance_);
}
static constexpr int kIndexInFileMessages =
20;
19;
friend void swap(AddColumnLocation& a, AddColumnLocation& b) {
a.Swap(&b);
@@ -4630,70 +4457,61 @@ inline void CreateFlowTaskExpr::set_allocated_task_name(std::string* task_name)
// @@protoc_insertion_point(field_set_allocated:greptime.v1.CreateFlowTaskExpr.task_name)
}
// repeated .greptime.v1.SchemaScopedTableName source_table_names = 3;
// repeated .greptime.v1.TableName source_table_names = 3;
inline int CreateFlowTaskExpr::_internal_source_table_names_size() const {
return _impl_.source_table_names_.size();
}
inline int CreateFlowTaskExpr::source_table_names_size() const {
return _internal_source_table_names_size();
}
inline void CreateFlowTaskExpr::clear_source_table_names() {
_impl_.source_table_names_.Clear();
}
inline ::greptime::v1::SchemaScopedTableName* CreateFlowTaskExpr::mutable_source_table_names(int index) {
inline ::greptime::v1::TableName* CreateFlowTaskExpr::mutable_source_table_names(int index) {
// @@protoc_insertion_point(field_mutable:greptime.v1.CreateFlowTaskExpr.source_table_names)
return _impl_.source_table_names_.Mutable(index);
}
inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::SchemaScopedTableName >*
inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::TableName >*
CreateFlowTaskExpr::mutable_source_table_names() {
// @@protoc_insertion_point(field_mutable_list:greptime.v1.CreateFlowTaskExpr.source_table_names)
return &_impl_.source_table_names_;
}
inline const ::greptime::v1::SchemaScopedTableName& CreateFlowTaskExpr::_internal_source_table_names(int index) const {
inline const ::greptime::v1::TableName& CreateFlowTaskExpr::_internal_source_table_names(int index) const {
return _impl_.source_table_names_.Get(index);
}
inline const ::greptime::v1::SchemaScopedTableName& CreateFlowTaskExpr::source_table_names(int index) const {
inline const ::greptime::v1::TableName& CreateFlowTaskExpr::source_table_names(int index) const {
// @@protoc_insertion_point(field_get:greptime.v1.CreateFlowTaskExpr.source_table_names)
return _internal_source_table_names(index);
}
inline ::greptime::v1::SchemaScopedTableName* CreateFlowTaskExpr::_internal_add_source_table_names() {
inline ::greptime::v1::TableName* CreateFlowTaskExpr::_internal_add_source_table_names() {
return _impl_.source_table_names_.Add();
}
inline ::greptime::v1::SchemaScopedTableName* CreateFlowTaskExpr::add_source_table_names() {
::greptime::v1::SchemaScopedTableName* _add = _internal_add_source_table_names();
inline ::greptime::v1::TableName* CreateFlowTaskExpr::add_source_table_names() {
::greptime::v1::TableName* _add = _internal_add_source_table_names();
// @@protoc_insertion_point(field_add:greptime.v1.CreateFlowTaskExpr.source_table_names)
return _add;
}
inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::SchemaScopedTableName >&
inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::TableName >&
CreateFlowTaskExpr::source_table_names() const {
// @@protoc_insertion_point(field_list:greptime.v1.CreateFlowTaskExpr.source_table_names)
return _impl_.source_table_names_;
}
// .greptime.v1.SchemaScopedTableName sink_table_name = 4;
// .greptime.v1.TableName sink_table_name = 4;
inline bool CreateFlowTaskExpr::_internal_has_sink_table_name() const {
return this != internal_default_instance() && _impl_.sink_table_name_ != nullptr;
}
inline bool CreateFlowTaskExpr::has_sink_table_name() const {
return _internal_has_sink_table_name();
}
inline void CreateFlowTaskExpr::clear_sink_table_name() {
if (GetArenaForAllocation() == nullptr && _impl_.sink_table_name_ != nullptr) {
delete _impl_.sink_table_name_;
}
_impl_.sink_table_name_ = nullptr;
inline const ::greptime::v1::TableName& CreateFlowTaskExpr::_internal_sink_table_name() const {
const ::greptime::v1::TableName* p = _impl_.sink_table_name_;
return p != nullptr ? *p : reinterpret_cast<const ::greptime::v1::TableName&>(
::greptime::v1::_TableName_default_instance_);
}
inline const ::greptime::v1::SchemaScopedTableName& CreateFlowTaskExpr::_internal_sink_table_name() const {
const ::greptime::v1::SchemaScopedTableName* p = _impl_.sink_table_name_;
return p != nullptr ? *p : reinterpret_cast<const ::greptime::v1::SchemaScopedTableName&>(
::greptime::v1::_SchemaScopedTableName_default_instance_);
}
inline const ::greptime::v1::SchemaScopedTableName& CreateFlowTaskExpr::sink_table_name() const {
inline const ::greptime::v1::TableName& CreateFlowTaskExpr::sink_table_name() const {
// @@protoc_insertion_point(field_get:greptime.v1.CreateFlowTaskExpr.sink_table_name)
return _internal_sink_table_name();
}
inline void CreateFlowTaskExpr::unsafe_arena_set_allocated_sink_table_name(
::greptime::v1::SchemaScopedTableName* sink_table_name) {
::greptime::v1::TableName* sink_table_name) {
if (GetArenaForAllocation() == nullptr) {
delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.sink_table_name_);
}
@@ -4705,9 +4523,9 @@ inline void CreateFlowTaskExpr::unsafe_arena_set_allocated_sink_table_name(
}
// @@protoc_insertion_point(field_unsafe_arena_set_allocated:greptime.v1.CreateFlowTaskExpr.sink_table_name)
}
inline ::greptime::v1::SchemaScopedTableName* CreateFlowTaskExpr::release_sink_table_name() {
inline ::greptime::v1::TableName* CreateFlowTaskExpr::release_sink_table_name() {
::greptime::v1::SchemaScopedTableName* temp = _impl_.sink_table_name_;
::greptime::v1::TableName* temp = _impl_.sink_table_name_;
_impl_.sink_table_name_ = nullptr;
#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
auto* old = reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp);
@@ -4720,34 +4538,35 @@ inline ::greptime::v1::SchemaScopedTableName* CreateFlowTaskExpr::release_sink_t
#endif // !PROTOBUF_FORCE_COPY_IN_RELEASE
return temp;
}
inline ::greptime::v1::SchemaScopedTableName* CreateFlowTaskExpr::unsafe_arena_release_sink_table_name() {
inline ::greptime::v1::TableName* CreateFlowTaskExpr::unsafe_arena_release_sink_table_name() {
// @@protoc_insertion_point(field_release:greptime.v1.CreateFlowTaskExpr.sink_table_name)
::greptime::v1::SchemaScopedTableName* temp = _impl_.sink_table_name_;
::greptime::v1::TableName* temp = _impl_.sink_table_name_;
_impl_.sink_table_name_ = nullptr;
return temp;
}
inline ::greptime::v1::SchemaScopedTableName* CreateFlowTaskExpr::_internal_mutable_sink_table_name() {
inline ::greptime::v1::TableName* CreateFlowTaskExpr::_internal_mutable_sink_table_name() {
if (_impl_.sink_table_name_ == nullptr) {
auto* p = CreateMaybeMessage<::greptime::v1::SchemaScopedTableName>(GetArenaForAllocation());
auto* p = CreateMaybeMessage<::greptime::v1::TableName>(GetArenaForAllocation());
_impl_.sink_table_name_ = p;
}
return _impl_.sink_table_name_;
}
inline ::greptime::v1::SchemaScopedTableName* CreateFlowTaskExpr::mutable_sink_table_name() {
::greptime::v1::SchemaScopedTableName* _msg = _internal_mutable_sink_table_name();
inline ::greptime::v1::TableName* CreateFlowTaskExpr::mutable_sink_table_name() {
::greptime::v1::TableName* _msg = _internal_mutable_sink_table_name();
// @@protoc_insertion_point(field_mutable:greptime.v1.CreateFlowTaskExpr.sink_table_name)
return _msg;
}
inline void CreateFlowTaskExpr::set_allocated_sink_table_name(::greptime::v1::SchemaScopedTableName* sink_table_name) {
inline void CreateFlowTaskExpr::set_allocated_sink_table_name(::greptime::v1::TableName* sink_table_name) {
::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
if (message_arena == nullptr) {
delete _impl_.sink_table_name_;
delete reinterpret_cast< ::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.sink_table_name_);
}
if (sink_table_name) {
::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(sink_table_name);
::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(
reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(sink_table_name));
if (message_arena != submessage_arena) {
sink_table_name = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
message_arena, sink_table_name, submessage_arena);
@@ -4981,110 +4800,6 @@ CreateFlowTaskExpr::mutable_task_options() {
// -------------------------------------------------------------------
// SchemaScopedTableName
// string schema_name = 1;
inline void SchemaScopedTableName::clear_schema_name() {
_impl_.schema_name_.ClearToEmpty();
}
inline const std::string& SchemaScopedTableName::schema_name() const {
// @@protoc_insertion_point(field_get:greptime.v1.SchemaScopedTableName.schema_name)
return _internal_schema_name();
}
template <typename ArgT0, typename... ArgT>
inline PROTOBUF_ALWAYS_INLINE
void SchemaScopedTableName::set_schema_name(ArgT0&& arg0, ArgT... args) {
_impl_.schema_name_.Set(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
// @@protoc_insertion_point(field_set:greptime.v1.SchemaScopedTableName.schema_name)
}
inline std::string* SchemaScopedTableName::mutable_schema_name() {
std::string* _s = _internal_mutable_schema_name();
// @@protoc_insertion_point(field_mutable:greptime.v1.SchemaScopedTableName.schema_name)
return _s;
}
inline const std::string& SchemaScopedTableName::_internal_schema_name() const {
return _impl_.schema_name_.Get();
}
inline void SchemaScopedTableName::_internal_set_schema_name(const std::string& value) {
_impl_.schema_name_.Set(value, GetArenaForAllocation());
}
inline std::string* SchemaScopedTableName::_internal_mutable_schema_name() {
return _impl_.schema_name_.Mutable(GetArenaForAllocation());
}
inline std::string* SchemaScopedTableName::release_schema_name() {
// @@protoc_insertion_point(field_release:greptime.v1.SchemaScopedTableName.schema_name)
return _impl_.schema_name_.Release();
}
inline void SchemaScopedTableName::set_allocated_schema_name(std::string* schema_name) {
if (schema_name != nullptr) {
} else {
}
_impl_.schema_name_.SetAllocated(schema_name, GetArenaForAllocation());
#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
if (_impl_.schema_name_.IsDefault()) {
_impl_.schema_name_.Set("", GetArenaForAllocation());
}
#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
// @@protoc_insertion_point(field_set_allocated:greptime.v1.SchemaScopedTableName.schema_name)
}
// string table_name = 2;
inline void SchemaScopedTableName::clear_table_name() {
_impl_.table_name_.ClearToEmpty();
}
inline const std::string& SchemaScopedTableName::table_name() const {
// @@protoc_insertion_point(field_get:greptime.v1.SchemaScopedTableName.table_name)
return _internal_table_name();
}
template <typename ArgT0, typename... ArgT>
inline PROTOBUF_ALWAYS_INLINE
void SchemaScopedTableName::set_table_name(ArgT0&& arg0, ArgT... args) {
_impl_.table_name_.Set(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
// @@protoc_insertion_point(field_set:greptime.v1.SchemaScopedTableName.table_name)
}
inline std::string* SchemaScopedTableName::mutable_table_name() {
std::string* _s = _internal_mutable_table_name();
// @@protoc_insertion_point(field_mutable:greptime.v1.SchemaScopedTableName.table_name)
return _s;
}
inline const std::string& SchemaScopedTableName::_internal_table_name() const {
return _impl_.table_name_.Get();
}
inline void SchemaScopedTableName::_internal_set_table_name(const std::string& value) {
_impl_.table_name_.Set(value, GetArenaForAllocation());
}
inline std::string* SchemaScopedTableName::_internal_mutable_table_name() {
return _impl_.table_name_.Mutable(GetArenaForAllocation());
}
inline std::string* SchemaScopedTableName::release_table_name() {
// @@protoc_insertion_point(field_release:greptime.v1.SchemaScopedTableName.table_name)
return _impl_.table_name_.Release();
}
inline void SchemaScopedTableName::set_allocated_table_name(std::string* table_name) {
if (table_name != nullptr) {
} else {
}
_impl_.table_name_.SetAllocated(table_name, GetArenaForAllocation());
#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
if (_impl_.table_name_.IsDefault()) {
_impl_.table_name_.Set("", GetArenaForAllocation());
}
#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
// @@protoc_insertion_point(field_set_allocated:greptime.v1.SchemaScopedTableName.table_name)
}
// -------------------------------------------------------------------
// DropFlowTaskExpr
// string catalog_name = 1;
@@ -7737,8 +7452,6 @@ inline void AddColumnLocation::set_allocated_after_column_name(std::string* afte
// -------------------------------------------------------------------
// -------------------------------------------------------------------
// @@protoc_insertion_point(namespace_scope)