http://vinoyang.com/

http://wuchong.me

Apache Flink源码解析之stream-source

https://yq.aliyun.com/articles/259154

Flink - watermark

https://yq.aliyun.com/articles/73191

http://wuchong.me/blog/2016/05/04/flink-internal-how-to-build-streamgraph/

http://vinoyang.com/

https://ci.apache.org/projects/flink/flink-docs-release-1.3/internals/task_lifecycle.html

https://www.slideshare.net/dataArtisans/flink-training-system-overv

https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals

http://www.cnblogs.com/fxjwind/p/5955990.html

http://www.cnblogs.com/fxjwind/category/778309.html

http://vinoyang.com/2016/04/14/akka-in-flink/

https://cwiki.apache.org/confluence/display/FLINK/Akka+and+Actors

Key GROUPS

https://issues.apache.org/jira/browse/FLINK-3755

https://dataartisans.github.io/flink-training/slides/flink_stream_statefulOps.pdf

http://blogoloquy.blogspot.hk/2016/02/getting-close-to-apache-flink-albeit-in.html

https://arxiv.org/pdf/1506.08603.pdf

http://flink.apache.org/news/2017/06/01/release-1.3.0.html

https://issues.apache.org/jira/browse/FLINK-5929

https://www.user.tu-berlin.de/asteriosk/assets/publications/flink-deb.pdf

https://cds.cern.ch/record/2208322/files/report.pdf

A {@link Trigger} that fires once the number of elements in a pane reaches the given count or the timeout expires, whichever happens first.

https://gist.github.com/shikhar/2cb9f1b792be31b7c16e

https://stackoverflow.com/questions/36305123/why-is-only-one-instance-of-globalwindow-used/36305578?noredirect=1#comment75752054_36305578

培训材料

https://stackoverflow.com/questions/44382329/can-we-combine-both-and-count-and-process-time-trigger-in-flink

https://github.com/apache/flink/blob/2bfead7d9bef51713ed203fa7979f71f23525733/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/triggers/StateCleaningCountTrigger.scala

how-do-i-debug-apache-flink

https://stackoverflow.com/questions/37659176/how-do-i-debug-apache-flink

https://stackoverflow.com/questions/21114066/attach-intellij-idea-debugger-to-a-running-java-process

build source code

https://github.com/apache/flink/blob/master/docs/internals/ide_setup.md#intellij-idea

https://github.com/apache/flink

windowing

https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/event_time.html

https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/event_timestamps_watermarks.html

https://stackoverflow.com/questions/36305123/why-is-only-one-instance-of-globalwindow-used/36305578?noredirect=1#comment75752054_36305578

https://stackoverflow.com/questions/36305123/why-is-only-one-instance-of-globalwindow-used

https://github.com/apache/flink/tree/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing

https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/windows.html

https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/stream/process_function.html

https://stackoverflow.com/questions/42200261/is-there-a-way-to-define-a-flink-count-window-which-evicts-all-messages-after-a

process_function

https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/stream/state.html

https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/stream/process_function.html

https://github.com/apache/flink/blob/12b4185c6c09101b64e12a84c33dc4d28f95cff9/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java

/**
* Windows this {@code KeyedStream} into tumbling count windows.
*
* @param size The size of the windows in number of elements.
*/
public WindowedStream<T, KEY, GlobalWindow> countWindow(long size) {

https://github.com/apache/flink/blob/12b4185c6c09101b64e12a84c33dc4d28f95cff9/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java

windowing/assigners

https://github.com/apache/flink/tree/12b4185c6c09101b64e12a84c33dc4d28f95cff9/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners

KeyGroupStreamPartitioner

https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/KeyGroupStreamPartitioner.java

KeyedStream.Java

https://github.com/apache/flink/blob/12b4185c6c09101b64e12a84c33dc4d28f95cff9/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java

KeyedStream.scala

countWindow,timeWindow,window,reduce,fold,max,min,sum,minby,

https://github.com/apache/flink/blob/54ceec16c11655da4181c0816a3b12d1c4bab465/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala

https://github.com/apache/flink/blob/61914abffa83a55d4f0a339dbcf64c540962a9cd/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamGroupWindowAggregate.scala

WindowedStream.scala

https://github.com/apache/flink/blob/67c4be648b1f51ceadae3a9e3dd41807802a89ef/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala

WindowedStream.Java

https://github.com/apache/flink/blob/545f50026c863c80978a2d0b9446ad6bf87a3596/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java

basic transformations

https://github.com/apache/flink/blob/545f50026c863c80978a2d0b9446ad6bf87a3596/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java

keyBy

DataStream

https://github.com/apache/flink/blob/545f50026c863c80978a2d0b9446ad6bf87a3596/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java

def keyBy ,map,flatMap,filter,timeWindowAll,split,print

https://github.com/apache/flink/blob/67c4be648b1f51ceadae3a9e3dd41807802a89ef/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala

kafaka consumer

KafkaConsumerThread

StringGeneratingSourceFunction
package org.apache.flink.streaming.connectors.kafka.internal;

https://stackoverflow.com/questions/42200261/is-there-a-way-to-define-a-flink-count-window-which-evicts-all-messages-after-a

https://stackoverflow.com/questions/44382329/can-we-combine-both-and-count-and-process-time-trigger-in-flink

Flink源码分析的更多相关文章

  1. Flink源码分析 - 源码构建

    原文地址:https://mp.weixin.qq.com/s?__biz=MzU2Njg5Nzk0NQ==&mid=2247483692&idx=1&sn=18cddc1ee ...

  2. flink checkpoint 源码分析 (二)

    转发请注明原创地址http://www.cnblogs.com/dongxiao-yang/p/8260370.html flink checkpoint 源码分析 (一)一文主要讲述了在JobMan ...

  3. 从flink-example分析flink组件(3)WordCount 流式实战及源码分析

    前面介绍了批量处理的WorkCount是如何执行的 <从flink-example分析flink组件(1)WordCount batch实战及源码分析> <从flink-exampl ...

  4. 《Flink 源码解析》—— 源码编译运行

    更新一篇知识星球里面的源码分析文章,去年写的,周末自己录了个视频,大家看下效果好吗?如果好的话,后面补录发在知识星球里面的其他源码解析文章. 前言 之前自己本地 clone 了 Flink 的源码,编 ...

  5. Flink源码阅读(1.7.2)

    目录 Client提交任务 flink的图结构 StreamGraph OptimizedPlan JobGraph ExecutionGraph flink部署与执行模型 Single Job Jo ...

  6. ABP源码分析一:整体项目结构及目录

    ABP是一套非常优秀的web应用程序架构,适合用来搭建集中式架构的web应用程序. 整个Abp的Infrastructure是以Abp这个package为核心模块(core)+15个模块(module ...

  7. HashMap与TreeMap源码分析

    1. 引言     在红黑树--算法导论(15)中学习了红黑树的原理.本来打算自己来试着实现一下,然而在看了JDK(1.8.0)TreeMap的源码后恍然发现原来它就是利用红黑树实现的(很惭愧学了Ja ...

  8. nginx源码分析之网络初始化

    nginx作为一个高性能的HTTP服务器,网络的处理是其核心,了解网络的初始化有助于加深对nginx网络处理的了解,本文主要通过nginx的源代码来分析其网络初始化. 从配置文件中读取初始化信息 与网 ...

  9. zookeeper源码分析之五服务端(集群leader)处理请求流程

    leader的实现类为LeaderZooKeeperServer,它间接继承自标准ZookeeperServer.它规定了请求到达leader时需要经历的路径: PrepRequestProcesso ...

随机推荐

  1. 转载——C++控制台贪吃蛇代码

    游戏截图: 以下是3个代码文件: Snake_Class.h文件: 1 #ifndef SNAKE 2 #define SNAKE 3 4 #include<windows.h> 5 #i ...

  2. ASIHTTPRequest下载示例(支持断点续传)

    一.创建网络请求队列 首先,创建网络请求队列,如下: ASINetworkQueue   *que = [[ASINetworkQueue alloc] init]; self.netWorkQueu ...

  3. Collection总结一览

    Java中集合大家族的成员实在是太丰富了,有常用的ArrayList.HashMap.HashSet,也有不常用的Stack.Queue,有线程安全的Vector.HashTable,也有线程不安全的 ...

  4. 向数据库中导入AWR数据

    使用$ORACLE_HOME/rdbms/admin/awrload.sql $ sqlplus '/as sysdba' SQL*Plus: Release Production on Fri No ...

  5. AWK处理日志入门(转)

    前言 这两天自己挽起袖子处理日志,终于把AWK给入门了.其实AWK的基本使用,学起来也就半天的时间,之前总是靠同事代劳,惰性呀. 此文仅为菜鸟入门,运维们请勿围观. 下面是被处理的日志的示例,不那么标 ...

  6. 原生javascript操作class-元素查找-元素是否存在-添加class-移除class

    //判断元素是否有classfunction hasClass(ele, cls) { return ele.className.match(new RegExp('(\\s|^)'+cls+'(\\ ...

  7. Windows Server 2008防火墙问题及Sql Server2005用户登录问题

    一.Windows Server 2008防火墙问题 1.  问题: 1.在 Windows 安全中心中单击“立即打开”以打开 Windows 防火墙时,会收到以下错误消息:安全中心无法打开 Wind ...

  8. c++程序内存泄露检測工具

    功能: 用于检測c++程序的内存泄露. 原理: 事实上非常easy,就是通过函数的重载机制,捕获应用程序的new, new[] , delete , delete[], malloc,calloc,f ...

  9. 10 个迅速提升你 Git 水平的提示(转)

    最近我们推出了两个教程:熟悉Git的基本功能和 让你在开发团队中熟练的使用Git . 我们所讨论的命令足够一个开发者在Git使用方面游刃有余.在这篇文章中,我们试图探索怎样有效的管理你的时间和充分的使 ...

  10. 轻松理解python中的闭包和装饰器(上)

    继面向对象编程之后函数式编程逐渐火起来了,在python中也同样支持函数式编程,我们平时使用的map, reduce, filter等都是函数式编程的例子.在函数式编程中,函数也作为一个变量存在,对应 ...