package com.sjw.flink import org.apache.flink.api.scala._import org.apache.flink.core.fs.FileSystem.WriteMode object Score { def main(args: Array[Stri ...
分类：
其他好文 时间：
2020-07-10 00:22:58
阅读次数：
60
package com.baway.loginfaildetect import java.util import org.apache.flink.cep.PatternSelectFunctionimport org.apache.flink.cep.scala.{CEP, PatternStr ...
分类：
其他好文 时间：
2020-07-10 00:15:34
阅读次数：
92
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
安全需求紧迫！区块链如何“乘风破浪”？ 欧洲创新与技术研究所(EIT)商业开发经理米歇尔·阿列西曾经认定，区块链技术可能是互联网面世以来最棒的发明。 2019年10月，区块链技术被提升为国家级的核心技术自主创新突破口，迎来“高光时刻”。此后，区块链这个“最棒的发明”以全新身份认真亮相，一路“披荆斩棘 ...
分类：
其他好文 时间：
2020-07-09 01:19:03
阅读次数：
97
