首页
课程广场
1.最新课程
2.精品课程
3.热门课程
4.公开课
5.免费体验课程
信息资源馆
1.技术资讯阅览
2.毕业设计项目参考
3.认证考试
大咖播报
1.近期活动预告
2.常温活动阅览
3.梦想活动掌舵手
常温社区
首页
课程广场
1.最新课程
2.精品课程
3.热门课程
4.公开课
5.免费体验课程
信息资源馆
1.技术资讯阅览
2.毕业设计项目参考
3.认证考试
大咖播报
1.近期活动预告
2.常温活动阅览
3.梦想活动掌舵手
常温社区
登录
注册
切换触屏版
登录
注册
大数据专修课
第170任务： 4-4-2SparkStreaming实时处理入门-代码实现
查看课程
任务列表
第1任务： 1-1大数据是什么
第2任务： 1-2Hadoop的概述
第3任务： 1-3Hadoop的安装部署
第4任务： 1-4SHELL
第5任务： 1-5HDFS的块&体系结构&工作流程
第6任务： 1-6IDE远程管理HDFS
第7任务： 2 YARN
第8任务： 3-1-MapReduce入门
第9任务： 3-2Hadoop序列化机制
第10任务： 3-3MapReduce基础
第11任务： 3-4MapReduce高级
第12任务： 4-1ZooKeeper概述
第13任务： 4-2ZooKeeper的安装部署
第14任务： 4-3ZooKeeper的节点操作
第15任务： 4-4ZooKeeper的工作原理
第16任务： 4-5分布式锁
第17任务： 4-6HA集群
第18任务： 5-1Hive的介绍
第19任务： 5-2Hive的安装
第20任务： 5-3Hive的库表操作
第21任务： 5-4Hive的Shell技巧
第22任务： 5-5Hive基本查询语法
第23任务： 5-6Hive的数据类型
第24任务： 5-7BI-01
第25任务： 5-7BI-02
第26任务： 5-7Hive的函数
第27任务： 5-8HIVE的分区
第28任务： 5-9Hive的分桶
第29任务： 5-10序列化反序列
第30任务： 5-11Hive的存储格式&Hive的存储格式&数据压缩与优化
第31任务： 6-1介绍
第32任务： 6-2安装
第33任务： 6-3命令
第34任务： 6-4实战-import
第35任务： 6-5实战-export
第36任务： 6-6JOB
第37任务： 6-7调优
第38任务： 7-1DataX介绍
第39任务： 7-2-01DataX初体验
第40任务： 7-2-02DataX插件体系-1
第41任务： 7-2-02DataX插件体系-2
第42任务： 7-3DataX使用案例
第43任务： 7-4DataX-Web
第44任务： 8-1Flume介绍
第45任务： 8-2Flume体系结构
第46任务： 8-3Agent
第47任务： 8-4实战
第48任务： 8-5拦截器
第49任务： 8-6实现
第50任务： 8-7功能
第51任务： 9-1Azkaban介绍
第52任务： 9-2Azkaban安装
第53任务： 9-3Azkaban案例
第54任务： 9-4调优
第55任务： 10-1DolphinScheduler概述
第56任务： 10-2DolphinScheduler架构
第57任务： 10-3DolphinScheduler部署
第58任务： 10-4DolphinScheduler工作-01
第59任务： 10-4DolphinScheduler工作-02
第60任务： 10-4DolphinScheduler工作-03
第61任务： 10-4DolphinScheduler工作-04
第62任务： 10-4DolphinScheduler工作-05
第63任务： 11.Superset
第64任务： 12-01FineBI简介
第65任务： 12-02FineBI安装部署
第66任务： 12-3速学FineBI
第67任务： 12-4FineBI分析案例-01
第68任务： 12-4FineBI分析案例-02
第69任务： 1-1数仓介绍
第70任务： 1-2离线数仓
第71任务： 1-3实时数仓
第72任务： 2-1数仓概述
第73任务： 2-2数仓之ODS
第74任务： 2-3DWD
第75任务： 2-4DWS-01
第76任务： 2-4DWS-02
第77任务： 2-5ADS-01
第78任务： 2-5ADS-02
第79任务： 2-6调度
第80任务： 3-1Scala基础
第81任务： 3-2变量与类型
第82任务： 3-3类型转换
第83任务： 3-4操作符
第84任务： 3-5表达式
第85任务： 3-6方法与函数
第86任务： 3-7项目实战
第87任务： 3-8集合-01
第88任务： 3-8集合-02
第89任务： 3-8集合-03
第90任务： 3-9集合应用
第91任务： 3-10高级函数
第92任务： 3-11实战应用
第93任务： 3-12类
第94任务： 3-13对象
第95任务： 3-14继承
第96任务： 3-15抽象类
第97任务： 3-16特质
第98任务： 3-17枚举
第99任务： 3-18包和包对象
第100任务： 3-19样例类
第101任务： 3-20模式匹配
第102任务： 3-21偏函数
第103任务： 3-22实战应用
第104任务： 3-23隐式转换
第105任务： 3-24泛型
第106任务： 3-25多线程
第107任务： 3-26实用工具
第108任务： 3-27实战应用
第109任务： 3-28ScalaActor模型
第110任务： 3-29Akka分布式应用框架
第111任务： 3-30Akka HTTP实现Web应用
第112任务： 3-31实战应用分布式爬虫CrawlerAppDemo类的定义与实现
第113任务： 3-32实战应用分布式-爬虫监控WorkBean、Messages、Master追加新内容
第114任务： 3-33剪刀石头布
第115任务： 3-34实战应用双色球
第116任务： 3-35实战应用奥特曼打小怪兽
第117任务： 3-36实战应用斗地主发牌
第118任务： 3-37SBT
第119任务： 4-1-1认识Spark
第120任务： 4-1-2Spark集群部署
第121任务： 4-1-3Spark作业提交
第122任务： 4-1-4SparkSShell介绍与使用
第123任务： 4-1-6-实战应用之蒙特卡洛方法计算p
第124任务： 4-1-5Spark编程入门
第125任务： 4-1-7
第126任务： 4-1-8创建RDD
第127任务： 4-1-9编程开发
第128任务： 4-1-10Transformatio算子
第129任务： 4-1-11Action算子
第130任务： 4-1-12
第131任务： 4-1-13RDD算子比较
第132任务： 4-1-14TextFile分区问题
第133任务： 4-1-15
第134任务： 4-1-16案例练习
第135任务： 4-1-17RDD依赖关系
第136任务： 4-1-18
第137任务： 4-1-19RDD持久机制
第138任务： 4-1-20
第139任务： 4-1-22累加器
第140任务： 4-1-21
第141任务： 4-1-23广播变量
第142任务： 4-1-24
第143任务： 4-1-25
第144任务： 4-1-26task提交-
第145任务： 4-1-27实战应用
第146任务： 4-1-28项目周
第147任务： 4-2-1SparkSQL介绍
第148任务： 4-2-2SparkSQL编程模型
第149任务： 4-2-3SparkSQL的编程入口
第150任务： 4-2-4SparkSQL读写数据
第151任务： 4-2-5SparkSQL和Hive的整合
第152任务： 4-2-6实战应用-实战案例一
第153任务： 4-2-7SparkSQL函数操作
第154任务： 4-2-9Spark SQL运行架构及原理架构
第155任务： 4-2-10Spark3.X版本新特性
第156任务： 4-2-8SparkSQL优化
第157任务： 4-2-11实战应用
第158任务： 4-3-1
第159任务： 4-3-2
第160任务： 4-3-3Kafka的操作
第161任务： 4-3-4Kafka架构
第162任务： 4-3-5Kafka事务
第163任务： 4-3-6Kafka的Log
第164任务： 4-3-7Kafka实战-01
第165任务： 4-3-7Kafka实战-02
第166任务： 4-3-8Kafka与Flume的整合
第167任务： 4-3-9KafkaConnect
第168任务： 4-3-10KafkaEagle的使用
第169任务： 4-4-1流式计算简介
第170任务： 4-4-2SparkStreaming实时处理入门-代码实现
第171任务： 4-4-3-SparkStreaming与Kafka整合-Direct的方式
第172任务： 4-4-4SparkStreaming常见transformation算子
第173任务： 4-4-5SparkStreaming优化-优化建议
第174任务： 4-4-6实战应用
第175任务： 4-5-1回顾和展望-Spark 编程模型的进化过程
第176任务： 4-5-2Spark的序列化的进化过程-序列化操作_ev
第177任务： 4-5-3SparkStreaming和Structured Streaming-流的对比
第178任务： 4-5-4StructuredStreaming入门-代码实现
第179任务： 4-5-5StucturedStreaming的体系和结构
第180任务： 4-5-6StreamingSource操作
第181任务： 4-5-7StreamingSink操作
第182任务： 4-5-8错误恢复和容错语义-概念操作说明
第183任务： 4-6-1ClickHouse简介说明
第184任务： 4-6-2ClickHouse安装部署（单机版）
第185任务： 4-6-3ClickHouse基本数据类型介绍
第186任务： 4-6-4
第187任务： 4-6-5ClickHouse外部集成HDFS操作
第188任务： 4-6-6ClickHouse函数操作（时间和类型转换）
第189任务： 4-6-7ClickHouse组件基本介绍
第190任务： 4-6-8ClickHouse客户端工具使用操作
第191任务： 4-6-9ClickHouse监控实现
第192任务： 5-1-1准实时数仓
第193任务： 5-1-1准实时数仓02
第194任务： 5-1-1准实时数仓03
第195任务： 5-1-1准实时数仓04
第196任务： 5-1-1准实时数仓05
第197任务： 5-1-1准实时数仓06
第198任务： 5-1-2-01准实时数仓需求模型&数据采集与变更&架构解析
第199任务： 5-1-2-02
第200任务： 5-1-2-03准实时数仓内容数据生成操作&Spark相关操作
第201任务： 5-1-2-04
第202任务： 5-1-2-05准实时数仓Spark写入HDFS&解析JSON串&处理动态Schema&解析User
第203任务： 5-1-2-06准实时数仓Spark写入Hudi&行为历史数据构建&分析模型介绍
第204任务： 5-1-2-07准实时数仓Presto官网&基本特性&安装部署及启动&函数
第205任务： 5-1-2-08准实时数仓Presto客户端工具连接&API连接&Slice操作&UDF函数
第206任务： 5-1-2-09准实时数仓Presto的UDAF函数&事件分析SQL实现&事件分析上卷函数操作
第207任务： 5-1-2-10准实时数仓漏斗分析需求&SQL实现&UDAF解析&UDAF工具方法
第208任务： 5-1-2-11准实时数仓漏斗UDAF代码第一步&第二步&第三步
第209任务： 5-1-2-12准实时数仓漏斗UDAF第三步代码&深度代码测试&聚合代码实现与测试
第210任务： 5-1-2-13准实时数仓留存分析SQL实现&分析&优化操作
第211任务： 5-1-2-14准实时数仓留存UDAF模型解析&代码讲解及测试&代码测试
第212任务： 5-1-2-15准实时数仓DAU需求说明&预测样本数据构建实现&预测平台API说明
第213任务： 5-1-2-16准实时数仓DAU预测测试程序&RestAPI平台SQL查询测试&RestAPI平台DAU查询测试
第214任务： 5-2-1用户画像之基本介绍&标签和向量解析&需求说明&实施方案解析&实施方案
第215任务： 5-2-2用户画像之项目架构说明
第216任务： 5-2-3-01用户画像之Chproxy安装部署&问题解决及工具连接&构建用户基本标签数据的思路
第217任务： 5-2-3-02用户画像
第218任务： 5-2-3-03用户画像之标签数据写入Hive表&基于Spark构建Clickhouse表&基本标签
第219任务： 5-2-3-04用户画像之基础标签&聚类标签&分词器介绍与准备
第220任务： 5-2-3-05用户画像之分词器HanLP的应用&分词加载自定义&分词处理
第221任务： 5-2-3-06用户画像之TF
第222任务： 5-2-3-07用户画像之TD&用户画像之Word2Vec
第223任务： 5-2-3-08用户画像之安装Milvus&Load数据到Milvus&相似用户搜索
第224任务： 5-2-4用户画像之人群圈定及标签查询
第225任务： 5-2-5用户画像总结
第226任务： 5-3-1推荐系统简介&召回策略&排序策略
第227任务： 5-3-2推荐系统需求说明
第228任务： 5-3-3推荐系统架构解析&召回策略&排序策略
第229任务： 5-3-4-01推荐系统协同过滤&物品相似矩阵图&构建用户对文章的行为表
第230任务： 5-3-4-02推荐系统之用户行为类型转换&本地矩阵构建&分布式坐标矩阵构建
第231任务： 5-3-4-03推荐系统用户评分矩阵&ItemCF&均方根误差及数据写入Hive表
第232任务： 5-3-4-04Hbase基础介绍&表结构及数据类型&安装部署&ItemCF数据写入Hbase
第233任务： 5-3-4-05推荐系统之ALS算法&0文章特征向量
第234任务： 5-3-4-06推荐系统之文章特征向量转换解析及代码实现
第235任务： 5-3-4-07推荐系统之用户特征向量写入Hbase&文章嵌入向量&召回阶段&排序阶段&逻辑回归模型
第236任务： 5-3-4-08推荐系统之制作样本数据&构建排序模型数据源&排序模式
第237任务： 5-3-4-09推荐系统之测试数据集排序模式&构建PMML跨平台&合并Hbase表
第238任务： 5-3-4-10推荐系统之合并处理Hbase表&Web实现推荐功能&整体项目总结回顾
第239任务： 6-1-1Flink介绍
第240任务： 6-1-2Flink安装部署01
第241任务： 6-1-2Flink安装部署02
第242任务： 6-1-2Flink安装部署03
第243任务： 6-1-3DataStream01
第244任务： 6-1-3DataStream02
第245任务： 6-1-3DataStream03
第246任务： 6-1-3DataStream04
第247任务： 6-1-3DataStream05
第248任务： 6-1-3DataStream06
第249任务： 6-1-4DataSet API
第250任务： 6-1-5-01执行模式&并行度
第251任务： 6-1-5-02并行度案例&分区器
第252任务： 6-1-5-03状态
第253任务： 6-1-5-04Checkpoint&后端状态存储
第254任务： 6-1-5-05保存点Savepoint及checkpoint与savepoint区别&重启和故障转
第255任务： 6-1-5-06广播状态&分布式缓存&Flink累加器
第256任务： 6-1-5-07处理函数&侧输流&异步IO
第257任务： 6-1-6窗口01
第258任务： 6-1-6窗口02
第259任务： 6-1-6窗口03
第260任务： 6-1-6窗口04
第261任务： 6-1-7CEP
第262任务： 6-2实时数仓01
第263任务： 6-2实时数仓02
第264任务： 6-2实时数仓03
第265任务： 6-2实时数仓04
第266任务： 6-2实时数仓05
第267任务： 6-2实时数仓06
第268任务： 6-2实时数仓07
第269任务： 6-2实时数仓08
第270任务： 6-2实时数仓09
