diff --git a/flyteidl/gen/pb-cpp/flyteidl/plugins/presto.grpc.pb.cc b/flyteidl/gen/pb-cpp/flyteidl/plugins/presto.grpc.pb.cc new file mode 100644 index 00000000000..04dda26e33f --- /dev/null +++ b/flyteidl/gen/pb-cpp/flyteidl/plugins/presto.grpc.pb.cc @@ -0,0 +1,24 @@ +// Generated by the gRPC C++ plugin. +// If you make any local change, they will be lost. +// source: flyteidl/plugins/presto.proto + +#include "flyteidl/plugins/presto.pb.h" +#include "flyteidl/plugins/presto.grpc.pb.h" + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +namespace flyteidl { +namespace plugins { + +} // namespace flyteidl +} // namespace plugins + diff --git a/flyteidl/gen/pb-cpp/flyteidl/plugins/presto.grpc.pb.h b/flyteidl/gen/pb-cpp/flyteidl/plugins/presto.grpc.pb.h new file mode 100644 index 00000000000..8172a55c49f --- /dev/null +++ b/flyteidl/gen/pb-cpp/flyteidl/plugins/presto.grpc.pb.h @@ -0,0 +1,47 @@ +// Generated by the gRPC C++ plugin. +// If you make any local change, they will be lost. +// source: flyteidl/plugins/presto.proto +#ifndef GRPC_flyteidl_2fplugins_2fpresto_2eproto__INCLUDED +#define GRPC_flyteidl_2fplugins_2fpresto_2eproto__INCLUDED + +#include "flyteidl/plugins/presto.pb.h" + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +namespace grpc_impl { +class Channel; +class CompletionQueue; +class ServerCompletionQueue; +} // namespace grpc_impl + +namespace grpc { +namespace experimental { +template +class MessageAllocator; +} // namespace experimental +} // namespace grpc_impl + +namespace grpc { +class ServerContext; +} // namespace grpc + +namespace flyteidl { +namespace plugins { + +} // namespace plugins +} // namespace flyteidl + + +#endif // GRPC_flyteidl_2fplugins_2fpresto_2eproto__INCLUDED diff --git a/flyteidl/gen/pb-cpp/flyteidl/plugins/presto.pb.cc b/flyteidl/gen/pb-cpp/flyteidl/plugins/presto.pb.cc new file mode 100644 index 00000000000..529929701bb --- /dev/null +++ b/flyteidl/gen/pb-cpp/flyteidl/plugins/presto.pb.cc @@ -0,0 +1,629 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: flyteidl/plugins/presto.proto + +#include "flyteidl/plugins/presto.pb.h" + +#include + +#include +#include +#include +#include +#include +#include +#include +#include +// @@protoc_insertion_point(includes) +#include + +namespace flyteidl { +namespace plugins { +class PrestoQueryDefaultTypeInternal { + public: + ::google::protobuf::internal::ExplicitlyConstructed _instance; +} _PrestoQuery_default_instance_; +} // namespace plugins +} // namespace flyteidl +static void InitDefaultsPrestoQuery_flyteidl_2fplugins_2fpresto_2eproto() { + GOOGLE_PROTOBUF_VERIFY_VERSION; + + { + void* ptr = &::flyteidl::plugins::_PrestoQuery_default_instance_; + new (ptr) ::flyteidl::plugins::PrestoQuery(); + ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); + } + ::flyteidl::plugins::PrestoQuery::InitAsDefaultInstance(); +} + +::google::protobuf::internal::SCCInfo<0> scc_info_PrestoQuery_flyteidl_2fplugins_2fpresto_2eproto = + {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsPrestoQuery_flyteidl_2fplugins_2fpresto_2eproto}, {}}; + +void InitDefaults_flyteidl_2fplugins_2fpresto_2eproto() { + ::google::protobuf::internal::InitSCC(&scc_info_PrestoQuery_flyteidl_2fplugins_2fpresto_2eproto.base); +} + +::google::protobuf::Metadata file_level_metadata_flyteidl_2fplugins_2fpresto_2eproto[1]; +constexpr ::google::protobuf::EnumDescriptor const** file_level_enum_descriptors_flyteidl_2fplugins_2fpresto_2eproto = nullptr; +constexpr ::google::protobuf::ServiceDescriptor const** file_level_service_descriptors_flyteidl_2fplugins_2fpresto_2eproto = nullptr; + +const ::google::protobuf::uint32 TableStruct_flyteidl_2fplugins_2fpresto_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = { + ~0u, // no _has_bits_ + PROTOBUF_FIELD_OFFSET(::flyteidl::plugins::PrestoQuery, _internal_metadata_), + ~0u, // no _extensions_ + ~0u, // no _oneof_case_ + ~0u, // no _weak_field_map_ + PROTOBUF_FIELD_OFFSET(::flyteidl::plugins::PrestoQuery, routing_group_), + PROTOBUF_FIELD_OFFSET(::flyteidl::plugins::PrestoQuery, catalog_), + PROTOBUF_FIELD_OFFSET(::flyteidl::plugins::PrestoQuery, schema_), + PROTOBUF_FIELD_OFFSET(::flyteidl::plugins::PrestoQuery, statement_), +}; +static const ::google::protobuf::internal::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = { + { 0, -1, sizeof(::flyteidl::plugins::PrestoQuery)}, +}; + +static ::google::protobuf::Message const * const file_default_instances[] = { + reinterpret_cast(&::flyteidl::plugins::_PrestoQuery_default_instance_), +}; + +::google::protobuf::internal::AssignDescriptorsTable assign_descriptors_table_flyteidl_2fplugins_2fpresto_2eproto = { + {}, AddDescriptors_flyteidl_2fplugins_2fpresto_2eproto, "flyteidl/plugins/presto.proto", schemas, + file_default_instances, TableStruct_flyteidl_2fplugins_2fpresto_2eproto::offsets, + file_level_metadata_flyteidl_2fplugins_2fpresto_2eproto, 1, file_level_enum_descriptors_flyteidl_2fplugins_2fpresto_2eproto, file_level_service_descriptors_flyteidl_2fplugins_2fpresto_2eproto, +}; + +const char descriptor_table_protodef_flyteidl_2fplugins_2fpresto_2eproto[] = + "\n\035flyteidl/plugins/presto.proto\022\020flyteid" + "l.plugins\032\031flyteidl/core/tasks.proto\"X\n\013" + "PrestoQuery\022\025\n\rrouting_group\030\001 \001(\t\022\017\n\007ca" + "talog\030\002 \001(\t\022\016\n\006schema\030\003 \001(\t\022\021\n\tstatement" + "\030\004 \001(\tB5Z3github.com/lyft/flyteidl/gen/p" + "b-go/flyteidl/pluginsb\006proto3" + ; +::google::protobuf::internal::DescriptorTable descriptor_table_flyteidl_2fplugins_2fpresto_2eproto = { + false, InitDefaults_flyteidl_2fplugins_2fpresto_2eproto, + descriptor_table_protodef_flyteidl_2fplugins_2fpresto_2eproto, + "flyteidl/plugins/presto.proto", &assign_descriptors_table_flyteidl_2fplugins_2fpresto_2eproto, 229, +}; + +void AddDescriptors_flyteidl_2fplugins_2fpresto_2eproto() { + static constexpr ::google::protobuf::internal::InitFunc deps[1] = + { + ::AddDescriptors_flyteidl_2fcore_2ftasks_2eproto, + }; + ::google::protobuf::internal::AddDescriptors(&descriptor_table_flyteidl_2fplugins_2fpresto_2eproto, deps, 1); +} + +// Force running AddDescriptors() at dynamic initialization time. +static bool dynamic_init_dummy_flyteidl_2fplugins_2fpresto_2eproto = []() { AddDescriptors_flyteidl_2fplugins_2fpresto_2eproto(); return true; }(); +namespace flyteidl { +namespace plugins { + +// =================================================================== + +void PrestoQuery::InitAsDefaultInstance() { +} +class PrestoQuery::HasBitSetters { + public: +}; + +#if !defined(_MSC_VER) || _MSC_VER >= 1900 +const int PrestoQuery::kRoutingGroupFieldNumber; +const int PrestoQuery::kCatalogFieldNumber; +const int PrestoQuery::kSchemaFieldNumber; +const int PrestoQuery::kStatementFieldNumber; +#endif // !defined(_MSC_VER) || _MSC_VER >= 1900 + +PrestoQuery::PrestoQuery() + : ::google::protobuf::Message(), _internal_metadata_(nullptr) { + SharedCtor(); + // @@protoc_insertion_point(constructor:flyteidl.plugins.PrestoQuery) +} +PrestoQuery::PrestoQuery(const PrestoQuery& from) + : ::google::protobuf::Message(), + _internal_metadata_(nullptr) { + _internal_metadata_.MergeFrom(from._internal_metadata_); + routing_group_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + if (from.routing_group().size() > 0) { + routing_group_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.routing_group_); + } + catalog_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + if (from.catalog().size() > 0) { + catalog_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.catalog_); + } + schema_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + if (from.schema().size() > 0) { + schema_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.schema_); + } + statement_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + if (from.statement().size() > 0) { + statement_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.statement_); + } + // @@protoc_insertion_point(copy_constructor:flyteidl.plugins.PrestoQuery) +} + +void PrestoQuery::SharedCtor() { + ::google::protobuf::internal::InitSCC( + &scc_info_PrestoQuery_flyteidl_2fplugins_2fpresto_2eproto.base); + routing_group_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + catalog_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + schema_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + statement_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} + +PrestoQuery::~PrestoQuery() { + // @@protoc_insertion_point(destructor:flyteidl.plugins.PrestoQuery) + SharedDtor(); +} + +void PrestoQuery::SharedDtor() { + routing_group_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + catalog_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + schema_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + statement_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} + +void PrestoQuery::SetCachedSize(int size) const { + _cached_size_.Set(size); +} +const PrestoQuery& PrestoQuery::default_instance() { + ::google::protobuf::internal::InitSCC(&::scc_info_PrestoQuery_flyteidl_2fplugins_2fpresto_2eproto.base); + return *internal_default_instance(); +} + + +void PrestoQuery::Clear() { +// @@protoc_insertion_point(message_clear_start:flyteidl.plugins.PrestoQuery) + ::google::protobuf::uint32 cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; + + routing_group_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + catalog_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + schema_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + statement_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); + _internal_metadata_.Clear(); +} + +#if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER +const char* PrestoQuery::_InternalParse(const char* begin, const char* end, void* object, + ::google::protobuf::internal::ParseContext* ctx) { + auto msg = static_cast(object); + ::google::protobuf::int32 size; (void)size; + int depth; (void)depth; + ::google::protobuf::uint32 tag; + ::google::protobuf::internal::ParseFunc parser_till_end; (void)parser_till_end; + auto ptr = begin; + while (ptr < end) { + ptr = ::google::protobuf::io::Parse32(ptr, &tag); + GOOGLE_PROTOBUF_PARSER_ASSERT(ptr); + switch (tag >> 3) { + // string routing_group = 1; + case 1: { + if (static_cast<::google::protobuf::uint8>(tag) != 10) goto handle_unusual; + ptr = ::google::protobuf::io::ReadSize(ptr, &size); + GOOGLE_PROTOBUF_PARSER_ASSERT(ptr); + ctx->extra_parse_data().SetFieldName("flyteidl.plugins.PrestoQuery.routing_group"); + object = msg->mutable_routing_group(); + if (size > end - ptr + ::google::protobuf::internal::ParseContext::kSlopBytes) { + parser_till_end = ::google::protobuf::internal::GreedyStringParserUTF8; + goto string_till_end; + } + GOOGLE_PROTOBUF_PARSER_ASSERT(::google::protobuf::internal::StringCheckUTF8(ptr, size, ctx)); + ::google::protobuf::internal::InlineGreedyStringParser(object, ptr, size, ctx); + ptr += size; + break; + } + // string catalog = 2; + case 2: { + if (static_cast<::google::protobuf::uint8>(tag) != 18) goto handle_unusual; + ptr = ::google::protobuf::io::ReadSize(ptr, &size); + GOOGLE_PROTOBUF_PARSER_ASSERT(ptr); + ctx->extra_parse_data().SetFieldName("flyteidl.plugins.PrestoQuery.catalog"); + object = msg->mutable_catalog(); + if (size > end - ptr + ::google::protobuf::internal::ParseContext::kSlopBytes) { + parser_till_end = ::google::protobuf::internal::GreedyStringParserUTF8; + goto string_till_end; + } + GOOGLE_PROTOBUF_PARSER_ASSERT(::google::protobuf::internal::StringCheckUTF8(ptr, size, ctx)); + ::google::protobuf::internal::InlineGreedyStringParser(object, ptr, size, ctx); + ptr += size; + break; + } + // string schema = 3; + case 3: { + if (static_cast<::google::protobuf::uint8>(tag) != 26) goto handle_unusual; + ptr = ::google::protobuf::io::ReadSize(ptr, &size); + GOOGLE_PROTOBUF_PARSER_ASSERT(ptr); + ctx->extra_parse_data().SetFieldName("flyteidl.plugins.PrestoQuery.schema"); + object = msg->mutable_schema(); + if (size > end - ptr + ::google::protobuf::internal::ParseContext::kSlopBytes) { + parser_till_end = ::google::protobuf::internal::GreedyStringParserUTF8; + goto string_till_end; + } + GOOGLE_PROTOBUF_PARSER_ASSERT(::google::protobuf::internal::StringCheckUTF8(ptr, size, ctx)); + ::google::protobuf::internal::InlineGreedyStringParser(object, ptr, size, ctx); + ptr += size; + break; + } + // string statement = 4; + case 4: { + if (static_cast<::google::protobuf::uint8>(tag) != 34) goto handle_unusual; + ptr = ::google::protobuf::io::ReadSize(ptr, &size); + GOOGLE_PROTOBUF_PARSER_ASSERT(ptr); + ctx->extra_parse_data().SetFieldName("flyteidl.plugins.PrestoQuery.statement"); + object = msg->mutable_statement(); + if (size > end - ptr + ::google::protobuf::internal::ParseContext::kSlopBytes) { + parser_till_end = ::google::protobuf::internal::GreedyStringParserUTF8; + goto string_till_end; + } + GOOGLE_PROTOBUF_PARSER_ASSERT(::google::protobuf::internal::StringCheckUTF8(ptr, size, ctx)); + ::google::protobuf::internal::InlineGreedyStringParser(object, ptr, size, ctx); + ptr += size; + break; + } + default: { + handle_unusual: + if ((tag & 7) == 4 || tag == 0) { + ctx->EndGroup(tag); + return ptr; + } + auto res = UnknownFieldParse(tag, {_InternalParse, msg}, + ptr, end, msg->_internal_metadata_.mutable_unknown_fields(), ctx); + ptr = res.first; + GOOGLE_PROTOBUF_PARSER_ASSERT(ptr != nullptr); + if (res.second) return ptr; + } + } // switch + } // while + return ptr; +string_till_end: + static_cast<::std::string*>(object)->clear(); + static_cast<::std::string*>(object)->reserve(size); + goto len_delim_till_end; +len_delim_till_end: + return ctx->StoreAndTailCall(ptr, end, {_InternalParse, msg}, + {parser_till_end, object}, size); +} +#else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER +bool PrestoQuery::MergePartialFromCodedStream( + ::google::protobuf::io::CodedInputStream* input) { +#define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure + ::google::protobuf::uint32 tag; + // @@protoc_insertion_point(parse_start:flyteidl.plugins.PrestoQuery) + for (;;) { + ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); + tag = p.first; + if (!p.second) goto handle_unusual; + switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { + // string routing_group = 1; + case 1: { + if (static_cast< ::google::protobuf::uint8>(tag) == (10 & 0xFF)) { + DO_(::google::protobuf::internal::WireFormatLite::ReadString( + input, this->mutable_routing_group())); + DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->routing_group().data(), static_cast(this->routing_group().length()), + ::google::protobuf::internal::WireFormatLite::PARSE, + "flyteidl.plugins.PrestoQuery.routing_group")); + } else { + goto handle_unusual; + } + break; + } + + // string catalog = 2; + case 2: { + if (static_cast< ::google::protobuf::uint8>(tag) == (18 & 0xFF)) { + DO_(::google::protobuf::internal::WireFormatLite::ReadString( + input, this->mutable_catalog())); + DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->catalog().data(), static_cast(this->catalog().length()), + ::google::protobuf::internal::WireFormatLite::PARSE, + "flyteidl.plugins.PrestoQuery.catalog")); + } else { + goto handle_unusual; + } + break; + } + + // string schema = 3; + case 3: { + if (static_cast< ::google::protobuf::uint8>(tag) == (26 & 0xFF)) { + DO_(::google::protobuf::internal::WireFormatLite::ReadString( + input, this->mutable_schema())); + DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->schema().data(), static_cast(this->schema().length()), + ::google::protobuf::internal::WireFormatLite::PARSE, + "flyteidl.plugins.PrestoQuery.schema")); + } else { + goto handle_unusual; + } + break; + } + + // string statement = 4; + case 4: { + if (static_cast< ::google::protobuf::uint8>(tag) == (34 & 0xFF)) { + DO_(::google::protobuf::internal::WireFormatLite::ReadString( + input, this->mutable_statement())); + DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->statement().data(), static_cast(this->statement().length()), + ::google::protobuf::internal::WireFormatLite::PARSE, + "flyteidl.plugins.PrestoQuery.statement")); + } else { + goto handle_unusual; + } + break; + } + + default: { + handle_unusual: + if (tag == 0) { + goto success; + } + DO_(::google::protobuf::internal::WireFormat::SkipField( + input, tag, _internal_metadata_.mutable_unknown_fields())); + break; + } + } + } +success: + // @@protoc_insertion_point(parse_success:flyteidl.plugins.PrestoQuery) + return true; +failure: + // @@protoc_insertion_point(parse_failure:flyteidl.plugins.PrestoQuery) + return false; +#undef DO_ +} +#endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER + +void PrestoQuery::SerializeWithCachedSizes( + ::google::protobuf::io::CodedOutputStream* output) const { + // @@protoc_insertion_point(serialize_start:flyteidl.plugins.PrestoQuery) + ::google::protobuf::uint32 cached_has_bits = 0; + (void) cached_has_bits; + + // string routing_group = 1; + if (this->routing_group().size() > 0) { + ::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->routing_group().data(), static_cast(this->routing_group().length()), + ::google::protobuf::internal::WireFormatLite::SERIALIZE, + "flyteidl.plugins.PrestoQuery.routing_group"); + ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( + 1, this->routing_group(), output); + } + + // string catalog = 2; + if (this->catalog().size() > 0) { + ::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->catalog().data(), static_cast(this->catalog().length()), + ::google::protobuf::internal::WireFormatLite::SERIALIZE, + "flyteidl.plugins.PrestoQuery.catalog"); + ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( + 2, this->catalog(), output); + } + + // string schema = 3; + if (this->schema().size() > 0) { + ::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->schema().data(), static_cast(this->schema().length()), + ::google::protobuf::internal::WireFormatLite::SERIALIZE, + "flyteidl.plugins.PrestoQuery.schema"); + ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( + 3, this->schema(), output); + } + + // string statement = 4; + if (this->statement().size() > 0) { + ::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->statement().data(), static_cast(this->statement().length()), + ::google::protobuf::internal::WireFormatLite::SERIALIZE, + "flyteidl.plugins.PrestoQuery.statement"); + ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( + 4, this->statement(), output); + } + + if (_internal_metadata_.have_unknown_fields()) { + ::google::protobuf::internal::WireFormat::SerializeUnknownFields( + _internal_metadata_.unknown_fields(), output); + } + // @@protoc_insertion_point(serialize_end:flyteidl.plugins.PrestoQuery) +} + +::google::protobuf::uint8* PrestoQuery::InternalSerializeWithCachedSizesToArray( + ::google::protobuf::uint8* target) const { + // @@protoc_insertion_point(serialize_to_array_start:flyteidl.plugins.PrestoQuery) + ::google::protobuf::uint32 cached_has_bits = 0; + (void) cached_has_bits; + + // string routing_group = 1; + if (this->routing_group().size() > 0) { + ::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->routing_group().data(), static_cast(this->routing_group().length()), + ::google::protobuf::internal::WireFormatLite::SERIALIZE, + "flyteidl.plugins.PrestoQuery.routing_group"); + target = + ::google::protobuf::internal::WireFormatLite::WriteStringToArray( + 1, this->routing_group(), target); + } + + // string catalog = 2; + if (this->catalog().size() > 0) { + ::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->catalog().data(), static_cast(this->catalog().length()), + ::google::protobuf::internal::WireFormatLite::SERIALIZE, + "flyteidl.plugins.PrestoQuery.catalog"); + target = + ::google::protobuf::internal::WireFormatLite::WriteStringToArray( + 2, this->catalog(), target); + } + + // string schema = 3; + if (this->schema().size() > 0) { + ::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->schema().data(), static_cast(this->schema().length()), + ::google::protobuf::internal::WireFormatLite::SERIALIZE, + "flyteidl.plugins.PrestoQuery.schema"); + target = + ::google::protobuf::internal::WireFormatLite::WriteStringToArray( + 3, this->schema(), target); + } + + // string statement = 4; + if (this->statement().size() > 0) { + ::google::protobuf::internal::WireFormatLite::VerifyUtf8String( + this->statement().data(), static_cast(this->statement().length()), + ::google::protobuf::internal::WireFormatLite::SERIALIZE, + "flyteidl.plugins.PrestoQuery.statement"); + target = + ::google::protobuf::internal::WireFormatLite::WriteStringToArray( + 4, this->statement(), target); + } + + if (_internal_metadata_.have_unknown_fields()) { + target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( + _internal_metadata_.unknown_fields(), target); + } + // @@protoc_insertion_point(serialize_to_array_end:flyteidl.plugins.PrestoQuery) + return target; +} + +size_t PrestoQuery::ByteSizeLong() const { +// @@protoc_insertion_point(message_byte_size_start:flyteidl.plugins.PrestoQuery) + size_t total_size = 0; + + if (_internal_metadata_.have_unknown_fields()) { + total_size += + ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( + _internal_metadata_.unknown_fields()); + } + ::google::protobuf::uint32 cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; + + // string routing_group = 1; + if (this->routing_group().size() > 0) { + total_size += 1 + + ::google::protobuf::internal::WireFormatLite::StringSize( + this->routing_group()); + } + + // string catalog = 2; + if (this->catalog().size() > 0) { + total_size += 1 + + ::google::protobuf::internal::WireFormatLite::StringSize( + this->catalog()); + } + + // string schema = 3; + if (this->schema().size() > 0) { + total_size += 1 + + ::google::protobuf::internal::WireFormatLite::StringSize( + this->schema()); + } + + // string statement = 4; + if (this->statement().size() > 0) { + total_size += 1 + + ::google::protobuf::internal::WireFormatLite::StringSize( + this->statement()); + } + + int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); + SetCachedSize(cached_size); + return total_size; +} + +void PrestoQuery::MergeFrom(const ::google::protobuf::Message& from) { +// @@protoc_insertion_point(generalized_merge_from_start:flyteidl.plugins.PrestoQuery) + GOOGLE_DCHECK_NE(&from, this); + const PrestoQuery* source = + ::google::protobuf::DynamicCastToGenerated( + &from); + if (source == nullptr) { + // @@protoc_insertion_point(generalized_merge_from_cast_fail:flyteidl.plugins.PrestoQuery) + ::google::protobuf::internal::ReflectionOps::Merge(from, this); + } else { + // @@protoc_insertion_point(generalized_merge_from_cast_success:flyteidl.plugins.PrestoQuery) + MergeFrom(*source); + } +} + +void PrestoQuery::MergeFrom(const PrestoQuery& from) { +// @@protoc_insertion_point(class_specific_merge_from_start:flyteidl.plugins.PrestoQuery) + GOOGLE_DCHECK_NE(&from, this); + _internal_metadata_.MergeFrom(from._internal_metadata_); + ::google::protobuf::uint32 cached_has_bits = 0; + (void) cached_has_bits; + + if (from.routing_group().size() > 0) { + + routing_group_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.routing_group_); + } + if (from.catalog().size() > 0) { + + catalog_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.catalog_); + } + if (from.schema().size() > 0) { + + schema_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.schema_); + } + if (from.statement().size() > 0) { + + statement_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.statement_); + } +} + +void PrestoQuery::CopyFrom(const ::google::protobuf::Message& from) { +// @@protoc_insertion_point(generalized_copy_from_start:flyteidl.plugins.PrestoQuery) + if (&from == this) return; + Clear(); + MergeFrom(from); +} + +void PrestoQuery::CopyFrom(const PrestoQuery& from) { +// @@protoc_insertion_point(class_specific_copy_from_start:flyteidl.plugins.PrestoQuery) + if (&from == this) return; + Clear(); + MergeFrom(from); +} + +bool PrestoQuery::IsInitialized() const { + return true; +} + +void PrestoQuery::Swap(PrestoQuery* other) { + if (other == this) return; + InternalSwap(other); +} +void PrestoQuery::InternalSwap(PrestoQuery* other) { + using std::swap; + _internal_metadata_.Swap(&other->_internal_metadata_); + routing_group_.Swap(&other->routing_group_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(), + GetArenaNoVirtual()); + catalog_.Swap(&other->catalog_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(), + GetArenaNoVirtual()); + schema_.Swap(&other->schema_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(), + GetArenaNoVirtual()); + statement_.Swap(&other->statement_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(), + GetArenaNoVirtual()); +} + +::google::protobuf::Metadata PrestoQuery::GetMetadata() const { + ::google::protobuf::internal::AssignDescriptors(&::assign_descriptors_table_flyteidl_2fplugins_2fpresto_2eproto); + return ::file_level_metadata_flyteidl_2fplugins_2fpresto_2eproto[kIndexInFileMessages]; +} + + +// @@protoc_insertion_point(namespace_scope) +} // namespace plugins +} // namespace flyteidl +namespace google { +namespace protobuf { +template<> PROTOBUF_NOINLINE ::flyteidl::plugins::PrestoQuery* Arena::CreateMaybeMessage< ::flyteidl::plugins::PrestoQuery >(Arena* arena) { + return Arena::CreateInternal< ::flyteidl::plugins::PrestoQuery >(arena); +} +} // namespace protobuf +} // namespace google + +// @@protoc_insertion_point(global_scope) +#include diff --git a/flyteidl/gen/pb-cpp/flyteidl/plugins/presto.pb.h b/flyteidl/gen/pb-cpp/flyteidl/plugins/presto.pb.h new file mode 100644 index 00000000000..20e9d6f2c4d --- /dev/null +++ b/flyteidl/gen/pb-cpp/flyteidl/plugins/presto.pb.h @@ -0,0 +1,467 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: flyteidl/plugins/presto.proto + +#ifndef PROTOBUF_INCLUDED_flyteidl_2fplugins_2fpresto_2eproto +#define PROTOBUF_INCLUDED_flyteidl_2fplugins_2fpresto_2eproto + +#include +#include + +#include +#if PROTOBUF_VERSION < 3007000 +#error This file was generated by a newer version of protoc which is +#error incompatible with your Protocol Buffer headers. Please update +#error your headers. +#endif +#if 3007000 < PROTOBUF_MIN_PROTOC_VERSION +#error This file was generated by an older version of protoc which is +#error incompatible with your Protocol Buffer headers. Please +#error regenerate this file with a newer version of protoc. +#endif + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include // IWYU pragma: export +#include // IWYU pragma: export +#include +#include "flyteidl/core/tasks.pb.h" +// @@protoc_insertion_point(includes) +#include +#define PROTOBUF_INTERNAL_EXPORT_flyteidl_2fplugins_2fpresto_2eproto + +// Internal implementation detail -- do not use these members. +struct TableStruct_flyteidl_2fplugins_2fpresto_2eproto { + static const ::google::protobuf::internal::ParseTableField entries[] + PROTOBUF_SECTION_VARIABLE(protodesc_cold); + static const ::google::protobuf::internal::AuxillaryParseTableField aux[] + PROTOBUF_SECTION_VARIABLE(protodesc_cold); + static const ::google::protobuf::internal::ParseTable schema[1] + PROTOBUF_SECTION_VARIABLE(protodesc_cold); + static const ::google::protobuf::internal::FieldMetadata field_metadata[]; + static const ::google::protobuf::internal::SerializationTable serialization_table[]; + static const ::google::protobuf::uint32 offsets[]; +}; +void AddDescriptors_flyteidl_2fplugins_2fpresto_2eproto(); +namespace flyteidl { +namespace plugins { +class PrestoQuery; +class PrestoQueryDefaultTypeInternal; +extern PrestoQueryDefaultTypeInternal _PrestoQuery_default_instance_; +} // namespace plugins +} // namespace flyteidl +namespace google { +namespace protobuf { +template<> ::flyteidl::plugins::PrestoQuery* Arena::CreateMaybeMessage<::flyteidl::plugins::PrestoQuery>(Arena*); +} // namespace protobuf +} // namespace google +namespace flyteidl { +namespace plugins { + +// =================================================================== + +class PrestoQuery final : + public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:flyteidl.plugins.PrestoQuery) */ { + public: + PrestoQuery(); + virtual ~PrestoQuery(); + + PrestoQuery(const PrestoQuery& from); + + inline PrestoQuery& operator=(const PrestoQuery& from) { + CopyFrom(from); + return *this; + } + #if LANG_CXX11 + PrestoQuery(PrestoQuery&& from) noexcept + : PrestoQuery() { + *this = ::std::move(from); + } + + inline PrestoQuery& operator=(PrestoQuery&& from) noexcept { + if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { + if (this != &from) InternalSwap(&from); + } else { + CopyFrom(from); + } + return *this; + } + #endif + static const ::google::protobuf::Descriptor* descriptor() { + return default_instance().GetDescriptor(); + } + static const PrestoQuery& default_instance(); + + static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY + static inline const PrestoQuery* internal_default_instance() { + return reinterpret_cast( + &_PrestoQuery_default_instance_); + } + static constexpr int kIndexInFileMessages = + 0; + + void Swap(PrestoQuery* other); + friend void swap(PrestoQuery& a, PrestoQuery& b) { + a.Swap(&b); + } + + // implements Message ---------------------------------------------- + + inline PrestoQuery* New() const final { + return CreateMaybeMessage(nullptr); + } + + PrestoQuery* New(::google::protobuf::Arena* arena) const final { + return CreateMaybeMessage(arena); + } + void CopyFrom(const ::google::protobuf::Message& from) final; + void MergeFrom(const ::google::protobuf::Message& from) final; + void CopyFrom(const PrestoQuery& from); + void MergeFrom(const PrestoQuery& from); + PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; + bool IsInitialized() const final; + + size_t ByteSizeLong() const final; + #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER + static const char* _InternalParse(const char* begin, const char* end, void* object, ::google::protobuf::internal::ParseContext* ctx); + ::google::protobuf::internal::ParseFunc _ParseFunc() const final { return _InternalParse; } + #else + bool MergePartialFromCodedStream( + ::google::protobuf::io::CodedInputStream* input) final; + #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER + void SerializeWithCachedSizes( + ::google::protobuf::io::CodedOutputStream* output) const final; + ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( + ::google::protobuf::uint8* target) const final; + int GetCachedSize() const final { return _cached_size_.Get(); } + + private: + void SharedCtor(); + void SharedDtor(); + void SetCachedSize(int size) const final; + void InternalSwap(PrestoQuery* other); + private: + inline ::google::protobuf::Arena* GetArenaNoVirtual() const { + return nullptr; + } + inline void* MaybeArenaPtr() const { + return nullptr; + } + public: + + ::google::protobuf::Metadata GetMetadata() const final; + + // nested types ---------------------------------------------------- + + // accessors ------------------------------------------------------- + + // string routing_group = 1; + void clear_routing_group(); + static const int kRoutingGroupFieldNumber = 1; + const ::std::string& routing_group() const; + void set_routing_group(const ::std::string& value); + #if LANG_CXX11 + void set_routing_group(::std::string&& value); + #endif + void set_routing_group(const char* value); + void set_routing_group(const char* value, size_t size); + ::std::string* mutable_routing_group(); + ::std::string* release_routing_group(); + void set_allocated_routing_group(::std::string* routing_group); + + // string catalog = 2; + void clear_catalog(); + static const int kCatalogFieldNumber = 2; + const ::std::string& catalog() const; + void set_catalog(const ::std::string& value); + #if LANG_CXX11 + void set_catalog(::std::string&& value); + #endif + void set_catalog(const char* value); + void set_catalog(const char* value, size_t size); + ::std::string* mutable_catalog(); + ::std::string* release_catalog(); + void set_allocated_catalog(::std::string* catalog); + + // string schema = 3; + void clear_schema(); + static const int kSchemaFieldNumber = 3; + const ::std::string& schema() const; + void set_schema(const ::std::string& value); + #if LANG_CXX11 + void set_schema(::std::string&& value); + #endif + void set_schema(const char* value); + void set_schema(const char* value, size_t size); + ::std::string* mutable_schema(); + ::std::string* release_schema(); + void set_allocated_schema(::std::string* schema); + + // string statement = 4; + void clear_statement(); + static const int kStatementFieldNumber = 4; + const ::std::string& statement() const; + void set_statement(const ::std::string& value); + #if LANG_CXX11 + void set_statement(::std::string&& value); + #endif + void set_statement(const char* value); + void set_statement(const char* value, size_t size); + ::std::string* mutable_statement(); + ::std::string* release_statement(); + void set_allocated_statement(::std::string* statement); + + // @@protoc_insertion_point(class_scope:flyteidl.plugins.PrestoQuery) + private: + class HasBitSetters; + + ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; + ::google::protobuf::internal::ArenaStringPtr routing_group_; + ::google::protobuf::internal::ArenaStringPtr catalog_; + ::google::protobuf::internal::ArenaStringPtr schema_; + ::google::protobuf::internal::ArenaStringPtr statement_; + mutable ::google::protobuf::internal::CachedSize _cached_size_; + friend struct ::TableStruct_flyteidl_2fplugins_2fpresto_2eproto; +}; +// =================================================================== + + +// =================================================================== + +#ifdef __GNUC__ + #pragma GCC diagnostic push + #pragma GCC diagnostic ignored "-Wstrict-aliasing" +#endif // __GNUC__ +// PrestoQuery + +// string routing_group = 1; +inline void PrestoQuery::clear_routing_group() { + routing_group_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline const ::std::string& PrestoQuery::routing_group() const { + // @@protoc_insertion_point(field_get:flyteidl.plugins.PrestoQuery.routing_group) + return routing_group_.GetNoArena(); +} +inline void PrestoQuery::set_routing_group(const ::std::string& value) { + + routing_group_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); + // @@protoc_insertion_point(field_set:flyteidl.plugins.PrestoQuery.routing_group) +} +#if LANG_CXX11 +inline void PrestoQuery::set_routing_group(::std::string&& value) { + + routing_group_.SetNoArena( + &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); + // @@protoc_insertion_point(field_set_rvalue:flyteidl.plugins.PrestoQuery.routing_group) +} +#endif +inline void PrestoQuery::set_routing_group(const char* value) { + GOOGLE_DCHECK(value != nullptr); + + routing_group_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); + // @@protoc_insertion_point(field_set_char:flyteidl.plugins.PrestoQuery.routing_group) +} +inline void PrestoQuery::set_routing_group(const char* value, size_t size) { + + routing_group_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), + ::std::string(reinterpret_cast(value), size)); + // @@protoc_insertion_point(field_set_pointer:flyteidl.plugins.PrestoQuery.routing_group) +} +inline ::std::string* PrestoQuery::mutable_routing_group() { + + // @@protoc_insertion_point(field_mutable:flyteidl.plugins.PrestoQuery.routing_group) + return routing_group_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline ::std::string* PrestoQuery::release_routing_group() { + // @@protoc_insertion_point(field_release:flyteidl.plugins.PrestoQuery.routing_group) + + return routing_group_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline void PrestoQuery::set_allocated_routing_group(::std::string* routing_group) { + if (routing_group != nullptr) { + + } else { + + } + routing_group_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), routing_group); + // @@protoc_insertion_point(field_set_allocated:flyteidl.plugins.PrestoQuery.routing_group) +} + +// string catalog = 2; +inline void PrestoQuery::clear_catalog() { + catalog_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline const ::std::string& PrestoQuery::catalog() const { + // @@protoc_insertion_point(field_get:flyteidl.plugins.PrestoQuery.catalog) + return catalog_.GetNoArena(); +} +inline void PrestoQuery::set_catalog(const ::std::string& value) { + + catalog_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); + // @@protoc_insertion_point(field_set:flyteidl.plugins.PrestoQuery.catalog) +} +#if LANG_CXX11 +inline void PrestoQuery::set_catalog(::std::string&& value) { + + catalog_.SetNoArena( + &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); + // @@protoc_insertion_point(field_set_rvalue:flyteidl.plugins.PrestoQuery.catalog) +} +#endif +inline void PrestoQuery::set_catalog(const char* value) { + GOOGLE_DCHECK(value != nullptr); + + catalog_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); + // @@protoc_insertion_point(field_set_char:flyteidl.plugins.PrestoQuery.catalog) +} +inline void PrestoQuery::set_catalog(const char* value, size_t size) { + + catalog_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), + ::std::string(reinterpret_cast(value), size)); + // @@protoc_insertion_point(field_set_pointer:flyteidl.plugins.PrestoQuery.catalog) +} +inline ::std::string* PrestoQuery::mutable_catalog() { + + // @@protoc_insertion_point(field_mutable:flyteidl.plugins.PrestoQuery.catalog) + return catalog_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline ::std::string* PrestoQuery::release_catalog() { + // @@protoc_insertion_point(field_release:flyteidl.plugins.PrestoQuery.catalog) + + return catalog_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline void PrestoQuery::set_allocated_catalog(::std::string* catalog) { + if (catalog != nullptr) { + + } else { + + } + catalog_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), catalog); + // @@protoc_insertion_point(field_set_allocated:flyteidl.plugins.PrestoQuery.catalog) +} + +// string schema = 3; +inline void PrestoQuery::clear_schema() { + schema_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline const ::std::string& PrestoQuery::schema() const { + // @@protoc_insertion_point(field_get:flyteidl.plugins.PrestoQuery.schema) + return schema_.GetNoArena(); +} +inline void PrestoQuery::set_schema(const ::std::string& value) { + + schema_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); + // @@protoc_insertion_point(field_set:flyteidl.plugins.PrestoQuery.schema) +} +#if LANG_CXX11 +inline void PrestoQuery::set_schema(::std::string&& value) { + + schema_.SetNoArena( + &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); + // @@protoc_insertion_point(field_set_rvalue:flyteidl.plugins.PrestoQuery.schema) +} +#endif +inline void PrestoQuery::set_schema(const char* value) { + GOOGLE_DCHECK(value != nullptr); + + schema_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); + // @@protoc_insertion_point(field_set_char:flyteidl.plugins.PrestoQuery.schema) +} +inline void PrestoQuery::set_schema(const char* value, size_t size) { + + schema_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), + ::std::string(reinterpret_cast(value), size)); + // @@protoc_insertion_point(field_set_pointer:flyteidl.plugins.PrestoQuery.schema) +} +inline ::std::string* PrestoQuery::mutable_schema() { + + // @@protoc_insertion_point(field_mutable:flyteidl.plugins.PrestoQuery.schema) + return schema_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline ::std::string* PrestoQuery::release_schema() { + // @@protoc_insertion_point(field_release:flyteidl.plugins.PrestoQuery.schema) + + return schema_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline void PrestoQuery::set_allocated_schema(::std::string* schema) { + if (schema != nullptr) { + + } else { + + } + schema_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), schema); + // @@protoc_insertion_point(field_set_allocated:flyteidl.plugins.PrestoQuery.schema) +} + +// string statement = 4; +inline void PrestoQuery::clear_statement() { + statement_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline const ::std::string& PrestoQuery::statement() const { + // @@protoc_insertion_point(field_get:flyteidl.plugins.PrestoQuery.statement) + return statement_.GetNoArena(); +} +inline void PrestoQuery::set_statement(const ::std::string& value) { + + statement_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); + // @@protoc_insertion_point(field_set:flyteidl.plugins.PrestoQuery.statement) +} +#if LANG_CXX11 +inline void PrestoQuery::set_statement(::std::string&& value) { + + statement_.SetNoArena( + &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); + // @@protoc_insertion_point(field_set_rvalue:flyteidl.plugins.PrestoQuery.statement) +} +#endif +inline void PrestoQuery::set_statement(const char* value) { + GOOGLE_DCHECK(value != nullptr); + + statement_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); + // @@protoc_insertion_point(field_set_char:flyteidl.plugins.PrestoQuery.statement) +} +inline void PrestoQuery::set_statement(const char* value, size_t size) { + + statement_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), + ::std::string(reinterpret_cast(value), size)); + // @@protoc_insertion_point(field_set_pointer:flyteidl.plugins.PrestoQuery.statement) +} +inline ::std::string* PrestoQuery::mutable_statement() { + + // @@protoc_insertion_point(field_mutable:flyteidl.plugins.PrestoQuery.statement) + return statement_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline ::std::string* PrestoQuery::release_statement() { + // @@protoc_insertion_point(field_release:flyteidl.plugins.PrestoQuery.statement) + + return statement_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); +} +inline void PrestoQuery::set_allocated_statement(::std::string* statement) { + if (statement != nullptr) { + + } else { + + } + statement_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), statement); + // @@protoc_insertion_point(field_set_allocated:flyteidl.plugins.PrestoQuery.statement) +} + +#ifdef __GNUC__ + #pragma GCC diagnostic pop +#endif // __GNUC__ + +// @@protoc_insertion_point(namespace_scope) + +} // namespace plugins +} // namespace flyteidl + +// @@protoc_insertion_point(global_scope) + +#include +#endif // PROTOBUF_INCLUDED_flyteidl_2fplugins_2fpresto_2eproto diff --git a/flyteidl/gen/pb-go/flyteidl/plugins/presto.pb.go b/flyteidl/gen/pb-go/flyteidl/plugins/presto.pb.go new file mode 100644 index 00000000000..fcb442aaaa2 --- /dev/null +++ b/flyteidl/gen/pb-go/flyteidl/plugins/presto.pb.go @@ -0,0 +1,110 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// source: flyteidl/plugins/presto.proto + +package plugins + +import ( + fmt "fmt" + proto "github.com/golang/protobuf/proto" + _ "github.com/lyft/flyteidl/gen/pb-go/flyteidl/core" + math "math" +) + +// Reference imports to suppress errors if they are not otherwise used. +var _ = proto.Marshal +var _ = fmt.Errorf +var _ = math.Inf + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the proto package it is being compiled against. +// A compilation error at this line likely means your copy of the +// proto package needs to be updated. +const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package + +// This message works with the 'presto' task type in the SDK and is the object that will be in the 'custom' field +// of a Presto task's TaskTemplate +type PrestoQuery struct { + RoutingGroup string `protobuf:"bytes,1,opt,name=routing_group,json=routingGroup,proto3" json:"routing_group,omitempty"` + Catalog string `protobuf:"bytes,2,opt,name=catalog,proto3" json:"catalog,omitempty"` + Schema string `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"` + Statement string `protobuf:"bytes,4,opt,name=statement,proto3" json:"statement,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *PrestoQuery) Reset() { *m = PrestoQuery{} } +func (m *PrestoQuery) String() string { return proto.CompactTextString(m) } +func (*PrestoQuery) ProtoMessage() {} +func (*PrestoQuery) Descriptor() ([]byte, []int) { + return fileDescriptor_881edc23a44f4737, []int{0} +} + +func (m *PrestoQuery) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_PrestoQuery.Unmarshal(m, b) +} +func (m *PrestoQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_PrestoQuery.Marshal(b, m, deterministic) +} +func (m *PrestoQuery) XXX_Merge(src proto.Message) { + xxx_messageInfo_PrestoQuery.Merge(m, src) +} +func (m *PrestoQuery) XXX_Size() int { + return xxx_messageInfo_PrestoQuery.Size(m) +} +func (m *PrestoQuery) XXX_DiscardUnknown() { + xxx_messageInfo_PrestoQuery.DiscardUnknown(m) +} + +var xxx_messageInfo_PrestoQuery proto.InternalMessageInfo + +func (m *PrestoQuery) GetRoutingGroup() string { + if m != nil { + return m.RoutingGroup + } + return "" +} + +func (m *PrestoQuery) GetCatalog() string { + if m != nil { + return m.Catalog + } + return "" +} + +func (m *PrestoQuery) GetSchema() string { + if m != nil { + return m.Schema + } + return "" +} + +func (m *PrestoQuery) GetStatement() string { + if m != nil { + return m.Statement + } + return "" +} + +func init() { + proto.RegisterType((*PrestoQuery)(nil), "flyteidl.plugins.PrestoQuery") +} + +func init() { proto.RegisterFile("flyteidl/plugins/presto.proto", fileDescriptor_881edc23a44f4737) } + +var fileDescriptor_881edc23a44f4737 = []byte{ + // 207 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x5c, 0x8f, 0x31, 0x4b, 0xc6, 0x30, + 0x10, 0x86, 0xa9, 0x4a, 0xa5, 0x51, 0x41, 0x32, 0x48, 0x14, 0x05, 0xd1, 0xc5, 0xc5, 0x66, 0x28, + 0xfe, 0x01, 0x17, 0x57, 0x75, 0x74, 0x91, 0x34, 0x5e, 0xd3, 0x60, 0x9a, 0x0b, 0xc9, 0x65, 0xe8, + 0xea, 0x2f, 0x17, 0x63, 0xdb, 0x0f, 0xbe, 0xf1, 0x7d, 0x9e, 0x7b, 0xe1, 0x5e, 0x76, 0x33, 0xb8, + 0x99, 0xc0, 0x7e, 0x39, 0x19, 0x5c, 0x36, 0xd6, 0x27, 0x19, 0x22, 0x24, 0xc2, 0x36, 0x44, 0x24, + 0xe4, 0xe7, 0xab, 0x6e, 0x17, 0x7d, 0x75, 0xb9, 0x15, 0x34, 0x46, 0x90, 0xa4, 0xd2, 0x77, 0xfa, + 0x3f, 0xbe, 0xfb, 0xa9, 0xd8, 0xc9, 0x6b, 0x69, 0xbf, 0x65, 0x88, 0x33, 0xbf, 0x67, 0x67, 0x11, + 0x33, 0x59, 0x6f, 0x3e, 0x4d, 0xc4, 0x1c, 0x44, 0x75, 0x5b, 0x3d, 0x34, 0xef, 0xa7, 0x0b, 0x7c, + 0xf9, 0x63, 0x5c, 0xb0, 0x63, 0xad, 0x48, 0x39, 0x34, 0xe2, 0xa0, 0xe8, 0x35, 0xf2, 0x0b, 0x56, + 0x27, 0x3d, 0xc2, 0xa4, 0xc4, 0x61, 0x11, 0x4b, 0xe2, 0xd7, 0xac, 0x49, 0xa4, 0x08, 0x26, 0xf0, + 0x24, 0x8e, 0x8a, 0xda, 0x81, 0xe7, 0xa7, 0x8f, 0xce, 0x58, 0x1a, 0x73, 0xdf, 0x6a, 0x9c, 0xa4, + 0x9b, 0x07, 0x92, 0xdb, 0xc7, 0x06, 0xbc, 0x0c, 0xfd, 0xa3, 0x41, 0xb9, 0xbf, 0xba, 0xaf, 0xcb, + 0x84, 0xee, 0x37, 0x00, 0x00, 0xff, 0xff, 0x97, 0x6e, 0x8d, 0x5f, 0x10, 0x01, 0x00, 0x00, +} diff --git a/flyteidl/gen/pb-go/flyteidl/plugins/presto.pb.validate.go b/flyteidl/gen/pb-go/flyteidl/plugins/presto.pb.validate.go new file mode 100644 index 00000000000..42b8695fa9d --- /dev/null +++ b/flyteidl/gen/pb-go/flyteidl/plugins/presto.pb.validate.go @@ -0,0 +1,110 @@ +// Code generated by protoc-gen-validate. DO NOT EDIT. +// source: flyteidl/plugins/presto.proto + +package plugins + +import ( + "bytes" + "errors" + "fmt" + "net" + "net/mail" + "net/url" + "regexp" + "strings" + "time" + "unicode/utf8" + + "github.com/golang/protobuf/ptypes" +) + +// ensure the imports are used +var ( + _ = bytes.MinRead + _ = errors.New("") + _ = fmt.Print + _ = utf8.UTFMax + _ = (*regexp.Regexp)(nil) + _ = (*strings.Reader)(nil) + _ = net.IPv4len + _ = time.Duration(0) + _ = (*url.URL)(nil) + _ = (*mail.Address)(nil) + _ = ptypes.DynamicAny{} +) + +// define the regex for a UUID once up-front +var _presto_uuidPattern = regexp.MustCompile("^[0-9a-fA-F]{8}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{12}$") + +// Validate checks the field values on PrestoQuery with the rules defined in +// the proto definition for this message. If any rules are violated, an error +// is returned. +func (m *PrestoQuery) Validate() error { + if m == nil { + return nil + } + + // no validation rules for RoutingGroup + + // no validation rules for Catalog + + // no validation rules for Schema + + // no validation rules for Statement + + return nil +} + +// PrestoQueryValidationError is the validation error returned by +// PrestoQuery.Validate if the designated constraints aren't met. +type PrestoQueryValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e PrestoQueryValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e PrestoQueryValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e PrestoQueryValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e PrestoQueryValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e PrestoQueryValidationError) ErrorName() string { return "PrestoQueryValidationError" } + +// Error satisfies the builtin error interface +func (e PrestoQueryValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sPrestoQuery.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = PrestoQueryValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = PrestoQueryValidationError{} diff --git a/flyteidl/gen/pb-java/flyteidl/plugins/Presto.java b/flyteidl/gen/pb-java/flyteidl/plugins/Presto.java new file mode 100644 index 00000000000..4ebb9a8be52 --- /dev/null +++ b/flyteidl/gen/pb-java/flyteidl/plugins/Presto.java @@ -0,0 +1,1031 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: flyteidl/plugins/presto.proto + +package flyteidl.plugins; + +public final class Presto { + private Presto() {} + public static void registerAllExtensions( + com.google.protobuf.ExtensionRegistryLite registry) { + } + + public static void registerAllExtensions( + com.google.protobuf.ExtensionRegistry registry) { + registerAllExtensions( + (com.google.protobuf.ExtensionRegistryLite) registry); + } + public interface PrestoQueryOrBuilder extends + // @@protoc_insertion_point(interface_extends:flyteidl.plugins.PrestoQuery) + com.google.protobuf.MessageOrBuilder { + + /** + * string routing_group = 1; + */ + java.lang.String getRoutingGroup(); + /** + * string routing_group = 1; + */ + com.google.protobuf.ByteString + getRoutingGroupBytes(); + + /** + * string catalog = 2; + */ + java.lang.String getCatalog(); + /** + * string catalog = 2; + */ + com.google.protobuf.ByteString + getCatalogBytes(); + + /** + * string schema = 3; + */ + java.lang.String getSchema(); + /** + * string schema = 3; + */ + com.google.protobuf.ByteString + getSchemaBytes(); + + /** + * string statement = 4; + */ + java.lang.String getStatement(); + /** + * string statement = 4; + */ + com.google.protobuf.ByteString + getStatementBytes(); + } + /** + * 
+   * This message works with the 'presto' task type in the SDK and is the object that will be in the 'custom' field
+   * of a Presto task's TaskTemplate
+   *
+ * + * Protobuf type {@code flyteidl.plugins.PrestoQuery} + */ + public static final class PrestoQuery extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:flyteidl.plugins.PrestoQuery) + PrestoQueryOrBuilder { + private static final long serialVersionUID = 0L; + // Use PrestoQuery.newBuilder() to construct. + private PrestoQuery(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + private PrestoQuery() { + routingGroup_ = ""; + catalog_ = ""; + schema_ = ""; + statement_ = ""; + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private PrestoQuery( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + this(); + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + case 10: { + java.lang.String s = input.readStringRequireUtf8(); + + routingGroup_ = s; + break; + } + case 18: { + java.lang.String s = input.readStringRequireUtf8(); + + catalog_ = s; + break; + } + case 26: { + java.lang.String s = input.readStringRequireUtf8(); + + schema_ = s; + break; + } + case 34: { + java.lang.String s = input.readStringRequireUtf8(); + + statement_ = s; + break; + } + default: { + if (!parseUnknownField( + input, unknownFields, extensionRegistry, tag)) { + done = true; + } + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return flyteidl.plugins.Presto.internal_static_flyteidl_plugins_PrestoQuery_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return flyteidl.plugins.Presto.internal_static_flyteidl_plugins_PrestoQuery_fieldAccessorTable + .ensureFieldAccessorsInitialized( + flyteidl.plugins.Presto.PrestoQuery.class, flyteidl.plugins.Presto.PrestoQuery.Builder.class); + } + + public static final int ROUTING_GROUP_FIELD_NUMBER = 1; + private volatile java.lang.Object routingGroup_; + /** + * string routing_group = 1; + */ + public java.lang.String getRoutingGroup() { + java.lang.Object ref = routingGroup_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + routingGroup_ = s; + return s; + } + } + /** + * string routing_group = 1; + */ + public com.google.protobuf.ByteString + getRoutingGroupBytes() { + java.lang.Object ref = routingGroup_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + routingGroup_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int CATALOG_FIELD_NUMBER = 2; + private volatile java.lang.Object catalog_; + /** + * string catalog = 2; + */ + public java.lang.String getCatalog() { + java.lang.Object ref = catalog_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + catalog_ = s; + return s; + } + } + /** + * string catalog = 2; + */ + public com.google.protobuf.ByteString + getCatalogBytes() { + java.lang.Object ref = catalog_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + catalog_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int SCHEMA_FIELD_NUMBER = 3; + private volatile java.lang.Object schema_; + /** + * string schema = 3; + */ + public java.lang.String getSchema() { + java.lang.Object ref = schema_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + schema_ = s; + return s; + } + } + /** + * string schema = 3; + */ + public com.google.protobuf.ByteString + getSchemaBytes() { + java.lang.Object ref = schema_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + schema_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int STATEMENT_FIELD_NUMBER = 4; + private volatile java.lang.Object statement_; + /** + * string statement = 4; + */ + public java.lang.String getStatement() { + java.lang.Object ref = statement_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + statement_ = s; + return s; + } + } + /** + * string statement = 4; + */ + public com.google.protobuf.ByteString + getStatementBytes() { + java.lang.Object ref = statement_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + statement_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private byte memoizedIsInitialized = -1; + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + if (!getRoutingGroupBytes().isEmpty()) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 1, routingGroup_); + } + if (!getCatalogBytes().isEmpty()) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 2, catalog_); + } + if (!getSchemaBytes().isEmpty()) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 3, schema_); + } + if (!getStatementBytes().isEmpty()) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 4, statement_); + } + unknownFields.writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (!getRoutingGroupBytes().isEmpty()) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, routingGroup_); + } + if (!getCatalogBytes().isEmpty()) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, catalog_); + } + if (!getSchemaBytes().isEmpty()) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(3, schema_); + } + if (!getStatementBytes().isEmpty()) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(4, statement_); + } + size += unknownFields.getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof flyteidl.plugins.Presto.PrestoQuery)) { + return super.equals(obj); + } + flyteidl.plugins.Presto.PrestoQuery other = (flyteidl.plugins.Presto.PrestoQuery) obj; + + if (!getRoutingGroup() + .equals(other.getRoutingGroup())) return false; + if (!getCatalog() + .equals(other.getCatalog())) return false; + if (!getSchema() + .equals(other.getSchema())) return false; + if (!getStatement() + .equals(other.getStatement())) return false; + if (!unknownFields.equals(other.unknownFields)) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + hash = (37 * hash) + ROUTING_GROUP_FIELD_NUMBER; + hash = (53 * hash) + getRoutingGroup().hashCode(); + hash = (37 * hash) + CATALOG_FIELD_NUMBER; + hash = (53 * hash) + getCatalog().hashCode(); + hash = (37 * hash) + SCHEMA_FIELD_NUMBER; + hash = (53 * hash) + getSchema().hashCode(); + hash = (37 * hash) + STATEMENT_FIELD_NUMBER; + hash = (53 * hash) + getStatement().hashCode(); + hash = (29 * hash) + unknownFields.hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static flyteidl.plugins.Presto.PrestoQuery parseFrom( + java.nio.ByteBuffer data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static flyteidl.plugins.Presto.PrestoQuery parseFrom( + java.nio.ByteBuffer data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static flyteidl.plugins.Presto.PrestoQuery parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static flyteidl.plugins.Presto.PrestoQuery parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static flyteidl.plugins.Presto.PrestoQuery parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static flyteidl.plugins.Presto.PrestoQuery parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static flyteidl.plugins.Presto.PrestoQuery parseFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static flyteidl.plugins.Presto.PrestoQuery parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + public static flyteidl.plugins.Presto.PrestoQuery parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input); + } + public static flyteidl.plugins.Presto.PrestoQuery parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input, extensionRegistry); + } + public static flyteidl.plugins.Presto.PrestoQuery parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static flyteidl.plugins.Presto.PrestoQuery parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + public static Builder newBuilder(flyteidl.plugins.Presto.PrestoQuery prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE + ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * 
+     * This message works with the 'presto' task type in the SDK and is the object that will be in the 'custom' field
+     * of a Presto task's TaskTemplate
+     *
+ * + * Protobuf type {@code flyteidl.plugins.PrestoQuery} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder implements + // @@protoc_insertion_point(builder_implements:flyteidl.plugins.PrestoQuery) + flyteidl.plugins.Presto.PrestoQueryOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return flyteidl.plugins.Presto.internal_static_flyteidl_plugins_PrestoQuery_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return flyteidl.plugins.Presto.internal_static_flyteidl_plugins_PrestoQuery_fieldAccessorTable + .ensureFieldAccessorsInitialized( + flyteidl.plugins.Presto.PrestoQuery.class, flyteidl.plugins.Presto.PrestoQuery.Builder.class); + } + + // Construct using flyteidl.plugins.Presto.PrestoQuery.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessageV3 + .alwaysUseFieldBuilders) { + } + } + @java.lang.Override + public Builder clear() { + super.clear(); + routingGroup_ = ""; + + catalog_ = ""; + + schema_ = ""; + + statement_ = ""; + + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return flyteidl.plugins.Presto.internal_static_flyteidl_plugins_PrestoQuery_descriptor; + } + + @java.lang.Override + public flyteidl.plugins.Presto.PrestoQuery getDefaultInstanceForType() { + return flyteidl.plugins.Presto.PrestoQuery.getDefaultInstance(); + } + + @java.lang.Override + public flyteidl.plugins.Presto.PrestoQuery build() { + flyteidl.plugins.Presto.PrestoQuery result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public flyteidl.plugins.Presto.PrestoQuery buildPartial() { + flyteidl.plugins.Presto.PrestoQuery result = new flyteidl.plugins.Presto.PrestoQuery(this); + result.routingGroup_ = routingGroup_; + result.catalog_ = catalog_; + result.schema_ = schema_; + result.statement_ = statement_; + onBuilt(); + return result; + } + + @java.lang.Override + public Builder clone() { + return super.clone(); + } + @java.lang.Override + public Builder setField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.setField(field, value); + } + @java.lang.Override + public Builder clearField( + com.google.protobuf.Descriptors.FieldDescriptor field) { + return super.clearField(field); + } + @java.lang.Override + public Builder clearOneof( + com.google.protobuf.Descriptors.OneofDescriptor oneof) { + return super.clearOneof(oneof); + } + @java.lang.Override + public Builder setRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + int index, java.lang.Object value) { + return super.setRepeatedField(field, index, value); + } + @java.lang.Override + public Builder addRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.addRepeatedField(field, value); + } + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof flyteidl.plugins.Presto.PrestoQuery) { + return mergeFrom((flyteidl.plugins.Presto.PrestoQuery)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(flyteidl.plugins.Presto.PrestoQuery other) { + if (other == flyteidl.plugins.Presto.PrestoQuery.getDefaultInstance()) return this; + if (!other.getRoutingGroup().isEmpty()) { + routingGroup_ = other.routingGroup_; + onChanged(); + } + if (!other.getCatalog().isEmpty()) { + catalog_ = other.catalog_; + onChanged(); + } + if (!other.getSchema().isEmpty()) { + schema_ = other.schema_; + onChanged(); + } + if (!other.getStatement().isEmpty()) { + statement_ = other.statement_; + onChanged(); + } + this.mergeUnknownFields(other.unknownFields); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + flyteidl.plugins.Presto.PrestoQuery parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (flyteidl.plugins.Presto.PrestoQuery) e.getUnfinishedMessage(); + throw e.unwrapIOException(); + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + + private java.lang.Object routingGroup_ = ""; + /** + * string routing_group = 1; + */ + public java.lang.String getRoutingGroup() { + java.lang.Object ref = routingGroup_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + routingGroup_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * string routing_group = 1; + */ + public com.google.protobuf.ByteString + getRoutingGroupBytes() { + java.lang.Object ref = routingGroup_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + routingGroup_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * string routing_group = 1; + */ + public Builder setRoutingGroup( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + routingGroup_ = value; + onChanged(); + return this; + } + /** + * string routing_group = 1; + */ + public Builder clearRoutingGroup() { + + routingGroup_ = getDefaultInstance().getRoutingGroup(); + onChanged(); + return this; + } + /** + * string routing_group = 1; + */ + public Builder setRoutingGroupBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + checkByteStringIsUtf8(value); + + routingGroup_ = value; + onChanged(); + return this; + } + + private java.lang.Object catalog_ = ""; + /** + * string catalog = 2; + */ + public java.lang.String getCatalog() { + java.lang.Object ref = catalog_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + catalog_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * string catalog = 2; + */ + public com.google.protobuf.ByteString + getCatalogBytes() { + java.lang.Object ref = catalog_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + catalog_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * string catalog = 2; + */ + public Builder setCatalog( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + catalog_ = value; + onChanged(); + return this; + } + /** + * string catalog = 2; + */ + public Builder clearCatalog() { + + catalog_ = getDefaultInstance().getCatalog(); + onChanged(); + return this; + } + /** + * string catalog = 2; + */ + public Builder setCatalogBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + checkByteStringIsUtf8(value); + + catalog_ = value; + onChanged(); + return this; + } + + private java.lang.Object schema_ = ""; + /** + * string schema = 3; + */ + public java.lang.String getSchema() { + java.lang.Object ref = schema_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + schema_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * string schema = 3; + */ + public com.google.protobuf.ByteString + getSchemaBytes() { + java.lang.Object ref = schema_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + schema_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * string schema = 3; + */ + public Builder setSchema( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + schema_ = value; + onChanged(); + return this; + } + /** + * string schema = 3; + */ + public Builder clearSchema() { + + schema_ = getDefaultInstance().getSchema(); + onChanged(); + return this; + } + /** + * string schema = 3; + */ + public Builder setSchemaBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + checkByteStringIsUtf8(value); + + schema_ = value; + onChanged(); + return this; + } + + private java.lang.Object statement_ = ""; + /** + * string statement = 4; + */ + public java.lang.String getStatement() { + java.lang.Object ref = statement_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + statement_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * string statement = 4; + */ + public com.google.protobuf.ByteString + getStatementBytes() { + java.lang.Object ref = statement_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + statement_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * string statement = 4; + */ + public Builder setStatement( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + statement_ = value; + onChanged(); + return this; + } + /** + * string statement = 4; + */ + public Builder clearStatement() { + + statement_ = getDefaultInstance().getStatement(); + onChanged(); + return this; + } + /** + * string statement = 4; + */ + public Builder setStatementBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + checkByteStringIsUtf8(value); + + statement_ = value; + onChanged(); + return this; + } + @java.lang.Override + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + + // @@protoc_insertion_point(builder_scope:flyteidl.plugins.PrestoQuery) + } + + // @@protoc_insertion_point(class_scope:flyteidl.plugins.PrestoQuery) + private static final flyteidl.plugins.Presto.PrestoQuery DEFAULT_INSTANCE; + static { + DEFAULT_INSTANCE = new flyteidl.plugins.Presto.PrestoQuery(); + } + + public static flyteidl.plugins.Presto.PrestoQuery getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser + PARSER = new com.google.protobuf.AbstractParser() { + @java.lang.Override + public PrestoQuery parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new PrestoQuery(input, extensionRegistry); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public flyteidl.plugins.Presto.PrestoQuery getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } + + } + + private static final com.google.protobuf.Descriptors.Descriptor + internal_static_flyteidl_plugins_PrestoQuery_descriptor; + private static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_flyteidl_plugins_PrestoQuery_fieldAccessorTable; + + public static com.google.protobuf.Descriptors.FileDescriptor + getDescriptor() { + return descriptor; + } + private static com.google.protobuf.Descriptors.FileDescriptor + descriptor; + static { + java.lang.String[] descriptorData = { + "\n\035flyteidl/plugins/presto.proto\022\020flyteid" + + "l.plugins\032\031flyteidl/core/tasks.proto\"X\n\013" + + "PrestoQuery\022\025\n\rrouting_group\030\001 \001(\t\022\017\n\007ca" + + "talog\030\002 \001(\t\022\016\n\006schema\030\003 \001(\t\022\021\n\tstatement" + + "\030\004 \001(\tB5Z3github.com/lyft/flyteidl/gen/p" + + "b-go/flyteidl/pluginsb\006proto3" + }; + com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = + new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() { + public com.google.protobuf.ExtensionRegistry assignDescriptors( + com.google.protobuf.Descriptors.FileDescriptor root) { + descriptor = root; + return null; + } + }; + com.google.protobuf.Descriptors.FileDescriptor + .internalBuildGeneratedFileFrom(descriptorData, + new com.google.protobuf.Descriptors.FileDescriptor[] { + flyteidl.core.Tasks.getDescriptor(), + }, assigner); + internal_static_flyteidl_plugins_PrestoQuery_descriptor = + getDescriptor().getMessageTypes().get(0); + internal_static_flyteidl_plugins_PrestoQuery_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_flyteidl_plugins_PrestoQuery_descriptor, + new java.lang.String[] { "RoutingGroup", "Catalog", "Schema", "Statement", }); + flyteidl.core.Tasks.getDescriptor(); + } + + // @@protoc_insertion_point(outer_class_scope) +} diff --git a/flyteidl/gen/pb-protodoc/flyteidl/plugins/index.rst b/flyteidl/gen/pb-protodoc/flyteidl/plugins/index.rst index 333cf659b54..c2943c6d26e 100644 --- a/flyteidl/gen/pb-protodoc/flyteidl/plugins/index.rst +++ b/flyteidl/gen/pb-protodoc/flyteidl/plugins/index.rst @@ -11,6 +11,7 @@ Plugins available in the Flyte system. :name: pluginstoc array_job.proto + presto.proto qubole.proto sidecar.proto spark.proto diff --git a/flyteidl/gen/pb-protodoc/flyteidl/plugins/presto.proto.rst b/flyteidl/gen/pb-protodoc/flyteidl/plugins/presto.proto.rst new file mode 100644 index 00000000000..f91c0c32e3d --- /dev/null +++ b/flyteidl/gen/pb-protodoc/flyteidl/plugins/presto.proto.rst @@ -0,0 +1,45 @@ +.. _api_file_flyteidl/plugins/presto.proto: + +presto.proto +============================= + +.. _api_msg_flyteidl.plugins.PrestoQuery: + +flyteidl.plugins.PrestoQuery +---------------------------- + +`[flyteidl.plugins.PrestoQuery proto] `_ + +This message works with the 'presto' task type in the SDK and is the object that will be in the 'custom' field +of a Presto task's TaskTemplate + +.. code-block:: json + + { + "routing_group": "...", + "catalog": "...", + "schema": "...", + "statement": "..." + } + +.. _api_field_flyteidl.plugins.PrestoQuery.routing_group: + +routing_group + (`string `_) + +.. _api_field_flyteidl.plugins.PrestoQuery.catalog: + +catalog + (`string `_) + +.. _api_field_flyteidl.plugins.PrestoQuery.schema: + +schema + (`string `_) + +.. _api_field_flyteidl.plugins.PrestoQuery.statement: + +statement + (`string `_) + + diff --git a/flyteidl/gen/pb_python/flyteidl/plugins/presto_pb2.py b/flyteidl/gen/pb_python/flyteidl/plugins/presto_pb2.py new file mode 100644 index 00000000000..bedbb58d327 --- /dev/null +++ b/flyteidl/gen/pb_python/flyteidl/plugins/presto_pb2.py @@ -0,0 +1,94 @@ +# -*- coding: utf-8 -*- +# Generated by the protocol buffer compiler. DO NOT EDIT! +# source: flyteidl/plugins/presto.proto + +import sys +_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1')) +from google.protobuf import descriptor as _descriptor +from google.protobuf import message as _message +from google.protobuf import reflection as _reflection +from google.protobuf import symbol_database as _symbol_database +# @@protoc_insertion_point(imports) + +_sym_db = _symbol_database.Default() + + +from flyteidl.core import tasks_pb2 as flyteidl_dot_core_dot_tasks__pb2 + + +DESCRIPTOR = _descriptor.FileDescriptor( + name='flyteidl/plugins/presto.proto', + package='flyteidl.plugins', + syntax='proto3', + serialized_options=_b('Z3github.com/lyft/flyteidl/gen/pb-go/flyteidl/plugins'), + serialized_pb=_b('\n\x1d\x66lyteidl/plugins/presto.proto\x12\x10\x66lyteidl.plugins\x1a\x19\x66lyteidl/core/tasks.proto\"X\n\x0bPrestoQuery\x12\x15\n\rrouting_group\x18\x01 \x01(\t\x12\x0f\n\x07\x63\x61talog\x18\x02 \x01(\t\x12\x0e\n\x06schema\x18\x03 \x01(\t\x12\x11\n\tstatement\x18\x04 \x01(\tB5Z3github.com/lyft/flyteidl/gen/pb-go/flyteidl/pluginsb\x06proto3') + , + dependencies=[flyteidl_dot_core_dot_tasks__pb2.DESCRIPTOR,]) + + + + +_PRESTOQUERY = _descriptor.Descriptor( + name='PrestoQuery', + full_name='flyteidl.plugins.PrestoQuery', + filename=None, + file=DESCRIPTOR, + containing_type=None, + fields=[ + _descriptor.FieldDescriptor( + name='routing_group', full_name='flyteidl.plugins.PrestoQuery.routing_group', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=_b("").decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR), + _descriptor.FieldDescriptor( + name='catalog', full_name='flyteidl.plugins.PrestoQuery.catalog', index=1, + number=2, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=_b("").decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR), + _descriptor.FieldDescriptor( + name='schema', full_name='flyteidl.plugins.PrestoQuery.schema', index=2, + number=3, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=_b("").decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR), + _descriptor.FieldDescriptor( + name='statement', full_name='flyteidl.plugins.PrestoQuery.statement', index=3, + number=4, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=_b("").decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=78, + serialized_end=166, +) + +DESCRIPTOR.message_types_by_name['PrestoQuery'] = _PRESTOQUERY +_sym_db.RegisterFileDescriptor(DESCRIPTOR) + +PrestoQuery = _reflection.GeneratedProtocolMessageType('PrestoQuery', (_message.Message,), dict( + DESCRIPTOR = _PRESTOQUERY, + __module__ = 'flyteidl.plugins.presto_pb2' + # @@protoc_insertion_point(class_scope:flyteidl.plugins.PrestoQuery) + )) +_sym_db.RegisterMessage(PrestoQuery) + + +DESCRIPTOR._options = None +# @@protoc_insertion_point(module_scope) diff --git a/flyteidl/gen/pb_python/flyteidl/plugins/presto_pb2_grpc.py b/flyteidl/gen/pb_python/flyteidl/plugins/presto_pb2_grpc.py new file mode 100644 index 00000000000..a89435267cb --- /dev/null +++ b/flyteidl/gen/pb_python/flyteidl/plugins/presto_pb2_grpc.py @@ -0,0 +1,3 @@ +# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! +import grpc + diff --git a/flyteidl/protos/flyteidl/plugins/presto.proto b/flyteidl/protos/flyteidl/plugins/presto.proto new file mode 100644 index 00000000000..211324e1d8a --- /dev/null +++ b/flyteidl/protos/flyteidl/plugins/presto.proto @@ -0,0 +1,16 @@ +syntax = "proto3"; + +package flyteidl.plugins; + +import "flyteidl/core/tasks.proto"; + +option go_package = "github.com/lyft/flyteidl/gen/pb-go/flyteidl/plugins"; + +// This message works with the 'presto' task type in the SDK and is the object that will be in the 'custom' field +// of a Presto task's TaskTemplate +message PrestoQuery { + string routing_group = 1; + string catalog = 2; + string schema = 3; + string statement = 4; +} diff --git a/flyteidl/setup.py b/flyteidl/setup.py index a2db089ed13..364bf679550 100644 --- a/flyteidl/setup.py +++ b/flyteidl/setup.py @@ -1,6 +1,6 @@ from setuptools import setup, find_packages -__version__ = '0.17.8' +__version__ = '0.17.9' setup( name='flyteidl',