pysparkのストラクチャードストリーミング

Question

他のサーバーからhbaseにデータをストリーミングし、Pythonで異なる列ファミリを定義できるかどうか。私は、スパークのドキュメントに周りを見回しただけで見てきた：

writestream.format('jdbc').start('jdbc:///') 

私は別の列の家族にデータをマッピングする機能でのHBaseに直接書き込むために同じ実装を持つことができますどのように？

Answer 1

あなたはforeachを使用してのHBaseにデータを書き込むことができます（スカラまたはJava）：http://spark.apache.org/docs/latest/structured-streaming-programming-guide.html#using-foreach