0

Flume Avro シンクと、シンクを読み取る SparkStreaming プログラムがあります。CDH 5.1、Flume 1.5.0、Spark 1.0、Spark のプログラム言語として Scala を使用

Spark の例を作成し、Flume Avro イベントをカウントすることができました。

ただし、Flume Avro イベントを文字列\テキストにシリアル化し、構造行を解析することはできませんでした。

Scalaを使用してこれを行う方法の例はありますか?

4

3 に答える 3

0

逆シリアル化するために、カスタム デコーダーを実装できます。予想される型情報を一緒に提供します。

于 2014-10-11T03:21:06.497 に答える