package com.sjw.flink import org.apache.flink.api.java.utils.ParameterToolimport org.apache.flink.streaming.api.scala._ object StremingWordCount { def ...
分类：
其他好文 时间：
2020-07-10 00:11:32
阅读次数：
56
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.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
Table API是流处理和批处理通用的关系型API，Table API可以基于流输入或者批输入来运行而不需要进行任何修改。Table API是SQL语言的超集并专门为Apache Flink设计的，Table API是Scala 和Java语言集成式的API。与常规SQL语言中将查询指定为字符串不 ...
分类：
数据库 时间：
2020-07-09 15:03:48
阅读次数：
83
首先要实现的是实时热门商品统计，我们将会基于UserBehavior数据集来进行分析。 项目主体用Scala编写，采用IDEA作为开发环境进行项目编写，采用maven作为项目构建和管理工具。首先我们需要搭建项目框架。 2.1 创建Maven项目 2.1.1 项目框架搭建 打开IDEA，创建一个mav ...
分类：
其他好文 时间：
2020-07-09 14:59:23
阅读次数：
87
现在计划开发一套线抽奖程序，这套程序是一种通用的抽奖程序，基于H5技术开发，要能覆盖大部分线上、线下的抽奖场景。程序目的通过此程序，可以让用户通过注册开通的方式，构建符合自己要求和适用场景的抽奖活动页面。最终达到的要求是此程序要能适用于市场上80%的抽奖场景。特别要注意的是，抽奖和开奖的概念。抽奖是指用户自己主动参与抽取奖品，系统实时的根据概率反馈给用户对应的奖品。开奖则是将用户名单或编号放入抽奖
分类：
Web程序 时间：
2020-07-09 13:46:40
阅读次数：
110
301. 删除无效的括号 描述： 思路：遍历。通过BFS遍历，因为BFS可以立马判断当前是否为最短修改的有效符号，之后不用再进行下一层。 303. 区域和检索 - 数组不可变 描述： 给定 nums = [-2, 0, 3, -5, 2, -1]，求和函数为 sumRange() sumRange( ...
分类：
其他好文 时间：
2020-07-09 12:05:04
阅读次数：
118
顾名思义，这是$min25dalao$发明的算法，可以用来处理一些积性函数求和的问题。 用途 我们现在有一个积性函数$F(x)$，要我们快速计算前缀和，即求 \(\sum_{i=1}^{n} F(i)\) 前置知识 数论函数基本性质,比较基础就不说了... 使用前提 $1.\forall p \in ...
分类：
其他好文 时间：
2020-07-09 00:48:22
阅读次数：
136
