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. linux下系统编程C环境搭建

    一.系统安装 我使用的是VMware8下的ubuntu12.04,这是培训老师说的,12.04相对来说,比较新,而且是5年长期支持版,不容易过时.对于系统的安装,我不想说很多,只是希望大家主义这几点: ...

  2. 从零开始学习jQuery (一) 入门篇

    本系列文章导航 从零开始学习jQuery (一) 入门篇 一.摘要 本系列文章将带您进入jQuery的精彩世界, 其中有很多作者具体的使用经验和解决方案,  即使你会使用jQuery也能在阅读中发现些 ...

  3. Oracle10g在Win2008R2下因版本无法安装问题的解决

    次文章为转载的: 首先需要从官网下载Windows_vista版本的oracle10g,下载地址为:http://download.oracle.com/otn/nt/oracle10g/10203/ ...

  4. 使用MyBatis Generator生成DAO

    虽然MyBatis很方便,但是想要手写全部的mapper还是很累人的,好在MyBatis官方推出了自动化工具,可以根据数据库和定义好的配置直接生成DAO层及以下的全部代码,非常方便. 需要注意的是,虽 ...

  5. js 中escape,encodeURI,encodeURIComponent的区别

    escape:方法不能能够用来对统一资源(URI)进行编码,对其编码应使用encodeURI和encodeURIComponent encodeURI:encodeURI ()方法返回一个编码的 UR ...

  6. [JS10] 获取时间

    <html> <head> <meta http-equiv="Content-Type" content="text/html; char ...

  7. 延长Toast显示时间

    ---恢复内容开始--- 由于Toast的显示时间只有两种: Toast.LENGTH_SHORT: 2秒 Toast.LENGTH_LONG: 3.5秒 而且是写死的,没给开发者自定义时间的权利,所 ...

  8. 小甲鱼第51讲:《__name__=&quot;__main__&quot;、搜索路径和包》课后练习题

    测试题: 0. __name__属性指的是在调用该模块的时候调用的函数名称,方便在模块的被调用的时候,模块内部被调用的函数不会被运行. 1. 当模块作为主程序运行的时候,__name__属性的值是“_ ...

  9. robotframework笔记1

    机器人框架是一个基于Python的,可扩展的关键字驱动的自动化测试最终到终端的验收测试和验收测试驱动开发(ATDD)框架.它可用于检测分布式异类应用程序,其中,验证要求感人几种技术和接口. 下面列出了 ...

  10. PowerShell_零基础自学课程_3_如何利用Powershell ISE调试PS脚本

    微软在推出PS的同时,没有忘记其一贯的作风,什么东东都弄一个IDE环境,这不微软没有忘记给PS也来一个IDE的环境, 通过这个IDE环境,可以建立psl文件,可以调试psl文件. 1.IDE界面 我们 ...