Spark新手求教 SparkStreaming能否连接MySQL进行查询操作

2025-04-24 12:33:17
推荐回答(1个)
回答1:

支持mysql的,下面是示例
spark streaming使用数据源方式插入mysql数据
import java.sql.{Connection, ResultSet}
import com.jolbox.bonecp.{BoneCP, BoneCPConfig}
import org.slf4j.LoggerFactory

object ConnectionPool {

val logger = LoggerFactory.getLogger(this.getClass)
private val connectionPool = {
try{