二、实验目的
掌握 StreamSQL 的基本用法。
掌握 Slipstream 流处理的基本过程。
理解输入流表、衍生流表、结果表和流任务的关系。
三、实验准备
下载并安装 TDH Client。
下载并安装 Waterdrop,StreamSQL 语句在 Waterdrop 中运行。
实验目录与命名规划
(1)本地目录
工作目录:/mnt/disk1/{student_name}
(2)Kafka Topic:{topic_log_student_name}
(3)输入流表名:{log_student_name}
(4)衍生流表名:{wlog_student_name}
(5)Inceptor 数据库名:{db_student_name}
(6){student_name}为变量,代表学员姓名全拼
四、实验内容
1、创建 Kafka Topic
任务:创建 Kafka Topic,作为输入流表的数据源。
步骤
评论0
最新资源