使用Apache Flink （以下简称Flink）编写处理逻辑时，新手总是容易被林林总总的概念所混淆：
为什么 Flink 有那么多的类型声明方式？
BasicTypeInfo.STRING_TYPE_INFO、Types.STRING 、Types.STRING() 有何区别？
TypeInfoFactory 又是什么？
TypeInformation.of 和 TypeHint 是如何使用的呢？

接下来本文将逐步解密 Flink 的类型和序列化机制。

在本文中，我们将从零开始，教您如何构建第一个Apache Flink （以下简称Flink）应用程序。

在上一篇入门教程中，我们已经能够快速构建一个基础的Apache Flink（以下简称Flink） 程序了。本文会一步步地带领你实现一个更复杂的 Flink 应用程序：实时热门商品。在开始本文前我们建议你先实践一遍上篇文章，因为本文会沿用上文的my-flink-project项目框架。

Apache Flink （以下简称Flink）是近年来越来越流行的一款开源大数据计算引擎，它同时支持了批处理和流处理，也能用来做一些基于事件的应用。使用官网的语句来介绍 Flink 就是 “Stateful Computations Over Streams”。