spark streaming 接收kafka數據寫入Hive分區表

直接上代碼web object KafkaToHive{ def main(args: Array[String]){ val sparkConf = new SparkConf().setAppName("KafkaToHive") val sc = new SparkContext(sparkConf) val ssc = new StringContext(sc,Seconds
相關文章
相關標籤/搜索