-
public class TablesQL{
public static void main(String[]args)throws Exception{
//1.获取上下文环境table的环境
//2.读取score.csv
//3.注册成内存表
//4.编写5q1然后提交执行
合?//5.结果进行打印
}//查看全部 -
Flink的编程模型和核心概念<br/>核心概念之并行度<br/>◆算子级别>运行环境级别>客户端级别>系统级别<br/>·并行度不能大于Slot个数查看全部
-
核心概念之并行度
◆算子级别设置flink的编程API修改
◆运行环境级别设置executionEnvironmentk的方法修改并行度
◆客户端级别$FLINK_HOME/bin/flink的-p参数
◆系统级别修改$轩LINK_HOME/conf/flink-confyaml文件查看全部 -
Flink table 与sql的算子操作
查看全部 -
并行
查看全部 -
demo
查看全部 -
课程大纲
查看全部 -
随便写点啥
查看全部 -
Flink Table & SQL API
查看全部 -
Flink Table & SQL
在Flink中,相等要使用三个 === 表示
查看全部 -
Flink 示意图
查看全部 -
Flink1.7.2新特性
(1)支持scala 2.12
(2) SQL 功能完善
(3)最新kafka连接器
(4)Streaming SQL新增Temporal Tables(时态表)
时态表:记录了数据发生该表的历史状态,该表可以返回特定时间点的表的内容
(5)Streaming SQL支持模式匹配
Flink CEP是Flink的复杂事件处理库,允许你在流上定义一系列的模式(pattern),最终使得你可以方便的抽取 自己需要的重要的事件处理。抽取自己需要的数据。
(6)Streaming SQL支持更多函数:REPLACE、REPEAT、LIRIM等函数
Blink 开源
阿里巴巴内部Flink 版本Blink已经开源,其最显著的特点就是强大的sql处理能力
查看全部 -
kafka
主题topic---消息分类
查看全部 -
查看消息队列中消息的列表
bin/kakfa-topics.sh --list --zookeeper localhost:2181
需求:有一个图书店铺,需要知道在促销期间每一本书买了多少
指定消费的位置,从哪里开始消费呢
consumer.setStartFromEarliest();
在上下文中设置source
env.addSource(consumer);
注册内存表
写sql
非常重要的知识点:回退更新:
tenv.toRetractStream(result,Row.class).print();
env.execute();
查看全部 -
FlinkSql实战项目之六十计算中的应用
kafka常用命令
创建消息
bin/kafka-topics.sh --create --zookeeper locahost:2181 --replication-factor 1 --partitions 1 --topic test2
启动生产者的客户端
bin/kafka-console-producer.sh --broker-list locahost:9092 --topic test2
启动消费者的客户端
bin/kafka-console-consumer.sh --bootstrao-server localhost:9092 --topic test2 --from-beginning
--from-beginning 从头开始消费消息队列中的数据
查看全部
举报