Flink中如何广播对象到Slot

Question

我在Flink做一个分词项目，如何将main方法中创建的jieba对象发送到每个slot中

Answer 1

如果 jieba 对象是可序列化的，那么您可以将其传递给某些自定义函数的构造函数并将其保存在 non-transient 字段中。当函数被Flink序列化并分发到各个任务管理器时，对象会在函数实例化时被反序列化。