From 1d61d7b56445ceeeeb8a9ec67532aff0c45745a5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Mon, 18 Dec 2023 20:31:48 +0000 Subject: [PATCH] Revert hstore/json/struct being map --- flow/model/qvalue/avro_converter.go | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/flow/model/qvalue/avro_converter.go b/flow/model/qvalue/avro_converter.go index f9a5849e19..1bffa9d130 100644 --- a/flow/model/qvalue/avro_converter.go +++ b/flow/model/qvalue/avro_converter.go @@ -16,11 +16,6 @@ type AvroSchemaArray struct { Items string `json:"items"` } -type AvroSchemaMap struct { - Type string `json:"type"` - Values string `json:"values"` -} - type AvroSchemaNumeric struct { Type string `json:"type"` LogicalType string `json:"logicalType"` @@ -61,10 +56,7 @@ func GetAvroSchemaFromQValueKind(kind QValueKind) (interface{}, error) { case QValueKindTime, QValueKindTimeTZ, QValueKindDate, QValueKindTimestamp, QValueKindTimestampTZ: return "string", nil case QValueKindHStore, QValueKindJSON, QValueKindStruct: - return AvroSchemaMap{ - Type: "map", - Values: "string", - }, nil + return "string", nil case QValueKindArrayFloat32: return AvroSchemaArray{ Type: "array",