如何解决Hazelcast Jet-如何在Jet管道中使用非静态方法
我在下面有一个基本的管道。在以下步骤之一中,我想通过从服务调用方法来转换对象,如下所示。但是Jet抛出错误,指出此mapFn
不可序列化。在这里做什么?对于静态方法,它工作得很好。
p.readFrom(source)
.map(r -> dataTransformer.transformRecord(r))// dataTransformer is a service
.writeTo(Sinks.filesBuilder(userHome).build());
解决方法
使用mapUsingService
并使用ServiceFactory
创建服务:
p.readFrom(source)
.mapUsingService(
ServiceFactories.sharedService(pctx -> new DataTransformer()),(dataTransformer,r) -> dataTransformer.transformRecord(r))
...
或者,如果您的服务是可序列化的和无状态的,则可以将其复制到本地变量:
DataTransformer dataTransformerLocal = dataTransformer;
p.readFrom(source)
.map(r -> dataTransformerLocal.transformRecord(r))
.writeTo(Sinks.filesBuilder(userHome).build());
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。