boost::log包含两个大部分:logger和sink logging::core是全局的一个单例 1，sink 在boost::log中有一个默认的sink与控制台流相关关联； 如果想把日志输出到指定的文件流中可以使用如下代码： auto sink=add_log_file("xxx.log" ...
分类：
其他好文 时间：
2018-10-31 18:28:30
阅读次数：
197
Flume中的拦截器（interceptor），用户Source读取events发送到Sink的时候，在events header中加入一些有用的信息，或者对events的内容进行过滤，完成初步的数据清洗。这在实际业务场景中非常有用，Flume-ng 1.6中目前提供了以下拦截器： Timestam ...
分类：
Web程序 时间：
2018-10-29 21:30:13
阅读次数：
146
1、概述 Flume：收集、聚集，移动大量日志数据到指定位置 2、核心组件 基本单位：agent source：收集 channel：聚集 sink：发送 3、一般写Flume配置文件能解决大部分问题 ...
分类：
Web程序 时间：
2018-10-27 18:43:14
阅读次数：
182
名词解释： 1、netcat：通过网络端口获取数据，source的实现类 2、logger：将数据显示到控制台，sink的实现类 3、memory： ，channel的实现类 4、capacity：是指channel的最大容量 5、spooldir：本地文件目录（文件夹）用来读取数据（文件） 6、f ...
分类：
Web程序 时间：
2018-10-27 00:20:10
阅读次数：
209
#include #define oo 1e9 using namespace std; const int N = 200000 + 3; int n, tot = 1, head[N], nex[2 * N], tov[2 * N], f[2 * N]; int src, sink, L, de... ...
分类：
其他好文 时间：
2018-10-18 00:51:58
阅读次数：
174
编译并构建Apache Spark 2.3.2的Docker image，并向Kubernetes集群提交Spark Job实践
分类：
Web程序 时间：
2018-09-26 14:25:28
阅读次数：
279
久违啦米娜桑！！！ 最近有点忙，一月有余没有更新了，实在对不起大家！！！ 上线后看到不少朋友发的私信，感谢大家的赞许与信任，后面我会尽最大的努力按时更新，不断推出更优质的文章！！！ 本来计划最后花1讲的篇幅写完groupcache的源码分析的，今天刷了一下发现量还是有点多，可能得分两三讲；不过不会等 ...
分类：
其他好文 时间：
2018-09-23 22:33:42
阅读次数：
231
之前分析了a2dp profile 的初始化的流程，这篇文章分析一下，音频流在bluedroid中的处理流程。 上层的音频接口是调用a2dp hal 里面的接口来进行命令以及数据的发送的。 关于控制通道的初始化以及建立的过程，这里就不分析了，我们主要看数据的流向和处理。我们从控制通道的最后一个命令s ...
分类：
其他好文 时间：
2018-09-13 17:25:24
阅读次数：
740
Java NIO 管道是2个线程之间的单向数据连接。Pipe有一个source通道和一个sink通道。数据会被写到sink通道，从source通道读取。 代码使用示例： ...
分类：
其他好文 时间：
2018-09-09 15:30:34
阅读次数：
226
阻塞IO 传统的 IO 流都是阻塞式的。 也就是说，当一个线程调用 read() 或 write()时，该线程被阻塞，直到有一些数据被读取或写入，该线程在此期间不能执行其他任务。 因此，在完成网络通信进行 IO 操作时，由于线程会阻塞，所以服务器端必须为每个客户端都提供一个独立的线程进行处理，当服务 ...
分类：
其他好文 时间：
2018-09-09 15:00:49
阅读次数：
167
