认识的Redis Redis是一个开源(BSD许可),内存数据结构存储,用作数据库,缓存和消息代理。它支持数据结构,如字符串,散列,列表,集合,带有范围查询的排序集,位图,超级日志,具有半径查询和流的地理空间索引。Redis具有内置复制,Lua脚本,LRU驱逐,事务和不同级别的磁盘持久性,并通过Re ...
分类:
其他好文 时间:
2019-04-11 14:50:03
阅读次数:
172
kafka集群介绍(安装配置、扩容、监控)说明:由于测试环境机器有限,这里就在一台机器上搭建伪集群环境kafka说明:一个Topic可以认为是一类消息,每个topic将被分成多个partition(区),,此外kafka还可以配置partitions需要备份的个数(replicas)。有多少个partitions就意味着有多少个"leader",kafka会将"lea
分类:
其他好文 时间:
2019-04-11 09:15:24
阅读次数:
134
Return: Map[TopicPartition, Long] Code: val props = new Properties() props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaPara("bootstrap.servers") ...
分类:
其他好文 时间:
2019-04-09 18:55:52
阅读次数:
180
``` class Solution { public: ListNode *partition(ListNode *head, int x) { ListNode *dummy = new ListNode(-1); dummy->next = head; ListNode *pre = dumm... ...
分类:
其他好文 时间:
2019-04-09 12:26:06
阅读次数:
111
CPA理论: 由于对系统或者数据进行了拆分,我们的系统不再是单机系统,而是分布式系统,针对分布式系统的CAP原理包含如下三个元素。 C:Consistency,一致性。在分布式系统中的所有数据 备份,在同一时刻具有同样的值,所有节点在同一时刻读取的数据都是最新的数据副本。 P: Partition ...
分类:
其他好文 时间:
2019-04-07 13:02:19
阅读次数:
192
package cn.piesat.testimport org.apache.spark.sql.SparkSessionimport scala.collection.mutable.ArrayBufferobject SparkSQLTest { def main(args: Array[St ...
分类:
数据库 时间:
2019-04-06 15:27:58
阅读次数:
200
This question is the same as "Max Chunks to Make Sorted" except the integers of the given array are not necessarily distinct, the input array could be ...
分类:
其他好文 时间:
2019-04-06 13:56:24
阅读次数:
125
原文:【SQL】ROW_NUMBER() OVER(partition by 分组列 order by 排序列)用法详解+经典实例 #用法说明 select row_number() over(partition by A order by B ) as rowIndex from table A ... ...
分类:
数据库 时间:
2019-04-03 23:48:09
阅读次数:
274
问题 问题 用过 Kafka 的同学用过都知道,每个 Topic 一般会有很多个 partitions。为了使得我们能够及时消费消息,我们也可能会启动多个 Consumer 去消费,而每个 Consumer 又会启动一个或多个streams去分别消费 Topic 里面的数据。我们又知道,Kafka ...
分类:
其他好文 时间:
2019-04-02 10:32:06
阅读次数:
187
硬盘是计算机的主要存储媒介。 分区是操作系统的逻辑概念,硬盘本身没有分区。 通过在Windows系统中打开磁盘管理可以看到磁盘分区的信息。如下图所示。 为什么要硬盘分区: https://www.disktool.cn/jiaocheng/hard-disk-partition.html 硬盘分区实 ...
分类:
其他好文 时间:
2019-03-30 18:46:01
阅读次数:
181