diff --git a/cpp/src/parquet/arrow/schema.cc b/cpp/src/parquet/arrow/schema.cc index 266215a8104..37fa56656ae 100644 --- a/cpp/src/parquet/arrow/schema.cc +++ b/cpp/src/parquet/arrow/schema.cc @@ -485,7 +485,7 @@ Status FieldToNode(const std::string& name, const std::shared_ptr& field, ARROW_ASSIGN_OR_RAISE(logical_type, LogicalTypeFromGeoArrowMetadata(ext_type->Serialize())); break; - } else if (ext_type->extension_name() == std::string("parquet.variant")) { + } else if (ext_type->extension_name() == std::string("arrow.parquet.variant")) { auto variant_type = std::static_pointer_cast(field->type()); return VariantToNode(variant_type, name, field->nullable(), field_id, properties, @@ -597,7 +597,7 @@ Status GroupToStruct(const GroupNode& node, LevelInfo current_levels, auto struct_type = ::arrow::struct_(arrow_fields); if (ctx->properties.get_arrow_extensions_enabled() && node.logical_type()->is_variant()) { - auto extension_type = ::arrow::GetExtensionType("parquet.variant"); + auto extension_type = ::arrow::GetExtensionType("arrow.parquet.variant"); if (extension_type) { ARROW_ASSIGN_OR_RAISE( struct_type, @@ -1147,7 +1147,7 @@ Result ApplyOriginalMetadata(const Field& origin_field, SchemaField* infer extension_supports_inferred_storage = arrow_extension_inferred || ::arrow::extension::UuidType::IsSupportedStorageType(inferred_type); - } else if (origin_extension_name == "parquet.variant") { + } else if (origin_extension_name == "arrow.parquet.variant") { extension_supports_inferred_storage = arrow_extension_inferred || VariantExtensionType::IsSupportedStorageType(inferred_type); diff --git a/cpp/src/parquet/arrow/variant_internal.cc b/cpp/src/parquet/arrow/variant_internal.cc index 87f88efaac7..1a450d493f1 100644 --- a/cpp/src/parquet/arrow/variant_internal.cc +++ b/cpp/src/parquet/arrow/variant_internal.cc @@ -66,7 +66,7 @@ std::string VariantExtensionType::Serialize() const { return ""; } std::shared_ptr VariantExtensionType::MakeArray( std::shared_ptr data) const { DCHECK_EQ(data->type->id(), Type::EXTENSION); - DCHECK_EQ("parquet.variant", + DCHECK_EQ("arrow.parquet.variant", ::arrow::internal::checked_cast(*data->type) .extension_name()); return std::make_shared(data); diff --git a/cpp/src/parquet/arrow/variant_internal.h b/cpp/src/parquet/arrow/variant_internal.h index d0b77c72c61..278725d52c1 100644 --- a/cpp/src/parquet/arrow/variant_internal.h +++ b/cpp/src/parquet/arrow/variant_internal.h @@ -50,7 +50,7 @@ class PARQUET_EXPORT VariantExtensionType : public ::arrow::ExtensionType { public: explicit VariantExtensionType(const std::shared_ptr<::arrow::DataType>& storage_type); - std::string extension_name() const override { return "parquet.variant"; } + std::string extension_name() const override { return "arrow.parquet.variant"; } bool ExtensionEquals(const ::arrow::ExtensionType& other) const override;