参考 原文链接1 原文链接2name：表示你的连接池的名称也就是你要访问连接池的地址auth：是连接池管理权属性，Container表示容器管理type：是对象的类型driverClassName：是数据库驱动的名称url：是数据库的地址username：是登陆数据库的用户名password：是登陆数据库的密码maxIdle，最大空闲数，始终保留在池中的最大连接数，如果启用，将定期检查限制连接，超

废话不多说，直接上代码片段，示例代码（scala版本）：val env = StreamExecutionEnvironment.getExecutionEnvironment// kafka 配置val ZOOKEEPER_HOST = "host:prot"val KAFKA_BROKERS = "host:port"val TRANSAC...

一、从数据流的逻辑上来讲，数据可以分为ODS层（原始日志数据），DW层（数据仓库），BN（统计结果数据）Spark/SparkStreaming任务加载原始日志（离线处理flume落地到hadoop集群的hdfs或实时消费kafka数据）提取业务最原始数据，根据业务逻辑生成ODS层数据（分类/分流后的原始日志）；再根据业务场景进一步将业务ODS层数据划分到DW层（处理后的数据模型）；最后跟...