本阶段主要内容
- Window的概念和类型
- TimeWindow的使用
- CountWindow的使用
- 自定义Window的使用
- Window中的增量聚合和全量聚合
- Flink中的Time
- Watermark的分析
- 开发Watermark代码
- 通过数据跟踪观察Watermark
- Watermark+EventTime处理乱序数据
- 延迟数据的三种处理方式
- 在多并行度下的Watermark应用
- Watermark案例总结
- 并行度介绍及四种设置方式
- 并行度案例分析
- KafkaConsumer的使用
- KafkaConsumer消费策略设置
- KafkaConsumer的容错
- KafkaProducer的使用
- KafkaProducer的容错
- SparkStreaming的WordCount程序开发
- SparkStreaming整合Kafka
欢迎加入QQ群聊人生、谈理想、解决各种大数据疑难问题！
QQ群号：938632081
