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
相关文章
相关标签/搜索