线程模型分类： 用户级线程（User Level Thread,ULT） 用户程序实现，不依赖操作系统核心，应用提供创建、同步、调度和管理线程函数来控制用汉语线程。不需要用户态/内核态切换，速度快。内核对UTL无感知，线程阻塞则进程（包括它的所有线程）阻塞。 内核级线程（KLT） 系统内核管理线程， ...
分类：
编程语言 时间：
2020-05-25 16:00:07
阅读次数：
62
查找?较简单，我们先来看?个经典的?分查找 有点类似幸运52的猜价格，?如让你在1和1000之间猜个数字，挨个猜是很蠢的，要先猜500，如果?了，那就是0~500 ，每次问题减半，很快就能查到 function binarySeatch(arr,target) { var low=0, high=a ...
分类：
编程语言 时间：
2020-05-25 12:34:59
阅读次数：
62
import logging logging.basicConfig(level=logging.DEBUG, format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s', datefmt='%a, %d ...
分类：
编程语言 时间：
2020-05-25 12:16:41
阅读次数：
88
Consumer之自动提交在上文中介绍了ProducerAPI的使用，现在我们已经知道如何将消息通过API发送到Kafka中了，那么现在的生产者/消费者模型就还差一位扮演消费者的角色了。因此，本文将介绍ConsumerAPI的使用，使用API从Kafka中消费消息，让应用成为一个消费者角色。还是老样子，首先我们得创建一个Consumer实例，并指定相关配置项，有了这个实例对象后我们才能进行其他的操
我们之前学习的转换算子是无法访问时间的时间戳信息和水位线信息的。而这些在一些应用场景下，极为重要，例如MapFunction这样的map转换算子就无法访问时间戳或者当前事件的事件时间。 基于此，DataStreamAPI提供了一系列的Low-Level的转换算子，可以访问时间戳、watermark以 ...
# 堆排序的向下调整性 # 排序步骤：建堆 交换堆顶元素和最后一个元素 调整使堆重新有序 i的指向前移（i指向最后一个元素）重复2以后的步骤 # 交换步骤将堆中的最大元素移动到了堆的最后位置，排序完成后，得到的是一个升序序列 # 大根堆的排序 # 向下调整 def sift(li,low,high) ...
分类：
编程语言 时间：
2020-05-24 11:46:57
阅读次数：
66
#include<conio.h> #include<bits/stdc++.h> #include<windows.h> #define CIN freopen("CONIN$", "r+t", stdin); #define COUT freopen("CONOUT$", "w+t", stdo ...
分类：
其他好文 时间：
2020-05-24 11:43:24
阅读次数：
58
同样是逻辑上的概念，是Kafka实现单播和广播两种消息模型的手段。同一个topic的数据，会广播给不同的group；同一个group中的worker，只有一个worker能拿到这个数据。换句话说，对于同一个topic，每个group都可以拿到同样的所有数据，但是数据进入group后只能被其中的一个w ...
分类：
其他好文 时间：
2020-05-24 10:06:48
阅读次数：
77
Level 8kyu ：Convert number to reversed array of digits 将数字转换为反转的数字数组 给定一个随机的非负数，您必须以相反的顺序返回该数字在数组中的数字。 例：348597 => [7,9,5,8,4,3] 主要方法： ArrayListy： get ...
分类：
其他好文 时间：
2020-05-24 00:51:47
阅读次数：
56
Kafka Kafka是最初由Linkedin公司开发，是一个分布式、支持分区的（partition）、多副本的（replica），基于zookeeper协调的分布式消息系统，它的最大的特性就是可以实时的处理大量数据以满足各种需求场景：比如基于hadoop的批处理系统、低延迟的实时系统、storm/ ...
分类：
其他好文 时间：
2020-05-23 18:03:51
阅读次数：
49
