Создание массива схемы массивов в файлах avdl для записи в kafka - PullRequest
Новая
       80

Создание массива схемы массивов в файлах avdl для записи в kafka

0 голосов
/ 10 июля 2020

Я пытаюсь опубликовать sh данные в kafka topi c с помощью AvroSerializer. Один из моих столбцов имеет массив массивов строк.

Пример данных выглядит так: 

{
"exp_user_id":"1004977",
"site_name":"EXPEDIA.MX",
"score": "0.645651633153341",
"decile": "25",
"next_best_action": [["6.719064841905476E-5","app_purchase"],["5.866961664787799E-5","app_purchase"],["1.016999934388668E-4","download_app"]],
"create_date": "2020-06-08"
}

Я пытаюсь создать файл avdl для указанного выше набора данных, но ударил при создании массива массивов строк. 

{
    "type" : "record",
    "name" : "ek_el_nba_test",
    "namespace" : "com.extensions",
    "fields" : [{"name" : "user_id", 
                 "type" : "string", 
                 "default" : "NONE"},

                {"name" : "site_name", 
                  "type" : "string", 
                  "default" : "NONE"},

                 {"name" : "score", 
                  "type" : "string", 
                  "default" : "NONE"},

                 {"name" : "decile", 
                  "type" : "string", 
                  "default" : "NONE"},

                  {"name" : "next_best_action", 
                   {"type" : "array", "items" : "array"},
                   "default": []
                   },

                    {"name" : "create_date", 
                  "type" : "string", 
                  "default" : "NONE"},
                          "default" : {}
                }
]
}

Спасибо за вашу помощь.!

...