Python 三元表达式 三目运算符 一般支持三目运算符的语言(如C语言)的语法格式一般是这样的: 判断条件(返回布尔值)?为真时的结果:为假时的结果 比如: x = x%2==1 ? x+1:x; python并不支持? :这种符号所表达的先判断再选择的含义,但仍然有相应的语法支持: 1. Python 的语法支持 为真时的结果 if 判断条件 else 为假时的结果(注意,没有冒号) 顺序略有不同, x = x+1 if x%2==1 else x 在比如我们欲实现一个基础版本(递归版本)的斐波那契数列: de…

2020年06月09日 0条评论 146点热度 0人点赞 阅读全文

Kafka是使用scala编写的运行与jvm虚拟机上的程序,虽然也可以在windows上使用,但是kafka基本上是运行在linux服务器上,因此我们这里也使用centos7来实战。 首先确保你的机器上安装了jdk,kafka需要java运行环境,以前的kafka还需要zookeeper,新版的kafka已经内置了一个zookeeper环境,所以我们可以直接使用,但还是建议使用自己安装的zookeeper ApacheKafka是一个分布式流媒体平台,它主要有3种功能 1、发布和订阅消息流,这个功能类似于消息队列,…

2020年06月08日 0条评论 129点热度 0人点赞 阅读全文

zookeeper的安装相对比较简单,不需要配置大量的参数。 但是zookeeper要求Java运行环境,并且需要jdk版本1.6以上,安装jdk可以参考文末链接。 简单介绍下zooKeeper,它是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop(HA、联邦)和Hbase的重要组件。 它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等,可用于注册中心。 ZooKeeper的目标就是封装好复杂易出错的关键服务,…

2020年06月07日 0条评论 125点热度 1人点赞 阅读全文

HBase,是一个高可靠性、高性能、面向列、可伸缩、 实时读写的分布式数据库 利用Hadoop HDFS作为其文件存储系统,利用Hadoop MapReduce来处理 HBase中的海量数据,利用Zookeeper作为其分布式协同服务 主要用来存储非结构化和半结构化的松散数据(列存NoSQL数据库) 由此来看,hbase的使用就需要hadoop、zookeeper,两者的安装可以参考文末链接! http://mirror.bit.edu.cn/apache/hbase/ Master 192.168.71.10 S…

2020年06月07日 0条评论 148点热度 0人点赞 阅读全文

  Apache Flink是一个面向数据流处理和批量数据处理的可分布式的开源计算框架,它基于同一个Flink流式执行模型(streaming execution model),能够支持流处理和批处理两种应用类型。 由于流处理和批处理所提供的SLA(服务等级协议)是完全不相同,流处理一般需要支持低延迟、Exactly-once保证,而批处理需要支持高吞吐、高效处理, 所以在实现的时候通常是分别给出两套实现方法,或者通过一个独立的开源框架来实现其中每一种处理方案。 比较典型的有:实现批处理的开源方案有MapReduc…

2020年06月07日 0条评论 155点热度 0人点赞 阅读全文
1234510