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

hyj 2021-3-22 30 4601

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

levycui 2020-6-30 5 3713

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

levycui 2020-9-2 3 3519

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

levycui 2020-7-8 3 4534

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

levycui 2020-7-22 2 8335

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

levycui 2020-7-7 2 3843

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

nettman 2020-7-9 2 3777

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

levycui 2020-7-21 2 2959

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

levycui 2020-7-1 1 8100

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

hyj 2020-6-24 1 2324

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

nettman 2020-6-28 1 4124

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

阿飞 2020-7-6 1 2023

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

hyj 2020-7-28 1 2564

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

hyj 2020-7-2 1 3011

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

hyj 2021-4-28 1 3430

下载链接： Flink-Clickhouse-Sink 描述 Flink Sink用于Clickhouse数据库。 由异步Http客户端提供支持。 用于将数据 ...

levycui 2020-8-11 0 6554

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

hanyunsong 2020-8-13 0 2549

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

nettman 2020-7-29 0 2564

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

hanyunsong 2020-7-15 0 2990

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

admin 2020-6-29 0 2560

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

阿飞 2020-12-30 0 5278

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

hanyunsong 2020-8-3 0 3929

本帖最后由 levycui 于 2020-9-8 16:40 编辑 下载链接: https://pan.baidu.com/s/1cPH4IU9Ax9Rm5AflzsSq8g 提取码: hfqn ...

levycui 2020-9-8 0 3816

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

阿飞 2020-7-13 0 10649

链接: https://pan.baidu.com/s/1NbCSBcwXKhZDOr0-gL61mw 提取码: d9zp 一．Windows开发环境构建 1. JDK 说明 ...

hanyunsong 2020-8-6 0 7613

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

nettman 2020-8-5 0 3240

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

阿飞 2020-7-13 0 7337

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

hanyunsong 2020-7-30 0 4926

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

hanyunsong 2020-7-16 0 2403

本帖最后由 levycui 于 2020-7-15 17:25 编辑 Flink 1.11的水印代码： [mw_shl_code=java,true]package datastre ...

levycui 2020-7-15 0 4862