客户端（与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...

监管与监控 监管的意思" level="3"> 监管的意思 顶级监管者 /user : 守护Actor" level="5"> /user : 守护Actor /system : 系统守护者 / : 根守护者 重启的含义" level="3"> 重启的含义 生命周期监控的含义 一对一策略 vs. 多对一策略 监管与监控 这一节将简...

Cloudstate Component format Spec metadata fields Introduction Setup Cloudstate Apply the configuration In Kubernetes Running the Cloudstate sidecar alongside Dapr Related li...

DataStream Connectors 预定义的 Source 和 Sink 附带的连接器 Apache Bahir 中的连接器 连接Flink的其他方法 异步 I/O 可查询状态 DataStream Connectors 预定义的 Source 和 Sink 一些比较基本的 Source 和 Sink 已经内置在 Flink 里。...

DataStream Connectors 预定义的 Source 和 Sink 附带的连接器 Apache Bahir 中的连接器 连接Fink的其他方法 异步 I/O 可查询状态 DataStream Connectors 预定义的 Source 和 Sink 一些比较基本的 Source 和 Sink 已经内置在 Flink 里...

DataStream Connectors 预定义的 Source 和 Sink 附带的连接器 Apache Bahir 中的连接器 连接Fink的其他方法 异步 I/O 可查询状态 DataStream Connectors 预定义的 Source 和 Sink 一些比较基本的 Source 和 Sink 已经内置在 Flink 里...

DataStream Connectors 预定义的 Source 和 Sink 附带的连接器 Apache Bahir 中的连接器 连接Flink的其他方法 异步 I/O 可查询状态 DataStream Connectors 预定义的 Source 和 Sink 一些比较基本的 Source 和 Sink 已经内置在 Flink 里。...

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

自定义receiver指南 实现一个自定义的Receiver 在Spark流应用程序中使用自定义的receiver Receiver可靠性 实现和使用自定义的基于actor的receiver 自定义receiver指南 Spark Streaming可以从包括内置数据源在内的任意数据源获取数据（其他数据源包括flume，kafka，kines...

DataStream Connectors 预定义的 Source 和 Sink 附带的连接器 Apache Bahir 中的连接器 连接Flink的其他方法 异步 I/O 可查询状态 DataStream Connectors 预定义的 Source 和 Sink 一些比较基本的 Source 和 Sink 已经内置在 Flink 里。...