pyspark의 구조화 된 스트리밍

Question

다른 서버에서 hbase로 데이터를 스트리밍하고 파이썬에서 다른 열 패밀리를 정의 할 수 있습니까? 나는 스파크 문서에 주위를 둘러 보았다 만 볼 수 있습니다 :

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

가 어떻게 같은 구현은 다른 열 가족에 데이터를 매핑 할 수있는 기능 HBase를 직접 작성해야합니까?

Answer 1

foreach (스칼라 또는 자바)을 사용하여 데이터를 쓸 수 있습니다 : http://spark.apache.org/docs/latest/structured-streaming-programming-guide.html#using-foreach