火花物品
spark流式计算电商商品关注度+推荐系统/关联系统
火花：2.6.5
Hadoop：2.6.0
Scala：2.11.8
开发方式：maven（java + scala）
前端：boostrap + springboot + echarts
spark-goods：后台springboot1：前端
2022-05-14 16:47:57
5.54MB
1
本文来自博客园，由火龙果软件Anna编辑、推荐。1.1.1流数据说明在实例演示中模拟实际情况，需要源源不断地接入流数据，为了在演示过程中更接近真实环境将定义流数据模拟器。该模拟器主要功能：通过Socket方式监听指定的端口号，当外部程序通过该端口连接并请求数据时，模拟器将定时将指定的文件数据随机获取发送给外部程序。1.1.2模拟器代码 1.1.3生成打包文件【注】可以参见第3课《Spark编程模型（下）--IDEA搭建及实战》进行打包在打包配置界面中，需要在ClassPath加入：/app/scala-2.10.4/lib/scala-swing.jar/app/scala-2.10.4/li
2022-05-14 14:35:47
1.23MB
1
hadoop生态圈所用到的组件，hadoop、hbase、kafka、spark、sqoop、zookeeper。远程连接服务器的Xshell和远程传送文件到服务器的Xftp。
2022-05-13 14:08:48
872.14MB
包含具体的实现论文、以及具体的实现代码，包含数据采集程序，spark数据分析代码，web数据分析平台代码，以及具体的部署和实现步骤
2022-05-12 18:11:17
21.61MB
Spark-Alarm
项目简介
提供一些基本的报警手段，并可以通过SparkListener实现对Spark内部执行逻辑进行监控报警
报警模式
使用限制
简介
邮件
通用，无限制
通过 SMTP 协议发送告警
哨兵
网易内部使用
通过 HTTP 协议发送告警
Smilodon
网易内部使用
通过 HTTP 协议发送告警
使用方法
编译
# 克隆本项目
git https://github.com/yaooqinn/spark-alarm.git
# cd spark-alarm
# mvn clean package
可以得到内置示例项目jar包：streaming-alarmer/target/streaming-alarmer-1.0-SNAPSHOT.jar，该构件实现了对Streaming程序"异常退出"和""任务堆积"等相关关键事件进行简单的告警服务
配置
配置工作分为三个过
2022-05-11 16:34:28
51KB
1
运行saprk-streaming所需的jar包,spark-streaming-kafka-assembly_2.10-1.6.3.jar
2022-05-11 11:37:35
12.73MB
1