目标 1.实现在流式数据处理时，做到At-Least-Once的能力，即保证数据不丢失，保证每条数据“至少被计算1次”。 2.实现Streaming任务在需要更新逻辑代码时，...
IP属地：浙江
-
PySparkStreaming At Least Once与不停机更新实现 -
未来数据存储与处理的主观臆想背景 从毕业到现在大概一年时间，主要从事后台开发工作，工作过程中也因为业务需要，逐渐接触了一些大数据组件，如HDFS、MapReduce、Spark、Hive、Elastic...
-
【Python】如何使用Logging模块第2期
Logging HOWTO 接上一期介绍完logging的一些基本概念（日志等级的概念等），基础的使用方式，本期还会介绍更多的使用场景。 从多个模块记录日志 我们再开发程序的...
-
docker是什么？docker能干嘛？dcokerfile计划第一期
与文章无关，当我再次打开docker文档的时候，映入眼帘的黑色主题（默认是亮色主题）直接把我带回去年在英国上云计算的课堂上，当时刚刚适应上课的节奏，基本上课和做作业时同时进行...
-
迭代器模式在前端的使用场景一、迭代器模式在Redux源码中的使用 二、迭代器模式在Koa2源码中的使用 场景一、二都是利用迭代器模式，依次调用中间件，从而实现各个框架中的洋葱模型。 三、 迭代器模式在...
-
Webpack中Loader的pitch方法一、Loader介绍 1.官网介绍：loader 用于对模块的源代码进行转换。loader 可以使你在 import 或"加载"模块时预处理文件。因此，loader 类似于其...
