avro

0熱

3答えて

Avro逆シリアル化エラー - ArrayIndexOutOfBoundsException

私のワークフローは - 私はavscファイルを作成し、avrogencppツールを使用してC++クラスを生成し、C++アプリケーションでavroバイナリエンコードデータを作成します。 シナリオ2が機能しない理由を調べようとしています。 シナリオ1 test.avsc { "namespace": "com.company.project", "name": "Component_DeviceI

java c++ deserialization avro 2017-10-06

---

0熱

1答えて

Apache Avro for c＃Microsoft.Avro.Core

私はavroを初めて使用しており、新しいプロジェクトでavroスキーマのシリアル化を実装しようとしています。利用可能な2つの異なるNuGetパッケージがあり、両方の違いが何であるか疑問に思っていました。 Microsoftのバージョン：https://github.com/welly87/Apache-Avro-Core（couldntのHadoopのと紺碧のバージョンを除いて、このための任意のド

c# apache schema avro 2017-10-17

---

0熱

1答えて

スキーマを使用してdataframeをavroに変換するにはどうすればよいですか？

ユーザ指定のスキーマを使用してデータフレームをAvroフォーマットに変換するにはどうすればよいですか？

apache-spark apache-spark-sql avro spark-avro 2017-10-18

---

2熱

1答えて

AVROスキーマのJSONは有効ですが、Kafkaスキーマレジストリから無効を返します

スキーマレジストリにAVROスキーマを登録しようとしています。スキーマにはレコードといくつかのフィールドが含まれています。 JSONをスキーマレジストリREST APIにポストしますが、JSONは正常に見えますが、サーバはcurl : {"error_code":42201,"message":"Input schema is an invalid Avro schema"}を返します。 他にもあ

json apache-kafka schema avro 2017-10-21

---

3熱

2答えて

Google Cloud Dataflow - Apache BeamのPython SDKを使用してスキーマを推論してavroファイルを読み書きする

問題： Python SDKを使用してGoogle Cloud StorageからAvroファイルを読み込むクラウドデータフローパイプラインを作成しようとしています。 Google Cloud StorageにAvroファイルを書き戻します。 Apache BeamのWebサイトで提供されているいくつかの例を調べたところ、次のコードを実行しようとしました。私はReadFromAvroとWriteT

python google-cloud-platform google-cloud-dataflow avro apache-beam 2017-10-24

---

0熱

1答えて

AvroシリアライザとスキーマレジストリでKafkaにメッセージを送信する方法

AvroシリアライザとスキーマレジストリでKafkaにオブジェクトを送信しようとしています。ここ は単純化されたコードです： Properties props = new Properties(); ... props.put(KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSe

apache-kafka avro confluent-kafka confluent-schema-registry 2017-10-31

---

0熱

1答えて

NiFi：入力フローファイルをAvroファイルとして読み取ることはできません。

NiFi 1.4からはじまったばかりです。 パイプ区切りのメッセージをkafka経由でHiveに送信しようとしています。だから私はConsumeKafkaRecord_0_10とPutHivStreamingプロセッサを使用しています。カフカリーダーを消費して、成功したデータをPutHiveStreamingに送信します。 はアブロ形式でカフカリーダー書き込みデータを消費けどPutHiveStre

hive apache-kafka avro apache-nifi 2017-11-03

---

0熱

1答えて

avroスキーマ（.avsc）をテストし、.avroに変換します。 AttributeError、array and encoding

私はただハープを始めています。私はAvro（fastavro）を使っています。 1-私はスキーマを検証し、.avroファイルに変換したいと考えています。 { "type": "record", "name": "Node", "fields": [ { "name": "nom", "type": "string" }, {

hadoop avro 2017-11-07

---

1熱

1答えて

Kafka Streamsがスキーマなしでavroトピックを作成する

私は、スキーマレジストリを使用してavroトピックからデータを読み込んで、単純な変換を行い、結果をコンソールに出力するJavaアプリケーションを開発しました。デフォルトでは、キーと値にはGenericAvroSerdeクラスを使用しました。すべては私がそれなしで final Map<String, String> serdeConfig = Collections.singletonMap("sc

java apache-kafka avro apache-kafka-streams confluent 2017-10-05

---