Building Flink from Source Build Flink Build PyFlink Dependency Shading Hadoop Versions Pre-bundled versions Custom / Vendor-specific versions Scala Versions Encrypted File ...

Operators DataStream Transformations Map DataStream → DataStream FlatMap DataStream → DataStream Filter DataStream → DataStream KeyBy DataStream → KeyedStream Reduce KeyedS...

独立应用程序 独立应用程序 现在假设我们想要使用 Spark API 写一个独立的应用程序。我们将通过使用 Scala(用 SBT)，Java(用 Maven) 和 Python 写一个简单的应用程序来学习。 我们用 Scala 创建一个非常简单的 Spark 应用程序。如此简单，事实上它的名字叫 SimpleApp.scala ： /* Sim...

与 Java 互动 与 Java 互动 Scala 的优点之一是它非常容易跟 Java 代码沟通。Scala 会默认 importjava.lang 底下之类，其他类则需要明确导入。 让我们看个展示这点的示例。取得当下日期并根据某个特定国家调整成该国格式，如法国。 Java 的标准函数库定义了一些有用的工具类，如Date 跟DateForma...

Building Flink from Source Build Flink Build PyFlink Prerequisites Installation Dependency Shading Scala Versions Encrypted File Systems Building Flink from Source This ...

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

Pulsar client libraries Feature matrix Third-party clients .NET Go Haskell Node.js PHP Rust Scala Pulsar client libraries Pulsar supports the following language-specifi...

高级配置主题 Flink 依赖剖析 Scala 版本 Table 依赖剖析 Table Planner 和 Table Planner 加载器 Hadoop 依赖 高级配置主题 Flink 依赖剖析 Flink 自身由一组类和依赖项组成，这些共同构成了 Flink 运行时的核心，在 Flink 应用程序启动时必须存在，会提供诸如通信协调、网...

The Neophyte's Guide to Scala The Neophyte's Guide to Scala From November 2012 to April 2013, I created and published a blog series called The Neophyte’s Guide to Scala, targ...

Graph Generators Circulant Graph Complete Graph Cycle Graph Echo Graph Empty Graph Grid Graph Hypercube Graph Path Graph RMat Graph Singleton Edge Graph Star Graph G...