问题描述： 通过堆排序，从小到大排序一个数组。 算法实现： public static void heapSort(int[] arr) { int N = arr.length - 1; for(int i = arr.length / 2 - 1; i >= 0; i--) { sink(arr ...
分类：
编程语言 时间：
2020-03-31 12:47:06
阅读次数：
67
今天，将kube-eventer放到influxdb后， 才发现入库的数据不堪显示 和报警， 于是，只好看看原因。 原来，value里的值太多，不好过滤。 于是，从源码出发，看如何增加参数，生成更多的tag来搞。 有了这一段。 https://github.com/AliyunContainerSe ...
分类：
其他好文 时间：
2020-03-30 23:49:19
阅读次数：
226
1. 状态一致性 有状态的流处理，内部每个算子任务都可以有自己的状态； 对于流处理器内部（没有接入sink）来说，所谓的状态一致性，其实就是我们所说的计算结果要保证准确； 一条数据不应该丢失，也不应该重复计算； 在遇到故障时可以恢复状态，恢复以后的重新计算，结果应该也是完全正常的； 状态一致性分类： ...
分类：
其他好文 时间：
2020-03-26 01:30:58
阅读次数：
150
# Rust异步网络编程 Rust的高性能异步网络编程模式目前是基于mio和futures这两个库构建的生态。 Tokio则连接这2个库构建了一个异步非阻塞事件驱动编程平台。 # 什么是 mio,futures,tokio ## 1- Mio Mio是Rust的轻量级快速低级IO库，专注于非阻塞AP ...
分类：
其他好文 时间：
2020-03-24 23:17:09
阅读次数：
80
单字节操作 | 单字节 IO 操作 | 说明 | | | | | is.get(ch) | 从 istream is 读取下一个字节存入字符 ch 中，返回 is | | os.put(ch) | 将字符 ch 输出到 ostream os，返回 os | | is.get() | 将 is 的下一 ...
分类：
其他好文 时间：
2020-03-03 20:58:49
阅读次数：
82
一、流向提取Flow Direction输入：使用dem数据；输出：flowdir_dem二、洼地的判定-汇 sink输入：flowdir_dem；输出：sink三、分水岭-watershed输入：1、flowdir_dem；2、sink；3、默认；输出：Watersh_sink四、分区分析-Zon... ...
分类：
其他好文 时间：
2020-02-21 09:44:38
阅读次数：
999
对于 Linux 系统管理员来说，清楚某个服务是否正确地绑定或监听某个端口，是至关重要的。如果你需要处理端口相关的问题，这篇文章可能会对你有用。 端口是 Linux 系统上特定进程之间逻辑连接的标识，包括物理端口和软件端口。由于 Linux 操作系统是一个软件，因此本文只讨论软件端口。软件端口始终与 ...
分类：
系统相关 时间：
2020-01-26 17:48:38
阅读次数：
106
先给出答案： 需要结合具体使用的source、channel和sink来分析，具体结果可看本文最后一节。 Flume事务 ====================== 一提到事务，我们首先就想到的是MySQL中的事务， 事务就是将一批操作做成原子性的 ，即这一批要么都成功，要么都失败。 同样的道理， ...
分类：
Web程序 时间：
2020-01-24 00:14:47
阅读次数：
972
Introduction 最大流问题就是求出一个可行流量使得从 单源点 到 单汇点 的流网络中流量最大。 且满足如下约束： 流过边$e$的流量不超过$e$的容量$capacity$ 对于每一个顶点$node_{\neq source,sink} \quad incoming flow=outgoin ...
分类：
其他好文 时间：
2020-01-22 23:37:39
阅读次数：
104
目录 一、背景 二、Flume的简介 三、Flume NG的介绍 3.1 Flume特点 3.2 Flume的一些核心概念 3.3 Flume NG的体系结构 3.4 Source 3.5 Channel 3.6 Sink 四、Flume的部署类型 4.1 单一流程 4.2 多代理流程（多个agen ...
分类：
Web程序 时间：
2020-01-22 10:51:06
阅读次数：
131
