大数据处理框架选型分析前言说起大数据处理，一切都起源于Google公司的经典论文：《MapReduce:Simplied Data Processing on Large Clusters》。
在当时（2000年左右），由于网页数量急剧增加，Google公司内部平时要编写很多的程序来处理大量的原始数据：爬虫爬到的网页、网页请求日志；计算各种类型的派生数据：倒排索引、网页的各种图结构等等。
这些计算在概念上很容易理解，但由于输入数据量很大，单机难以处理。
所以需要利用分布式的方式完成计算，并且需要考虑如何进行并行计算、分配数据和处理失败等等问题。
针对这些复杂的问题，Google决定设计一套抽象模型来执行这些简单计算，并隐藏并发、容错、数据分布和均衡负载等方面的细节。
受到Lisp和其它函数式编程语言map、reduce思想的启发，论文的作者意识到许多计算都涉及对每条数据执行map操作，得到一批中间key/value对，然后利用reduce操作合并那些key值相同的k-v对。
这种模型能很容易实现大规模并行计算。
事实上，与很多人理解不同的是，MapReduce对大数据计算的最大贡献，其实并不是它名字直观显示的Map和Reduce思想（正如上文提到的，Map和Reduce思想在Lisp等函数式编程语言中很早就存在了），而是这个计算框架可以运行在一群廉价的PC机上。
MapReduce的伟大之处在于给大众们普及了工业界对于大数据计算的理解：它提供了良好的横向扩展性和容错处理机制，至此大数据计算由集中式过渡至分布式。
以前，想对更多的数据进行计算就要造更快的计算机，而现在只需要添加计算节点。
话说当年的Google有三宝：MapReduce、GFS和BigTable。
但Google三宝虽好，寻常百姓想用却用不上，原因很简单：它们都不开源。
于是Hadoop应运而生，初代Hadoop的MapReduce和HDFS即为Google的MapReduce和GFS的开源实现（另一宝BigTable的开源实现是同样大名鼎鼎的HBase）。
自此，大数据处理框架的历史大幕正式的缓缓拉开。
一、基础1.大数据的定义“大数据”一词的确切定义其实是很难给出的，因为不同的人（供应商、从业者、商业公司等）对它的理解也并不完全一致。
通常来讲，大数据是：- 大数据集- 用于处理大数据集的某类技术此处的“大数据集”是指一个数据集的数据量太大以至于无法使用传统工具或单机方式来处理和存储，而处理技术包括数据接入、数据持久化存储、数据计算和分析、数据展示（可视化）等等。
2.大数据的特征大数据系统的基本需求与传统系统并没有本质上的不同。
但大数据系统虽然具有海量的数据规模，但是对数据的接入和处理速度上也有较高的要求，而且在每个阶段都要对数据进行处理。
这些特点还是为设计解决方案时提供了新的挑战。
在2001年，美国Gartner公司的Doug Laney首先提出了“3V”模型来描述大数据处理系统与传统数据处理系统的不同：Volume待处理数据的规模在很大程度决定了系统是否为大数据系统。
大数据系统中的数据规模可能比传统处理系统中的数据集大几个数量级，这也为数据处理和存储带来了更多的挑战。
由于数据处理和存储等工作超出了单台计算机所能达到的性能极限，所以大数据系统通常采用集群方式。
集群方式更加考验资源的分配和协调，集群管理和任务分配算法变得越来越重要。
Velocity大数据与其他数据系统另一个显著的差异体现在数据的“流动”速度。
在大数据系统中，数据经常从多种数据源流入系统，并且以一种近实时的方式进行处理。
数据被持续不断的接入、修改、处理和分析以便能够跟得上新数据的接入速度。
由于近实时处理可以尽早的提供有价值的信息，目前很多商业公司更加青睐于实时处理系统而不是传统的批处理系统。
Variety大数据系统的问题通常是其他系统所不具备的，因为它所处理的数据来源广泛。
数据源可以是应用程序的日志信息，也可以是社交媒体的用户信息，甚至是物理设备传感器的采集数据。
不论何种数据，大数据系统的目标都是在海量数据中寻找有用的数据。
3.大数据处理流程那么大数据系统实际上是如何处理数据的呢？虽然不同公司的架构设计不尽相同，但我们可以总结出一个基本的流程。
下面介绍的流程虽然不是适用于所有情况，但它们确实被广泛使用。
大数据处理的基本流程是：- 接入数据到系统中- 将数据持久化到存储系统- 计算和分析数据- 展示结果（可视化）4.大数据处理框架的定义说完了大数据，我们来说说本文的重点——大数据处理框架。
大数据处理框架负责对大数据系统中的数据进行计算。
数据包括从持久存储中读取的数据或通过消息队列等方式接入到系统中的数据，而计算则是从数据中提取信息的过程。
除了大数据处理框架，有些同学可能还听到过“大数据计算框架”、“大数据框架”，这些术语没有严格的区分，但基本可以理解为是一种东西，只不过是对“big data processing framework”不同的翻译（大数据框架是“big data framework”的翻译）。
还有一个名词是“大数据处理引擎”，那么这个“引擎”和我们说的“框架”又有什么关系呢？其实并没有区分他们的权威的定义，但一般来说，前者是实际负责处理操作的组件，而后者可以理解为用来完成同样工作的一系列组件。
比如Apache Hadoop可以看做是以MapReduce为默认处理引擎的处理框架。
二、数据处理框架分类不论是系统中存在的历史数据，还是持续不断接入系统中的实时数据，只要数据是可访问的，我们就可以对数据进行处理。
按照对所处理的数据形式和得到结果的时效性分类，数据处理框架可以分为两类：- 批处理系统- 流处理系统批处理是一种用来计算大规模数据集的方法。
批处理的过程包括将任务分解为较小的任务，分别在集群中的每个计算机上进行计算，根据中间结果重新组合数据，然后计算和组合最终结果。
当处理非常巨大的数据集时，批处理系统是最有效的。
典型的批处理系统就是Apache Hadoop。
而流处理则对由连续不断的单条数据项组成的数据流进行操作，注重数据处理结果的时效性。
典型的流处理系统有Apache Storm，Apache Samza。
还有一种系统，同时具备批处理与流处理的能力，这种称为混合处理系统，比如Apache Spark，Apache Flink。
接下来我们来详细介绍这三种处理系统。
三、批处理系统批处理系统在大数据世界中有着悠久的历史。
批处理系统主要操作大量的、静态的数据，并且等到全部处理完成后才能得到返回的结果。
批处理系统中的数据集一般符合以下特征：- 有限：数据集中的数据必须是有限的（无限的数据一批就处理不完了啊。
连续不断的数据一般会使用流处理系统来进行处理，我们后面会讲到）- 持久：批处理系统处理的数据一般存储在持久存储系统上（比如硬盘上、数据库中）- 海量：极海量的数据通常只能使用批处理系统来处理。
批处理系统在设计之初就充分的考虑了数据量巨大的问题，实际上批处理系统也是为此而生的。
由于批处理系统在处理海量的持久数据方面表现出色，所以它通常被用来处理历史数据，很多OLAP （在线分析处理）系统的底层计算框架就是使用的批处理系统。
但是由于海量数据的处理需要耗费很多时间，所以批处理系统一般不适合用于对延时要求较高的场景。
Apache Hadoop说起大数据处理框架，永远也绕不开Hadoop。
Hadoop是首个在开源社区获得极大关注的大数据处理框架，在很长一段时间内，它几乎可以作为大数据技术的代名词。
在2.0版本以后，Hadoop由以下组件组成：- Hadoop分布式文件系统HDFS：HDFS是一种分布式文件系统，它具有很高的容错性，适合部署在廉价的机器集群上。
HDFS能提供高吞吐量的数据访问，非常适合在大规模数据集上使用。
它可以用于存储数据源，也可以存储计算的最终结果。
- 资源管理器YARN：YARN可以为上层应用提供统一的资源管理和调度，它可以管理服务器的资源（主要是CPU和内存），并负责调度作业的运行。
在Hadoop中，它被设计用来管理MapReduce 的计算服务。
但现在很多其他的大数据处理框架也可以将YARN作为资源管理器，比如Spark。
- MapReduce：即为Hadoop中默认的数据处理引擎，也是Google的MapReduce论文思想的开源实现。
使用HDFS作为数据源，使用YARN进行资源管理。
从今天的眼光来看，MapReduce作为Hadoop默认的数据处理引擎，存在着很多的不足。
比如：编程模型抽象程度较低，仅支持Map和Reduce两种操作，需要手工编写大量的代码；Map的中间结果需要写入磁盘，多个MR之间需要使用HDFS交换数据，因此不适合迭代计算（机器学习、图计算）；任务的启动和调度开销较大等。
随着更多高性能处理引擎的发展，目前在企业中使用MapReduce进行计算的应用已经呈下降趋势（HDFS及YARN仍然被广泛使用），但虽然如此，MapReduce作为最早的大数据处理引擎，仍然值得被我们铭记。
四、流处理系统批处理系统好理解，那什么是流处理系统呢？小学的时候我们都做过这么一道数学题：一个水池有一个进水管和一个出水管，只打开进水管8个小时充满水，只打开出水管6个小时流光水，那么同时打开进水管和出水管，水池多长时间充满水？好吧，这道题的答案是永远也充不满……因为出水管出水比较快嘛。
流处理系统就相当于这个水池，把流进来的水（数据）进行加工，比如加盐让它变成盐水，然后再把加工过的水（数据）从出水管放出去。
这样，数据就像水流一样永不停止，而且在水池中就被处理过了。
所以，这种处理永不停止的接入数据的系统就叫做流处理系统。
流处理系统与批处理系统所处理的数据不同之处在于，流处理系统并不对已经存在的数据集进行操作，而是对从外部系统接入的的数据进行处理。
流处理系统可以分为两种：- 逐项处理：每次处理一条数据，是真正意义上的流处理。
- 微批处理：这种处理方式把一小段时间内的数据当作一个微批次，对这个微批次内的数据进行处理。
不论是哪种处理方式，其实时性都要远远好于批处理系统。
因此，流处理系统非常适合应用于对实时性要求较高的场景，比如日志分析，设备监控、网站实时流量变化等等。
由于很多情况下，我们想要尽快看到计算结果，所以近些年流处理系统的应用越来越广泛。
下面我们来了解两种流处理系统。
Apache StormApache Storm是一种侧重于低延迟的流处理框架，它可以处理海量的接入数据，以近实时方式处理数据。
Storm延时可以达到亚秒级。
Storm含有如下关键概念：- Topology：Storm topology中封装了实时应用程序的逻辑。
