// consumer data from kafka
val tmp_stream = ReceiverLauncher.launch(ssc, props, numberOfReceivers,StorageLevel.MEMORY_ONLY)
tmp_stream.foreachRDD(rdd => {
rdd.collect()
val count = rdd.count() // here I can get the count of datas
// How can I get data here ?
})
你知道如何完成这个代码来获取数据吗 foreachRDD
从创建的流 ReceiverLauncher.launch
1条答案
按热度按时间xfyts7mz1#
你可以打电话给
getPayLoad
去吃生的byte[]
. 像这样的