文件名称:实验内容-开源硬件diy building open source hardware pdf
文件大小:478KB
文件格式:PDF
更新时间:2024-07-21 18:32:51
大数据 hadoop 星环 Slipstream流处理过程
一、基本信息 文档编号 文档版本 1.0 实验名称 StreamSQL 基本用法 所属课程 第 13 讲 实时流处理引擎 Slipstream 认证等级 数据工程师(初级) 授课形式 上机实验 实验批次 第 9 次 / 共 11 次 二、实验目的 掌握 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,作为输入流表的数据源。 步骤