gpt4 book ai didi

How does one operator pass on event stream to another operator?(一个操作符如何将事件流传递给另一个操作符?)

转载 作者:bug小助手 更新时间:2023-10-28 09:23:42 24 4
gpt4 key购买 nike



Operator one can pass on event data to operator two, in a pipeline, through GoLang channel, if implemented in GoLang. This helps avoid separation of concerns, amidst runtime failure.

运算符1可以通过GoLang通道(如果在GoLang中实现)在管道中将事件数据传递给运算符2。这有助于避免在运行时失败时分离关注点。


Does flink operator pass on event to another operator through a direct method call or through some Queuing technique?

Flink操作符是通过直接方法调用还是通过某种排队技术将事件传递给另一个操作符?


更多回答
优秀答案推荐


Does flink operator pass on event to another operator through a direct method call or through some Queuing technique?



That depends. Two or more operators in an operator chain (operators connected only by forward connections) pass events through direct method calls. Otherwise the messages are serialized and sent either via shared memory buffers (if the operators are in the same JVM) or via the network.

那得看情况了。运算符链中的两个或多个运算符(仅通过前向连接连接的运算符)通过直接方法调用传递事件。否则,消息将被序列化并通过共享内存缓冲区(如果运营商位于同一JVM中)或通过网络发送。


更多回答

In what scenarios, messages are serialized? And sent via shared memory buffer

在哪些情况下,消息会被序列化?并通过共享内存缓冲区发送

If the operators are not chained, then the messages are serialized. The serialized messages are sent via the network when the sender and recipient are in different JVMs, otherwise they use shared memory.

如果操作符没有链接,则消息被序列化。当发送方和接收方位于不同的JVM中时,序列化的消息通过网络发送,否则它们使用共享内存。

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com