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
相關文章
相關標籤/搜索