Arity-0 Postfix Notation Arity-1 (Infix Notation) Symbolic Methods/Operators Higher-Order Functions Generally speaking, method invocation in Scala follows Java conventions.In...

Data Types & Serialization Type handling in Flink Most Frequent Issues Flink’s TypeInformation class Rules for POJO types Creating a TypeInformation or TypeSerializer Type In...

Map类的操作 mutable.Map类中的操作 同步集合（Set）和映射（Map） 映射（Map）是一种可迭代的键值对结构（也称映射或关联）。Scala的Predef类提供了隐式转换，允许使用另一种语法：key -> value ，来代替(key, value) 。如：Map("x" -> 24, "y" -> 25, "z" -> 26) 等同于...

FlinkCEP - Complex event processing for Flink Getting Started The Pattern API Individual Patterns Quantifiers Conditions where(condition) or(condition) until(condition) su...

Effective Scala Effective Scala Marius Eriksen, Twitter Inc.marius@twitter.com (@marius )[translated by hongjiang(@hongjiang ), tongqing(@tongqing )] 来源： http://github.com...

Actions Actions 下面的表格列了 Spark 支持的一些常用 actions。详细内容请参阅 RDD API 文档(Scala , Java , Python ) 和 PairRDDFunctions 文档(Scala , Java )。 Action Meaning reduce(func) Aggregate ...

Data Types Data Type Data Types in the Table API Physical Hints List of Data Types Character Strings CHAR VARCHAR / STRING Binary Strings BINARY VARBINARY / BYTES Ex...

Data Types Data Type Data Types in the Table API Physical Hints List of Data Types Character Strings CHAR VARCHAR / STRING Binary Strings BINARY VARBINARY / BYTES Ex...

算子 数据流转换 Map DataStream → DataStream FlatMap DataStream → DataStream Filter DataStream → DataStream KeyBy DataStream → KeyedStream Reduce KeyedStream → DataStream Window ...

Project Configuration Flink Core and Application Dependencies Setting up a Project: Basic Dependencies Adding Connector and Library Dependencies Scala Versions Hadoop Dependenc...