使用foreachRDD把数据上传到Mysql数据库

简介 dstream.foreachRDD是一个强大的原语,可以将数据发送到外部系统。 DStream由输出操作延迟执行,就像RDD由RDD操作延迟执行一样。具体来说,DStream输出操作内部的RDD动作会强制处理接收到的数据。因此,如果您的应用程序没有任何输出操作,或者dstream.foreachRDD()内部没有任何RDD操作,就不会执行任何输出操作。系统将仅接收数据并将其丢弃。 在默认情况下,输出操作一次执行一次。它们按照在应用程序中定义的顺序执行。 案例:把数据直接上传到mysql数据库指定的表 代码: 在启动spark-shell时加入mysql驱动的jar包 [root@c