flink框架优势 在分布式计算框架中，需要处理分散在多台机器上的海量数据，对于大数据开发人员面临最大的挑战就是代码的编写、部署、调度、容错等。...

应用场景 需求：需要按小时统计用户在某个网页上的浏览次数，观察一天内网站活跃度分布情况。 编程思路： 利用flink来计算这个问题的话， 可以采...

概念 在flink中定义了三类时间： Event Time 是事件在现实世界中发生的时间，它通常由事件中的时间戳描述。 Ingestion Ti...

程序介绍 flink的基本编程模型就是从一个source数据源读入数据，以stream的方式加工处理，并输出sink到某个地方，我们这里依照官方...

配置flink的环境变量 flink命令位于flink目录中的bin目录下, 经常使用的话可以把目录配置到环境变量中， 这样就可以在任何目录下直...

flink官方提供了一些测试的jar包供用户使用。以examples/streaming/SocketWindowWordCount.jar为例...

环境准备 系统环境 : mac os 为例 (windows/linux同理) Java版本: JAVA 7 及以上都可以（必须）查看Java...