描述 代码 Flink1.12 内容 链接: https://pan.baidu.com/s/1aoy157op8fT2_ShM6zuVnQ 提取码: **** 本内容被作者 ...

hyj 2021-3-22 30 4607

案例1：一个大数据实时数仓项目的demo 技术架构： kafka+Redis+Spark+ES 语言： Scala+Java+Shell 链接: https ...

nettman 2020-7-9 2 3778

[/td][/tr] [/table] [/td][/tr] [/table] 本仓库主要包含两个demo，分别为单词计数和cdn流量统计，代码分 ...

levycui 2020-6-30 5 3719

链接: https://pan.baidu.com/s/1_WNnt690-WWf8BX8uvNaKw 提取码: uscr DataCenter Todo: [*] CDH, hbase,z ...

levycui 2020-7-8 3 4536

介绍： 基于Flink实现的商品实时推荐系统。flink统计商品热度，放入redis缓存，分析日志信息，将画像标签和实时记录放入Hbase。 ...

nettman 2020-6-28 1 4127

技术路线 一图胜千言，如图是所使用的大数据组件，离线数仓的搭建涉及Kafka、Flume、Sqoop、Hive，实时路线包含Kafka、SparkS ...

hyj 2020-7-2 1 3012

代码下载：https://github.com/lyy289065406/hadoop-for-winx64 网盘下载： 链接: https://pan.baidu.com/s/1f2OeLJ4hHhvL ...

levycui 2020-7-1 1 8101

有如下功能： 1.hive元数据信息的查看，包括表基本信息，数据库基本信息，字段信息，分区信息，索引信息等； 2.对hive元数 ...

hyj 2020-7-6 0 2766

本帖最后由 levycui 于 2020-9-2 21:21 编辑 测试环境 [*] flink 版本：1.4.2 [*] cpu：Intel(R) Core(TM) i7-479 ...

levycui 2020-9-2 3 3521

基于用户行为的用户画像项目 链接: https://pan.baidu.com/s/1C91tPfvppzbiG3mPDOC1Pg 提取码: r9ej 项目结构说明 ...

levycui 2020-7-7 2 3843

本帖最后由 levycui 于 2020-7-22 11:33 编辑 下载链接: https://pan.baidu.com/s/1X9RetFsSDbZL1D7GPZM2jA 提取码: 37ak ...

levycui 2020-7-22 2 8335

链接: https://pan.baidu.com/s/1J9v5uvOeKpvUdgiv8wy2Xw 提取码: 9kjy 项目说明： [*]该项目主要分析深圳通刷卡 ...

levycui 2020-8-12 0 6412

本帖最后由 levycui 于 2020-7-21 15:18 编辑 下载链接： 1、Flink 从入门到实战 - Scala/Java双语言版本1 核心知识点 ...

levycui 2020-7-21 2 2961

kafka核心Api kafka有四个核心API 应用程序使用producer API发布消息到1个或多个topic中。 应用程序使用consumer API来 ...

hyj 2020-6-24 1 2325

版本说明： Spark:2.3/2.4 代码下载： 1 Structured内置的输入源 Source 官网文档：http://s ...

admin 2020-6-29 0 2561

介绍： 使用flink进行nginx日志监控，检测异常访问ip，并将数据发送到业务系统 详细： flink-analysis 使用flink进行n ...

阿飞 2020-12-30 0 5280

问题导读： 1. Block和Block Stream的区别是什么？ 2. Clickhouse的写入逻辑是什么？ 3. Clickhouse的读取逻辑是什么？ 4. ...

hanyunsong 2020-8-3 0 3931

有关flink使用的基础demo 代码包括 [*]world count [*]stream [*]kafka发送接收 [*]hbase存储 部分截图： ...

hyj 2020-7-28 1 2566

代码下载： 链接: https://pan.baidu.com/s/1Qc7_TZGs_ODa3UZP38klgQ 提取码: 8tjf 代码内容： 更多相关说明; ...

nettman 2020-8-5 0 3242

懒松鼠Flink-Boot 脚手架让Flink全面拥抱Spring生态体系，使得开发者可以以Java WEB开发模式开发出分布式运行的流处理程序，懒松 ...

hyj 2021-4-28 1 3433

说明： Class Dataserver将侦听端口7777上的连接，并将每秒两次将1-6的随机数发送到任何已连接的sockets 。 StateServer类 ...

阿飞 2020-7-6 1 2024

Flink提供了一个file system connector，可以使用DDL创建一个table，然后使用sql的方法将数据写入hdfs、local等文件系统，支持 ...

阿飞 2020-7-13 0 7338

问题导读： 1. IRR内部收益率的概念是什么？ 2. Spark之计算IRR需要做哪些数据准备？ 3. Spark与Pandas效率对比如何？ ...

hanyunsong 2020-8-13 0 2552

日志分析系统 系统架构 本使用kafka，spark，hbase开发日志分析系统。 软件模块 Kafka：作为日志事件的消 ...

nettman 2020-7-29 0 2567

链接: https://pan.baidu.com/s/1iEU_jtmExp0wt18npAE0ow 提取码: tpu7 基于Spark2.x新闻网大数据实时分析可视化系统项 ...

hanyunsong 2020-7-15 0 2993

链接：https://pan.baidu.com/s/14fx455_jrtm8MNbAAOu43g 提取码：4qdx Apache Flink SQL Practice[hr] This repos ...

hanyunsong 2020-7-16 0 2405

链接: https://pan.baidu.com/s/184-ycG0bdVxp4FjjMNdhPg 提取码: 9mad FlinkProj 案例开发应用场景： [*]数据清洗【 ...

levycui 2020-9-1 0 7503

问题导读： 1. 如何下载Spark3.0源码？ 2. 如何配置pom.xml？ 3. 如何用IDEA编译Spark3.0源码？ 4. 在Spark的standalone ...

hanyunsong 2020-7-30 0 4929

链接: https://pan.baidu.com/s/1TRawzGHNsk6B4vJp9s22Dg 提取码: weqh Flink从入门到项目实践 [hr] Apache Flink ...

hanyunsong 2020-7-27 0 3100

修改hive配置 上一篇介绍了使用sql将流式数据写入文件系统，这次我们来介绍下使用sql将文件写入hive,对于如果想写入已经存 ...

阿飞 2020-7-13 0 10649