pyspark中的結構化流式傳輸

Question

我試圖將數據從另一臺服務器流式傳輸到hbase並能夠在python中定義不同的列系列。我在火花文檔環顧四周，只看到：

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

我怎麼能有相同的實現與地圖數據不同的列族的能力直接寫入到HBase的？

Answer 1

您可以使用foreach（Scala或Java）將數據寫入HBase：http://spark.apache.org/docs/latest/structured-streaming-programming-guide.html#using-foreach