SparkStreaming整合kafka直连模式direct方式

org.apache.spark spark-streaming_2.10 1.6.2 org.apache.spark spark-streaming-kafka_2.10 1.6.2 val checkpoint =“hdfs://bdha/checkpoint” val conf = new SparkConf().setMaster(“local”).setAppName(“AdRealS
相关文章
相关标签/搜索