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.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
Oracle11g 优点 性能优越, 大型数据库中的典范 大型数据库:sybase、Oracle、db2 中型数据库:mysql、SqlServer、infomix 小型数据库:Access、Visual Foxpro 是对象关系型的数据库管理系统 (ORDBMS) 应用广泛,在管理信息系统、企业数 ...
分类:
数据库 时间:
2020-07-10 00:00:08
阅读次数:
105
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