客户端（与redis完全一致，redis支持的pika都支持） ActionScript C C C++ Clojure Common Lisp D Dart emacs lisp Erlang Fancy Go Haskell haXe Io Java Lua Matlab Nimrod Node.js Object...

导入 Flink 到 IDE 中 准备 忽略重构提交 IntelliJ IDEA 安装 Scala 插件 导入 Flink 代码格式化 Java 规范检查 Scala 规范检查 版权信息 常问问题 Eclipse PyCharm 导入 flink-python Python 规范检查 导入 Flink 到 IDE 中 以下...

给 DataSet 中的元素编号 以密集索引编号 以唯一标识符编号 给 DataSet 中的元素编号 在一些算法中，可能需要为数据集元素分配唯一标识符。 本文档阐述了如何将 DataSetUtils 用于此目的。 以密集索引编号 zipWithIndex 为元素分配连续的标签，接收数据集作为输入并返回一个新的 (unique id, ini...

第三方开发的库 第三方开发的库 放弃 Yandex不维护下面列出的库，也没有进行任何广泛的测试以确保其质量。 Python infi.clickhouse_orm clickhouse-driver clickhouse-client PHP SeasClick phpClickHouse clickhouse-php-clien...

19.1 Frequently Asked Questions (FAQ) Does Micronaut modify my byte code? Why Doesn’t Micronaut use Spring? Does Micronaut support Scala? Can Micronaut be used for purposes othe...

RxJava介绍 RxJava 是轻量级的 RxJava 是一个多语言实现 RxJava 第三方库 使用指南 编译构建 故障排除 RxJava是 ReactiveX 在JVM上的一个实现，ReactiveX使用Observable序列组合异步和基于事件的程序。更多关于ReactiveX的资料，可以查看 ReactiveX 介绍 页面。 ...

数据类型以及序列化 Flink 中的类型处理 最常见问题 Flink 的 TypeInformation 类 POJO 类型的规则 创建 TypeInformation 或者 TypeSerializer Scala API 中的类型信息 No Implicit Value for Evidence Parameter 错误 泛型方法 Ja...

Spark 引擎 Spark 引擎 本文主要介绍在Linkis1.X中，spark引擎的配置、部署和使用。 如果您希望在您的服务器上使用spark引擎，您需要保证以下的环境变量已经设置正确并且引擎的启动用户是有这些环境变量的。 强烈建议您在执行spark任务之前，检查下执行用户的这些环境变量。 环境变量名 环境变量内容 备注 JAVA_HOME ...

共享变量 广播变量 累加器 共享变量 一般情况下，当一个传递给Spark操作(例如map和reduce)的函数在远程节点上面运行时，Spark操作实际上操作的是这个函数所用变量的一个独立副本。这些变量被复制到每台机器上，并且这些变量在远程机器上的所有更新都不会传递回驱动程序。通常跨任务的读写变量是低效的，但是，Spark还是为两种常见的使用模式提...

Dependency Information Apache Maven Apache Buildr Apache Ivy Groovy Grape Gradle/Grails Scala SBT Leiningen Dependency Information Apache Maven <dependency> <groupI...