1.环境准备: 1.搭建zookeeper和kafka 2.虚拟机上nc -l 9000方式产生数据 2.需求分析: 通过socket的nc -l 9000方式产生数据,然后将数据以字符串的形式存入到kafka中 3.代码实例 flink-kafka-example ...
分类:
其他好文 时间:
2019-11-26 17:49:18
阅读次数:
90
1)半数机制:集群中半数以上机器存活,集群可用。所以Zookeeper适合安装奇数台服务器。 2)Zookeeper虽然在配置文件中并没有指定Master和Slave。但是,Zookeeper工作时,是有一个节点为Leader,其他则为Follower,Leader是通过内部的选举机制临时产生的。 ...
分类:
其他好文 时间:
2019-11-26 13:07:53
阅读次数:
57
什么是Zookeeper Zookeeper是一个分布式开源框架,提供了协调分布式应用的基本服务,它向外部应用暴露一组通用服务——分布式同步(Distributed Synchronization)、命名服务(Naming Service)、集群维护(Group Maintenance)等,简化分布 ...
分类:
其他好文 时间:
2019-11-25 18:35:22
阅读次数:
54
前言 众所周知,架构师的角色,更偏向于策划、而非指挥,塑造、而非支配,其存在的意义,在于引导大家讨论、而非自己主宰一切。 但是,具体应该如何执行呢?本文作者整理了 30 个公认的架构原则,来帮助大家解决此问题。也许有的原则,你从未听说,但你看完就能快速学会。 基本原则 原则1 KISS (Keep ...
分类:
其他好文 时间:
2019-11-25 00:04:52
阅读次数:
80
一、利用 forever forever是一个nodejs守护进程,完全由命令行操控。forever会监控nodejs服务,并在服务挂掉后进行重启。 1、安装 forever npm install forever -g2、启动服务 service forever start3、使用 forever ...
分类:
Web程序 时间:
2019-11-24 15:49:57
阅读次数:
184
pandas数据处理 1、删除重复元素 重复行判断 df.duplicated() # 重复行 显示为True,其他False (重复行第一次出现不为重复) keep : 默认first 从前往后看, last 从后往前看 (重复出现的行) subset=['B','C','D'] 默认对整行判断, ...
分类:
其他好文 时间:
2019-11-24 12:11:00
阅读次数:
77
KEEP CODING 代码改变世界 20180909 解析JS Cookie的设置,获取和检索 引用: JavaScript Cookie - by runoob.com Cookie是储存在电脑文本文件中的数据,用于保存访问者的信息,并可以在下次打开页面时引用。 页面在设置/引用访问者信息时,需 ...
分类:
其他好文 时间:
2019-11-24 12:05:55
阅读次数:
92
DataFrame.duplicated(self, subset=None, keep='first') Return boolean Series denoting duplicate rows, optionally only considering certain columns. Para ...
分类:
其他好文 时间:
2019-11-23 00:00:36
阅读次数:
101
Series.duplicated(self, keep='first') Indicate duplicate Series values. Duplicated values are indicated as True values in the resulting Series. Either ...
分类:
其他好文 时间:
2019-11-22 23:42:46
阅读次数:
118
DataFrame.drop_duplicates(self, subset=None, keep='first', inplace=False) Return DataFrame with duplicate rows removed, optionally only considering ce ...
分类:
其他好文 时间:
2019-11-22 22:11:05
阅读次数:
83