Как преобразовать входной JSON (чтение из файла) в Avro с помощью Beam? - PullRequest
Новая
       20

Как преобразовать входной JSON (чтение из файла) в Avro с помощью Beam?

0 голосов
/ 02 октября 2018

У меня есть файл json, который мне нужно преобразовать в Avro с помощью apache beam. 

[{
    "id": 1,
    "username": "mrscarter",
    "email_address": null,
    "phone_number": null,
    "first_name": "Beyonce",
    "last_name": "Knowles-Carter",
    "middle_name": null,
    "sex": null,
    "birthdate": "1981-09-04",
    "join_date": "2016-01-01",
    "previous_logins": 10000,
    "last_ip": "testing"
},

{    
    "id": 2,
    "username": "jayz",
    "email_address": null,
    "phone_number": null,
    "first_name": "Shawn",
    "last_name": "Carter",
    "middle_name": "Corey",
    "sex": null,
    "birthdate": "1969-12-04",
    "join_date": "2016-01-01",
    "previous_logins": 20000,
    "last_ip": null
}]

Кто-нибудь знает, как это сделать?Я только начал работать над лучом и не смог найти много примеров в Интернете

...