Flink总结 Flink简介 Apache Flink作为一款高吞吐量、低延迟的针对流数据和批数据的分布式实时处理引擎，是当前实时处理领域的一颗炙手可热的新星 flink技...
发简信
IP属地：湖北
-
Flink总结 -
spark读写mysql、hive、kafka数据demo
读取hive库数据 pom.xml依赖配置 读取hive数据demo 读取mysql数据 pom.xml配置文件 读取mysql数据demo SPARKSTREAMING读取...
-
IDEA配置spark开发环境1开发环境 基于IntelliJ IDEA构建spark开发环境 1）安装Scala插件 更改maven源 maven默认源在国外，由于众所周知的原因下载速度很慢，因此我们更...
-
认真的
CDH 5.13安装spark2
for my darling! 1、前言 CDH安装的是较新版本的CDH-5.13.0，但是CDH-5.13.0默认支持的还是spark1.6版本。这里需要将spark升级...
-
@phycsgy 这个不是应该每天执行一遍while循环吗 这样的话在while里面的程序应该都会执行啊
Spark Streaming 实时统计商户当日累计PV流量
一、问题 对实时流量日志过滤筛选商户流量，对每个商户的流量进行累计，统计商户实时累计流量。 当时间超过24时时，重新统计当日商户的实时累计流量。 二、实现步骤 1、采用Spa...
-
楼主 我按照你的程序运行，在每次重启ssc的时候删除redis里面的数据，但是在运行的时候删除操作并没有执行，
删除操作时在while（true）后面操作的Spark Streaming 实时统计商户当日累计PV流量
一、问题 对实时流量日志过滤筛选商户流量，对每个商户的流量进行累计，统计商户实时累计流量。 当时间超过24时时，重新统计当日商户的实时累计流量。 二、实现步骤 1、采用Spa...
-
CDH 5.13安装spark2for my darling! 1、前言 CDH安装的是较新版本的CDH-5.13.0，但是CDH-5.13.0默认支持的还是spark1.6版本。这里需要将spark升级...
-
HIVE安装指南
for my honey! 1、前言 安装hive前提是要先安装hadoop集群，并且hive只需要再hadoop的namenode节点集群里安装即可，可以不在datanod...
-
微信公众号：硬刻时代<br>私人微信号：yksd100<br>【专业背景：美国运动医学院（NASM-CPT）私人教练；亚协体适能健身学院（AAASP）华中区教学总监；AAASP运动理疗康复课程创始人；美国（BASI）普拉提教练认证；肌筋膜链康复训练技术认证 。】
-
左手科技互联网，右手文娱与消费。
-
从数码发烧友到酷玩评测人，笔点君一直在路上。<br>微博及自媒体：笔点酷玩；<br>微信：bidiankuwan，欢迎交流提问。
-
科技大数据自媒体 <br>微信公众号：景辰(iJingChen) <br>个人微信：iamJingChen QQ：97674798<br>
-
阿里云官网内容平台！汇聚阿里云优质内容（入门、文档、案例、最佳实践、直播等）！如需转载或内容类合作，邮件yqgroup@service.aliyun.com 秒级回复！<br>
-
我们不仅仅是一家软件公司，同时也是一个社区：我们汇集满怀激情的软件精英，通过技术和客户共同应对最艰巨的挑战。同时我们寻求IT行业的革新，并致力于对社会产生积极的影响力。<br>
-
开源中国社区官方账号，每天为开发者推送最新最热的技术资讯。
-
ONES Piece 是一个由 ONES Ventures 发起的非营利翻译计划，聚焦科技创新、生活方式、未来商业。如有优质内容推荐或想要加入计划，请发送邮件至 embrace@onespiece.com。
-
终身学习者、大学教师。稍微懂一点儿写作、演讲、Python和机器学习。欢迎微信关注并置顶我的公众号“玉树芝兰”(nkwangshuyi)。我已委托“维权骑士”（rightknights.com）为我的文章进行维权行动。
-
