아파치 스파크 내가 작업 스트리밍 데이터</p> <pre><code>val contents = tweets.map(status => status.getText()) val tSender = tweets.map(status => status.getUser().getScreenName()) tSender.print() contents.print() </code></pre> <p>이 코드를 병합 할 텍스트

Question

스트리밍 병합하지만 난 tSender + 내용 형식이 필요합니다. 시도했습니다.

println(tSender + contents) 

하지만 작동하지 않습니다. 누군가 나를 도울 수있는 sth에 대해 알고 있다면?

Answer 1

그냥 모든 필드를 추출 당신은 함께 원하는 :

tweets.map(status => 
    s"${ status.getUser().getScreenName()} ${status.getText()}" 
).print