如果在 GoLang 中实现,操作员一可以通过 GoLang 通道在管道中将事件数据传递给操作员二。这有助于避免在运行时失败时出现关注点分离。
flink 运算符是否通过直接方法调用或某种队列技术将事件传递给另一个运算符?
这要看情况。运算符链中的两个或多个运算符(仅通过前向连接连接的运算符)通过直接方法调用传递事件。否则,消息将被序列化并通过共享内存缓冲区(如果操作员位于同一 JVM 中)或通过网络发送。