本章主要介绍了三部分内容，即Flink的wordcount实现、本地模式的部署和Flink SQL Client的简单使用。

介绍了Flink的历史背景以及未来规划、Flink的核心特性以及Flink的API层次结构，在使用过程中会有一个总体上的概念。

第一节是本章的导入章节，主要是为了引入状态的概念，该部分已经在本书第三章“有状态流处理”章节介绍了。第二节是介绍如何使用状态，涉及的内容有KeyedDataStream的两种key的定义形式、Keyed State的有效期及两种不同的清理方式，同时也介绍了算子状态和广播状态及算子状态使用。第三节就广播状态进行了更为深入的介绍，比如广播状态的API、使用时要注意的关键点。

第六节讲述了Flink非常重要的应用-窗口的应用，介绍了滑动、滚动和累积窗口，并介绍了窗口的聚合，同时讲述了Top-N和窗口的Top-N，以详细的示例进行说明。

因为Spring Batch 会启用一个 H2 数据库，在这个数据库中，Sping 会对 Batch 需要的配置进行配置。以上，完成了读取文本文件内容并求和、存储至mysql数据库中，是通过注解完成该项工作。数据源文件能正常的读取到，且能针对每个学生的数据进行求和并存储至mysql中。本文使用的是jdk8，较高版本的spring batch需要jdk11环境。启动app.java，然后观察应用程序

介绍了Flink的历史背景以及未来规划、Flink的核心特性以及Flink的API层次结构，在使用过程中会有一个总体上的概念。

软件测试是一个非常专业的工作，在大多数的软件建设组织中，都会有软件测试类的岗位（或类似名称的岗位）来对交付的软件进行验证。在软件全生命周期质量保证的理念下，基于软件过程的测试类别被更为细致的提出来，如需求测试、架构测试、设计测试、单元测试、集成测试、用户验证测试等。对软件质量来说，单元测试有非常积极的作用，是测试金字塔中最重要的部分。有一些团队会直接使用生产上的数据作为测试环境数据，实际上这不是非

因为Spring Batch 会启用一个 H2 数据库，在这个数据库中，Sping 会对 Batch 需要的配置进行配置。以上，完成了读取文本文件内容并求和、存储至mysql数据库中，是通过注解完成该项工作。数据源文件能正常的读取到，且能针对每个学生的数据进行求和并存储至mysql中。本文使用的是jdk8，较高版本的spring batch需要jdk11环境。启动app.java，然后观察应用程序

介绍了Flink的历史背景以及未来规划、Flink的核心特性以及Flink的API层次结构，在使用过程中会有一个总体上的概念。

本文通过在hdfs中三种不同数据格式文件存储相同数量的数据，通过hive和impala两种客户端查询进行比较。本文前提：熟悉hadoop、hive和impala、kafka、flink等，并且其环境都可正常使用。（在后续的专栏中都会将对应的内容补全，目前已经完成了zookeeper和hadoop的部分。）本文分为一般建议，下面通过实际操作进行比较实现1亿条数据在hive和impala中不同sql的