avro

0ısı

1cevap

Flink [Scala] 'da RollingSink kullanılarak Avro ile seri hale getirilmiş nesnelerin yazılması [Scala]

Flink'te RollingSink kullanılarak HDFS'ye seri hale getirilmiş vaka sınıfları yazmaya çalışıyorum. HDFS tarafından avro dosyaları deserialize edilebilir hale getirmek için FSDataOutputStream'ı saran D

0ısı

1cevap

Aralık dışı index this.buf.utf8Slice

confluent.io kafka paketini kullanarak avro mesajıyla bir kafka akışı var. Bu java uygulamaları için iyi çalışıyor. Ama şimdi bu mesajlarda javascript'te okumaya çalışıyorum. Şema kullanarak, bir arab

0ısı

1cevap

amqp

ile ile seri hale getirme protokolü olarak apache avro'yu kullanın Heterojen uygulamalar AMQP kullanarak birbirleriyle iletişim kurduğunda, apache avro'nun serileştirme kitaplığı olarak kullanılmasını

1ısı

1cevap

Parke'yi Avro'ya Dönüştürme

Avro dosyalarını Parke'ye dönüştürme konusunda birçok örnek görüyorum. Parfe, meta verilerde Avro şemasını tutuyor. Eğer karşıt-dönüştürücü Parke'yi Avro'ya çevirmenin basit bir yolu varsa, şaşkınım.

3ısı

3cevap

Java nesneleri Hbase için

Şu anda java nesnelerini HBase ile işlemek için KITE API + AVRO kullanıyorum. Fakat çeşitli problemlerden dolayı bir alternatif arıyorum. Phoenix Yerli Hbase Api: Ben okuyorduk. Ama daha alternatif va

1ısı

1cevap

Impala/hive storage için gelişen avro şemasını kullanma

Impala/kovanda kullanmamız ve ayırmamız gereken bir JSON yapımız var. JSON yapısı geliştikçe Avro'yu kullanabileceğimizi düşündük. JSON'u ayrıştırmayı ve bunu avro olarak biçimlendirmeyi planladık. Av

0ısı

1cevap

Convert JSON to Avro schema içinde Nodejs

Ben Nodejs içinde Avro schema CSV dönüştürmek istedim. CSV'yi JSON'a dönüştürmeyi başardım ve şimdi JSON'u AVRO şemasına dönüştürmeye çalıştım. Nodejs'de herhangi bir paket var mı? Teşekkürler

1ısı

1cevap

Avro şemasında bayt [] ve LocalDateTime nasıl tanımlanır?

Yeni gelen Avro schema. Ben kafka kullanarak java nesnelerini yayınlamaya/tüketmeye çalışıyorum. LocalDateTime ve byte [] ile alanları içeren java fasülyesi sınıflarım var. Hem avro şema ilkel türleri

7ısı

1cevap

Avro kod çözme, java.io.EOFException

Kafka 0.0.8V ile Apache avro şemasını kullanır. Ben üretici/tüketici uçlarında aynı şemayı kullanın. Şemada NO HERHANGİ Değişiklikler var. Ama ben mesajları tüketmeye çalıştığımda tüketiciye bir istis

5ısı

1cevap

Spark-avro kullanarak kayıttaki alanları atlama

Güncelleme: Bu senaryoyu desteklemek için spark-avro paketi güncellendi. https://github.com/databricks/spark-avro/releases/tag/v3.1.0 Kıvılcımı kullanmam gereken üçüncü tarafım tarafından kontrolümün