去年华为大佬就开始在用flink,今天刚有空就稍微跟着写了个demo玩起来（就不用java了 spark和flink还是用scala玩） flink的离线操作 ...

参考Spring3.x企业实战 1.新建web工程chapter5，导入jar包。注意：cglib和commons-dbcp这两个包 2.设计数据库 t_login_log表结构（存放日 ...

1、Main文件 2、applicationContext.xml 运行效果 3、注意点 * 注意点1：依赖注入的是靠 get和set方法的名字来确认 ...

平台：Pycharm Django 使用 Pycharm 进行开发，需要提前在 Pycharm 中（File > Settings > Project: Python > Proj ...

#coding=utf-8import tensorflow as tfimport numpy as np x_data = np.random.rand(3).astype(np.flo ...

之前看了视频学习第一个flink word count使用，但是对于socket发送数据作为数据源我这里有点忘记了，加上最近有个项目要发布，一直在忙，所以迟迟无法完成； 1、首先我们要有数据源，因为不论是流计算处理还是批次处理，都需要数据源，然后经过transformation转换成我们想要 ...

一、从WordCount开始 1.1 Maven依赖 2.11 表示 Flink 是使用 Scala 2.11 编译的； 1.8.1 表示的是 Flink 的版本号；截止撰写本文，Flink 已经有 1.14.0 版本了 Download Flink 1.2 Flink ...

窗口的第一个时间窗口是如何定义的呢？查看源码： 滑动窗口： 这里的offset是用来指定时间戳的时区的，timestamp（1970年1月1号的毫秒数，默认是格林威治0时区的时间），北京时间 ...