目前大家理财主要有三种方式: 基金 股票 定期 有的人偏爱基金,因为相对平稳,风险也能承担;有的人偏爱股票,因为长期价值投资也是可以的;也有人偏爱定期理财,通常大家都会配置一点,确实稳。 我对基金情有独钟,不喜欢股票和定期理财;一方面是因为股票风险大,我也不会挑选好股票,也没那么多时间去关注和频繁买卖;另一方面是定期理财利息太低了,去年放了一年年化收益才4%,通货膨胀都超过10%啦。 我现在买了一些基金,目前还是亏本的,主要是年后抄底在半山腰,哈哈。 虽然近期反弹,可以我还是没有回本,因为抄底太早啦,但凡晚抄底一天…

2021-04-07 1条评论 996点热度 0人点赞 柯广 阅读全文

在上一篇文章中我们介绍了窗口相关的内容,那么问题来了,比如公司组织春游,规定周六早晨8:00 ~ 8:30清查人数,人齐则发车出发,可是总有那么个同学会睡懒觉迟到,这时候通常也会等待20分钟,但是不能一直等下去,如果到了20分钟则认为,想自己在家过周末,不参与春游活动了,不会继续等待了,直接出发。 这种机制跟这里要讲的watermark机制是一个意思。指的是,由于网络延迟等原因,一条数据会迟到计算,比如使用event time来划分窗口,我们知道窗口中的数据是计算一段时间的数据,如果一个数据来晚了,它的时间范围已经…

2021-04-01 0条评论 1385点热度 0人点赞 柯广 阅读全文

关注公众号:Java大数据与数据仓库,回复 "资料",领取大数据资料,学习大数据技术。 窗口 在流处理应用中,数据是连续不断的,因此我们不可能等到所有数据都到了才开始处理。当然我们可以每来一个消息就处理一次,但是有时我们需要做一些聚合类的处理,例如:在过去的1分钟内有多少用户点击了我们的网页。在这种情况下,我们必须定义一个窗口,用来收集最近一分钟内的数据,并对这个窗口内的数据进行计算。 Flink 认为 Batch 是 Streaming 的一个特例,所以 Flink 底层引擎是一个流式引擎,在上面实现了流处理和批…

2021-04-01 0条评论 1297点热度 0人点赞 柯广 阅读全文

经过年前一波大行情,我的心态就变了。 人有多大胆,基有多大产。 年后两天下跌,我很兴奋,继续抄底基金,跟女朋友说了这件事,她好像也比较感兴趣,让我推荐基金。 让我推荐基金,这个我在行啊,是时候表演真正的技术啦。 我迫不及待的在年后的第一个周五,当天好像也是下跌的,给她推荐了沪深300和创业板50这两只基金。 后来她说她买了几千块。 信心满满,静等上涨,静等女朋友的夸赞,小柯同学真棒! 然而,天有不测风云,股市变幻莫测。 结果接下来啪啪打脸,我自己一路抄底亏了好多不说吧,还把她带入了坑。 天生我材必有用,千金散尽还复…

2021-03-20 0条评论 1709点热度 1人点赞 柯广 阅读全文

耐得住寂寞,方能守得住繁华。 最近几天,大盘逐渐企稳,没有上周一那种恐怖性杀跌了。成交量也在萎缩,接下来大概率不会大跌了。 可以抄底啦。 本轮下跌,其实也是有经验教训在里面的。 那我自己来说,大跌之后,我开始抄底,然后依次大跌5%以上,我会再次抄底,结果是抄在半山腰。 试想一下,如果第一周大跌,没有急慌慌去抄底,而是稳住了。也不会回吐大部分利润,并且目前这个位置,相对比较安全,抄底岂不是更安全。 其实,我们回顾一下2020年,全年行情虽然不错,但是真正行情阶段就那么几天,7月上旬,12月下旬到2021年一月,其它时…

2021-03-17 0条评论 1752点热度 0人点赞 柯广 阅读全文

TopN的常见应用场景,最热商品购买量,最高人气作者的阅读量等等。 1. 用到的知识点 Flink创建kafka数据源; 基于 EventTime 处理,如何指定 Watermark; Flink中的Window,滚动(tumbling)窗口与滑动(sliding)窗口; State状态的使用; ProcessFunction 实现 TopN 功能; 2. 案例介绍 通过用户访问日志,计算最近一段时间平台最活跃的几位用户topN。 创建kafka生产者,发送测试数据到kafka; 消费kafka数据,使用滑动(sl…

2021-03-10 0条评论 2089点热度 0人点赞 柯广 阅读全文

这是今年以来我的基金收益率,不用说,肯定全国都垫底啦,跑输沪深300五个点多,我也是服了。 但是有一个信念,一直在我的脑海里,它也支撑着我开年以来一直加仓,做了一颗最合格的韭菜。这个信念很多人应该都有:长期看好中国未来经济。 确实是这样的,我是去年2020年春节开始玩儿的基金,大部分时间我的基金里面是有10万块的,不多也不少,跟很多平凡的追梦少年一样,试图通过理财来获得额外的收益,中间经历过大起大落,最终还是挣钱了,去年那走势,基金不挣钱,天理不容。 去年过年前几天,市场很猛,我当时是准备离场的,里面只留了3万元过…

2021-03-05 1条评论 2417点热度 0人点赞 柯广 阅读全文

explode 和 lateral view 为什么把这两个放一块呢,因为这两个经常放在一起用啊。 explode与lateral view在关系型数据库中本身是不该出现的,因为他的出现本身就是在操作不满足第一范式的数据(每个属性都不可再分),本身已经违背了数据库的设计原理(不论是业务系统还是数据仓库系统),不过大数据技术普及后,很多类似pv,uv的数据,在业务系统中是存贮在非关系型数据库中,用json存储的概率比较大,直接导入hive为基础的数仓系统中,就需要经过ETL过程解析这类数据,explode与later…

2021-03-04 0条评论 2671点热度 0人点赞 柯广 阅读全文

最近在深入了解新媒体这个行业过程中,越发看到行业的黑暗面。 以短视频行业为例,各种数据造假最严重的。 xx直播带货,在线认识显示31万人,实际上在线人数不足一万人,另外30万哪来的,全靠机器刷。 xx直播带货,号称一晚上卖了一个亿,实际上多少,200万,另外9800万的销售数据哪来的,全靠刷,后台退单率98%。 xx直播带货,抖音3000万粉丝大V,一晚上带货多少,不足一万,终于有数据真实的一个良心大V了。 那些花了上百万坑位费的商家怎么办,哭吧,面对各种虚假数据,面对各种高量退款,面对各种黑暗操作,叫天天不应,叫…

2021-03-01 1条评论 2558点热度 0人点赞 柯广 阅读全文

当前很多人都很浮躁,能刷头条的10分钟绝不会认真思考一会人生,能刷120分钟抖音的时间,绝不会静下心来去看一部经典电影。碎片化学习、生活变得如此常见,让人们变得过分自负,好挣快钱,渐渐没有了点滴积累、循序渐进做事的那份耐心了。有时候我也意识到了自己的这个问题,面对充满机遇的2021年,我给自己定了一些计划,然后写下来,时刻提醒自己,免得我又被某个热点吸引走了,我要培养自己的执行力,拿出实际行动来,多做尝试,多条腿走路。 暂时列出了这么多,大部分都是这几年的烂尾项目,还有几个新项目,后面如果想到了新的项目,我也会列出…

2021-02-23 0条评论 2812点热度 0人点赞 柯广 阅读全文

因为最近在使用Vue和SpringBoot结合开发,异步请求使用axios这个插件,本身在后端已经配置了跨域,前端指定了axios.defaults.baseURL,对于get请求是没有问题的,本来以为可以安心写页面了,结果发现对于后端配置的需要验证authc才能访问的post页面完全不能访问。查询资料才知道,因为前端访问时候没有把cookie放到请求头里面,查阅了一下资料,这里记录下。axios我的配置是这样的: var axios = require('axios') axios.defau…

2021-02-07 0条评论 3529点热度 0人点赞 柯广 阅读全文

先来看一下2019年人口普查,也是第七次人口普查的男女性别比例数据,是目前最新的数据了。这里性别比,女性基数是100,例如:20 ~ 24这个区间,性别比是114.61,也就是说,114.6个男性对应100个女性。 可以看出,男女数量差异比较明显,但是在这个人口基数大国中,这个差异得以放大。那么,这个性别数量差异是怎么造成的呢?我们继续探究。 故事一 以前在农村重男轻女现象比较严重,我村里一户人家想要一个男孩,结果接连生了5胎,都是女孩。人生就是这样的倔强,也需要顽强,有时候你不坚持一下,你都不知道什么叫绝望。 故…

2021-02-03 0条评论 3624点热度 0人点赞 柯广 阅读全文

关注公众号:Java大数据与数据仓库,领取资料,学习大数据技术。 理想情况下,我们应用对Yarn资源的请求应该立刻得到满足,但现实情况资源往往是有限的,特别是在一个很繁忙的集群,一个应用资源的请求经常需要等待一段时间才能的到相应的资源。在Yarn中,负责给应用分配资源的就是Scheduler。其实调度本身就是一个难题,很难找到一个完美的策略可以解决所有的应用场景。为此,Yarn提供了多种调度器和可配置的策略供我们选择。YARN架构如下: ResourceManager(RM):负责对各NM上的资源进行统一管理和调度…

2021-01-27 0条评论 3936点热度 0人点赞 柯广 阅读全文

Driver spark.driver.cores driver端分配的核数,默认为1,thriftserver是启动thriftserver服务的机器,资源充足的话可以尽量给多。 spark.driver.memory driver端分配的内存数,默认为1g,同上。 spark.driver.maxResultSize driver端接收的最大结果大小,默认1GB,最小1MB,设置0为无限。 这个参数不建议设置的太大,如果要做数据可视化,更应该控制在20-30MB以内。过大会导致OOM。 spark.extraL…

2021-01-26 0条评论 3855点热度 0人点赞 柯广 阅读全文

大学里的三点收获 2001年我考入了南开大学,起初大学的生活是让人有点失落的,但慢慢地从安静朴素的校园和踏实努力的氛围中,我还是找到了自己的节奏。大学期间我主要在做三件事情 ,一是写代码,因为我是搞技术的;二是看书,看了很多很多书;三是修电脑。基于此自己也有三点收获:耐心,知识,伙伴。 第一点收获:耐心。有耐心,能独处,并基于长期思考做判断,而不为短期因素所干扰,耐心地等待你设想和努力的事情逐步发生,这对创业来说是非常重要的事情。事实上,你经常想象的很美好,设计的也很完整,你也很努力,但你所期待的事情,经常需要很长…

2021-01-25 0条评论 3935点热度 0人点赞 柯广 阅读全文
1234518