多易教育 flink

flink资料

flink-day01

flink-day02

flink-day03

flink-day04

flink-day05

flink-day06

flink-day07

flink-day08

flink-day09

flink-day10

视频-day01

01Flink为什么这么火.mp4 243.14M

02Flink简介.mp4 330.48M

03Flink的standalone环境搭建.mp4 236.37M

04向flink集群提交job.mp4 218.06M

05创建flink的java项目模板.mp4 128.85M

06使用java编写实时WordCount.mp4 286.72M

07上一个程序的优化.mp4 227.42M

08使用javaLambda编写WordCount.mp4 290.97M

09使用scala编写WordCount.mp4 171.32M

10打包上传集群中执行.mp4 102.36M

11Source的并行度问题.mp4 334.48M

12lSource-ocal模式引入webui.mp4 142.15M

13Source-单并行的Source.mp4 187.37M

14Source-多并行的Source.mp4 195.66M

15Source-readFile的使用.mp4 190.13M

16Source-readTextFile的使用.mp4 168.44M

17Source-KafkaSource.mp4 350.16M

视频-day02

18Source-自定义Source01.mp4 171.64M

19Source-自定义Source02.mp4 304.56M

20Sink-printSink底层实现.mp4 254.30M

21Sink-writeAsText的使用.mp4 69.23M

22Sink-writeToSocke的使用.mp4 56.85M

23Sink-kafkaSink的使用.mp4 108.46M

24Sink-redisSink的使用.mp4 163.60M

25Sink-StreamingFileSink的使用.mp4 111.15M

26Sink-JDBCSink的使用.mp4 99.90M

27Transformation-map的基本使用.mp4 139.75M

28Transformation-map底层的实现.mp4 239.51M

29Transformation-flatMap底层实现.mp4 183.33M

30Transformation-filter底层的实现.mp4 119.32M

31Transformation-key的用法1.mp4 178.11M

32Transformation-key的用法2.mp4 133.35M

33Transformation-key的用法3.mp4 105.10M

视频-day03

35Transformation-reduce源码分析.mp4 184.29M

36Transformation-keyBy底层源码分析.mp4 268.65M

37Transformation-fold底层实现.mp4 73.17M

38Transformation-min底层实现.mp4 199.91M

38Transformation-sum底层实现.mp4 188.02M

39Transformation-min和minBy的区别.mp4 153.19M

40Transformation-union的使用.mp4 130.22M

41Transformation-connect的使用.mp4 142.39M

42Transformation-Iterate的使用.mp4 122.04M

43Transformation-project的使用.mp4 114.82M

44Transformation-split和select的使用.mp4 105.95M

45Transformation-rebalance的使用.mp4 208.68M

46Transformation-shuffle的使用.mp4 93.75M

47Transformation-Broadcast的使用.mp4 50.98M

48Transformation-rescaling的使用.mp4 36.59M

49Transformation-partitionCustom的使用.mp4 90.32M

视频-day04

50Flink的窗口和时间.mp4 123.45M

51Flink的窗口类型.mp4 145.00M

52CountWindow的使用.mp4 174.88M

53WindowFunction增量聚合.mp4 134.27M

54Window数据全量聚合.mp4 143.42M

55Window数据全量排序.mp4 47.40M

56Keyed的CountWindow.mp4 88.28M

57Keyed的CountWindow聚合.mp4 56.93M

58NoKeyedProcessingTime滚动窗口.mp4 158.27M

59KeyedProcessTime滚动窗口.mp4 147.31M

60NoKeyedProcessingTime滑动窗口.mp4 173.07M

61KeyedProcessingTime滑动窗口.mp4 118.41M

62NoKeyedProcessingTime会话窗口.mp4 47.42M

63KeyedProcessingTime会话窗口.mp4 71.03M

64NoKeyedEventTime滚动窗口.mp4 273.00M

65KeyedEventTime滚动窗口..mp4 265.50M

66多分区生成watermark窗口触发条件.mp4 171.44M

67EventTime会话窗口.mp4 66.26M

68WaterMark使用和详解.mp4 143.09M

视频-day05

69案例-关联mysql查询维度数据.mp4 336.84M

70案例-使用httpclient查询高德地图.mp4 209.11M

71窗口join的使用.mp4 311.68M

72窗口leftOuterJoin的使用.mp4 189.46M

73intervalJoin的使用.mp4 202.18M

74flink的task划分.mp4 174.97M

75flink共享资源槽.mp4 116.99M

76task算子链.mp4 159.82M

77startNewChain的使用.mp4 83.54M

78disableChaining的使用.mp4 40.74M

79设置资源槽组名称.mp4 215.88M

视频-day06

80为什么需要state.mp4 106.45M

81flink容错相关概念.mp4 103.07M

82固定次数重启策略.mp4 179.13M

83错误率重启策略.mp4 235.38M

84使用hashMap模拟KeyedState.mp4 160.15M

85自己实现一个简单的KeyedState.mp4 256.76M

86ValueState的基本使用.mp4 205.24M

87ValueState底层源码分析.mp4 245.52M

88MapState的使用和原理.mp4 213.50M

89ListState的使用和原理.mp4 148.00M

90使用ValueState实现ListState.mp4 100.82M

91Operator和KeyedState的区别.mp4 162.33M

92OperatorSate案例需求.mp4 40.65M

93使用OperatorState实现AtLeastOnceSource.mp4 463.11M

视频-day09

134flinkKafkaProduce实现ExactlyOnce.mp4 216.03M

135checkpoint完整过程.mp4 157.13M

136实现ExactlyOnce代码.mp4 545.20M

137数据采集架构.mp4 163.23M

138openresty安装.mp4 88.35M

139openresty整合lua.mp4 263.03M

140flume整合kafka.mp4 221.48M

141nginx的kafka-module.mp4 310.14M

视频-day10

142FlinkUtils工具类编写.mp4 114.39M

143工具类完善.mp4 174.84M

144数据预处理需求.mp4 122.02M

145数据预处理测试.mp4 616.01M

146布隆过滤器结合TTL.mp4 80.42M

147布隆过滤器结合TTL实现.mp4 425.62M

148热门商品topN需求.mp4 70.27M

149热门商品topN实现.mp4 360.47M

视频day07

100侧流输出获取窗口迟到的数据.mp4 184.88M

101WindowFunction的使用.mp4 214.76M

102aggregate结合windowFunction.mp4 206.98M

103ProcessWindowFunction的使用.mp4 150.43M

94ProcessFunction的使用.mp4 228.78M

95KeyedProcessFunction的使用.mp4 56.41M

96注册定时器OnTimer.mp4 245.28M

97注册订单群并集合ValueState聚合.mp4 143.66M

98OnTimer触发的时机.mp4 112.62M

99侧流输出.mp4 216.18M

视频day08

104State的TTL存活时间.mp4 247.79M

105案例-统计去重人数.mp4 331.04M

106BroadcastState的使用.mp4 550.32M

107QueryableState的使用.mp4 187.22M

108异步IO的使用.mp4 341.44M

109数据一致性的实现.mp4 254.45M

110向hdfs写checkpoint的出错问题.mp4 197.54M

111向hdfs写checkpoint的出依赖.mp4 275.81M

112flink的job重启从checkpoint恢复.mp4 141.29M

113checkpoint和savepoint的区别.mp4 117.47M