Я использую avro4s https://github.com/sksamuel/avro4s Я написал этот код implicit val schema = AvroSchema[SalesRecord]
val output = AvroOutputStream[SalesRecord](new File(outputLocation))
output.wri
Я новичок в AVRO и, пожалуйста, извините меня, если это простой вопрос. У меня есть вариант использования, когда я использую схему AVRO для записи вызовов. Скажем, у меня есть Avro схемы {
"name"
Я новичок в AVRO. Мы начали использовать схему AVRO для чтения данных. Теперь у нас есть прецедент, где мне нужно обрезать данные во время чтения. Пусть мой Avro schcema, как это {
"name": "table
Я столкнулся с проблемой на карте, уменьшая файл avro, который имеет как значения строки, так и значения массива. `Describe hdfs:/test/test.avro
number STRING
totalProduc