类型和泛型 变型 类型别名 隐式转换 类型和泛型 类型系统的首要目的是检测程序错误。类型系统有效的提供了一个静态检测的有限形式，允许我们代码中明确某种类型的变量并且编译器可以验证。类型系统当然也提供了其他好处，但错误检测是他存在的理由(Raison d’Être) 我们使用类型系统应当反映这一目标，但我们必须考虑到读者（译注：读你代码的人）：...

DataStream API 简介 什么能被转化成流？ Java tuples 和 POJOs Tuples POJOs Scala tuples 和 case classes 一个完整的示例 Stream 执行环境 基本的 stream source 基本的 stream sink 调试 动手实践 更多阅读 DataStrea...

DataStream API 简介 什么能被转化成流？ Java tuples 和 POJOs Tuples POJOs Scala tuples 和 case classes 一个完整的示例 Stream 执行环境 基本的 stream source 基本的 stream sink 调试 动手实践 更多阅读 DataStrea...

Testing Testing User-Defined Functions Unit Testing Stateless, Timeless UDFs Unit Testing Stateful or Timely UDFs & Custom Operators Unit Testing ProcessFunction Testing Flink ...

Testing Testing User-Defined Functions Unit Testing Stateless, Timeless UDFs Unit Testing Stateful or Timely UDFs & Custom Operators Unit Testing ProcessFunction Testing Flink ...

FAQ How can I write the annotations which gRPC-Gateway requires? I want to support a certain style of HTTP request but the code generated by gRPC-Gateway does not. How can I suppo...

连接器 下载连接器（connector）和格式（format）jar 包 如何使用连接器 内置的 Sources 和 Sinks 和 Pandas 之间互转 from_elements() 用户自定义的 source 和 sink 连接器 本篇描述了如何在 PyFlink 中使用连接器，并着重介绍了在 Python 程序中使用 Flink...

旁路输出 旁路输出 除了由 DataStream 操作产生的主要流之外，你还可以产生任意数量的旁路输出结果流。结果流中的数据类型不必与主要流中的数据类型相匹配，并且不同旁路输出的类型也可以不同。当你需要拆分数据流时，通常必须复制该数据流，然后从每个流中过滤掉不需要的数据，这个操作十分有用。 使用旁路输出时，首先需要定义用于标识旁路输出流的 Outp...

部署依赖 集群依赖 spark thrift Chunjun maven依赖 构建依赖 编辑器依赖 部署依赖 集群依赖 spark thrift 下载spark 安装包，我们选择的是spark2.1.3b 解压spark-2.1.3-bin-hadoop2.7.tgz 将core-site.xml、hdfs-site.xml、yar...

Graph API Graph Representation Graph Creation Graph Properties Graph Transformations Graph Mutations Neighborhood Methods Graph Validation Graph API Graph Representation...