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/
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://*.com/questions/44382329/can-we-combine-both-and-count-and-process-time-trigger-in-flink
how-do-i-debug-apache-flink
https://*.com/questions/37659176/how-do-i-debug-apache-flink
https://*.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://*.com/questions/36305123/why-is-only-one-instance-of-globalwindow-used
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
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
/**
* 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) {
windowing/assigners
KeyGroupStreamPartitioner
KeyedStream.Java
KeyedStream.scala
countWindow,timeWindow,window,reduce,fold,max,min,sum,minby,
WindowedStream.scala
WindowedStream.Java
basic transformations
keyBy
def keyBy ,map,flatMap,filter,timeWindowAll,split,print
kafaka consumer
KafkaConsumerThread
StringGeneratingSourceFunction
package org.apache.flink.streaming.connectors.kafka.internal;
https://*.com/questions/44382329/can-we-combine-both-and-count-and-process-time-trigger-in-flink