数据类型和序列化

Flink 中的类型处理 Flink会尝试推断出在分布式计算过程当中被交换和存储的数据类型的大量信息，你能够想象这就像数据库推断表的模式(schema)同样。在大多数状况下，Flink可以完美地推断出全部必须的信息，这些类型信息使得Flink能够作一些很酷的事情：html 使用POJOs类型并经过推断的字段名字(如：dataSet.keyBy("username"))完成分组(group)/链接(

>>阅读原文<<