package com.sjw.flink import org.apache.flink.api.common.typeinfo.BasicTypeInfoimport org.apache.flink.api.java.io.jdbc.JDBCInputFormatimport org.apac ...
分类:
数据库 时间:
2020-07-10 00:07:12
阅读次数:
121
package com.sjw.flink import org.apache.flink.api.scala._ object WordCount { def main(args: Array[String]): Unit = { //创建批处理执行环境 val env: ExecutionEnv ...
分类:
其他好文 时间:
2020-07-10 00:05:16
阅读次数:
84
package com.sjw.hbase; import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.*;import org.apache.hadoop.hbase.client.*;import org ...
package com.sjw.flink import java.sql.{Connection, DriverManager, PreparedStatement} import org.apache.flink.configuration.Configurationimport org.apa ...
分类:
数据库 时间:
2020-07-10 00:01:11
阅读次数:
81
package com.sjw.flink import org.apache.flink.streaming.api.scala._import org.apache.flink.streaming.api.windowing.time.Time object WindowTest { def m ...
分类:
其他好文 时间:
2020-07-09 23:59:55
阅读次数:
253
package com.sjw.flink.sql import org.apache.flink.api.scala._import org.apache.flink.table.api.{Table, TableEnvironment}import org.apache.flink.types. ...
分类:
数据库 时间:
2020-07-09 23:55:33
阅读次数:
145
1.1 电商的用户行为 电商平台中的用户行为频繁且较复杂,系统上线运行一段时间后,可以收集到大量的用户行为数据,进而利用大数据技术进行深入挖掘和分析,得到感兴趣的商业指标并增强对风险的控制。 电商用户行为数据多样,整体可以分为用户行为习惯数据和业务行为数据两大类。用户的行为习惯数据包括了用户的登录方 ...
分类:
其他好文 时间:
2020-07-09 15:13:49
阅读次数:
80
承接上一篇,NoSQL实验 MapReduce实验 如何在Eclipse中运行MapReduce程序,参考厦大数据库实验室博客 总体代码: package org.apache.hadoop.examples; import java.io.IOException; import java.util ...
分类:
其他好文 时间:
2020-07-09 15:08:03
阅读次数:
127
过去几年间,Serverless 发展迅猛,与其相伴的还有从小程序、移动端等到前后端一体化的演进与实践,也正因如此,从云计算到前端,众多开发者都极为关注。本文介绍了腾讯云CloudBase 的 Serverless 实践,相信会对关注 Serverless 以及研发模式的开发者有所裨益。 Serve ...
分类:
其他好文 时间:
2020-07-09 12:25:21
阅读次数:
82
01官宣7月8日,WeDataSphere开源社区与KubeSphere开源社区联合宣布两大社区正式开启合作。微众银行(WeBank)大数据平台套件WeDataSphere产品团队及WeBank人工智能部运维团队,与KubeSphere产品团队共同进行了多次线上沟通,深入交流了WeDataSphere的总体架构、技术理念以及对外合作模式。双方讨论了KubeSphere在WeBank人工智能部主导开
分类:
Web程序 时间:
2020-07-09 09:13:28
阅读次数:
107