code-craft - SegmentFault 思否

聊聊flink的TimerService

codecraft

2019-01-17

阅读 15 分钟

3.4k

flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/TimerService.java

聊聊flink的ProcessFunction

codecraft

2019-01-16

阅读 4 分钟

本实例展示了如何在ProcessFunction里头使用keyed state以及timer；process方法使用的ProcessFunction是CountWithTimeoutFunction

聊聊flink DataStream的iterate操作

codecraft

2019-01-15

阅读 9 分钟

4.5k

本实例展示了IterativeStream的一些基本用法，使用iterate创建IterativeStream，使用IterativeStream的closeWith方法来关闭feedbackStream

聊聊flink DataStream的split操作

codecraft

2019-01-14

阅读 7 分钟

6.4k

flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/datastream/DataStream.java

聊聊flink DataStream的connect操作

codecraft

2019-01-13

阅读 10 分钟

5.3k

flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/datastream/DataStream.java

聊聊flink DataStream的window coGroup操作

codecraft

2019-01-12

阅读 16 分钟

2.6k

flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/datastream/DataStream.java

聊聊flink KeyedStream的intervalJoin操作

codecraft

2019-01-11

阅读 16 分钟

4.5k

flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/datastream/KeyedStream.java

这里首先调用join，与另外一个stream合并，返回的是JoinedStreams，之后就可以调用JoinedStreams的where操作来构建Where对象构造条件；Where有equalTo操作可以构造EqualTo，而EqualTo有window操作可以构造WithWindow，而WithWindow可以设置windowAssigner、trigger、evictor、allowedLateness，它提供apply操作

聊聊flink的consecutive windowed operations

codecraft

2019-01-09

阅读 12 分钟

1.9k

本实例首先根据key进行partition，然后再按指定的window对这些key进行计数，之后对该dataStream进行windowAll操作，其时间WindowAssigner与前面的相同，这样可以达到在同样的时间窗口内先partition汇总，再全局汇总的效果(可以解决类似top-k elements的问题)

聊聊flink的Allowed Lateness

codecraft

2019-01-08

阅读 14 分钟

3.7k

flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/datastream/WindowedStream.java

聊聊flink的Evictors

codecraft

2019-01-07

阅读 8 分钟

3.2k

flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/windowing/evictors/Evictor.java

聊聊flink的Triggers

codecraft

2019-01-06

阅读 14 分钟

3.9k

flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/windowing/triggers/Trigger.java

聊聊flink的Global Window

codecraft

2019-01-05

阅读 5 分钟

4.2k

flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/windowing/windows/GlobalWindow.java

聊聊flink的Session Window

codecraft

2019-01-04

阅读 13 分钟

3.2k

flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/windowing/assigners/MergingWindowAssigner.java

聊聊flink的Sliding Window

codecraft

2019-01-03

阅读 7 分钟

3.2k

flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java

聊聊flink的Tumbling Window

codecraft

2019-01-02

阅读 12 分钟

2.7k

flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/windowing/assigners/WindowAssigner.java

聊聊flink的window操作

codecraft

2019-01-01

阅读 7 分钟

5.9k

flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/datastream/DataStream.java

2018年终总结

codecraft

2018-12-31

阅读 10 分钟

6.2k

整体而言，今年技术层面稍微有点拓宽，跨入了外表看上去高大上的流式计算领域，打开了另外一扇窗；而基于java的分布式/微服务领域，今年变化比较大，spring cloud netflix的部分组件宣布将要进入维护阶段，而国内spring cloud alibaba组件逐渐活跃起来，目前看来处于PublicEvolving阶段；而java自身也处在不断进化中，今...