Flink Meetup [190629] 北京站
Apache Flink 1.9 特性解读 打造基于Flink Table API的机器学习生态 基于Flink on Kubernetes的大数据平台
- 781
- 1
- 阅读全文
Apache Flink 1.9 特性解读 打造基于Flink Table API的机器学习生态 基于Flink on Kubernetes的大数据平台
Flink程序在Debug的过程中为了方便看到代码执行详细和相关指标,支持ExecutionEnvironment创建带有UI的LocalEnvironment: [crayon-607edf9929fa2569624897/] 但是程序在IDEA真正执行起来以后如果打开http://127.0.0…
在实时数仓方面除了直接将数据写入Druid,Kafka等相关的消息队列以外,Flink还支持将数据写出到HDFS上并以Parquet格式进行存储,本案例简单地介绍了整个过程的实现,为后续实时数仓或者其他业务线提供参考。 除了Flink所依赖的常规Jar包以外,还需要提供以下依赖: [crayon-6…
近年来,流处理变得越来越流行。作为高度创新的开源流处理器,Flink拥有诸多优势,包括容错性、高吞吐、低延迟,以及同时支持流处理和批处理的能力。本书分为6章,侧重于介绍Flink的核心设计理念、功能和用途,内容涉及事件时间和处理时间、窗口和水印机制、检查点机制、性能测评,以及Flink如何实现批处理…
2018年12月20日 中国•北京•国家会议中心 http://t.cn/EUsQs9s 分会场1:https://yq.aliyun.com/live/703 分会场2:https://yq.aliyun.com/live/702 分会场3:https://yq.aliyun.com/live/7…
Maven Dependency Supported since Consumer and Producer Class name Kafka version Notes flink-connector-kafka-0.8_2.11 1.0.0 FlinkKafkaConsumer08 FlinkK…