Catalogs Catalog Types GenericInMemoryCatalog JdbcCatalog HiveCatalog User-Defined Catalog How to Create and Register Flink Tables to Catalog Using SQL DDL Using Java, Scala ...

Catalogs Catalog Types GenericInMemoryCatalog JdbcCatalog HiveCatalog User-Defined Catalog How to Create and Register Flink Tables to Catalog Using SQL DDL Using Java, Scala ...

继承与重写 继承与重写 Scala 中所有的类都继承自一个父类。像前一节的Complex 这种没有指定的例子，Scala 会默认使用scala.AnyRef 。 Scala 中可以重写继承自父类的函数。但是为了避免意外重写，必须加上override 修饰字来明确表示要重写函数。我们以重写Complex 类中来自Object 的toStrin...

Scala类型层次结构 类型转换 Nothing和Null 在Scala中，所有的值都有类型，包括数值和函数。下图阐述了类型层次结构的一个子集。 Scala类型层次结构 Any 是所有类型的超类型，也称为顶级类型。它定义了一些通用的方法如equals 、hashCode 和toString 。Any 有两个直接子类：AnyVal 和An...

Pulsar client libraries 功能矩阵 第三方客户端 Pulsar client libraries Pulsar 支持以下客户端库： Java 客户端 Go client Python client C++ client Node.js 客户端 WebSocket 客户端 C# client 功能矩阵 ...

Examples Bundled Examples Examples on the Web Examples Bundled Examples The Flink sources include many examples for Flink’s different APIs: DataStream applications (Java ...

Bipartite Graph Bipartite Graph Graph Representation Graph Creation Graph Transformations Bipartite Graph Bipartite Graph currently only supported in Gelly Java API. Bi...

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

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

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...