Importing Flink into an IDE Preparation Ignoring Refactoring Commits IntelliJ IDEA Installing the Scala plugin Importing Flink Code Formatting Checkstyle For Java Checkstyle ...

Duration 有限与无限 Scala Deadline Duration 注：本节未经校验，如有问题欢迎提issue Duration在Akka库中被广泛使用，这代表一个特殊的数据类型——scala.concurrent.duration.Duration 。这个类型的值可以表示无限(Duration.Inf , Duration....

ALTER Statements Run an ALTER statement ALTER TABLE ALTER VIEW ALTER DATABASE ALTER FUNCTION ALTER Statements ALTER statements are used to modified a registered table/view/...

一个 RDD 有多少个分区？ 使用 UI 查看在分区上执行的任务数 使用 UI 查看分区缓存 编程查看 RDD 分区 一个 RDD 有多少个分区？ 在调试和故障处理的时候，我们通常有必要知道 RDD 有多少个分区。这里有几个方法可以找到这些信息： 使用 UI 查看在分区上执行的任务数 当 stage 执行的时候，你可以在 Spark UI...

译者结语 译者结语 到这里，有关 Scala 的知识已经讲的差不多了。原博文还有两篇用来讲述 Akka Actor，但个人觉得放在新手指南里并不合适。不是说 actor 不重要，毕竟不是核心库的一部分，对于理解 scala 这门语言用处不大。 所以，就到这里结束吧，希望读者能喜欢上 Scala。另外，欢迎对此译文的任何建议和批评。

从源码构建 Flink 构建 Flink 构建 PyFlink 先决条件 安装 依赖屏蔽 Scala 版本 加密的文件系统 从源码构建 Flink 本篇主题是如何从版本 1.17.2 的源码构建 Flink。 构建 Flink 首先需要准备源码。可以[从发布版本下载源码](http://nightlies.apache.org/fli...

从源码构建 Flink 构建 Flink 构建 PyFlink 先决条件 安装 依赖屏蔽 Scala 版本 加密的文件系统 从源码构建 Flink 本篇主题是如何从版本 1.16.0 的源码构建 Flink。 构建 Flink 首先需要准备源码。可以[从发布版本下载源码](http://nightlies.apache.org/fli...

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

Pulsar client libraries Language-specific client libraries Language-agnostic client libraries Feature matrix Third-party clients .NET (C#/F#/VB) Go Haskell Node.js PHP Rust...

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