StructuredStreaming结构化流马士兵教育官网

章节1:Structured Streaming 概述 (4节)

课时01

01-Structured Streaming 结构化流课程内容

3分55秒

课时02

02-SparkStreaming 处理流式数据弊端

11分46秒

课时03

03-Structured Streaming 概念及特点

17分51秒

课时04

04-Structured Streaming 编程模型

19分24秒

章节2:Structured Streaming 应用 (6节)

课时05

05-Structured Streaming 读取Socket数据并写出

14分16秒

课时06

06-Structured Streaming WordCount案例及输出模式测试

16分33秒

课时07

07-Structured Streaming Java版本WordCount及注意点

10分34秒

课时08

08-Structured Streaming Stream Table API

19分18秒

课时09

09-Structured Streaming Triggers

13分16秒

课时10

10-Structured Streaming Continuous连续处理

11分58秒

章节3:Structured Streaming Source与Sink (11节)

课时11

11-Sturctured Streaming InputSource之监控Text文件

16分19秒

课时12

12-Sturctured Streaming InputSource之监控CSV文件

8分55秒

课时13

13-Structured Streaming InputSource之监控Json文件

5分26秒

课时14

14-Structured Streaming Rate Source

8分57秒

课时15

15-Structured Streaming Checkpoint设置及目录介绍

7分14秒

课时16

16-Structured Streaming outputSink之File Sink

6分3秒

课时17

17-Structured Streaming outputSink之Memory Sink

4分40秒

课时18

18-Structured Streaming outputSink之foreachBatch Scala代码

11分27秒

课时19

19-Structured Streaming outputSink之foreachBatch Java代码

7分34秒

课时20

20-Structured Streaming outputSink之foreach Scala代码

8分6秒

课时21

21-Structured Streaming outputSink之foreach Java代码

5分36秒

章节4:Structured Streaming API与窗口操作 (16节)

课时22

22-Structured Streaming 结构化流 DataFrame API scala代码操作

13分49秒

课时23

23-Structured Streaming 结构化流 DataFrame API Java代码操作

4分39秒

课时24

24-Structured Streaming 结构化流 Dataset API scala操作

6分32秒

课时25

25-Structured Streaming 结构化流 Dataset API Java操作

9分9秒

课时26

26-Structured Streaming 基于事件时间的窗口操作

7分25秒

课时27

27-Structured Streaming 基于事件时间的窗口Scala代码

27分56秒

课时28

28-Structured Streaming 基于事件时间的窗口Java代码及注意点

18分20秒

课时29

29-Structured Streaming 基于事件时间的窗口划分规则

21分30秒

课时30

30-Structured Streaming Watermarking机制

22分45秒

课时31

31-Structured Streaming Watermarking设置方式及Complete输出测试

13分58秒

课时32

32-Structured Streaming Watermarking Update输出测试

16分39秒

课时33

33-Structured Streaming Watermarking Append输出测试

10分7秒

课时34

34-Structured Streaming Watermarking 使用注意点

2分41秒

课时35

35-Structured Streaming 窗口分类

5分3秒

课时36

36-Structured Streaming Session会话窗口代码

6分21秒

课时37

37-Structured Streaming 动态生成Session会话窗口

12分24秒

章节5:Structured Streaming Join操作及流去重 (7节)

课时38

38-Structured Streaming Stream与Static Join操作-01

12分35秒

课时39

39-Structured Streaming Stream与Static Join操作-02

8分32秒

课时40

40-Structured Streaming Stream与Stream join操作

24分31秒

课时41

41-Structured Streaming 代码获取输出Watermark

11分21秒

课时42

42-Structured Streaming Stream与Stream Join类型及注意点

7分48秒

课时43

43-Structured Streaming 流去重及代码实现

10分41秒

课时44

44-Structured Streaming 注意点

2分14秒

章节6:Structured Streaming 与Kafka 整合 (9节)

课时45

45-Structured Streaming Kafka Source Scala代码

13分13秒

课时46

46-Structured Streaming Kafka Source Java代码及总结

11分45秒

课时47

47-Structured Streaming Kafka Sink Scala代码

12分12秒

课时48

48-Structured Streaming Kafak Sink Java代码及总结

11分32秒

课时49

49-Structured Streaming 整合Kafka 不支持配置项

2分44秒

课时50

50-Structured Streaming 综合案例之数据准备

8分40秒

课时51

51-Structured Streaming 综合案例之代码编写

21分3秒

课时52

52-Structured Streaming 综合案例之代码测试及缓存

16分32秒

课时53

53-Structured Streaming 课程总结

3分2秒