flink-shaded-hadoop-3-uber-3.1.1.7.2.9.0-173-9.0.jar
2022-04-06 02:50:32
56.84MB
1
通过指定目录进行多线程执行合并小文件程序，由于hdfs小文件过多，可用于自定义合并orc小文件。
2022-04-06 02:50:23
4KB
分享课程——大数据开发工程师2022，课程一共5个阶段，23周，2022年最新升级版，提供配套的源码+课件+电子书+软件安装包下载地址。
前沿技术体系+丰富实战案例+最佳学习路径，直击大厂Offer。课程从linux—>hadoop—>flume—>hbase—>hive—>scala—>spark—>数仓—>kafka—>Redis—>flink—>es—>数据中台，你能想到的大数据知识点，这里全都有！
2022-04-06 02:48:35
623B
1
《剑指大数据——Flink学习精要（Java版）》（最终修订版）.pdf
2022-03-28 22:04:30
10.58MB
1
Streaming_benchmark
流基准测试旨在测量流处理系统（如flink和spark）的性能。 模拟了三个用例（用户访问会话分析，实时广告评估和购物记录分析）。 原始数据将生成并存储在Kafka中。 流映射到流表中，并且对这些表进行查询。
建造
mvn clean package
先决条件
您应该在集群中安装Apache Kafka，Apache zookeeper，Apache Spark和Blink。
设置
将项目克隆到您的母版中。
更新conf / benchmarkConf.yaml（Kafka，Zookeeper，基准测试的属性...）
streambench.zkHost ip1:2181,ip2:2181,ip3:2181...
streambench.kafka.brokerList ip
2022-03-24 23:45:30
59KB
1
flink 以connector形式连接clickhouse，资源稀缺，阿里云已经找不到了
id Int,
age Int,
sex Int,
create_date Date
) WITH (
'connector' = 'clickhouse',
'url' = 'jdbc:clickhouse://10.1.3.176:8123/test',
'table-name' = 'tb_user',
'username' = '',
'password' = '',
'format' = 'json'
)
2022-03-24 16:16:21
6.5MB
1
基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join
2022-03-20 09:12:26
267KB
1
通过该资源您将
l 了解流处理的基本概念
l 掌握DataStream的算子操作（source、transformation、sink）
l 掌握水印使用及其原理
l 掌握状态和容错机制
l 掌握异步io的使用和原理
l 掌握端对端一次性语义的使用和原理
l 掌握Streaming file sink的使用
l 掌握Streaming综合案例开发
2022-02-24 17:08:06
2.71MB